|
@@ -87,7 +87,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int pauseJob(SysJob job) throws SchedulerException {
|
|
public int pauseJob(SysJob job) throws SchedulerException {
|
|
Long jobId = job.getJobId();
|
|
Long jobId = job.getJobId();
|
|
String jobGroup = job.getJobGroup();
|
|
String jobGroup = job.getJobGroup();
|
|
@@ -105,7 +105,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int resumeJob(SysJob job) throws SchedulerException {
|
|
public int resumeJob(SysJob job) throws SchedulerException {
|
|
Long jobId = job.getJobId();
|
|
Long jobId = job.getJobId();
|
|
String jobGroup = job.getJobGroup();
|
|
String jobGroup = job.getJobGroup();
|
|
@@ -123,7 +123,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int deleteJob(SysJob job) throws SchedulerException {
|
|
public int deleteJob(SysJob job) throws SchedulerException {
|
|
Long jobId = job.getJobId();
|
|
Long jobId = job.getJobId();
|
|
String jobGroup = job.getJobGroup();
|
|
String jobGroup = job.getJobGroup();
|
|
@@ -141,7 +141,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @return 结果
|
|
* @return 结果
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public void deleteJobByIds(Long[] jobIds) throws SchedulerException {
|
|
public void deleteJobByIds(Long[] jobIds) throws SchedulerException {
|
|
for (Long jobId : jobIds) {
|
|
for (Long jobId : jobIds) {
|
|
SysJob job = getById(jobId);
|
|
SysJob job = getById(jobId);
|
|
@@ -155,7 +155,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int changeStatus(SysJob job) throws SchedulerException {
|
|
public int changeStatus(SysJob job) throws SchedulerException {
|
|
int rows = 0;
|
|
int rows = 0;
|
|
String status = job.getStatus();
|
|
String status = job.getStatus();
|
|
@@ -173,7 +173,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public void run(SysJob job) throws SchedulerException {
|
|
public void run(SysJob job) throws SchedulerException {
|
|
Long jobId = job.getJobId();
|
|
Long jobId = job.getJobId();
|
|
String jobGroup = job.getJobGroup();
|
|
String jobGroup = job.getJobGroup();
|
|
@@ -190,7 +190,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息 调度信息
|
|
* @param job 调度信息 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int insertJob(SysJob job) throws SchedulerException, TaskException {
|
|
public int insertJob(SysJob job) throws SchedulerException, TaskException {
|
|
job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
|
|
job.setStatus(ScheduleConstants.Status.PAUSE.getValue());
|
|
int rows = baseMapper.insert(job);
|
|
int rows = baseMapper.insert(job);
|
|
@@ -206,7 +206,7 @@ public class SysJobServiceImpl extends ServicePlusImpl<SysJobMapper, SysJob, Sys
|
|
* @param job 调度信息
|
|
* @param job 调度信息
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
- @Transactional
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
public int updateJob(SysJob job) throws SchedulerException, TaskException {
|
|
public int updateJob(SysJob job) throws SchedulerException, TaskException {
|
|
SysJob properties = selectJobById(job.getJobId());
|
|
SysJob properties = selectJobById(job.getJobId());
|
|
int rows = baseMapper.updateById(job);
|
|
int rows = baseMapper.updateById(job);
|