fix(107562): processNodes 接口返回数据异常

完成 107562 计划的代码实施

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

Author: jaquanli

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

@@ -8,6 +8,10 @@
 import com.codingapi.flow.manager.NodeStrategyManager;
 import com.codingapi.flow.manager.OperatorManager;
 import com.codingapi.flow.node.IFlowNode;
+import com.codingapi.flow.node.nodes.ConditionBranchNode;
+import com.codingapi.flow.node.nodes.ConditionElseBranchNode;
+import com.codingapi.flow.node.nodes.InclusiveBranchNode;
+import com.codingapi.flow.node.nodes.InclusiveElseBranchNode;
 import com.codingapi.flow.node.nodes.StartNode;
 import com.codingapi.flow.operator.IFlowOperator;
 import com.codingapi.flow.pojo.request.FlowProcessNodeRequest;
@@ -187,10 +191,41 @@ private void fetchNextNode(FlowSession flowSession, List<IFlowNode> nexNodes) {
                 }
                 this.nodeList.add(processNode);
                 List<IFlowNode> nextNodes = workflow.nextNodes(flowNode);
-                this.fetchNextNode(flowSession.updateSession(flowNode), nextNodes);
+                List<IFlowNode> selected = selectBranchNodes(nextNodes, flowSession.updateSession(flowNode));
+                this.fetchNextNode(flowSession.updateSession(flowNode), selected);
             }
         }
 
+        private List<IFlowNode> selectBranchNodes(List<IFlowNode> nextNodes, FlowSession flowSession) {
+            if (nextNodes == null || nextNodes.isEmpty()) {
+                return nextNodes;
+            }
+            IFlowNode first = nextNodes.get(0);
+            String type = first.getType();
+            boolean isBranchControl =
+                    ConditionBranchNode.NODE_TYPE.equals(type)
+                            || ConditionElseBranchNode.NODE_TYPE.equals(type)
+                            || InclusiveBranchNode.NODE_TYPE.equals(type)
+                            || InclusiveElseBranchNode.NODE_TYPE.equals(type);
+            if (!isBranchControl) {
+                return nextNodes;
+            }
+            try {
+                // 优先按 if 条件脚本匹配；脚本天然 fallback else（else.handle() 恒为 true）
+                List<IFlowNode> matched = first.filterBranches(nextNodes, flowSession);
+                if (matched != null && !matched.isEmpty()) {
+                    return matched;
+                }
+            } catch (Exception ignored) {
+                // 表单数据缺失导致条件脚本异常 —— 降级到 else
+            }
+            List<IFlowNode> elseOnly = nextNodes.stream()
+                    .filter(n -> ConditionElseBranchNode.NODE_TYPE.equals(n.getType())
+                            || InclusiveElseBranchNode.NODE_TYPE.equals(n.getType()))
+                    .toList();
+            return elseOnly.isEmpty() ? nextNodes : elseOnly;
+        }
+
         public List<ProcessNode> loadNextNode(FlowSession flowSession) {
             this.fetchNextNode(flowSession, List.of(this.currentNode));