From 49bcab3824c1902a5f591fca8e2fed564aa801cf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com>
Date: Mon, 9 Sep 2024 00:08:28 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=BA=BF=E7=A8=8B=E6=B1=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/service/impl/TaskServiceImpl.java    | 15 ++++-----------
 1 file changed, 4 insertions(+), 11 deletions(-)

diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
index 631d0af..5b1a32b 100644
--- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
@@ -7,11 +7,9 @@ import com.muyu.common.core.utils.StringUtils;
 import com.muyu.domain.*;
 import com.muyu.domain.req.TaskInfoReq;
 import com.muyu.mapper.TaskMapper;
-import com.muyu.service.TaskInputService;
-import com.muyu.service.TaskJoinService;
-import com.muyu.service.TaskOutputService;
-import com.muyu.service.TaskService;
+import com.muyu.service.*;
 import com.muyu.task.feign.DataValueClient;
+import com.muyu.task.feign.RuleFeign;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -234,7 +232,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
         long firstArray = 0L;
         int totalSegments = (int) Math.ceil((double) count / pageSize);
         for (int i = 0; i < totalSegments; i++) {
-            log.info("调用第{}次", i);
+            log.info("当前页为{}", i);
             String limit = " limit " + i * pageSize + "," + pageSize;
             firstArray = Math.min(pageSize, count - i * pageSize);
             if (firstArray >= pageSize) {
@@ -247,13 +245,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
             log.info("远程调用完毕,调用数量{}",tableValue.length);
             for (DataValue[] dataValues : tableValue) {
                 for (DataValue dataValue : dataValues) {
-                    log.info(dataValue.toString());
                     String key = dataValue.getKey();
-                    log.info("传来的值的键为{}",key);
                     String newKey = newAndOldMap.get(key);
-                    log.info("取出来的值的键为{}",newKey);
-                    log.info("新的目标字段{}",newKey);
-                    log.info("通过map字段取到的值为{}", newKey);
                     dataValue.setKey(newKey);
                 }
             }
@@ -350,7 +343,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
 
 //    @Autowired
 //    private NodeRuleService nodeRuleService;
-
+//
 //    @Autowired
 //    private RuleFeign ruleFeign;