From 10df7e29b51d6a2efacc83d870856f57d97a9b66 Mon Sep 17 00:00:00 2001 From: yanghui <2536613402@qq.com> Date: 星期一, 24 十月 2022 13:48:24 +0800 Subject: [PATCH] #feat 修改别名 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java | 33 ++++++++++++++++++++++++++------- 1 files changed, 26 insertions(+), 7 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 cce3e34..7684a72 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,6 +19,7 @@ import javax.annotation.Resource; +import cn.hutool.core.collection.CollUtil; import com.panzhihua.common.constants.HttpStatus; import com.panzhihua.common.model.dtos.community.ActivityInviteDTO; import com.panzhihua.service_community.dao.ComActNeighborCircleDAO; @@ -306,14 +307,23 @@ } page.setSize(pageSize); page.setCurrent(pageNum); + Long communityId = comActActivityVO.getCommunityId(); + if (null != communityId){ + List<Long> communityIds = comActDAO.selectIds(communityId); + if (CollUtil.isEmpty(communityIds)) { + communityIds = new ArrayList<>(); + communityIds.add(communityId); + } + comActActivityVO.setCommunityIds(communityIds); + } 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()); - } + ComActDO comActDO = comActDAO.selectById(comActActivityVO.getCommunityId()); + if (nonNull(comActDO)) { + comActActivityVO.setStreetId(comActDO.getStreetId()); + } } iPage = comActActivityDAO.pageProjectActivity(page, comActActivityVO); } else { @@ -819,10 +829,8 @@ // 修改报名状态 变为报名中 // int num1 = comActActivityDAO.updateStatusToBeginSign(); // log.info("定时任务--修改社区活动报名状态活动数量【{}】", num1); - int num3 = comActActivityDAO.updateStatusToBeginAfterSingEnd(); - log.info("定时任务--报名结束修改社区活动进行状态活动数量【{}】", num3); // 查询已经结束的活动,需要计算积分 - List<Long> activityEndIds = comActActivityDAO.getActivityEndIds(); + List<Long> activityEndIds = comActActivityDAO.selectBeginIds(); if(!CollectionUtils.isEmpty(activityEndIds)){ activityEndIds.forEach(activityId->{ List<String> openIds=comActActivityDAO.selectOpenIdByActivityId(activityId); @@ -838,6 +846,8 @@ } }); } + int num3 = comActActivityDAO.updateStatusToBeginAfterSingEnd(); + log.info("定时任务--报名结束修改社区活动进行状态活动数量【{}】", num3); // 修改进行状态 变为进行中或者已结束 List<Long> ids = comActActivityDAO.getActivityEndIds(); if(!CollectionUtils.isEmpty(ids)){ @@ -882,6 +892,15 @@ } page.setSize(pageSize); page.setCurrent(pageNum); + Long communityId = comActActivityVO.getCommunityId(); + if (null != communityId){ + List<Long> communityIds = comActDAO.selectIds(communityId); + if (CollUtil.isEmpty(communityIds)) { + communityIds = new ArrayList<>(); + communityIds.add(communityId); + } + comActActivityVO.setCommunityIds(communityIds); + } IPage<ComActActivityVO> iPage = comActActivityDAO.pageActivityCommunityBack(page, comActActivityVO); iPage.getRecords().forEach(vo ->{ List<ComActActEvaluateDO> comActActEvaluateDOList = comActActEvaluateDAO -- Gitblit v1.7.1