From aa76c2b0bb73e9fe463387fb5656ea80094eceec Mon Sep 17 00:00:00 2001
From: tangxiaobao <303826152@qq.com>
Date: 星期三, 04 八月 2021 15:15:59 +0800
Subject: [PATCH] 值班表导入bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java |   18 ++++++++++++++----
 1 files changed, 14 insertions(+), 4 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 b1da84d..99f60c5 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
@@ -2,6 +2,7 @@
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -189,7 +190,14 @@
     public ComActActivityVO inforActivity(Long id, Long userId) {
         ComActActivityVO comActActivityVO=comActActivityDAO.inforActivity(id);
         if (!ObjectUtils.isEmpty(comActActivityVO)) {
-            ComActActSignDO comActActSignDO = comActActSignDAO.selectOne(new QueryWrapper<ComActActSignDO>().lambda().eq(ComActActSignDO::getActivityId, id).eq(ComActActSignDO::getUserId, userId));
+
+            LambdaQueryWrapper<ComActActSignDO> actSignQuery = new LambdaQueryWrapper<>();
+            actSignQuery.eq(ComActActSignDO::getActivityId, id);
+            if(userId != null){
+                actSignQuery.eq(ComActActSignDO::getUserId, userId);
+            }
+
+            ComActActSignDO comActActSignDO = comActActSignDAO.selectOne(actSignQuery);
             if (!ObjectUtils.isEmpty(comActActSignDO)) {
                 comActActivityVO.setIsSign(1);
                 comActActivityVO.setIsVolunteer(comActActSignDO.getIsVolunteer());
@@ -271,11 +279,11 @@
                 //查询当前活动下参与志愿者/居民数量
                 Integer count = comActActSignDAO.selectCount(new QueryWrapper<ComActActSignDO>().lambda().eq(ComActActSignDO::getActivityId,activityId)
                         .eq(ComActActSignDO::getIsVolunteer,isVolunteer));
-                if(isVolunteer.equals(1) && actActivityDO.getVolunteerMax() <= count){
+                if(isVolunteer.equals(1) && actActivityDO.getVolunteerMax() <= count && !actActivityDO.getVolunteerMax().equals(-1)){
                     return R.fail("志愿者报名人数已满");
                 }
 
-                if(isVolunteer.equals(0) && actActivityDO.getParticipantMax() <= count){
+                if(isVolunteer.equals(0) && actActivityDO.getParticipantMax() <= count && !actActivityDO.getParticipantMax().equals(-1)){
                     return R.fail("居民报名人数已满");
                 }
             }
@@ -397,12 +405,14 @@
 //        修改报名状态 变为报名中
         int num1=comActActivityDAO.updateStatusToBeginSign();
         log.info("定时任务--修改社区活动报名状态活动数量【{}】",num1);
+        //查询已经结束的活动,需要计算积分
+        List<Long> activityEndIds = comActActivityDAO.getActivityEndIds();
 //        修改进行状态 变为进行中或者已结束
         int num2=comActActivityDAO.updateStatusToBeginActiveOrEnd();
         log.info("定时任务--修改社区活动进行状态活动数量【{}】",num2);
         int num3=comActActivityDAO.updateStatusToBeginAfterSingEnd();
         log.info("定时任务--报名结束修改社区活动进行状态活动数量【{}】",num3);
-        return R.ok();
+        return R.ok(activityEndIds);
     }
 
     /**

--
Gitblit v1.7.1