maven
昨天 6047f24edc72a13b71813c3fb6cc0d087c0f6cd7
ruoyi-quartz/src/main/java/com/ruoyi/quartz/service/impl/SysJobServiceImpl.java
@@ -1,6 +1,10 @@
package com.ruoyi.quartz.service.impl;
import java.util.List;
import com.ruoyi.business.entity.TimingTask;
import com.ruoyi.business.mapper.TimingTaskMapper;
import com.ruoyi.business.service.impl.TimingTaskScheduler;
import jakarta.annotation.PostConstruct;
import org.quartz.JobDataMap;
import org.quartz.JobKey;
@@ -31,17 +35,27 @@
    @Autowired
    private SysJobMapper jobMapper;
    @Autowired
    private TimingTaskMapper timingTaskMapper;
    @Autowired
    private TimingTaskScheduler timingTaskScheduler;
    /**
     * 项目启动时,初始化定时器 主要是防止手动修改数据库导致未同步到定时任务处理(注:不能手动修改数据库ID和任务组名,否则会导致脏数据)
     */
    @PostConstruct
    public void init() throws SchedulerException, TaskException
    {
        scheduler.clear();
        List<SysJob> jobList = jobMapper.selectJobAll();
        for (SysJob job : jobList)
        {
            ScheduleUtils.createScheduleJob(scheduler, job);
//        scheduler.clear();
//        List<SysJob> jobList = jobMapper.selectJobAll();
//        for (SysJob job : jobList)
//        {
//            ScheduleUtils.createScheduleJob(scheduler, job);
//        }
        List<TimingTask> timingTasks = timingTaskMapper.selectList(null);
        for (TimingTask timingTask : timingTasks) {
            timingTaskScheduler.scheduleTimingTask(timingTask);
        }
    }