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

修改bug

master
Cui YongXing 2024-09-04 17:16:42 +08:00
parent 31c589da46
commit a01a5a957b
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -240,7 +240,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
Long data = countResult.getData(); Long data = countResult.getData();
String finalFieName = fieName; String finalFieName = fieName;
String finalJoint = joint; String finalJoint = joint;
long count = data/10000==0?1:data/10000; long count = data/10000==0?1:data/10000+1;
if (Weight.high.getValue().equals(weight)){ if (Weight.high.getValue().equals(weight)){
log.info("执行高级任务"); log.info("执行高级任务");
for (long i = 1; i <= count; i++) { for (long i = 1; i <= count; i++) {
@ -292,7 +292,6 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String key = dataValue.getKey(); String key = dataValue.getKey();
String newKey = map.get(key); String newKey = map.get(key);
dataValue.setKey(newKey); dataValue.setKey(newKey);
log.info(dataValue);
} }
} }
Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue); Result result = datasourceFeign.addProduct(newBasicId, tableId, tableValue);