| | |
|---|
| | | scheduler.deleteJob(getJobKey(jobId, jobGroup));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | scheduler.scheduleJob(jobDetail, trigger);
|
|---|
| | | // 判断任务是否过期
|
|---|
| | | if (StringUtils.isNotNull(CronUtils.getNextExecution(job.getCronExpression())))
|
|---|
| | | {
|
|---|
| | | // 执行调度任务
|
|---|
| | | scheduler.scheduleJob(jobDetail, trigger);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 暂停任务
|
|---|
| | | if (job.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))
|
|---|
| | |
|---|
| | | return StringUtils.containsAnyIgnoreCase(invokeTarget, Constants.JOB_WHITELIST_STR);
|
|---|
| | | }
|
|---|
| | | Object obj = SpringUtils.getBean(StringUtils.split(invokeTarget, ".")[0]);
|
|---|
| | | return StringUtils.containsAnyIgnoreCase(obj.getClass().getPackage().getName(), Constants.JOB_WHITELIST_STR);
|
|---|
| | | String beanPackageName = obj.getClass().getPackage().getName();
|
|---|
| | | return StringUtils.containsAnyIgnoreCase(beanPackageName, Constants.JOB_WHITELIST_STR)
|
|---|
| | | && !StringUtils.containsAnyIgnoreCase(beanPackageName, Constants.JOB_ERROR_STR);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
