提交 b4a057d4 authored 作者: taojinlong's avatar taojinlong

fix: 更新任务状态-> 执行结束

上级 e4b16b33
...@@ -4,7 +4,6 @@ import io.dataease.base.domain.*; ...@@ -4,7 +4,6 @@ import io.dataease.base.domain.*;
import io.dataease.base.mapper.DatasetTableMapper; import io.dataease.base.mapper.DatasetTableMapper;
import io.dataease.base.mapper.DatasetTableTaskMapper; import io.dataease.base.mapper.DatasetTableTaskMapper;
import io.dataease.base.mapper.ext.ExtDataSetTaskMapper; import io.dataease.base.mapper.ext.ExtDataSetTaskMapper;
import io.dataease.base.mapper.ext.UtilMapper;
import io.dataease.base.mapper.ext.query.GridExample; import io.dataease.base.mapper.ext.query.GridExample;
import io.dataease.commons.constants.JobStatus; import io.dataease.commons.constants.JobStatus;
import io.dataease.commons.constants.ScheduleType; import io.dataease.commons.constants.ScheduleType;
...@@ -93,13 +92,15 @@ public class DataSetTableTaskService { ...@@ -93,13 +92,15 @@ public class DataSetTableTaskService {
datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask); datasetTableTaskMapper.updateByPrimaryKeySelective(datasetTableTask);
} }
scheduleService.addSchedule(datasetTableTask);
// simple // simple
if (datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())) { // SIMPLE 类型,提前占位 if (datasetTableTask.getRate().equalsIgnoreCase(ScheduleType.SIMPLE.toString())) { // SIMPLE 类型,提前占位
execNow(datasetTableTask); execNow(datasetTableTask);
}else { }else {
checkTaskIsStopped(datasetTableTask); checkTaskIsStopped(datasetTableTask);
} }
scheduleService.addSchedule(datasetTableTask);
return datasetTableTask; return datasetTableTask;
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论