From 04449e4c41084f4f045532ae6f5d055da6c1e926 Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Tue, 10 Sep 2024 16:19:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=B6=85=E6=97=B6=E6=97=B6?= =?UTF-8?q?=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../task/server/service/impl/TaskInfoServiceImpl.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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(); } }