| | |
| | | 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; |
| | |
| | | /** |
| | | * 表达式触发器 |
| | | */ |
| | | public org.quartz.CronTrigger getCronTrigger (Integer jobId){ |
| | | public CronTrigger getCronTrigger (Integer jobId){ |
| | | try { |
| | | return (CronTrigger) this.scheduler.getTrigger(getTriggerKey(jobId)) ; |
| | | } catch (SchedulerException e){ |
| | |
| | | .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); |
| | |
| | | .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); |