4dkankan-fusion/src/main/java/com/fdkankan/fusion/task/TaskService.java

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<CaseLive> list = caseLiveService.list();
        for (CaseLive caseLive : list) {
            Date hoursTime = DateUtils.getHoursTime(caseLive.getCreateTime());
            if(hoursTime.getTime() <= new Date().getTime()){
                caseLiveService.removeById(caseLive);
            }
        }
    }
}