liutongsz/fibo-rule
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

开始 > 分组 > 聚合 > 决策选项 聚合之后节点不会执行问题bugfix

Browse Source
This commit is contained in:
杜刚
2025-04-27 14:16:18 +08:00
parent 9ba4c9a98d
commit 9baf7220b9
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
ddp/ddp-enginex/risk-engine/src/main/java/com/fibo/ddp/enginex/riskengine/runner/business/impl/RiskEngineBusinessImpl.java
View File

@@ -323,11 +323,16 @@ public class RiskEngineBusinessImpl implements RiskEngineBusiness {
nextEngineNode = engineNodeMap.get(outMap.get("nextNode")); nextEngineNode = engineNodeMap.get(outMap.get("nextNode"));
outMap.remove("nextNode"); outMap.remove("nextNode");
} }
// 会导致 开始 > 分组 > 聚合 > 决策选项 不会执行 ，先注释掉 20250427
if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) { // if (nextEngineNode != null && nextEngineNode.getNodeType() == NodeTypeEnum.AGGREGATION.getValue()) {
// 并行节点后面的分支为多线程执行，执行到聚合节点则结束 // 并行节点后面的分支为多线程执行，执行到聚合节点则结束
resultNode = nextEngineNode; //resultNode = nextEngineNode;
} else { //} else {
// resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap);
//}
// 20250427 之前的逻辑 会导致 开始 > 分组 > 聚合 > 决策选项 不会执行 ， 使用以下代码
if (nextEngineNode != null){
resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap); resultNode = recursionEngineNode(inputParam, nextEngineNode, engineNodeMap, outMap);
} }
} }