| | |
| | | * @param sysJob 执行计划 |
| | | * @return 具体执行任务类 |
| | | */ |
| | | private static Class<? extends Job> getQuartzJobClass(HiddenDangerCheckJob job) |
| | | private static Class<? extends org.quartz.Job> getQuartzJobClass(HiddenDangerCheckJob job) |
| | | { |
| | | boolean isConcurrent = "0".equals(job.getConcurrent()); |
| | | return isConcurrent ? QuartzJobExecution.class : QuartzDisallowConcurrentExecution.class; |
| | |
| | | */ |
| | | public static void createScheduleJob(Scheduler scheduler, HiddenDangerCheckJob job) throws SchedulerException, TaskException |
| | | { |
| | | Class<? extends Job> jobClass = getQuartzJobClass(job); |
| | | Class<? extends org.quartz.Job> jobClass = getQuartzJobClass(job); |
| | | // 构建job信息 |
| | | Long jobId = job.getJobId(); |
| | | String jobGroup = job.getJobGroup(); |