package com.project.core.config;

import com.project.common.exception.job.TaskException;
import com.project.quartz.domain.SysJob;
import com.project.quartz.mapper.SysJobMapper;
import com.project.quartz.service.ISysJobDelayService;
import com.project.quartz.util.DelayScheduleUtils;
import com.project.quartz.util.ScheduleUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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


@Slf4j
@Component
@RequiredArgsConstructor(onConstructor_ = @Autowired)
public class JobInitConfig
{

    private final ISysJobDelayService delayService;
    private final Scheduler scheduler;
    private final SysJobMapper jobMapper;
    private final DelayScheduleUtils delayScheduleUtils;

    /**
     * 项目启动时，初始化定时器 主要是防止手动修改数据库导致未同步到定时任务处理（注：不能手动修改数据库ID和任务组名，否则会导致脏数据）
     */
    @PostConstruct
    public void initJob() throws SchedulerException, TaskException
    {
        log.info("初始化定时器,延时器---------------");

        scheduler.clear();

        List<SysJob> jobList = jobMapper.selectJobAll();
        for (SysJob job : jobList)
        {
            ScheduleUtils.createScheduleJob(scheduler, job);
        }

//        List<SysJobDelay> delays = delayService.list();
//        if (StringUtils.isNotEmpty(delays)){
//            for (SysJobDelay delay : delays) {
//                Map<String, Object> extraParam = new HashMap<>();  extraParam.put("orderNo", delay.getJobOrder());
//                log.info("初始化延时任务："+delay.getJobName());
//                delayScheduleUtils.addSimpleJob(delay.getJobName(), delay.getTriggerTime(),extraParam , OrderCancelJob.class);
//            }
//        }

    }


}