Commit c3c0554f by huangfusuper

增加待运行节点统计

parent 414af5d8
...@@ -902,11 +902,11 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -902,11 +902,11 @@ public class ApiFlowServiceImpl implements ApiFlowService {
*/ */
public StatisticData statisticsNodeData (List<RunRecording> betweenRunRecording) { public StatisticData statisticsNodeData (List<RunRecording> betweenRunRecording) {
//剔除未运行状态的实例 //剔除未运行状态的实例
List<RunRecording> runRecordings = betweenRunRecording.stream().filter(recording -> !recording.getFlowStatus().equals("1")).collect(Collectors.toList()); //List<RunRecording> runRecordings = betweenRunRecording.stream().filter(recording -> !recording.getFlowStatus().equals("1")).collect(Collectors.toList());
List<JobTaskRunLogWithBLOBs> logWithBLOBs = new ArrayList<>(32); List<JobTaskRunLogWithBLOBs> logWithBLOBs = new ArrayList<>(32);
int total = 0; int total = 0;
//查询所有的节点 //查询所有的节点
for (RunRecording runRecording : runRecordings) { for (RunRecording runRecording : betweenRunRecording) {
total += runRecording.getFlowNodeCount(); total += runRecording.getFlowNodeCount();
String runId = runRecording.getRunId(); String runId = runRecording.getRunId();
Integer flowId = runRecording.getFlowId(); Integer flowId = runRecording.getFlowId();
......
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