| | |
| | | CronScheduleBuilder scheduleBuilder = CronScheduleBuilder |
| | | .cronSchedule(quartzJob.getCronExpres()) |
| | | .withMisfireHandlingInstructionDoNothing(); |
| | | // 任务触发器 |
| | | CronTrigger trigger = getCronTrigger(quartzJob.getId()) |
| | | .getTriggerBuilder().withIdentity(triggerKey) |
| | | .withSchedule(scheduleBuilder).build(); |
| | | trigger.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY, quartzJob); |
| | | scheduler.rescheduleJob(triggerKey, trigger); |
| | | // 状态校验 |
| | | checkStop(quartzJob) ; |
| | | CronTrigger t = getCronTrigger(quartzJob.getId()); |
| | | if(t !=null){ |
| | | // 任务触发器 |
| | | CronTrigger trigger = t |
| | | .getTriggerBuilder().withIdentity(triggerKey) |
| | | .withSchedule(scheduleBuilder).build(); |
| | | trigger.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY, quartzJob); |
| | | scheduler.rescheduleJob(triggerKey, trigger); |
| | | // 状态校验 |
| | | checkStop(quartzJob) ; |
| | | } |
| | | |
| | | } catch (SchedulerException e) { |
| | | throw new RuntimeException("updateJob Fail",e) ; |
| | | } |