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

添加字段和表

master
Cui YongXing 2024-09-03 15:23:53 +08:00
parent e8e9146a64
commit e150812b07
6 changed files with 37 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-task-common/src/main/java/com/muyu/common/domian/TaskInput.java
View File

@ -71,7 +71,7 @@ public class TaskInput extends BaseEntity {
/**
* 字段规则
*/
private Long fieIdAsEngineId;
private String fieIdAsEngineId;
public static TaskInputResp build(TaskInput node) {
return TaskInputResp.builder()

2
cloud-task-common/src/main/java/com/muyu/common/domian/req/TaskInputUpdReq.java
View File

@ -54,5 +54,5 @@ public class TaskInputUpdReq {
/**
* 字段规则
*/
private Long fieIdAsEngineId;
private String fieIdAsEngineId;
}

2
cloud-task-common/src/main/java/com/muyu/common/domian/resp/TaskInputResp.java
View File

@ -60,5 +60,5 @@ public class TaskInputResp {
/**
* 字段规则
*/
private Long fieIdAsEngineId;
private String fieIdAsEngineId;
}

2
cloud-task-common/src/main/java/com/muyu/common/domian/vo/TableVo.java
View File

@ -25,5 +25,5 @@ public class TableVo {
/**
* 字段规则
*/
private Long fieIdAsEngineId;
private String fieIdAsEngineId;
}

39
cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInputController.java
View File

@ -52,21 +52,44 @@ public class TaskInputController {
map.put("node_id",req.getNodeId());
taskInputService.removeByMap(map);
List<TableVo> list = req.getList();
List<TaskInput> inputs = list.stream().map(inputAddReq -> {
TaskInput build = TaskInput.builder()
String tableFieId="";
String tableAsFieId="";
String fieIdAsEngineId="";
for (TableVo tableVo : list) {
tableFieId += "," + tableVo.getColumnName();
tableAsFieId += "," + tableVo.getTableAsName();
fieIdAsEngineId += "," + tableVo.getFieIdAsEngineId();
}
tableFieId = tableFieId.substring(1);
tableAsFieId = tableAsFieId.substring(1);
fieIdAsEngineId = fieIdAsEngineId.substring(1);
// List<TaskInput> inputs = list.stream().map(inputAddReq -> {
// TaskInput build = TaskInput.builder()
// .nodeId(req.getNodeId())
// .nodeName(req.getNodeName())
// .taskId(req.getTaskId())
// .databaseId(req.getDatabaseId())
// .tableName(req.getTableName())
// .tableAsName(req.getTableAsName())
// .tableFieId(inputAddReq.getColumnName())
// .tableAsFieId(inputAddReq.getTableAsName())
// .fieIdAsEngineId(inputAddReq.getFieIdAsEngineId())
// .build();
// return build;
// }).toList();
TaskInput build = TaskInput.builder()
.nodeId(req.getNodeId())
.nodeName(req.getNodeName())
.taskId(req.getTaskId())
.databaseId(req.getDatabaseId())
.tableName(req.getTableName())
.tableAsName(req.getTableAsName())
.tableFieId(inputAddReq.getColumnName())
.tableAsFieId(inputAddReq.getTableAsName())
.fieIdAsEngineId(inputAddReq.getFieIdAsEngineId())
.tableFieId(tableFieId)
.tableAsFieId(tableAsFieId)
.fieIdAsEngineId(fieIdAsEngineId)
.build();
return build;
}).toList();
taskInputService.saveBatch(inputs);
taskInputService.save(build);
return Result.success();
}

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

@ -230,6 +230,8 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String newKey = map.get(key);
dataValue.setKey(newKey);
log.info(dataValue);
}
}
return "执行成功";