package com.gk.hotwork.doublePrevention.scheduls;

import com.gk.hotwork.doublePrevention.entity.PreventDangerCheckTask;
import com.gk.hotwork.doublePrevention.entity.PreventDangerCheckWork;
import com.gk.hotwork.doublePrevention.service.baseService.PreventDangerCheckTaskService;
import com.gk.hotwork.doublePrevention.service.baseService.PreventDangerCheckWorkService;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.util.Date;
import java.util.List;

@Component
public class PreventSearchWorkStatusSchedule {

    private static final org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(PreventSearchWorkStatusSchedule.class);

    @Autowired
    private PreventDangerCheckTaskService preventDangerCheckTaskService;
    @Autowired
    private PreventDangerCheckWorkService preventDangerCheckWorkService;

    @Scheduled(cron = "0 0/20 * * * ?")
    //@PostConstruct
    public void searchTask(){
        logger.info("【】重置任务状态开始执行....");
        Date date = new Date();
        Date startTime = null;
        Date endTime = null;

        startTime = date;
        endTime = new Date(date.getTime() + 60 * 60 * 1000L);
        //检查后面30分钟内的所有work,看是否有未关闭，且未生成任务的，如果
        //检索所有即将到时间的任务 ，nextExecTime
        List<PreventDangerCheckWork> checkWorkList = preventDangerCheckWorkService.listExecCheckWork(startTime, endTime);

        for (PreventDangerCheckWork checkWork : checkWorkList) {
            PreventDangerCheckTask task = preventDangerCheckTaskService.getTaskByCheckWorkIdAndStartTime(checkWork.getId(), checkWork.getNextCheckTime());
            if (ObjectUtils.isEmpty(task)){
                preventDangerCheckWorkService.resetCheckWorkStatus(checkWork.getId());
            }
        }
        logger.info("【】重置任务状态执行结束");

    }

}