update 定时任务更新异常
This commit is contained in:
-5
@@ -43,7 +43,6 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = JeroBootException.class)
|
|
||||||
public boolean saveAndScheduleJob(QuartzJob quartzJob) {
|
public boolean saveAndScheduleJob(QuartzJob quartzJob) {
|
||||||
// DB设置修改
|
// DB设置修改
|
||||||
quartzJob.setDelFlag(CommonConstant.DEL_FLAG_0);
|
quartzJob.setDelFlag(CommonConstant.DEL_FLAG_0);
|
||||||
@@ -59,7 +58,6 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
|
|||||||
* 恢复定时任务
|
* 恢复定时任务
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = JeroBootException.class)
|
|
||||||
public boolean resumeJob(QuartzJob quartzJob) {
|
public boolean resumeJob(QuartzJob quartzJob) {
|
||||||
schedulerDelete(quartzJob.getId());
|
schedulerDelete(quartzJob.getId());
|
||||||
schedulerAdd(quartzJob.getId(), quartzJob.getJobClassName().trim(), quartzJob.getCronExpression().trim(), quartzJob.getParameter());
|
schedulerAdd(quartzJob.getId(), quartzJob.getJobClassName().trim(), quartzJob.getCronExpression().trim(), quartzJob.getParameter());
|
||||||
@@ -73,7 +71,6 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
|
|||||||
* @throws SchedulerException
|
* @throws SchedulerException
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = JeroBootException.class)
|
|
||||||
public boolean editAndScheduleJob(QuartzJob quartzJob) throws SchedulerException {
|
public boolean editAndScheduleJob(QuartzJob quartzJob) throws SchedulerException {
|
||||||
if (CommonConstant.STATUS_NORMAL.equals(quartzJob.getStatus())) {
|
if (CommonConstant.STATUS_NORMAL.equals(quartzJob.getStatus())) {
|
||||||
schedulerDelete(quartzJob.getId());
|
schedulerDelete(quartzJob.getId());
|
||||||
@@ -88,7 +85,6 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
|
|||||||
* 删除&停止删除定时任务
|
* 删除&停止删除定时任务
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = JeroBootException.class)
|
|
||||||
public boolean deleteAndStopJob(QuartzJob job) {
|
public boolean deleteAndStopJob(QuartzJob job) {
|
||||||
schedulerDelete(job.getId());
|
schedulerDelete(job.getId());
|
||||||
return this.removeById(job.getId());
|
return this.removeById(job.getId());
|
||||||
@@ -118,7 +114,6 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = JeroBootException.class)
|
|
||||||
public void pause(QuartzJob quartzJob) {
|
public void pause(QuartzJob quartzJob) {
|
||||||
schedulerDelete(quartzJob.getId());
|
schedulerDelete(quartzJob.getId());
|
||||||
quartzJob.setStatus(CommonConstant.STATUS_DISABLE);
|
quartzJob.setStatus(CommonConstant.STATUS_DISABLE);
|
||||||
|
|||||||
Reference in New Issue
Block a user