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 findList(TaskInputListReq req) { @@ -35,6 +39,9 @@ public class TaskInputServiceImpl extends ServiceImpl wrapper = new QueryWrapper<>(); @@ -47,8 +54,16 @@ public class TaskInputServiceImpl extends ServiceImpl jointQueryWrapper = new QueryWrapper<>(); + jointQueryWrapper.eq("task_id",taskId); + List jointList = nodeJointService.list(jointQueryWrapper); + for (NodeJoint nodeJoint : jointList) { + + } + fieName = fieName.substring(1); -// tableService.selectTableName(taskId); + // tableService.selectTableName(taskId); return null; } }