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);
+    }
 }