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

添加字段和表

master
Cui YongXing 2024-09-01 16:10:40 +08:00
parent c0725308b6
commit a942afa811
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInfoController.java
View File

@ -122,13 +122,7 @@ public class TaskInfoController {
return Result.success();
}
@PostMapping("/findByTableFieName/{taskId}")
public Result findByTableFieName(@PathVariable("taskId") Long taskId){
QueryWrapper<TaskInfo> wrapper = new QueryWrapper<>();
wrapper.eq("task_id",taskId);
List<TaskInfo> list = taskInfoService.list(wrapper);
return Result.success(list);
}
}

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

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.muyu.common.core.domain.Result;
import com.muyu.common.domian.Structure;
import com.muyu.common.domian.TaskInfo;
import com.muyu.common.domian.TaskInput;
import com.muyu.common.domian.req.*;
import com.muyu.common.domian.resp.TaskInputResp;
@ -116,5 +117,11 @@ public class TaskInputController {
taskInputService.updateById(TaskInput.updBuild(req, () -> id));
return Result.success(null, "操作成功");
}
@PostMapping("/findByTableFieName/{taskId}")
public Result findByTableFieName(@PathVariable("taskId") Long taskId){
QueryWrapper<TaskInput> wrapper = new QueryWrapper<>();
wrapper.eq("task_id",taskId);
List<TaskInput> list = taskInputService.list(wrapper);
return Result.success(list);
}
}