package com.fdkankan.fusion.task; import com.fdkankan.fusion.common.util.DateUtils; import com.fdkankan.fusion.entity.CaseLive; import com.fdkankan.fusion.service.ICaseLiveService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import java.util.Date; import java.util.List; @Service public class TaskService { @Autowired ICaseLiveService caseLiveService; //@Scheduled(initialDelay = 2000, fixedDelay = 1000 * 60) public void run() { List list = caseLiveService.list(); for (CaseLive caseLive : list) { Date hoursTime = DateUtils.getHoursTime(caseLive.getCreateTime()); if(hoursTime.getTime() <= new Date().getTime()){ caseLiveService.removeById(caseLive); } } } }