nidapeng
2024-04-22 2d34613f07deabbbe7e5065c13eec61cfe2a4dcf
server/dmvisit_service/src/main/java/com/doumee/dao/timer/scheduler/QuartzManage.java
@@ -1,8 +1,9 @@
package com.doumee.scheduler;
package com.doumee.dao.timer.scheduler;
import com.doumee.constant.JobState;
import com.doumee.entity.QuartzJob;
import com.doumee.dao.timer.entity.JobState;
import com.doumee.dao.timer.entity.QuartzJob;
import org.quartz.*;
import org.quartz.CronTrigger;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -37,7 +38,7 @@
    /**
     * 表达式触发器
     */
    public org.quartz.CronTrigger getCronTrigger (Integer jobId){
    public CronTrigger getCronTrigger (Integer jobId){
        try {
            return (CronTrigger) this.scheduler.getTrigger(getTriggerKey(jobId)) ;
        } catch (SchedulerException e){
@@ -59,7 +60,7 @@
                                                .cronSchedule(quartzJob.getCronExpres())
                                                .withMisfireHandlingInstructionDoNothing() ;
            // 任务触发器
            org.quartz.CronTrigger trigger = TriggerBuilder.newTrigger()
            CronTrigger trigger = TriggerBuilder.newTrigger()
                                                .withIdentity(getTriggerKey(quartzJob.getId()))
                                                .withSchedule(scheduleBuilder).build() ;
            jobDetail.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY,quartzJob);
@@ -83,7 +84,7 @@
                                                .cronSchedule(quartzJob.getCronExpres())
                                                .withMisfireHandlingInstructionDoNothing();
            // 任务触发器
            org.quartz.CronTrigger trigger = getCronTrigger(quartzJob.getId())
            CronTrigger trigger = getCronTrigger(quartzJob.getId())
                                .getTriggerBuilder().withIdentity(triggerKey)
                                .withSchedule(scheduleBuilder).build();
            trigger.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY, quartzJob);