xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat：解决定时器启动时卡死问题

Browse Source
This commit is contained in:
orgin 2023-08-18 17:07:59 +08:00
parent d39247d991
commit 9b9af8a481
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/quartz/service/impl/QuartzJobServiceImpl.java
View File

@ -66,7 +66,9 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
@Override @Override
@Transactional(rollbackFor = JeecgBootException.class) @Transactional(rollbackFor = JeecgBootException.class)
public boolean resumeJob(QuartzJob quartzJob) { public boolean resumeJob(QuartzJob quartzJob) {
schedulerDelete(quartzJob.getId()); if (CommonConstant.STATUS_NORMAL.equals(quartzJob.getStatus())) {
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());
quartzJob.setStatus(CommonConstant.STATUS_NORMAL); quartzJob.setStatus(CommonConstant.STATUS_NORMAL);
return this.updateById(quartzJob); return this.updateById(quartzJob);
@ -74,7 +76,7 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
/** /**
* 编辑&启停定时任务 * 编辑&启停定时任务
* @throws SchedulerException * @throws SchedulerException
*/ */
@Override @Override
@Transactional(rollbackFor = JeecgBootException.class) @Transactional(rollbackFor = JeecgBootException.class)
@ -163,7 +165,7 @@ public class QuartzJobServiceImpl extends ServiceImpl<QuartzJobMapper, QuartzJob
/** /**
* 删除定时任务 * 删除定时任务
* *
* @param id * @param id
*/ */
private void schedulerDelete(String id) { private void schedulerDelete(String id) {