TreeData
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加联查信息方法

master
陈思豪 2024-09-06 18:48:04 +08:00
parent c074e17487
commit 64fc1ef7b5
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
View File

@ -2,6 +2,7 @@ package com.muyu.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; 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.common.core.utils.StringUtils;
import com.muyu.domain.TaskInfo; import com.muyu.domain.TaskInfo;
import com.muyu.domain.TaskInputInfo; import com.muyu.domain.TaskInputInfo;
@ -51,7 +52,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
private TaskOutputService taskOutputService; private TaskOutputService taskOutputService;
@Autowired @Autowired
private DataValueClient dataValueFeign; private DataValueClient dataValueClient;
@Override @Override
public List<TaskInfo> selectList(TaskInfoReq taskInfoReq) { public List<TaskInfo> selectList(TaskInfoReq taskInfoReq) {
@ -170,7 +171,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
String sqlCount = "select count(1) from "+leftJoin; 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; sql = sql + leftJoin;
@ -202,6 +204,10 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
} }
String limitSelect = sql + limit; String limitSelect = sql + limit;
SegmentTask segmentTask = new SegmentTask(limitSelect, basicId, tableId,newAndOldMap, Weight.getWeight(weigh)); SegmentTask segmentTask = new SegmentTask(limitSelect, basicId, tableId,newAndOldMap, Weight.getWeight(weigh));
Result tableValue = dataValueClient.findTableValue(basicId, sql);
log.info("远程调用完毕，调用的值为{}",tableValue.getData());
log.info("创建任务添加到队列当中"); log.info("创建任务添加到队列当中");
queue.add(segmentTask); queue.add(segmentTask);
log.info("添加到queue里成功"); log.info("添加到queue里成功");