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

添加字段和表

master
Cui YongXing 2024-09-03 16:26:27 +08:00
parent 39d1fdd994
commit 61b06f8c55
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskOutputController.java
View File

@ -17,12 +17,21 @@ public class TaskOutputController {
private TaskOutputService taskOutputService;
@PostMapping("/{id}")
public Result save(@PathVariable("id") Long id, @RequestBody List<TaskOutput> taskOutputs) {
@PostMapping("/{id}/{tableId}/{basicId}")
public Result save(@PathVariable("id") Long id,@PathVariable("tableId") Long tableId ,@PathVariable("basicId") Long basicId,@RequestBody List<TaskOutput> taskOutputs) {
QueryWrapper<TaskOutput> wrapper = new QueryWrapper<>();
wrapper.eq("task_id", id);
taskOutputService.remove(wrapper);
boolean save = taskOutputService.saveBatch(taskOutputs);
String newFieName ="";
String lastFieName="";
for (TaskOutput taskOutput : taskOutputs) {
newFieName += ","+taskOutput.getNewFieName();
lastFieName+=","+ taskOutput.getLastFieName();
}
newFieName = newFieName.substring(1);
lastFieName = lastFieName.substring(1);
TaskOutput build = TaskOutput.builder().taskId(id).basicId(basicId).tableId(tableId).newFieName(newFieName).lastFieName(lastFieName).build();
boolean save = taskOutputService.save(build);
return Result.success(save);
}