spring mybatis匯總統計處理的示例分析

這篇文章主要為大家展示了“spring mybatis匯總統計處理的示例分析”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“spring mybatis匯總統計處理的示例分析”這篇文章吧。

public PageInfo getCenterInvestAnswerSum(GetCenterInvestSumReq askReq)
   throws BusinessException {
  PageInfo pageResult = new PageInfo();
  final String METHOD = "getCenterAskInvestSum";
  try {
   PageHelper.startPage(askReq.getPageNum(), askReq.getPageSize());
   LogUtil.logInput(LOG_TYPE.BIZ.val, this, METHOD, askReq);
   // 1.如果存在投顧,es查詢投顧信息
   List adviserIdList = null;
   Map adviserMap = null;
   if (StringUtils.hasLength(askReq.getInvestAdviserName())) {
    AdviserEsReq adviserEsReq = new AdviserEsReq();
    adviserEsReq.setInvestAdviserName(askReq.getInvestAdviserName());
    adviserEsReq.setPageSize(1000);
    PageInfo pageInfo = AdviserEsUtils.findByParams(adviserEsReq);
    if (CollectionUtils.isEmpty(pageInfo.getList())) {
     return pageResult;
    }
    adviserIdList = new ArrayList();
    adviserMap = new HashMap();
    for (VdInvestAdviser adviser : pageInfo.getList()) {
     adviserIdList.add(adviser.getId());
     adviserMap.put(adviser.getId(), adviser);
    }
   }
   // 2.查詢需要統計的問股數據
   AskStockStatisticsReq statisticsReq = new AskStockStatisticsReq();
   statisticsReq.setBeginDate(DateUtils.toDate(askReq.getStartDate(), DateFormat.YEAR_MONTH_DAY));
   statisticsReq.setEndDate(
     DateUtils.nextDays(DateUtils.toDate(askReq.getEndDate(), DateFormat.YEAR_MONTH_DAY), 1));
   statisticsReq.setAdviserIdList(adviserIdList);
   List askList = this.apAskExtMapper.findByCreateTime(statisticsReq);
   if (CollectionUtils.isEmpty(askList)) {
    return pageResult;
   }
   // 3.判斷是否需要查詢投顧信息,用戶未根據投顧姓名搜索則需要重新查詢投顧信息
   if (CollectionUtils.isEmpty(adviserIdList)) {
    adviserIdList = new ArrayList();// 最后循環組數據要用
    Set adviserIdSet = new HashSet();// 去重用
    adviserMap = new HashMap();
    askList.forEach(ask -> {
     adviserIdSet.add(ask.getAdviserId());
    });
    adviserIdList.addAll(adviserIdSet);
    List adviserList = AdviserEsUtils.findByIds(adviserIdList);
    for (VdInvestAdviser adviser : adviserList) {
     adviserMap.put(adviser.getId(), adviser);
    }
   }
   // 4.統計數據
   Map askCountMap = new HashMap();// 提問數map
   Map answerCountMap = new HashMap();// 解答數map
   Map reportCountMap = new HashMap();// 舉報數map
   Map qualifiedCountMap = new HashMap();// 合格數map
   Map complianceCountMap = new HashMap();// 合規數map
   askList.forEach(ask -> {
    Long key = ask.getAdviserId();
    setDataMap(askCountMap, key, 1);
    if (ask.getAnswerFlag() != null && ask.getAnswerFlag()) {
     setDataMap(answerCountMap, key, 1);
    }
    if (ask.getReportFlag() != null && ask.getReportFlag()) {
     setDataMap(reportCountMap, key, 1);
    }
    if (ask.getQualifiedFlag() != null && ask.getQualifiedFlag()) {
     setDataMap(qualifiedCountMap, key, 1);
    }
    if (ask.getComplianceFlag() != null && ask.getComplianceFlag()) {
     setDataMap(complianceCountMap, key, 1);
    }
   });
   // 5.組返回頁面數據
   List resultList = new ArrayList();
   for (Long adviserId : adviserIdList) {
    VdInvestAdviser adviser = adviserMap.get(adviserId);
    GetCenterInvestSumRes res = new GetCenterInvestSumRes();
    res.setAdviserId(adviserId);
    res.setInvestAdviserName(adviser.getInvestAdviserName());
    res.setInvestAdviserDept(adviser.getInvestAdviserDept());
    res.setSatisfied(adviser.getAverageSatisfied());
    res.setYybCode(adviser.getYybCode());
    res.setAskAdviserCount(answerCountMap.containsKey(adviserId) ? answerCountMap.get(adviserId) : 0);
    res.setAskCount(askCountMap.containsKey(adviserId) ? askCountMap.get(adviserId) : 0);
    res.setQualifiedCount(qualifiedCountMap.containsKey(adviserId) ? qualifiedCountMap.get(adviserId) : 0);
    res.setComplianceCount(
      complianceCountMap.containsKey(adviserId) ? complianceCountMap.get(adviserId) : 0);
    res.setReportFlagCount(reportCountMap.containsKey(adviserId) ? reportCountMap.get(adviserId) : 0);
    resultList.add(res);
   }
   pageResult.setList(resultList);
  } catch (Exception e) {
   LogUtil.logError(LOG_TYPE.BIZ.val, this, METHOD, e);
   throw ExceptionUtil.generateException("統計解答問股的投股信息", e);
  }
  return pageResult;
 }

以上是“spring mybatis匯總統計處理的示例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！