| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int pauseJob(SysJob job) throws SchedulerException
|
| | | {
|
| | | Long jobId = job.getJobId();
|
| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int resumeJob(SysJob job) throws SchedulerException
|
| | | {
|
| | | Long jobId = job.getJobId();
|
| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int deleteJob(SysJob job) throws SchedulerException
|
| | | {
|
| | | Long jobId = job.getJobId();
|
| | |
| | | * @return 结果
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public void deleteJobByIds(Long[] jobIds) throws SchedulerException
|
| | | {
|
| | | for (Long jobId : jobIds)
|
| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int changeStatus(SysJob job) throws SchedulerException
|
| | | {
|
| | | int rows = 0;
|
| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | public void run(SysJob job) throws SchedulerException
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public boolean run(SysJob job) throws SchedulerException
|
| | | {
|
| | | boolean result = false;
|
| | | Long jobId = job.getJobId();
|
| | | String jobGroup = job.getJobGroup();
|
| | | SysJob properties = selectJobById(job.getJobId());
|
| | | // 参数
|
| | | JobDataMap dataMap = new JobDataMap();
|
| | | dataMap.put(ScheduleConstants.TASK_PROPERTIES, properties);
|
| | | scheduler.triggerJob(ScheduleUtils.getJobKey(jobId, jobGroup), dataMap);
|
| | | JobKey jobKey = ScheduleUtils.getJobKey(jobId, jobGroup);
|
| | | if (scheduler.checkExists(jobKey))
|
| | | {
|
| | | result = true;
|
| | | scheduler.triggerJob(jobKey, dataMap);
|
| | | }
|
| | | return result;
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @param job 调度信息 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int insertJob(SysJob job) throws SchedulerException, TaskException
|
| | | {
|
| | | job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
|
| | |
| | | * @param job 调度信息
|
| | | */
|
| | | @Override
|
| | | @Transactional
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public int updateJob(SysJob job) throws SchedulerException, TaskException
|
| | | {
|
| | | SysJob properties = selectJobById(job.getJobId());
|