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

first commit

Browse Source
This commit is contained in:
刘通
2024-10-30 15:10:27 +08:00
parent 35e92433e3
commit 9dde3cf3c2
114 changed files with 14584 additions and 1979 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ddp/ddp-enginex/runner-node/src/main/java/com/fibo/ddp/enginex/runner/canal/CanalClient.java
View File

@@ -24,7 +24,7 @@ import java.util.Optional;
* Canal数据同步
* 实现ApplicationRunner接口，springboot启动成功后会执行run方法
*/
@Component
public class CanalClient implements ApplicationRunner {
private final Logger logger = LoggerFactory.getLogger(this.getClass());

2
ddp/ddp-enginex/runner-node/src/main/java/com/fibo/ddp/enginex/runner/node/impl/DecisionTablesNode.java
View File

@@ -210,7 +210,7 @@ public class DecisionTablesNode implements EngineRunnerNode {
if (row >= 0 && column >= 0) {
//根据行列去结果集中找结果返回
DecisionTablesResultVo resultSet = versionVo.getResultSet();
if (row < resultSet.getRows() && column < resultSet.getColumns()) {
if (row < resultSet.getRo() && column < resultSet.getColum()) {
String resultValue = resultSet.getResultValue();
JSONArray array = JSON.parseArray(resultValue);
JSONArray rowArray = JSON.parseArray(JSON.toJSONString(array.get(row)));