折线图统计BUG修改

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JobSnapshotThreadRunHelper.java

 package com.byit.thread.helper;
 
 import com.byit.dto.StatisticsConditionDto;
+import com.byit.enums.ExecuteStatusEnum;
 import com.byit.enums.NodeRunStatusPropertyEnum;
 import com.byit.enums.ScheduleStatusEnum;
+import com.byit.enums.task.RunResultEnum;
 import com.byit.job.utils.DateUtil;
 import com.byit.mapper.FlowStatusSnapshootMapper;
 import com.byit.mapper.WaitingRecordMapper;
@@ -152,7 +154,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
      */
     public void filterKillFlow(List<RunRecording> thisDayRunRecording, List<FlowStatusSnapshoot> killFlow) {
         List<RunRecording> collect = thisDayRunRecording.stream()
-                .filter(runRecording -> ScheduleStatusEnum.ERROR.getCode().equals(runRecording.getFlowStatus()))
+                .filter(runRecording -> ExecuteStatusEnum.KILL.getCode().equals(runRecording.getFlowRunResult()))
                 .collect(Collectors.toList());
 
         collect.forEach(runRecording ->{
@@ -170,7 +172,8 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
      */
     public void filterErrorFlow(List<RunRecording> thisDayRunRecording, List<FlowStatusSnapshoot> errorFlow) {
         List<RunRecording> collect = thisDayRunRecording.stream()
-                .filter(runRecording -> ScheduleStatusEnum.ERROR.getCode().equals(runRecording.getFlowStatus()))
+                .filter(runRecording -> ExecuteStatusEnum.FAIL.getCode().equals(runRecording.getFlowRunResult())
+                                ||ExecuteStatusEnum.REPAIR_FAIL.getCode().equals(runRecording.getFlowRunResult()))
                 .collect(Collectors.toList());
 
         collect.forEach(runRecording ->{
@@ -188,7 +191,8 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
      */
     public void filterSuccessFlow (List<RunRecording> thisDayRunRecording, List<FlowStatusSnapshoot> successFlow) {
         List<RunRecording> collect = thisDayRunRecording.stream()
-                .filter(runRecording -> ScheduleStatusEnum.FINISH.getCode().equals(runRecording.getFlowStatus()))
+                .filter(runRecording -> ExecuteStatusEnum.SUCCESS.equals(runRecording.getFlowRunResult()) ||
+                        ExecuteStatusEnum.REPAIR_SUCCESS.getCode().equals(runRecording.getFlowRunResult()))
                 .collect(Collectors.toList());
         collect.forEach(runRecording ->{
             FlowStatusSnapshoot flowStatusSnapshoot = new FlowStatusSnapshoot();