Commit a3a108eea675dc94a0f22ff7b4bb1f51d46e13f5
1 parent
50edfb21
fix: 修复脚本转换脚本阻塞RPC调用
1、无论脚本转换节点是否成功执行都要继续传递给下一个节点 RPC不包括脚本转换的数据
Showing
1 changed file
with
6 additions
and
0 deletions
| @@ -373,11 +373,17 @@ public class ConvertConfigServiceImpl | @@ -373,11 +373,17 @@ public class ConvertConfigServiceImpl | ||
| 373 | int newFirstNodeIndex = ruleChainMetaData.getNodes().size() - 1; | 373 | int newFirstNodeIndex = ruleChainMetaData.getNodes().size() - 1; |
| 374 | ruleChainMetaData.setFirstNodeIndex(newFirstNodeIndex); | 374 | ruleChainMetaData.setFirstNodeIndex(newFirstNodeIndex); |
| 375 | // 3. Add Connection | 375 | // 3. Add Connection |
| 376 | + NodeConnectionInfo failedConnectionInfo = new NodeConnectionInfo(); | ||
| 377 | + failedConnectionInfo.setFromIndex(newFirstNodeIndex); | ||
| 378 | + failedConnectionInfo.setType("Failure"); | ||
| 379 | + failedConnectionInfo.setToIndex(firstNodeIndex); | ||
| 380 | + | ||
| 376 | NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo(); | 381 | NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo(); |
| 377 | nodeConnectionInfo.setFromIndex(newFirstNodeIndex); | 382 | nodeConnectionInfo.setFromIndex(newFirstNodeIndex); |
| 378 | nodeConnectionInfo.setType(connectionType); | 383 | nodeConnectionInfo.setType(connectionType); |
| 379 | nodeConnectionInfo.setToIndex(firstNodeIndex); | 384 | nodeConnectionInfo.setToIndex(firstNodeIndex); |
| 380 | ruleChainMetaData.getConnections().add(nodeConnectionInfo); | 385 | ruleChainMetaData.getConnections().add(nodeConnectionInfo); |
| 386 | + ruleChainMetaData.getConnections().add(failedConnectionInfo); | ||
| 381 | } | 387 | } |
| 382 | 388 | ||
| 383 | private void addSceneRuleNode(RuleNode ruleNode, RuleChainMetaData ruleChainMetaData) { | 389 | private void addSceneRuleNode(RuleNode ruleNode, RuleChainMetaData ruleChainMetaData) { |