| | |
|---|
| | | */ |
|---|
| | | @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(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
