| | |
| | | JobDetail jobDetail = JobBuilder.newJob(QuartzRecord.class) |
| | | .withIdentity(getJobKey(quartzJob.getId())).build() ; |
| | | |
| | | |
| | | // 构建Cron调度器 |
| | | CronScheduleBuilder scheduleBuilder = CronScheduleBuilder |
| | | .cronSchedule(quartzJob.getCronExpres()) |
| | | .withMisfireHandlingInstructionDoNothing() ; |
| | | |
| | | // 任务触发器 |
| | | CronTrigger trigger = TriggerBuilder.newTrigger() |
| | | .withIdentity(getTriggerKey(quartzJob.getId())) |
| | |
| | | jobDetail.getJobDataMap().put(QuartzJob.JOB_PARAM_KEY,quartzJob); |
| | | scheduler.scheduleJob(jobDetail,trigger) ; |
| | | // 状态校验 |
| | | checkStop(quartzJob) ; |
| | | // checkStop(quartzJob) ; |
| | | } catch (SchedulerException e){ |
| | | throw new RuntimeException("createJob Fail",e) ; |
| | | } |