From b2fce0dc7dc4ea5dec9792a2bc3ceb9d33d6e07b Mon Sep 17 00:00:00 2001
From: lidongdong <1459917685@qq.com>
Date: 星期一, 04 九月 2023 13:59:52 +0800
Subject: [PATCH] 修改后台社区动态加载不出来

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java |   39 ++++++++++++++++++++++++++++-----------
 1 files changed, 28 insertions(+), 11 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 7684a72..9c38e44 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
@@ -19,8 +19,10 @@
 
 import javax.annotation.Resource;
 
+import cn.binarywang.wx.miniapp.api.WxMaService;
 import cn.hutool.core.collection.CollUtil;
 import com.panzhihua.common.constants.HttpStatus;
+import com.panzhihua.common.model.dtos.PageBaseDTO;
 import com.panzhihua.common.model.dtos.community.ActivityInviteDTO;
 import com.panzhihua.service_community.dao.ComActNeighborCircleDAO;
 import com.panzhihua.service_community.dao.ComActNeighborCircleTopicWestMapper;
@@ -28,6 +30,7 @@
 import com.panzhihua.service_community.entity.ComActActivityInvite;
 import com.panzhihua.service_community.model.dos.ComActNeighborCircleTopicWestDO;
 import com.panzhihua.service_community.service.ComActActivityInviteService;
+import com.panzhihua.service_community.util.WxMaConfiguration;
 import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -140,6 +143,8 @@
     private ComActActivityInviteService comActActivityInviteService;
     @Resource
     private ComActNeighborCircleDAO comActNeighborCircleDAO;
+    @Resource
+    private WxMaConfiguration wxMaConfiguration;
 
     /**
      * 新增社区活动
@@ -251,8 +256,8 @@
             List<ActivitySignVO> activitySignVOS = comActActSignDAO.listActivitySigns(activitySignVO);
             if (!activitySignVOS.isEmpty()) {
                 try {
-                    WxXCXTempSend util = new WxXCXTempSend();
-                    String accessToken = util.getAccessToken();
+                    WxMaService maService = wxMaConfiguration.getMaService("wx118de8a734d269f0");
+                    String accessToken = maService.getAccessToken();
                     ComActDO comActDO=comActDAO.selectById(comActActivityDO.getCommunityId());
                     R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),1);
                     activitySignVOS.forEach(activitySignVO1 -> {
@@ -831,6 +836,7 @@
 //        log.info("定时任务--修改社区活动报名状态活动数量【{}】", num1);
         // 查询已经结束的活动,需要计算积分
         List<Long> activityEndIds = comActActivityDAO.selectBeginIds();
+        WxMaService maService = wxMaConfiguration.getMaService("wx118de8a734d269f0");
         if(!CollectionUtils.isEmpty(activityEndIds)){
             activityEndIds.forEach(activityId->{
                 List<String> openIds=comActActivityDAO.selectOpenIdByActivityId(activityId);
@@ -838,7 +844,7 @@
                     openIds.forEach(op->{
                         WxXCXTempSend wxXCXTempSend=new WxXCXTempSend();
                         try {
-                            WxUtil.sendLongTimeTemplate(op,wxXCXTempSend.getAccessToken("wx118de8a734d269f0"),"活动开始提醒","您参加的活动已开始","packageC/pages/activity/communityActivityDetails/communityActivityDetails?id="+activityId);
+                            WxUtil.sendLongTimeTemplate(op,maService.getAccessToken(),"活动开始提醒","您参加的活动已开始","packageC/pages/activity/communityActivityDetails/communityActivityDetails?id="+activityId);
                         } catch (Exception e) {
                             e.printStackTrace();
                         }
@@ -859,7 +865,7 @@
                     openIds.forEach(op->{
                         WxXCXTempSend wxXCXTempSend=new WxXCXTempSend();
                         try {
-                            WxUtil.sendLongTimeTemplate(op,wxXCXTempSend.getAccessToken("wx118de8a734d269f0"),"活动结束提醒","您参加的活动已结束","packageC/pages/activity/communityActivityDetails/communityActivityDetails?id="+id);
+                            WxUtil.sendLongTimeTemplate(op,maService.getAccessToken(),"活动结束提醒","您参加的活动已结束","packageC/pages/activity/communityActivityDetails/communityActivityDetails?id="+id);
                         } catch (Exception e) {
                             e.printStackTrace();
                         }
@@ -1001,9 +1007,9 @@
             .lambda().le(ComActActivityDO::getBeginAt, DateUtils.addDays(new Date(), 1))
             .ge(ComActActivityDO::getBeginAt, new Date()).notIn(ComActActivityDO::getStatus,5,6));
         if (!actActivityList.isEmpty()) {
-            WxXCXTempSend util = new WxXCXTempSend();
+            WxMaService maService = wxMaConfiguration.getMaService("wx118de8a734d269f0");
             try {
-                String accessToken = util.getAccessToken();
+                String accessToken = maService.getAccessToken();
                 actActivityList.forEach(actActivity -> {
                     ComActDO comActDO=comActDAO.selectById(actActivity.getCommunityId());
                     R<SysTemplateConfigVO> r=userService.selectTemplate(comActDO.getAreaCode(),9);
@@ -1250,8 +1256,14 @@
 
     @Override
     public R partyMemberCount(Long communityId, String year) {
-        PartyActivityStatics partyActivityStatics=this.comActActivityDAO.selectActivityStatics(communityId);
-        List<PartyActivityTypeChart> partyActivityTypeChart=this.comActActivityDAO.selectActivityChart(communityId);
+
+        List<Long> communityIds = comActDAO.selectIds(communityId);
+        if (CollUtil.isEmpty(communityIds)){
+            communityIds = new ArrayList<>();
+            communityIds.add(communityId);
+        }
+        PartyActivityStatics partyActivityStatics=this.comActActivityDAO.selectActivityStatics(communityIds);
+        List<PartyActivityTypeChart> partyActivityTypeChart=this.comActActivityDAO.selectActivityChart(communityIds);
         if(partyActivityStatics.getActivityCount()!=null&&partyActivityStatics.getActivityCount()>0){
             if(!CollectionUtils.isEmpty(partyActivityTypeChart)){
                 partyActivityTypeChart.forEach(partyActivityTypeChart1 -> {
@@ -1260,7 +1272,7 @@
             }
         }
         partyActivityStatics.setPartyActivityTypeChartList(partyActivityTypeChart);
-        partyActivityStatics.setPartyActivityLines(getPoints(communityId,year));
+        partyActivityStatics.setPartyActivityLines(getPoints(communityIds,year));
         return R.ok(partyActivityStatics);
     }
 
@@ -1274,7 +1286,7 @@
         return R.ok(comActActivityDAO.exportPartyMemberDetail(commonPage));
     }
 
-    public List<PartyActivityLine> getPoints(Long communityId,String year){
+    public List<PartyActivityLine> getPoints(List<Long> communityIds,String year){
         List<PartyActivityLine> partyActivityLines=new ArrayList<>();
         for(int i=1;i<=12;i++){
             String x="";
@@ -1286,10 +1298,15 @@
             }
             PartyActivityLine partyActivityLine=new PartyActivityLine();
             partyActivityLine.setX(i+"月");
-            Integer y=this.comActActivityDAO.selectActivityLine(communityId,year,x);
+            Integer y=this.comActActivityDAO.selectActivityLine(communityIds,year,x);
             partyActivityLine.setY(y);
             partyActivityLines.add(partyActivityLine);
         }
         return partyActivityLines;
     }
+
+    @Override
+    public R pageActivityBigScreen(PageBaseDTO pageBaseDTO) {
+        return R.ok(comActActivityDAO.pageActivityBigScreen(new Page<>(pageBaseDTO.getPageNum(),pageBaseDTO.getPageSize())));
+    }
 }

--
Gitblit v1.7.1