From 4105f520eaf7e1875a3d314dbaacf78064d07d35 Mon Sep 17 00:00:00 2001
From: huanghongfa <huanghongfa123456>
Date: 星期一, 21 六月 2021 12:29:16 +0800
Subject: [PATCH] 修改bug

---
 springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java |   67 ++++++++++++++++++++++++++++++---
 1 files changed, 60 insertions(+), 7 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java
index 8347a58..1d6ac06 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/service/impl/ComBpActivityServiceImpl.java
@@ -12,6 +12,7 @@
 import com.panzhihua.common.model.vos.partybuilding.PageActivityMembersVO;
 import com.panzhihua.common.model.vos.partybuilding.PartyBuildingActivityVO;
 import com.panzhihua.common.model.vos.partybuilding.PartyBuildingMemberVO;
+import com.panzhihua.common.utlis.SensitiveUtil;
 import com.panzhihua.service_dangjian.dao.ComBpActivityDAO;
 import com.panzhihua.service_dangjian.dao.ComPbActivityMemberDAO;
 import com.panzhihua.service_dangjian.dao.ComPbMemberDAO;
@@ -48,6 +49,7 @@
     @Resource
     private ComPbMemberDAO comPbMemberDAO;
 
+
     /**
      * 查询某个党员加入的所有党员活动
      *
@@ -81,6 +83,9 @@
         page.setSize(pageSize);
         page.setCurrent(pageNum);
         IPage<PageActivityMembersVO> iPage = comPbActivityMemberDAO.pageActivityMembers(page, pageActivityMembersVO);
+        iPage.getRecords().forEach(record->{
+            record.setPhone(SensitiveUtil.desensitizedPhoneNumber(record.getPhone()));
+        });
         Map<String,Object> map=new HashMap<>(3);
         ComPbActivityDO comPbActivityDO = comBpActivityDAO.selectById(activityId);
         map.put("page",iPage);
@@ -109,8 +114,26 @@
         }
         PartyBuildingActivityVO partyBuildingActivityVO = new PartyBuildingActivityVO();
         BeanUtils.copyProperties(comPbActivityDO, partyBuildingActivityVO);
-        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
+
         List<PartyBuildingMemberVO> partyBuildingMemberVOS = new ArrayList<>();
+        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
+        if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
+            int size = comPbActivityMemberDOS.size();
+            if (size>=6) {
+                comPbActivityMemberDOS = comPbActivityMemberDOS.subList(0,6);
+            }
+            comPbActivityMemberDOS.forEach(member->{
+                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
+                BeanUtils.copyProperties(member, partyBuildingMemberVO);
+                partyBuildingMemberVO.setCreateAt(member.getCreateAt());
+                partyBuildingMemberVOS.add(partyBuildingMemberVO);
+            });
+            partyBuildingActivityVO.setParticipationActualNum(comPbActivityMemberDOS.size());
+        }else{
+            partyBuildingActivityVO.setParticipationActualNum(0);
+        }
+        //List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
+       /* List<PartyBuildingMemberVO> partyBuildingMemberVOS = new ArrayList<>();
         if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
             List<Long> collect = comPbActivityMemberDOS.stream().map(ComPbActivityMemberDO::getMemberId).collect(Collectors.toList());
             int size = collect.size();
@@ -126,7 +149,7 @@
             partyBuildingActivityVO.setParticipationActualNum(size);
         } else {
             partyBuildingActivityVO.setParticipationActualNum(0);
-        }
+        }*/
         ComPbActivityMemberDO comPbActivityMemberDO=comPbActivityMemberDAO.selectByUserIdActivityId(id,userId);
         if (ObjectUtils.isEmpty(comPbActivityMemberDO)) {
             partyBuildingActivityVO.setIsSign(0);
@@ -136,6 +159,12 @@
         partyBuildingActivityVO.setPartyBuildingMemberVOS(partyBuildingMemberVOS);
         partyBuildingActivityVO.setIsPerson(isPerson);
         partyBuildingActivityVO.setCreateByName(loginUserInfoVO.getName());
+
+        //查询社区名称
+        if(partyBuildingActivityVO.getCommunityId() != null){
+            partyBuildingActivityVO.setCommunityName(comBpActivityDAO.selectCommunityNameByCommunityId(partyBuildingActivityVO.getCommunityId()));
+        }
+
         return R.ok(partyBuildingActivityVO);
     }
 
@@ -149,7 +178,16 @@
     public R addactivity(PartyBuildingActivityVO partyBuildingActivityVO) {
         ComPbActivityDO comPbActivityDO = new ComPbActivityDO();
         BeanUtils.copyProperties(partyBuildingActivityVO, comPbActivityDO);
-        comPbActivityDO.setCreateAt(new Date());
+        Date now = new Date();
+        comPbActivityDO.setEnrollTimeBegin(now);
+        comPbActivityDO.setCreateAt(now);
+
+        Integer status = partyBuildingActivityVO.getStatus();
+        if(status!=null && status.intValue()==2) {//点击'保存并发布' 按钮
+            //默认设置为“进行中”
+            comPbActivityDO.setStatus(4);
+        }
+
         int insert = comBpActivityDAO.insert(comPbActivityDO);
         if (insert > 0) {
             return R.ok();
@@ -280,11 +318,11 @@
     @Override
     public R listActivity(Long userId, Long communityId) {
         List<ComActActivityVO> comActActivityVOS = new ArrayList<>();
-        Long memberId=comPbActivityMemberDAO.selectMemberIdByUserId(userId,communityId);
+        /*Long memberId=comPbActivityMemberDAO.selectMemberIdByUserId(userId,communityId);
         if (ObjectUtils.isEmpty(memberId)) {
             return R.fail();
-        }
-        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getMemberId, memberId));
+        }*/
+        List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getUserId, userId));
         if (ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
             return R.fail();
         }
@@ -328,6 +366,14 @@
         List<PartyBuildingMemberVO> partyBuildingMemberVOS = new ArrayList<>();
         List<ComPbActivityMemberDO> comPbActivityMemberDOS = comPbActivityMemberDAO.selectList(new QueryWrapper<ComPbActivityMemberDO>().lambda().eq(ComPbActivityMemberDO::getActivityId, id).orderByDesc(ComPbActivityMemberDO::getCreateAt));
         if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
+            comPbActivityMemberDOS.forEach(member->{
+                PartyBuildingMemberVO partyBuildingMemberVO = new PartyBuildingMemberVO();
+                BeanUtils.copyProperties(member, partyBuildingMemberVO);
+                partyBuildingMemberVO.setCreateAt(member.getCreateAt());
+                partyBuildingMemberVOS.add(partyBuildingMemberVO);
+            });
+        }
+        /*if (!ObjectUtils.isEmpty(comPbActivityMemberDOS)) {
             List<Long> collect = comPbActivityMemberDOS.stream().map(ComPbActivityMemberDO::getMemberId).collect(Collectors.toList());
             List<ComPbMemberDO> comPbMemberDOS = comPbMemberDAO.selectList(new QueryWrapper<ComPbMemberDO>().lambda().in(ComPbMemberDO::getId, collect));
             comPbMemberDOS.forEach(comPbMemberDO -> {
@@ -337,7 +383,7 @@
                 partyBuildingMemberVO.setCreateAt(comPbActivityMemberDO1.getCreateAt());
                 partyBuildingMemberVOS.add(partyBuildingMemberVO);
             });
-        }
+        }*/
         return R.ok(partyBuildingMemberVOS);
     }
 
@@ -368,6 +414,10 @@
                 ComPbActivityMemberDO comPbActivityMemberDO1=new ComPbActivityMemberDO();
                 comPbActivityMemberDO1.setActivityId(id);
                 comPbActivityMemberDO1.setMemberId(comPbMemberDO.getId());
+                comPbActivityMemberDO1.setUserId(userId);
+                //添加参加活动的党员快照信息,防止党员信息删除后无法显示
+                comPbActivityMemberDO1.setName(comPbMemberDO.getName());
+                comPbActivityMemberDO1.setPhotoPath(comPbMemberDO.getPhotoPath());
                 comPbActivityMemberDO1.setCreateAt(new Date());
                 mum=comPbActivityMemberDAO.insert(comPbActivityMemberDO1);
             } else {
@@ -471,6 +521,9 @@
             comPbActivityMemberDO.setMemberId(comPbMemberDOId);
             comPbActivityMemberDO.setActivityId(comPbActivityDO1Id);
             comPbActivityMemberDO.setCreateAt(new Date());
+            comPbActivityMemberDO.setUserId(comPbActivityDTO.getCreateBy());
+            comPbActivityMemberDO.setName(comPbMemberDO.getName());
+            comPbActivityMemberDO.setPhotoPath(comPbMemberDO.getPhotoPath());
             comPbActivityMemberDAO.insert(comPbActivityMemberDO);
             return R.ok();
         }

--
Gitblit v1.7.1