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;
    }

}