添加联查信息方法
parent
47fdfa7637
commit
fbef7fc857
|
@ -201,7 +201,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
|
||||||
firstArray=pageSize;
|
firstArray=pageSize;
|
||||||
}
|
}
|
||||||
String limitSelect = sql + limit;
|
String limitSelect = sql + limit;
|
||||||
SegmentTask segmentTask = new SegmentTask(limitSelect, tableId, basicId,newAndOldMap, Weight.getWeight(weigh));
|
SegmentTask segmentTask = new SegmentTask(limitSelect, basicId, tableId,newAndOldMap, Weight.getWeight(weigh));
|
||||||
log.info("创建任务添加到队列当中");
|
log.info("创建任务添加到队列当中");
|
||||||
queue.add(segmentTask);
|
queue.add(segmentTask);
|
||||||
log.info("添加到queue里成功");
|
log.info("添加到queue里成功");
|
||||||
|
|
Loading…
Reference in New Issue