| | |
| | | package com.dsh.communityWorldCup.util; |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author shaqian |
| | |
| | | @Component |
| | | public class TaskUtilCompetition { |
| | | |
| | | @Resource |
| | | private CompetitionService competitionService; |
| | | |
| | | /** |
| | | * 每秒去处理的定时任务 |
| | |
| | | @Scheduled(fixedRate = 30000) |
| | | public void taskMinute() { |
| | | try { |
| | | List<Competition> list = competitionService.list(new QueryWrapper<Competition>() |
| | | .ne("status", 4).ne("state", 3)); |
| | | for (Competition competition : list) { |
| | | // 当前时间小于开始时间 |
| | | if (competition.getStartTime().after(new Date())) { |
| | | competition.setStatus(1); |
| | | } |
| | | if (competition.getStartTime().before(new Date())) { |
| | | if (competition.getEndTime().after(new Date())) { |
| | | competition.setStatus(2); |
| | | } else { |
| | | competition.setStatus(3); |
| | | } |
| | | } |
| | | competitionService.updateById(competition); |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |