spring中mybatis多表查询处理的示例分析

这篇文章将为大家详细讲解有关spring中mybatis多表查询处理的示例分析，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

package com.swhy.bw.advisor.center.comment; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.swhy.bw.advisor.dal.mapper.ApCommentExtMapper; import com.swhy.bw.advisor.dao.biz.response.theme.AdviserThemeDetailRes; import com.swhy.bw.advisor.dao.biz.response.user.UserInfoRes; import com.swhy.bw.advisor.dao.center.request.comment.CommentCenterListReq; import com.swhy.bw.advisor.dao.center.request.comment.CommentCenterModifyReq; import com.swhy.bw.advisor.dao.center.request.comment.SelectCommentReq; import com.swhy.bw.advisor.dao.center.response.comment.CommentCenterListRes; import com.swhy.bw.advisor.dao.center.response.comment.CommentDetailRes; import com.swhy.bw.advisor.dao.entity.ApComment; import com.swhy.bw.advisor.dao.entity.ApLiveRoom; import com.swhy.bw.advisor.dao.entity.VdInvestAdviser; import com.swhy.bw.advisor.elasticsearch.utils.AdviserEsUtils; import com.swhy.bw.advisor.elasticsearch.utils.AdviserThemeEsUtils; import com.swhy.bw.advisor.elasticsearch.utils.LiveRoomEsUtils; import com.swhy.bw.advisor.elasticsearch.utils.UserEsUtils; import com.swhy.bw.advisor.enums.CommentEnums; import com.swhy.bw.advisor.util.CollectionUtils; import com.swhy.bw.advisor.util.ExceptionUtil; import com.swhy.bw.advisor.util.StringUtils; import com.swhy.bw.advisor.util.date.DateFormat; import com.swhy.bw.advisor.util.date.DateUtils; import com.swhy.bw.advisor.util.exception.BusinessException; import com.swhy.bw.advisor.util.log.LOG_TYPE; import com.swhy.bw.advisor.util.log.LogUtil; import com.swhy.bw.advisor.util.route.RouteUtil; import com.swhy.bw.common.util.date.DateUtil; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.*; import java.util.stream.Collectors; @Service public class ApCommentMgmtService {     @Autowired     private ApCommentExtMapper apCommentExtMapper;     @Autowired     private AdviserThemeEsUtils adviserThemeEsUtils;     public PageInfo findApCommentList(CommentCenterListReq apCommentReq) throws BusinessException {         final String METHOD = "findApCommentList";         try {             PageHelper.startPage(apCommentReq.getPageNum(), apCommentReq.getPageSize());             LogUtil.logInput(LOG_TYPE.BIZ.val, this, METHOD, apCommentReq);             // 请求参数             if (apCommentReq.getEndDate() != null)                 apCommentReq.setEndDate(DateUtil.addDay(apCommentReq.getEndDate(), 1));             // 查询评论列表             Page records = (Page) apCommentExtMapper.selectCommentListAll(apCommentReq);             if (records == null) {                 return new PageInfo<>();             }             Page resPage = new Page<>();             BeanUtils.copyProperties(records, resPage);             // 查询投顾信息             HashMap adviserMap = getAdviserInfo(records);             // 查询标题信息             HashMap titleMap;             if (apCommentReq.getCommentType().equals(CommentEnums.comment_type_theme.getValue())) {                 titleMap = getThemeInfo(records);             } else {                 titleMap = getLiveroomInfo(records);             }             // 转换             records.forEach(record -> {                 CommentCenterListRes res = new CommentCenterListRes();                 BeanUtils.copyProperties(record, res);                 res.setTitle(titleMap.getOrDefault(record.getCommentId(), ""));                 res.setInvestAdviserName(adviserMap.getOrDefault(record.getAdviserId(), ""));                 res.setPublishTime(DateUtil.formateDate2Str(record.getPublishTime(), "yyyy-MM-dd HH:mm:ss"));                 res.setCommentContent(record.getContent());                 resPage.add(res);             });             return new PageInfo<>(resPage);         } catch (Exception e) {             LogUtil.logError(LOG_TYPE.BIZ.val, this, METHOD, e);             throw ExceptionUtil.generateException("评论列表查询异常", e);         }     }     private HashMap getThemeInfo(Page records) {         HashMap themeMap = new HashMap<>();         List themeIds = records.stream().map(ApComment::getCommentId).distinct().collect(Collectors.toList());         List themeDetailResList = adviserThemeEsUtils.findThemeByIds(themeIds);         if (CollectionUtils.isNotEmpty(themeDetailResList))             themeDetailResList.forEach(theme -> themeMap.put(theme.getId(), theme.getTitle()));         return themeMap;     }     private HashMap getLiveroomInfo(Page records) {         HashMap themeMap = new HashMap<>();         List liveroomIds = records.stream().map(ApComment::getCommentId).distinct().collect(Collectors.toList());         List liveRooms = LiveRoomEsUtils.findByIds(liveroomIds);         if (CollectionUtils.isNotEmpty(liveRooms))             liveRooms.forEach(liveRoom -> themeMap.put(liveRoom.getId(), liveRoom.getTitle()));         return themeMap;     }     private HashMap getAdviserInfo(Page records) {         HashMap adviserMap = new HashMap<>();         List adviserIds = records.stream().map(ApComment::getAdviserId).distinct().collect(Collectors.toList());         List advisers = AdviserEsUtils.findByIds(adviserIds);         if (CollectionUtils.isNotEmpty(advisers))             advisers.forEach(adviser -> adviserMap.put(adviser.getId(), adviser.getInvestAdviserName()));         return adviserMap;     } }

关于“spring中mybatis多表查询处理的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。