From 3aa749db68503ae710a5f7f9c66a1a1df40842a7 Mon Sep 17 00:00:00 2001 From: tangxiaobao <303826152@qq.com> Date: 星期五, 10 九月 2021 17:44:13 +0800 Subject: [PATCH] 修改社区活动定时任务设置取消状态 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java | 55 ++++++++++++++++++++++++++++--------------------------- 1 files changed, 28 insertions(+), 27 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 25ce9da..4bc5d82 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 @@ -558,33 +558,34 @@ */ @Override public R timedTaskActActivity() { - List<Long> longs = comActActivityDAO.selectTimedTaskActActivity(); - if (ObjectUtils.isEmpty(longs)) { - return R.fail("没有需要取消的社区活动"); - } - List<ComActActivityDO> comActActivityDOS = comActActivityDAO.selectBatchIds(longs); - List<ComActActivityVO> comActActivityVOS = new ArrayList<>(); - if (!ObjectUtils.isEmpty(comActActivityDOS)) { - comActActivityDOS.forEach(comActActivityDO -> { - ComActActivityVO comActActivityVO = new ComActActivityVO(); - BeanUtils.copyProperties(comActActivityDO, comActActivityVO); - List<ComActActSignDO> comActActSignDOS = comActActSignDAO.selectList(new QueryWrapper<ComActActSignDO>() - .lambda().eq(ComActActSignDO::getActivityId, comActActivityDO.getId())); - if (!ObjectUtils.isEmpty(comActActSignDOS)) { - List<ActivitySignVO> activitySignVOList = new ArrayList<>(); - comActActSignDOS.forEach(comActActSignDO -> { - ActivitySignVO activitySignVO = new ActivitySignVO(); - BeanUtils.copyProperties(comActActSignDO, activitySignVO); - activitySignVOList.add(activitySignVO); - comActActivityVO.setActivitySignVOList(activitySignVOList); - }); - } - comActActivityVOS.add(comActActivityVO); - }); - int num = comActActivityDAO.updateIdBatch(longs); - log.info("定时任务--一共取消社区活动数量【{}】", num); - } - return R.ok(comActActivityVOS); +// List<Long> longs = comActActivityDAO.selectTimedTaskActActivity(); +// if (ObjectUtils.isEmpty(longs)) { +// return R.fail("没有需要取消的社区活动"); +// } +// List<ComActActivityDO> comActActivityDOS = comActActivityDAO.selectBatchIds(longs); +// List<ComActActivityVO> comActActivityVOS = new ArrayList<>(); +// if (!ObjectUtils.isEmpty(comActActivityDOS)) { +// comActActivityDOS.forEach(comActActivityDO -> { +// ComActActivityVO comActActivityVO = new ComActActivityVO(); +// BeanUtils.copyProperties(comActActivityDO, comActActivityVO); +// List<ComActActSignDO> comActActSignDOS = comActActSignDAO.selectList(new QueryWrapper<ComActActSignDO>() +// .lambda().eq(ComActActSignDO::getActivityId, comActActivityDO.getId())); +// if (!ObjectUtils.isEmpty(comActActSignDOS)) { +// List<ActivitySignVO> activitySignVOList = new ArrayList<>(); +// comActActSignDOS.forEach(comActActSignDO -> { +// ActivitySignVO activitySignVO = new ActivitySignVO(); +// BeanUtils.copyProperties(comActActSignDO, activitySignVO); +// activitySignVOList.add(activitySignVO); +// comActActivityVO.setActivitySignVOList(activitySignVOList); +// }); +// } +// comActActivityVOS.add(comActActivityVO); +// }); +// int num = comActActivityDAO.updateIdBatch(longs); +// log.info("定时任务--一共取消社区活动数量【{}】", num); +// } +// return R.ok(comActActivityVOS); + return R.ok(); } /** -- Gitblit v1.7.1