Skip to content

B
byit-myth-job
Commit 8e8528d0 by huangfusuper
Options

合并重跑与补批的逻辑

parent 93498e54
Showing with 7 additions and 4 deletions
byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JobTaskThreadRunHelper.java
...@@ -90,10 +90,13 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -90,10 +90,13 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
if (nodeVerification.superiorNodeStatus(jobTask)) { if (nodeVerification.superiorNodeStatus(jobTask)) {
log.debug("检测到虚节点：{}，切满足执行条件，开始运行", jobTask); log.debug("检测到虚节点：{}，切满足执行条件，开始运行", jobTask);
Integer scheduleType = jobTask.getScheduleType(); Integer scheduleType = jobTask.getScheduleType();
if (ScheduleTypeEnum.REPEAT.getCode().equals(scheduleType)){ /*if (ScheduleTypeEnum.REPEAT.getCode().equals(scheduleType)){
log.debug("虚节点{},是重跑状态", jobTask); log.debug("虚节点{},是重跑状态", jobTask)
runRecordingAndJobTaskService.updateRunRecordingAndSaveTask(jobTask); runRecordingAndJobTaskService.updateRunRecordingAndSaveTask(jobTask)
}else if (ScheduleTypeEnum.REPAIR.getCode().equals(scheduleType)){ }else */
if (ScheduleTypeEnum.REPAIR.getCode().equals(scheduleType) ||
ScheduleTypeEnum.REPEAT.getCode().equals(scheduleType)){
log.debug("虚节点{},是重跑或者补批状态", jobTask);
runRecordingAndJobTaskService.saveRunRecordingAndTask(jobTask,true); runRecordingAndJobTaskService.saveRunRecordingAndTask(jobTask,true);
}else { }else {
runRecordingAndJobTaskService.saveRunRecordingAndTask(jobTask,false); runRecordingAndJobTaskService.saveRunRecordingAndTask(jobTask,false);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment