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里成功");