From d3bd8c27cc8a1b73bd495a2050fefbefd7873620 Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Sun, 8 Sep 2024 00:58:21 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=BB=E6=89=BE=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/TaskInfoServiceImpl.java | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) 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 54898c1..1ff82fd 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 @@ -344,8 +344,16 @@ public class TaskInfoServiceImpl extends ServiceImpl i DataValue[][] data = tableValueResult.getData(); log.info("执行{}查询的方法结束", sqlSelect); - - executeTheRule(data,map,newBasicId,tableId); + for (DataValue[] datum : data) { + for (DataValue dataValue : datum) { + String key = dataValue.getKey(); + String newKey = map.get(key); + dataValue.setKey(newKey); + } + } + Result result = datasourceFeign.addProduct(newBasicId, tableId, data); + log.info("{}添加结束", result); + //executeTheRule(data,map,newBasicId,tableId); } @@ -389,15 +397,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i } try { DataValue[][] afterFilteringDataValue = currentFuture.get(); - for (DataValue[] datum : afterFilteringDataValue) { - for (DataValue dataValue : datum) { - String key = dataValue.getKey(); - String newKey = map.get(key); - dataValue.setKey(newKey); - } - } - Result result = datasourceFeign.addProduct(newBasicId, tableId, afterFilteringDataValue); - log.info("{}添加结束", result); + } catch (InterruptedException e) { throw new RuntimeException(e);