diff --git a/service/src/main/java/com/hzya/frame/web/quartz/QuartzJobFactoryUtils.java b/service/src/main/java/com/hzya/frame/web/quartz/QuartzJobFactoryUtils.java index 786adf78..78948158 100644 --- a/service/src/main/java/com/hzya/frame/web/quartz/QuartzJobFactoryUtils.java +++ b/service/src/main/java/com/hzya/frame/web/quartz/QuartzJobFactoryUtils.java @@ -107,7 +107,9 @@ public class QuartzJobFactoryUtils { .withMisfireHandlingInstructionDoNothing() ) .build(); - JobDetail jobDetail = JobBuilder.newJob(com.hzya.frame.web.quartz.QuartzJobFactory.class).withIdentity(integrationTaskEntity.getTaskName(), integrationTaskEntity.getTaskCode()).build(); +// JobDetail jobDetail = JobBuilder.newJob(com.hzya.frame.web.quartz.QuartzJobFactory.class).withIdentity(integrationTaskEntity.getTaskName(), integrationTaskEntity.getTaskCode()).build(); + JobDetail jobDetail = JobBuilder.newJob(com.hzya.frame.web.quartz.QuartzJobFactory.class).withIdentity(integrationTaskEntity.getTaskName(), integrationTaskEntity.getTaskCode()) + .requestRecovery().storeDurably().build(); jobDetail.getJobDataMap().put("job", job); scheduler.scheduleJob(jobDetail, cronTrigger); logger.info("添加" + integrationTaskEntity.getTaskName() + "任务成功");