| | |
| | | import org.apache.commons.collections4.CollectionUtils; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | |
| | | //获得所有 活动 |
| | | List<Activity> activeActivities = new LambdaQueryChainWrapper<Activity>(activityMapper) |
| | | .orderByAsc(Activity::getCreateTime) // 按创建时间升序 |
| | | .eq(Activity::getDeleteFlag,Boolean.FALSE) |
| | | .list(); |
| | | Date now = new Date(); // 获取当前时间 |
| | | |
| | | List<Activity> newActivities = new ArrayList<>(); |
| | | for (Activity activity : activeActivities) { |
| | | String status = activity.getStatus(); |
| | | |
| | | if (isInProgress(now, activity)) { |
| | | activity.setStatus(ActivityStatusEnum.IN_PROGRESS.getType()); |
| | | } else if (isRecruiting(now, activity)) { |
| | |
| | | else { |
| | | activity.setStatus(ActivityStatusEnum.ENDED.getType()); |
| | | } |
| | | if (status != null && !status.equals(activity.getStatus())) { |
| | | newActivities.add(activity); |
| | | } |
| | | } |
| | | activityMapper.batchUpdateActivities(activeActivities); |
| | | if (!newActivities.isEmpty()) { |
| | | activityMapper.batchUpdateActivities(newActivities); |
| | | } |
| | | |
| | | // 修改 |
| | | XxlJobHelper.log("执行完成:活动状态改变"); |