From 9baf7220b95cdcd13bee860f09d68ce5e01c2c8d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=9C=E5=88=9A?= <53732908@qq.com> Date: Sun, 27 Apr 2025 14:16:18 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E5=A7=8B=20>=20=E5=88=86=E7=BB=84=20>?= =?UTF-8?q?=20=E8=81=9A=E5=90=88=20>=20=E5=86=B3=E7=AD=96=E9=80=89?= =?UTF-8?q?=E9=A1=B9=20=20=20=E8=81=9A=E5=90=88=E4=B9=8B=E5=90=8E=E8=8A=82?= =?UTF-8?q?=E7=82=B9=E4=B8=8D=E4=BC=9A=E6=89=A7=E8=A1=8C=E9=97=AE=E9=A2=98?= =?UTF-8?q?bugfix?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business/impl/RiskEngineBusinessImpl.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) 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); } }