From 00a59b93c16b24e7be77c6f1ce4866c75a2e0431 Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期二, 19 四月 2022 16:32:21 +0800
Subject: [PATCH] 花城E+防疫修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java |   51 +++++++++++++++++++++++++++++++++++----------------
 1 files changed, 35 insertions(+), 16 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
index 9b7cf9d..aac7347 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java
@@ -15,6 +15,7 @@
 
 import javax.annotation.Resource;
 
+import com.panzhihua.common.model.dtos.property.CommonPage;
 import com.panzhihua.common.model.vos.community.*;
 import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.beans.BeanUtils;
@@ -198,6 +199,7 @@
         if (comActActivityVO.getSignUpEnd() != null && now.getTime() < comActActivityVO.getSignUpEnd().getTime()
         && now.getTime() > comActActivityVO.getSignUpBegin().getTime()) {
             comActActivityDO.setStatus(3);
+            comActActivityDO.setPublishAt(new Date());
         }
         boolean b = this.updateById(comActActivityDO);
         if (b) {
@@ -308,7 +310,7 @@
                     List<ComActActRegistDO> collect = regList.stream().sorted(Comparator.comparing(ComActActRegistDO::getId).reversed()).collect(Collectors.toList());
                     comActActivityVO.setTimes(collect.get(0).getTimes());
                     ComActActRegistDO comActActRegistDO=collect.get(0);
-                    if(comActActRegistDO.getType()==2){
+                    if(comActActRegistDO.getType()==3){
                         if(comActActRegistDO.getEndTime()==null){
                             comActActivityVO.setSignType(2);
                         }
@@ -472,6 +474,9 @@
         if (isNull(actActivityDO)) {
             return R.fail("活动不存在");
         }
+        if(actActivityDO.getSignUpBegin().after(new Date())){
+            return R.fail("未到报名时间");
+        }
         int num = 0;
         ComActActSignDO comActActSignDO = comActActSignDAO.selectOne(new QueryWrapper<ComActActSignDO>()
                 .lambda().eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getUserId, userId));
@@ -480,6 +485,7 @@
                 return R.fail("已经报名过了,请勿重复提交");
             }
             Integer volunteerMax = actActivityDO.getVolunteerMax();
+            Integer activityType = actActivityDO.getType();
             Integer residentMax = actActivityDO.getParticipantMax();
             R<LoginUserInfoVO> userInfoR = userService.getUserInfoByUserId(String.valueOf(userId));
             LoginUserInfoVO loginUserInfoVO =
@@ -487,7 +493,7 @@
             // 查询当前活动下参与居民
             Integer residentCount = comActActSignDAO.selectCount(new QueryWrapper<ComActActSignDO>().lambda()
                     .eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getIsVolunteer, 0).eq(ComActActSignDO::getStatus, 1));
-            if (volunteerMax != 0) {
+            if (activityType.equals(1)) {
                 //志愿者活动
                 boolean userIsVolunteer = loginUserInfoVO.getIsVolunteer() == 1;
                 // 查询当前活动下参与志愿者
@@ -544,12 +550,14 @@
                 comActActSignDO.setCreateAt(new Date());
                 comActActSignDO.setReason(null);
                 comActActSignDO.setIsVolunteer(isVolunteer);
+                comActActSignDO.setTimes(comActActSignDO.getTimes()+1);
                 num = comActActSignDAO.updateById(comActActSignDO);
             } else {
                 comActActSignDO = new ComActActSignDO();
                 comActActSignDO.setActivityId(activityId);
                 comActActSignDO.setUserId(userId);
                 comActActSignDO.setIsVolunteer(isVolunteer);
+                comActActSignDO.setTimes(1);
                 num = comActActSignDAO.insert(comActActSignDO);
             }
         } else {
@@ -575,7 +583,7 @@
                 AddComActIntegralUserDTO addComActIntegralUserDTO = new AddComActIntegralUserDTO();
                 addComActIntegralUserDTO.setUserId(userId);
                 addComActIntegralUserDTO.setIntegralType(8);
-                addComActIntegralUserDTO.setActivityType(1);
+                addComActIntegralUserDTO.setActivityType(actActivityDO.getType());
                 addComActIntegralUserDTO.setIsVolunteer(comActActSignDO.getIsVolunteer());
                 addComActIntegralUserDTO.setCommunityId(actActivityDO.getCommunityId());
                 addComActIntegralUserDTO.setServiceId(activityId);
@@ -615,7 +623,7 @@
                         .filter(activityDO -> activityDO.getStatus().equals(status)).collect(Collectors.toList());
             }
         }
-        if(isNull(type)){
+        if(!isNull(type)){
             comActActivityDOS=comActActivityDOS.stream().filter(comActActivityDO -> comActActivityDO.getType().equals(type)).collect(Collectors.toList());
         }
         if (!comActActivityDOS.isEmpty()) {
@@ -623,15 +631,12 @@
                 ComActActivityVO comActActivityVO = new ComActActivityVO();
                 BeanUtils.copyProperties(comActActivityDO, comActActivityVO);
                 List<ActivitySignVO> collect = activitySignVOList.stream()
-                        .filter(activitySignVO -> activitySignVO.getActivityId().equals(comActActivityVO.getId())).limit(1)
+                        .filter(activitySignVO -> activitySignVO.getActivityId().equals(comActActivityVO.getId()))
                         .collect(Collectors.toList());
+                comActActivityVO.setSignCount(collect.size());
+                comActActivityVO.setIsComment(0);
+                comActActivityVO.setIsRegist(0);
                 ActivitySignVO activitySignVO = collect.get(0);
-                Integer isVolunteer = activitySignVO.getIsVolunteer();
-                if (isVolunteer.intValue() == 1) {
-                    comActActivityVO.setType(1);
-                } else {
-                    comActActivityVO.setType(2);
-                }
                 Integer activityStatus = comActActivityVO.getStatus();
                 if (activityStatus.intValue() == 3) {
                     comActActivityVO.setStatus(4);
@@ -644,9 +649,9 @@
                     log.error("时间转换异常【{}】", e.getMessage());
                 }
                 comActActivityVO.setSingDate(createAt);
-                comActActivityVO.setTimes(activitySignVO.getTimes());
                 Integer totalAward = comActActRegistDAO.selectTotalAwardWithRegist(activitySignVO.getActivityId(), userId);
                 comActActivityVO.setAward(totalAward);
+                comActActivityVO.setActivitySignVOList(collect);
                 comActActivityVOS.add(comActActivityVO);
             });
         }
@@ -929,7 +934,7 @@
 //            return R.fail("你已签到,如要再次签到请三十分钟后尝试!");
 //        }
             ComActActRegistDO comActActRegistDO = new ComActActRegistDO();
-            if(comActActRegistVO.getType()!=null&&comActActRegistVO.getType()==2){
+            if(comActActRegistVO.getSignType()!=null&&comActActRegistVO.getSignType()==2){
                 ComActActRegistDO comActActActRegistDO=comActActRegistDAO.selectOne(new QueryWrapper<ComActActRegistDO>()
                         .lambda().eq(ComActActRegistDO::getActivityId, activityId).eq(ComActActRegistDO::getUserId, userId).eq(ComActActRegistDO::getCodeId,comActActRegistVO.getCodeId()));
                 if(comActActActRegistDO==null){
@@ -938,7 +943,7 @@
                 if(comActActActRegistDO.getEndTime()!=null){
                     return R.fail("无法重复签退");
                 }
-                comActActRegistDO.setId(comActActRegistVO.getId());
+                comActActRegistDO.setId(comActActActRegistDO.getId());
                 comActActRegistDO.setEndTime(new Date());
                 int result=comActActRegistDAO.updateById(comActActRegistDO);
                 if (result > 0) {
@@ -972,7 +977,7 @@
                 }
                 comActActRegistDO.setActivityId(activityId);
                 comActActRegistDO.setStartTime(new Date());
-                comActActRegistDO.setType(1);
+                comActActRegistDO.setType(comActActivityDO.getType());
                 comActActRegistDO.setUserId(userId);
                 comActActRegistDO.setIsVolunteer(comActActSignDO.getIsVolunteer());
                 comActActRegistDO.setCreateAt(nowDate);
@@ -981,7 +986,7 @@
                 comActActRegistDO.setPosition(comActActRegistVO.getPosition());
                 comActActRegistDO.setTimes(signAllCount+1);
                 int result = comActActRegistDAO.insert(comActActRegistDO);
-                if (result > 0&&comActActRegistDO.getType()==1) {
+                if (result > 0&&comActActivityDO.getType()!=3) {
                     if (isHave) {
                         boolean isVolunteerAct = comActActivityDO.getVolunteerMax() != 0;
                         AddComActIntegralUserDTO addComActIntegralUserDTO=new AddComActIntegralUserDTO();
@@ -996,6 +1001,9 @@
                     } else {
                         return R.ok();
                     }
+                }
+                else {
+                    return R.ok();
                 }
             }
             return R.fail("网络错误,请重试");
@@ -1138,6 +1146,17 @@
         partyActivityStatics.setPartyActivityLines(getPoints(communityId,year));
         return R.ok(partyActivityStatics);
     }
+
+    @Override
+    public R partyMemberDetail(CommonPage commonPage) {
+        return R.ok(comActActivityDAO.partyMemberDetail(new Page<>(commonPage.getPage(),commonPage.getSize()),commonPage));
+    }
+
+    @Override
+    public R exportPartyMemberDetail(CommonPage commonPage) {
+        return R.ok(comActActivityDAO.exportPartyMemberDetail(commonPage));
+    }
+
     public List<PartyActivityLine> getPoints(Long communityId,String year){
         List<PartyActivityLine> partyActivityLines=new ArrayList<>();
         for(int i=1;i<=12;i++){

--
Gitblit v1.7.1