diff --git a/cloud-task-common/src/main/java/com/muyu/common/domian/TaskOutput.java b/cloud-task-common/src/main/java/com/muyu/common/domian/TaskOutput.java
new file mode 100644
index 0000000..b51bffb
--- /dev/null
+++ b/cloud-task-common/src/main/java/com/muyu/common/domian/TaskOutput.java
@@ -0,0 +1,23 @@
+package com.muyu.common.domian;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName(value = "etl_output")
+public class TaskOutput {
+    @TableId(value = "id",type = IdType.AUTO)
+    private Long id;
+    private Long taskId;
+    private String newFieName;
+    private String lastFieName;
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInputController.java b/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInputController.java
index 25fbf6a..f211b34 100644
--- a/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInputController.java
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskInputController.java
@@ -3,17 +3,14 @@ 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;
-import com.muyu.common.domian.TaskInfo;
 import com.muyu.common.domian.TaskInput;
-import com.muyu.common.domian.req.*;
-import com.muyu.common.domian.resp.TaskInputResp;
+import com.muyu.common.domian.req.InputAddReq;
+import com.muyu.common.domian.req.TaskInputListReq;
+import com.muyu.common.domian.req.TaskInputUpdReq;
 import com.muyu.common.domian.vo.TableVo;
-import com.muyu.task.server.service.StructureService;
 import com.muyu.task.server.service.TaskInputService;
 import io.swagger.v3.oas.annotations.Operation;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.HashMap;
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskOutputController.java b/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskOutputController.java
new file mode 100644
index 0000000..51f753b
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/controller/TaskOutputController.java
@@ -0,0 +1,27 @@
+package com.muyu.task.server.controller;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.common.domian.TaskOutput;
+import com.muyu.task.server.service.TaskOutputService;
+import org.checkerframework.checker.units.qual.C;
+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;
+
+@RestController
+@RequestMapping("output")
+public class TaskOutputController {
+
+    @Autowired
+    private TaskOutputService taskOutputService;
+
+    @PostMapping
+    public Result save(@RequestBody TaskOutput taskOutput) {
+        boolean save = taskOutputService.save(taskOutput);
+        return Result.success(save);
+    }
+
+
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/mapper/TaskOutputMapper.java b/cloud-task-server/src/main/java/com/muyu/task/server/mapper/TaskOutputMapper.java
new file mode 100644
index 0000000..248846e
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/mapper/TaskOutputMapper.java
@@ -0,0 +1,9 @@
+package com.muyu.task.server.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.common.domian.TaskOutput;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface TaskOutputMapper extends BaseMapper<TaskOutput> {
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/TaskOutputService.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/TaskOutputService.java
new file mode 100644
index 0000000..7abf964
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/TaskOutputService.java
@@ -0,0 +1,8 @@
+package com.muyu.task.server.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.common.domian.TaskOutput;
+
+public interface TaskOutputService extends IService<TaskOutput> {
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskOutputServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskOutputServiceImpl.java
new file mode 100644
index 0000000..2a580dc
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskOutputServiceImpl.java
@@ -0,0 +1,11 @@
+package com.muyu.task.server.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.common.domian.TaskOutput;
+import com.muyu.task.server.mapper.TaskOutputMapper;
+import com.muyu.task.server.service.TaskOutputService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class TaskOutputServiceImpl extends ServiceImpl<TaskOutputMapper, TaskOutput> implements TaskOutputService {
+}