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

添加联查信息方法

master
陈思豪 2024-09-06 17:33:40 +08:00
parent a2c2d9e29e
commit 47fdfa7637
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -202,7 +202,9 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
} }
String limitSelect = sql + limit; String limitSelect = sql + limit;
SegmentTask segmentTask = new SegmentTask(limitSelect, tableId, basicId,newAndOldMap, Weight.getWeight(weigh)); SegmentTask segmentTask = new SegmentTask(limitSelect, tableId, basicId,newAndOldMap, Weight.getWeight(weigh));
log.info("创建任务添加到队列当中");
queue.add(segmentTask); queue.add(segmentTask);
log.info("添加到queue里成功");
} }
// 启动线程池执行任务 // 启动线程池执行任务

2
cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java
View File

@ -42,6 +42,8 @@ public class SegmentTask implements Runnable, Comparable<SegmentTask> {
@Override @Override
public void run() { public void run() {
log.info("开始执行任务：" + basicId + " " + sql + " " + weight + " " + tableId, tableId);
// 查询数据 // 查询数据
Result<List<List<DataValue>>> tableValue = dataValueClient.findTableValue(basicId, sql); Result<List<List<DataValue>>> tableValue = dataValueClient.findTableValue(basicId, sql);
List<List<DataValue>> data = tableValue.getData(); List<List<DataValue>> data = tableValue.getData();