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