From d50ef0ec94f90ddf92bcd42671aa62ae38df81b9 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期三, 20 七月 2022 15:36:06 +0800
Subject: [PATCH] bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java |  108 +++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 83 insertions(+), 25 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
index 42b9d5e..b1ce6a0 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
@@ -35,6 +35,7 @@
 import com.panzhihua.service_community.service.ComActNeighborCircleService;
 
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.CollectionUtils;
 
 /**
  * @auther lyq
@@ -236,6 +237,18 @@
             ComActDO actDO = comActDAO.selectById(circleDetailAppVO.getCommunityId());
             if (actDO != null) {
                 circleDetailAppVO.setName(actDO.getName());
+            }
+        }
+        if(circleDetailAppVO.getOrderType()!=null){
+            if(circleDetailAppVO.getOrderType()==2){
+                AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(circleDetailAppVO.getSolveId());
+                circleDetailAppVO.setSolveName(user1.getName());
+            }
+            if(circleDetailAppVO.getOrderType()==1){
+                ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(circleDetailAppVO.getSolveUnitId());
+                if(comPbCheckUnit!=null){
+                    circleDetailAppVO.setSolveName(comPbCheckUnit.getName());
+                }
             }
         }
 
@@ -711,16 +724,20 @@
         AdministratorsUserVO user = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getReleaseId());
         DetailNeighborCircleAdminVO vo = new DetailNeighborCircleAdminVO();
         BeanUtils.copyProperties(comActNeighborCircleDO, vo);
-        vo.setReleaseName(user.getName());
-        vo.setImageUrl(user.getImageUrl());
-        if(comActNeighborCircleDO.getSolveId()!=null){
-            AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getSolveId());
-            comActNeighborCircleDO.setSolveName(user1.getName());
+        if(user!=null){
+            vo.setReleaseName(user.getName());
+            vo.setImageUrl(user.getImageUrl());
         }
-        if(comActNeighborCircleDO.getSolveUnitId()!=null){
-            ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(comActNeighborCircleDO.getSolveUnitId());
-            if(comPbCheckUnit!=null){
-                comActNeighborCircleDO.setSolveName(comPbCheckUnit.getName());
+        if(comActNeighborCircleDO.getOrderType()!=null){
+            if(comActNeighborCircleDO.getOrderType()==2){
+                AdministratorsUserVO user1 = this.baseMapper.selectUserByUserId(comActNeighborCircleDO.getSolveId());
+                vo.setSolveName(user1.getName());
+            }
+            if(comActNeighborCircleDO.getOrderType()==1){
+                ComPbCheckUnit comPbCheckUnit=comPbCheckUnitDao.selectById(comActNeighborCircleDO.getSolveUnitId());
+                if(comPbCheckUnit!=null){
+                    vo.setSolveName(comPbCheckUnit.getName());
+                }
             }
         }
 
@@ -1015,7 +1032,7 @@
             ComPbMemberDO comPbMemberDO=comPbMemberDAO.selectOne(new QueryWrapper<ComPbMemberDO>().lambda().eq(ComPbMemberDO::getPhone,serviceStaticDTO.getPhone()).last("limit 1"));
             if(comPbMemberDO!=null){
                 serviceStaticsVO.setWorkActivityList(comActActivityDAO.selectListByRelationId(comPbMemberDO.getCheckUnitId(),serviceStaticDTO.getYear()));
-                serviceStaticsVO.setServiceActivityList(comActActivityDAO.selectListByCommunityId(comPbMemberDO.getCommunityId(),serviceStaticDTO.getYear()));
+                serviceStaticsVO.setServiceActivityList(comActActivityDAO.selectListByCommunityId(comPbMemberDO.getCommunityId(),serviceStaticDTO.getYear(),serviceStaticDTO.getPhone()));
             }
 
         }
@@ -1023,7 +1040,7 @@
     }
 
     @Override
-    public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId,Integer page,Integer size,String belongTo) {
+    public R institutionalUnitServiceAnalysis(Integer year, Integer type, Integer range, Long communityId,Integer page,Integer size,String belongTo,Long unitId) {
         ActivityAnalysisVO activityVO=new ActivityAnalysisVO();
         String beginTime=null;
         String endTime=null;
@@ -1036,9 +1053,9 @@
         activityVO.setPartyMemberCount(comActDAO.selectUnitCount());
         activityVO.setUnitCount(comActDAO.selectMemberCount());
         //获取单位活动统计数据(邻里圈)
-        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo);
+        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo,communityId);
         //获取单位活动统计数据(活动)
-        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo);
+        List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId);
         if (unitActivityAnalysisVOS.size()>0){
             for (UnitActivityAnalysisVO unitActivityAnalysisVO : unitActivityAnalysisVOS){
                 if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO)){
@@ -1079,7 +1096,25 @@
             }
         }
         //获取党员活动统计数据
-        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo);
+        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId);
+        List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId);
+        if (partyMemberAnalysisVOS1.size()>0){
+            for (PartyMemberAnalysisVO vo : partyMemberAnalysisVOS1) {
+                if (ObjectUtils.isNotEmpty(vo)){
+                    if (ObjectUtils.isNotEmpty(vo.getMemberId())){
+                        Map<String, Integer> param = memberAlreadyAnalysis(vo.getMemberId(), partyMemberAnalysisVOS);
+                        if (param.get("flag")==1){
+                            Integer serviceTime = vo.getServiceTime();
+                            Integer serviceTimes = vo.getServiceTimes();
+                            partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
+                            partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
+                        }else{
+                            partyMemberAnalysisVOS.add(vo);
+                        }
+                    }
+                }
+            }
+        }
         //统计总时长和总次数
         Integer unitServiceCount=0;
         Integer unitServiceTotalTime=0;
@@ -1112,17 +1147,17 @@
         activityVO.setPartyMemberServiceTotalCount(memberServiceCount);
         activityVO.setPartyMemberServiceTotalTime(memberServiceTotalTome);
         //处理排序
-        if (null != type){
-            if (type.equals(1)){
-                //按时长排序
-                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTime");
-                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTime");
-            }else if (type.equals(2)){
-                //按次数排序
-                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTimes");
-                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTimes");
-            }
-        }
+//        if (null != type){
+//            if (type.equals(1)){
+//                //按时长排序
+//                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTime");
+//                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTime");
+//            }else if (type.equals(2)){
+//                //按次数排序
+//                ListUtil.sortByProperty(unitActivityAnalysisVOS, "serviceTimes");
+//                ListUtil.sortByProperty(partyMemberAnalysisVOS, "serviceTimes");
+//            }
+//        }
         //处理分页
         PageVO<List<UnitActivityAnalysisVO>> unitPage=new PageVO<>();
         PageVO<List<PartyMemberAnalysisVO>> memberPage=new PageVO<>();
@@ -1210,6 +1245,29 @@
         }
     }
 
+    /**
+     * 判断党员的统计是是否已存在
+     * */
+    public Map<String,Integer> memberAlreadyAnalysis(Long memberId,List<PartyMemberAnalysisVO> list){
+        Map<String,Integer> map=new HashMap<>();
+        if (memberId != null && list.size() > 0){
+            for (int i=0;i<list.size();i++) {
+                PartyMemberAnalysisVO vo = list.get(i);
+                if (ObjectUtils.isNotEmpty(vo)){
+                    if (ObjectUtils.isNotEmpty(vo.getMemberId())){
+                        if (memberId.equals(vo.getMemberId())){
+                            map.put("index",i );
+                            map.put("flag",1 );
+                            return map;
+                        }
+                    }
+                }
+            }
+        }
+        map.put("flag",0 );
+        return map;
+    }
+
 
 
 

--
Gitblit v1.7.1