From 417c1d6add68ac6d5738e5c2abe3149ce72e889c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com>
Date: Fri, 30 Aug 2024 20:48:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9E=E4=BD=93=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/controller/TaskInputInfoController.java | 12 ++++++++----
 .../main/java/com/muyu/service/TaskInputService.java |  4 ++++
 .../muyu/service/impl/TaskInputInfoServiceImpl.java  |  8 ++++++++
 3 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java b/cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java
index 262e6a5..48ff27a 100644
--- a/cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java
+++ b/cloud-task-server/src/main/java/com/muyu/controller/TaskInputInfoController.java
@@ -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));
+    }
+
 }
diff --git a/cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java b/cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java
index 49fe199..5e74a85 100644
--- a/cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java
+++ b/cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java
@@ -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);
 }
diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java
index 8f8c934..fd37ce7 100644
--- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputInfoServiceImpl.java
@@ -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);
+    }
 }