|
@@ -13,6 +13,7 @@ import edp.davinci.dto.qualityAuditor.QualityAuditorDto;
|
|
|
import edp.davinci.dto.qualityAuditor.QualityTaskDto;
|
|
|
import edp.davinci.dto.sourceDto.SourceDetail;
|
|
|
import edp.davinci.dto.viewDto.ViewBaseInfo;
|
|
|
+import edp.davinci.model.CronJob;
|
|
|
import edp.davinci.model.QualityAuditor;
|
|
|
import edp.davinci.model.QualityTask;
|
|
|
import edp.davinci.model.User;
|
|
@@ -229,14 +230,18 @@ public class QualityTaskController extends BaseController {
|
|
|
// 2. 判断任务状态
|
|
|
if (null != qualityTask) {
|
|
|
if (!StringUtils.isEmpty(qualityTask.getCronJobId())) {
|
|
|
- // 停止
|
|
|
- cronJobService.stopCronJob(qualityTask.getCronJobId(),user);
|
|
|
- // 删掉任务
|
|
|
- cronJobService.deleteCronJob(qualityTask.getCronJobId(),user);
|
|
|
+ CronJob cronJob1 = cronJobService.getCronJob(qualityTask.getCronJobId(), user);
|
|
|
+ if (null != cronJob1) {
|
|
|
+ // 停止
|
|
|
+ cronJobService.stopCronJob(qualityTask.getCronJobId(), user);
|
|
|
+ // 删掉任务
|
|
|
+ cronJobService.deleteCronJob(qualityTask.getCronJobId(), user);
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
// 3. 创建任务
|
|
|
- CronJobInfo jobInfo = cronJobService.createCronJob(cronJob,user);
|
|
|
+ CronJobInfo jobInfo = cronJobService.createCronJob(cronJob, user);
|
|
|
|
|
|
// 4. 更新定时规则id到任务中
|
|
|
qualityTask.setCronJobId(jobInfo.getId());
|