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

Compare commits

base: TreeData:d05503724e8f79c1e82e5c3a16a36932c4cc75e1
Branches Tags
TreeData:master
...
compare: TreeData:f77645a954f4a159e354e0b7eab4d3c5dca712ae
Branches Tags
TreeData:master

2 Commits
d05503724e ... f77645a954

Author SHA1 Message Date
lwj f77645a954 测试线程池 2024-09-08 02:38:41 +08:00
lwj 3eaa65b3b0 测试线程池 2024-09-08 02:35:46 +08:00
1 changed files with 3 additions and 1 deletions
Show Stats Expand all files Collapse all files

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

@ -125,13 +125,14 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
String[] tableAsFieldList = taskInputList.get(i).getTableAsField().split(",");
for (int j = 0; j < tableAsFieldList.length; j++) {
for (int o = 0; o < newFileName.length; o++) {
newAndOldMap.put(outPutFileName[j], newFileName[j]);
newAndOldMap.put(outPutFileName[o], newFileName[o]);
if(tableAsFieldList[j].equals(outPutFileName[o])){
sql += ","+taskInputList.get(i).getTableAsName() + "." + tableFieldList[j] +" " +
tableAsFieldList[j] + " ";
}
}
fieldAsNameMap.put(tableAsFieldList[j], tableFieldList[j]);
fieldAsNameMap.put(tableAsFieldList[j], tableFieldList[j]);
}
}
@ -249,6 +250,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
List<List<DataValue>> data = (List<List<DataValue>>) tableValue.getData();
log.info("远程调用完毕,调用数量{}",data.size());
for (List<DataValue> datum : data) {
log.info(datum.toString());
for (DataValue dataValue : datum) {
String key = dataValue.getKey();
String newKey = fieldAsNameMap.get(key);