From 64fc1ef7b5624f71382cc8cd92ed44c26257e1a5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com> Date: Fri, 6 Sep 2024 18:48:04 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=81=94=E6=9F=A5=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/muyu/service/impl/TaskServiceImpl.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 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 3b3d323..6623159 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 @@ -2,6 +2,7 @@ package com.muyu.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.common.core.domain.Result; import com.muyu.common.core.utils.StringUtils; import com.muyu.domain.TaskInfo; import com.muyu.domain.TaskInputInfo; @@ -51,7 +52,7 @@ public class TaskServiceImpl extends ServiceImpl implement private TaskOutputService taskOutputService; @Autowired - private DataValueClient dataValueFeign; + private DataValueClient dataValueClient; @Override public List selectList(TaskInfoReq taskInfoReq) { @@ -170,7 +171,8 @@ public class TaskServiceImpl extends ServiceImpl implement String sqlCount = "select count(1) from "+leftJoin; //查询出总条数 - Integer count = dataValueFeign.findCount(Long.valueOf(taskOutputInfo.getBasicId()), sqlCount); + Integer count = dataValueClient.findCount(Long.valueOf(taskOutputInfo.getBasicId()), sqlCount); + log.info("查询到的条数为{}",count); //查询数据 sql = sql + leftJoin; @@ -202,6 +204,10 @@ public class TaskServiceImpl extends ServiceImpl implement } String limitSelect = sql + limit; SegmentTask segmentTask = new SegmentTask(limitSelect, basicId, tableId,newAndOldMap, Weight.getWeight(weigh)); + + Result tableValue = dataValueClient.findTableValue(basicId, sql); + log.info("远程调用完毕，调用的值为{}",tableValue.getData()); + log.info("创建任务添加到队列当中"); queue.add(segmentTask); log.info("添加到queue里成功");