From 5c9a72973e7670651680a679e56d86315872ecc0 Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Wed, 4 Sep 2024 22:32:24 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/TaskInfoServiceImpl.java | 28 +++++++++---------- 1 file changed, 14 insertions(+), 14 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 23821d0..0b22b4c 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 @@ -274,19 +274,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i for (long i = 1; i <= count; i++) { long pageNum = (i - 1) * 5000; submitEmergencyTask(()->{ - String sqlSelect = " SELECT " + finalFieName + " FROM " + finalJoint +" limit "+pageNum +",5000 "; - log.info(sqlSelect); - Result>> tableValueResult = datasourceFeign.findTableValue(basicId, sql); - List> tableValue = tableValueResult.getData(); - for (List dataValues : tableValue) { - for (DataValue dataValue : dataValues) { - String key = dataValue.getKey(); - String newKey = map.get(key); - dataValue.setKey(newKey); - } - } - Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue); - log.info(result); + //getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map); }); } @@ -296,7 +284,19 @@ public class TaskInfoServiceImpl extends ServiceImpl i @NotNull private void getString(Long pageNum,String fieName,String joint,Long basicId,Long newBasicId,Long tableId,HashMap map ) { - + String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +",5000 "; + log.info(sqlSelect); + Result>> tableValueResult = datasourceFeign.findTableValue(basicId, sqlSelect); + List> tableValue = tableValueResult.getData(); + for (List dataValues : tableValue) { + for (DataValue dataValue : dataValues) { + String key = dataValue.getKey(); + String newKey = map.get(key); + dataValue.setKey(newKey); + } + } + Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue); + log.info(result); }