diff --git a/cloud-task-common/src/main/java/com/muyu/domain/TaskOutputInfo.java b/cloud-task-common/src/main/java/com/muyu/domain/TaskOutputInfo.java
new file mode 100644
index 0000000..f0adbc7
--- /dev/null
+++ b/cloud-task-common/src/main/java/com/muyu/domain/TaskOutputInfo.java
@@ -0,0 +1,26 @@
+package com.muyu.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @PackageName:com.muyu.domain
+ * @ClassName:TaskOutputInfo
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/9/3 16:52
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class TaskOutputInfo {
+    private String id;
+    private String taskId;
+    private String newFileName;
+    private String lastFileName;
+    private String tableId;
+    private String basicId;
+}
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 6a84455..0626558 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
@@ -1,12 +1,15 @@
 package com.muyu.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.muyu.common.core.domain.Result;
 import com.muyu.domain.TaskInputInfo;
 import com.muyu.domain.resp.TaskInputInfoResp;
+import com.muyu.mapper.TaskInputInfoMapper;
 import com.muyu.service.TaskInputService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.Arrays;
 import java.util.List;
 
 
@@ -25,6 +28,9 @@ public class TaskInputInfoController {
     @Autowired
     private TaskInputService taskInputService;
 
+    @Autowired
+    private TaskInputInfoMapper taskInputInfoMapper;
+
     @PostMapping(value = "addTaskInput")
     public Result<String> addTaskInput(@RequestBody TaskInputInfo taskInputInfo){
         return Result.success(null,taskInputService.addTaskInput(taskInputInfo));
@@ -35,4 +41,16 @@ public class TaskInputInfoController {
         return Result.success(taskInputService.findByNodeId(nodeId));
     }
 
+    @PostMapping(value = "findById/{nodeId}")
+    public Result<String> findById(@PathVariable("nodeId") String nodeId){
+        LambdaQueryWrapper<TaskInputInfo> eq = new LambdaQueryWrapper<TaskInputInfo>().eq(TaskInputInfo::getNodeId, nodeId);
+        TaskInputInfo taskInputInfo = taskInputInfoMapper.selectOne(eq);
+        String tableField = taskInputInfo.getTableField();
+        List<String> list = Arrays.asList(tableField);
+        System.out.println(list);
+        return Result.success();
+    }
+
+
+
 }
diff --git a/cloud-task-server/src/main/java/com/muyu/controller/TaskOutPutController.java b/cloud-task-server/src/main/java/com/muyu/controller/TaskOutPutController.java
new file mode 100644
index 0000000..f50408b
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/controller/TaskOutPutController.java
@@ -0,0 +1,31 @@
+package com.muyu.controller;
+
+import com.muyu.domain.TaskOutputInfo;
+import com.muyu.mapper.TaskOutputMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @PackageName:com.muyu.controller
+ * @ClassName:TaskOutPutController
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/9/3 16:54
+ */
+@RestController
+@RequestMapping(value = "/taskOutPut")
+public class TaskOutPutController {
+
+    @Autowired
+    private TaskOutputMapper taskOutPutMapper;
+
+    //添加数据输出方法
+    @RequestMapping(value = "addTaskOutPut")
+    public void addTaskOutPut(@RequestBody TaskOutputInfo taskOutputInfo){
+        int insert = taskOutPutMapper.insert(taskOutputInfo);
+    }
+
+
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/mapper/TaskJoinMapper.java b/cloud-task-server/src/main/java/com/muyu/mapper/TaskJoinMapper.java
index cb3569d..6c4f540 100644
--- a/cloud-task-server/src/main/java/com/muyu/mapper/TaskJoinMapper.java
+++ b/cloud-task-server/src/main/java/com/muyu/mapper/TaskJoinMapper.java
@@ -1,7 +1,6 @@
 package com.muyu.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.muyu.domain.TaskInfo;
 import com.muyu.domain.TaskJoinInfo;
 import org.apache.ibatis.annotations.Mapper;
 
diff --git a/cloud-task-server/src/main/java/com/muyu/mapper/TaskOutputMapper.java b/cloud-task-server/src/main/java/com/muyu/mapper/TaskOutputMapper.java
new file mode 100644
index 0000000..7373e45
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/mapper/TaskOutputMapper.java
@@ -0,0 +1,9 @@
+package com.muyu.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.domain.TaskOutputInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface TaskOutputMapper extends BaseMapper<TaskOutputInfo> {
+}