diff --git a/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java b/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java index c2e93e5..1b7da16 100644 --- a/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java +++ b/ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java @@ -323,11 +323,16 @@ public class RiskEngineBusinessImpl implements RiskEngineBusiness { nextEngineNode = engineNodeMap.get(outMap.get("nextNode")); outMap.remove("nextNode"); } - - if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) { + // 会导致 开始 > 分组 > 聚合 > 决策选项 不会执行 ,先注释掉 20250427 + // if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) { // 并行节点后面的分支为多线程执行,执行到聚合节点则结束 - resultNode = nextEngineNode; - } else { + //resultNode = nextEngineNode; + //} else { + // resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap); + //} + + // 20250427 之前的逻辑 会导致 开始 > 分组 > 聚合 > 决策选项 不会执行 , 使用以下代码 + if (nextEngineNode != null){ resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap); } }