refactor(024982): processNodes 数据返回修复

完成 024982 计划的代码实施

Co-Authored-By: Claude <noreply@anthropic.com>

Author: xlorne

flow-engine-framework/src/main/java/com/codingapi/flow/pojo/response/ProcessNode.java

@@ -115,7 +115,11 @@ public boolean equals(Object target) {
 
     @Override
     public int hashCode() {
-        return Objects.hash(nodeId, nodeName, nodeType, state, operators);
+        return Objects.hash(nodeId);
+    }
+
+    public void addOperator(FlowOperatorBody operator) {
+        this.operators.add(operator);
     }
 
     /**

flow-engine-framework/src/main/java/com/codingapi/flow/service/impl/FlowProcessNodeService.java

@@ -23,7 +23,9 @@
 import lombok.Getter;
 
 import java.util.ArrayList;
+import java.util.LinkedHashMap;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 流程节点记录服务
@@ -90,11 +92,9 @@ public List<ProcessNode> processNodes() {
             backupId = this.flowRecord.getWorkRuntimeId();
             // 如果当前记录已结束，则不查询后续流程
             if (this.flowRecord.isDone()) {
-                List<FlowRecord> historyRecords = flowRecordService.findFlowRecordByProcessId(this.flowRecord.getProcessId());
-                for (FlowRecord historyRecord : historyRecords) {
-                    ProcessNode processNode = new ProcessNode(historyRecord, this.workflow);
-                    nodeList.add(processNode);
-                }
+                List<FlowRecord> allRecords = flowRecordService.findFlowRecordByProcessId(this.flowRecord.getProcessId());
+                List<FlowRecord> doneRecords = allRecords.stream().filter(FlowRecord::isDone).toList();
+                nodeList.addAll(buildHistoryNodes(doneRecords));
                 if (this.flowRecord.isFinish()) {
                     nodeList.add(ProcessNode.createEndNode(this.workflow));
                 } else {
@@ -104,10 +104,7 @@ public List<ProcessNode> processNodes() {
             } else {
                 // 查询历史记录
                 List<FlowRecord> historyRecords = flowRecordService.findFlowRecordBeforeRecords(flowRecord.getProcessId(), flowRecord.getId());
-                for (FlowRecord historyRecord : historyRecords) {
-                    ProcessNode processNode = new ProcessNode(historyRecord, this.workflow);
-                    nodeList.add(processNode);
-                }
+                nodeList.addAll(buildHistoryNodes(historyRecords));
             }
         }
 
@@ -116,6 +113,19 @@ public List<ProcessNode> processNodes() {
         return this.nodeList;
     }
 
+    private List<ProcessNode> buildHistoryNodes(List<FlowRecord> records) {
+        Map<String, ProcessNode> nodeMap = new LinkedHashMap<>();
+        for (FlowRecord record : records) {
+            ProcessNode existing = nodeMap.get(record.getNodeId());
+            if (existing != null) {
+                existing.addOperator(new ProcessNode.FlowOperatorBody(record));
+            } else {
+                nodeMap.put(record.getNodeId(), new ProcessNode(record, this.workflow));
+            }
+        }
+        return new ArrayList<>(nodeMap.values());
+    }
+
 
     private void loadNextNode(long backupId) {