Skip to content

B
byit-myth-job
Commit 46cdfaf3 by huangfusuper
Options

修正运行结果枚举取值错误

parent 67d7e214
Showing with 1 addition and 1 deletion
byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/JobSnapshotThreadRunHelper.java
...@@ -191,7 +191,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper { ...@@ -191,7 +191,7 @@ public class JobSnapshotThreadRunHelper extends BaseThreadRunHelper {
*/ */
public void filterSuccessFlow (List<RunRecording> thisDayRunRecording, List<FlowStatusSnapshoot> successFlow) { public void filterSuccessFlow (List<RunRecording> thisDayRunRecording, List<FlowStatusSnapshoot> successFlow) {
List<RunRecording> collect = thisDayRunRecording.stream() List<RunRecording> collect = thisDayRunRecording.stream()
.filter(runRecording -> ExecuteStatusEnum.SUCCESS.equals(runRecording.getFlowRunResult()) || .filter(runRecording -> ExecuteStatusEnum.SUCCESS.getCode().equals(runRecording.getFlowRunResult()) ||
ExecuteStatusEnum.REPAIR_SUCCESS.getCode().equals(runRecording.getFlowRunResult())) ExecuteStatusEnum.REPAIR_SUCCESS.getCode().equals(runRecording.getFlowRunResult()))
.collect(Collectors.toList()); .collect(Collectors.toList());
collect.forEach(runRecording ->{ collect.forEach(runRecording ->{
......
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