From 823631867dcb9b8bbf2cc7ff4e60f2500ea11bb3 Mon Sep 17 00:00:00 2001
From: Cui YongXing <2835316714@qq.com>
Date: Sat, 31 Aug 2024 19:08:25 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AD=97=E6=AE=B5=E5=92=8C?=
 =?UTF-8?q?=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TaskInputServiceImpl.java      | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInputServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInputServiceImpl.java
index e2d1db7..ee7cdcc 100644
--- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInputServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInputServiceImpl.java
@@ -6,9 +6,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.domain.Result;
 import com.muyu.common.core.utils.StringUtils;
+import com.muyu.common.domian.NodeJoint;
 import com.muyu.common.domian.TaskInput;
 import com.muyu.common.domian.req.TaskInputListReq;
 import com.muyu.task.server.mapper.TaskInputMapper;
+import com.muyu.task.server.service.NodeJointService;
 import com.muyu.task.server.service.NodeTableService;
 import com.muyu.task.server.service.TaskInputService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -25,6 +27,8 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
     @Autowired
     private NodeTableService tableService;
 
+    @Autowired
+    private NodeJointService nodeJointService;
 
     @Override
     public Page<TaskInput> findList(TaskInputListReq req) {
@@ -35,6 +39,9 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
         return this.page(page, wrapper);
     }
 
+
+
+
     @Override
     public String findByFieName(Long taskId) {
         QueryWrapper<TaskInput> wrapper = new QueryWrapper<>();
@@ -47,8 +54,16 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputMapper, TaskInput
         for (int i = 0; i < list.size(); i++) {
             fieName+= ","+list.get(i).getTableAsFieId();
         }
+
+        QueryWrapper<NodeJoint> jointQueryWrapper = new QueryWrapper<>();
+        jointQueryWrapper.eq("task_id",taskId);
+        List<NodeJoint> jointList = nodeJointService.list(jointQueryWrapper);
+        for (NodeJoint nodeJoint : jointList) {
+
+        }
+
         fieName = fieName.substring(1);
-//        tableService.selectTableName(taskId);
+ //       tableService.selectTableName(taskId);
         return null;
     }
 }