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

添加字段和表

master
Cui YongXing 2024-08-28 20:17:08 +08:00
parent 4126b4899c
commit 982b853753
2 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cloud-task-server/src/main/java/com/muyu/task/server/controller/NodeTableController.java
View File

@ -1,5 +1,6 @@
package com.muyu.task.server.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.muyu.common.core.domain.Result;
import com.muyu.common.domian.NodeTable;
import com.muyu.task.server.service.NodeTableService;
@ -13,7 +14,13 @@ public class NodeTableController {
@Autowired
private NodeTableService nodeTableService;
@DeleteMapping
private Result delete(@PathVariable("id") Long id) {
QueryWrapper<NodeTable> wrapper = new QueryWrapper<>();
wrapper.eq("node_id", id);
boolean save = nodeTableService.remove(wrapper);
return Result.success(save);
}
@PostMapping
private Result addNodeTable(@RequestBody NodeTable nodeTable) {
boolean save = nodeTableService.save(nodeTable);
@ -21,7 +28,9 @@ public class NodeTableController {
}
@GetMapping("/{id}")
private Result getNodeTable(@PathVariable("id") Long id) {
NodeTable byId = nodeTableService.getById(id);
QueryWrapper<NodeTable> wrapper = new QueryWrapper<>();
wrapper.eq("node_id", id);
NodeTable byId = nodeTableService.getOne(wrapper);
return Result.success(byId);
}

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

@ -1,5 +1,6 @@
package com.muyu.task.server.controller;
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;
@ -93,7 +94,9 @@ public class TaskInputController {
@DeleteMapping("/{id}")
@Operation(summary = "删除任务", description = "通过任务id删除任务信息")
public Result delete(@PathVariable("id") Long id) {
taskInputService.removeById(id);
QueryWrapper<TaskInput> taskInputQueryWrapper = new QueryWrapper<>();
taskInputQueryWrapper.eq("node_id",id);
taskInputService.remove(taskInputQueryWrapper);
return Result.success(null, "操作成功");
}