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

添加实体类

master
陈思豪 2024-08-30 20:48:38 +08:00
parent 72cfcc5580
commit 417c1d6add
3 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java
View File

@ -4,10 +4,9 @@ import com.muyu.common.core.domain.Result;
import com.muyu.domain.TaskInputInfo;
import com.muyu.service.TaskInputService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
@ -30,4 +29,9 @@ public class TaskInputInfoController {
return Result.success(null,taskInputService.addTaskInput(taskInputInfo));
}
@GetMapping(value = "findByNodeId/{nodeId}")
public Result<TaskInputInfo> findByNodeId(@PathVariable("nodeId") String nodeId){
return Result.success(taskInputService.findByNodeId(nodeId));
}
}

4
cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java
View File

@ -4,6 +4,10 @@ package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.TaskInputInfo;
import java.util.List;
public interface TaskInputService extends IService<TaskInputInfo> {
String addTaskInput(TaskInputInfo taskInputInfo);
TaskInputInfo findByNodeId(String nodeId);
}

8
cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java
View File

@ -11,6 +11,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Iterator;
import java.util.List;
/**
* @PackageName:com.muyu.service.impl
@ -33,4 +34,11 @@ public class TaskInputInfoServiceImpl extends ServiceImpl<TaskInputInfoMapper, T
}
return "添加成功";
}
@Override
public TaskInputInfo findByNodeId(String nodeId) {
LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(TaskInputInfo::getNodeId, nodeId);
return taskInputInfoMapper.selectOne(queryWrapper);
}
}