diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java index 5146b42..e18fb57 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java @@ -401,17 +401,23 @@ public class TaskInfoServiceImpl extends ServiceImpl i Result result = ruleConfig.findVersionById(nodeRule.getRuleId()); RuleEngineVersion data = result.getData(); final Future finalCurrentFuture = currentFuture; - log.info(finalCurrentFuture); + // log.info(finalCurrentFuture); Callable task = () -> { DataValue[][] prevResult = finalCurrentFuture.get(); HashSet set = new HashSet<>(); //log.info(data.getClassName()); if (data.getRuleId().equals("3")) { + log.info("1"); DataValueRows dataValueRows = new DataValueRows(); + log.info("2"); dataValueRows.setDataValue(prevResult); + log.info("3"); dataValueRows.setKey(nodeRule.getConfig()); + log.info("4"); Result result1 = ruleConfig.DataSetEngine(data.getClassName(), dataValueRows); + log.info("5"); if (result1.getCode() == 200) { + log.info("6"); prevResult = result1.getData(); } }