spring中mybatis多表查询处理的示例分析
这篇文章将为大家详细讲解有关spring中mybatis多表查询处理的示例分析,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
创新互联主营资溪网站建设的网络公司,主营网站建设方案,成都APP应用开发,资溪h5成都微信小程序搭建,资溪网站营销推广欢迎资溪等地区企业咨询
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多表查询处理的示例分析”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。
分享题目:spring中mybatis多表查询处理的示例分析
链接URL:http://pwwzsj.com/article/jjigpd.html