From 7bfa6a85ad6a6c537b0f7ddb9f6a8795c8e8c866 Mon Sep 17 00:00:00 2001
From: puhanshu <a9236326>
Date: 星期四, 09 六月 2022 16:44:24 +0800
Subject: [PATCH] 五社&社区企业&人大代表

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java |   39 ++++++++++++++++++++++++++++++++++++---
 1 files changed, 36 insertions(+), 3 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..34e08f5 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,7 @@
 
 import com.panzhihua.common.model.dtos.property.CommonPage;
 import com.panzhihua.common.model.vos.community.*;
+import com.panzhihua.service_community.entity.ComActSocialProject;
 import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -88,6 +89,10 @@
     private ComActActivityCodeService comActActivityCodeService;
     @Resource
     private ComActDAO comActDAO;
+    @Resource
+    private ComActSocialProjectDao comActSocialProjectDao;
+    @Resource
+    private ComStreetDAO comStreetDAO;
 
     /**
      * 新增社区活动
@@ -171,8 +176,24 @@
                 try {
                     WxXCXTempSend util = new WxXCXTempSend();
                     String accessToken = util.getAppAccessToken();
-                    ComActDO comActDO=comActDAO.selectById(comActActivityDO.getCommunityId());
-                    R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),1);
+                    Integer type = comActActivityDO.getType();
+                    String areaCode;
+                    if (nonNull(type) && type.equals(4)) {
+                        ComActSocialProject comActSocialProject = comActSocialProjectDao.selectById(comActActivityDO.getProjectId());
+                        Long streetId = comActSocialProject.getStreetId();
+                        Long communityId = comActSocialProject.getCommunityId();
+                        if (nonNull(streetId)) {
+                            ComStreetDO comStreetDO = comStreetDAO.selectById(streetId);
+                            areaCode = comStreetDO.getAreaCode().toString();
+                        } else {
+                            ComActDO comActDO = comActDAO.selectById(communityId);
+                            areaCode = comActDO.getAreaCode();
+                        }
+                    } else {
+                        ComActDO comActDO = comActDAO.selectById(comActActivityDO.getCommunityId());
+                        areaCode = comActDO.getAreaCode();
+                    }
+                    R<SysTemplateConfigVO> r=userService.selectTemplate(areaCode,1);
                     activitySignVOS.forEach(activitySignVO1 -> {
                         // 变更社区活动推送订阅消息给用户
                         WxUtil.sendSubscribeHDBG(activitySignVO1.getOpenid(), accessToken,
@@ -228,7 +249,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 -> {

--
Gitblit v1.7.1