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

Compare commits

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

No commits in common. "f77645a954f4a159e354e0b7eab4d3c5dca712ae" and "d05503724e8f79c1e82e5c3a16a36932c4cc75e1" have entirely different histories.
f77645a954 ... d05503724e

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