From 0cf26c2fbb74f5260f05ad9bc9d4f46f1d609d0c Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期日, 24 七月 2022 14:07:53 +0800
Subject: [PATCH] bug修改

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java |   33 +++++++++++++++++++++++++++++----
 1 files changed, 29 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 aac7347..d47001b 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
@@ -17,6 +17,8 @@
 
 import com.panzhihua.common.model.dtos.property.CommonPage;
 import com.panzhihua.common.model.vos.community.*;
+import com.panzhihua.common.utlis.Snowflake;
+import com.panzhihua.service_community.entity.ComPbCheckUnit;
 import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -88,6 +90,12 @@
     private ComActActivityCodeService comActActivityCodeService;
     @Resource
     private ComActDAO comActDAO;
+    @Resource
+    private ComPbCheckUnitDao comPbCheckUnitDao;
+    @Resource
+    private ComActSocialProjectDao comActSocialProjectDao;
+    @Resource
+    private ComStreetDAO comStreetDAO;
 
     /**
      * 新增社区活动
@@ -121,6 +129,10 @@
         if(comActActivityVO.getType()==4){
             comActActivityDO.setIsProject(1);
         }
+        if(comActActivityVO.getType()==5){
+            comPbCheckUnitDao.selectOne(new QueryWrapper<ComPbCheckUnit>().lambda().eq(ComPbCheckUnit::getAdminPhone,comActActivityVO.getPhone()).last("limit 1"));
+        }
+
         boolean save = this.save(comActActivityDO);
         if (!save) {
             return R.fail();
@@ -170,7 +182,7 @@
             if (!activitySignVOS.isEmpty()) {
                 try {
                     WxXCXTempSend util = new WxXCXTempSend();
-                    String accessToken = util.getAppAccessToken();
+                    String accessToken = util.getAccessToken();
                     ComActDO comActDO=comActDAO.selectById(comActActivityDO.getCommunityId());
                     R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),1);
                     activitySignVOS.forEach(activitySignVO1 -> {
@@ -228,7 +240,19 @@
         }
         page.setSize(pageSize);
         page.setCurrent(pageNum);
-        IPage<ComActActivityVO> iPage = comActActivityDAO.pageActivity(page, comActActivityVO);
+        Integer type = comActActivityVO.getType();
+        IPage<ComActActivityVO> iPage = null;
+        if (nonNull(type) && type.equals(4)) {
+            if (nonNull(comActActivityVO.getCommunityId())) {
+                ComActDO comActDO = comActDAO.selectById(comActActivityVO.getCommunityId());
+                if (nonNull(comActDO)) {
+                    comActActivityVO.setStreetId(comActDO.getStreetId());
+                }
+            }
+            iPage = comActActivityDAO.pageProjectActivity(page, comActActivityVO);
+        } else {
+            iPage = comActActivityDAO.pageActivity(page, comActActivityVO);
+        }
 //        List<ComActActivityVO> records = iPage.getRecords();
 //        if (!ObjectUtils.isEmpty(records)) {
 //            records.forEach(comActActivityVO1 -> {
@@ -310,7 +334,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()==3){
+                    if(comActActRegistDO.getType()==3||comActActRegistDO.getType()==5){
                         if(comActActRegistDO.getEndTime()==null){
                             comActActivityVO.setSignType(2);
                         }
@@ -853,7 +877,7 @@
         if (!actActivityList.isEmpty()) {
             WxXCXTempSend util = new WxXCXTempSend();
             try {
-                String accessToken = util.getAppAccessToken();
+                String accessToken = util.getAccessToken();
                 actActivityList.forEach(actActivity -> {
                     ComActDO comActDO=comActDAO.selectById(actActivity.getCommunityId());
                     R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),9);
@@ -1118,6 +1142,7 @@
     @Override
     public R addActivityType(ComActActivityTypeVO comActActivityTypeVO) {
         try {
+            comActActivityTypeVO.setId(Snowflake.getId());
             this.baseMapper.addActivityType(comActActivityTypeVO);
         } catch (Exception e) {
             log.error("添加活动类型错误【{}】", e.getMessage());

--
Gitblit v1.7.1