添加实体类

cloud-task-common/src/main/java/com/muyu/domain/Structure.java

@@ -1,5 +1,10 @@
 package com.muyu.domain;
 
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
 /**
  * @PackageName:com.muyu.domain
  * @ClassName:aaA
@@ -7,6 +12,10 @@ package com.muyu.domain;
  * @author: ￥陈思豪￥
  * @date: 2024/8/23 18:53
  */
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Builder
 public class Structure {
     private Integer id;
     private String fieldName;

cloud-task-common/src/main/java/com/muyu/domain/TaskInputInfo.java

@@ -41,7 +41,7 @@ public class TaskInputInfo extends BaseEntity {
     /**
      * 数据库id
      */
-    private Integer databaseId;
+    private String databaseId;
 
     /**
      * 表名称
@@ -56,7 +56,7 @@ public class TaskInputInfo extends BaseEntity {
     /**
      * 表字段
      */
-    private String[] tableField;
+    private String tableField;
 
     /**
      * 表字段别名

cloud-task-server/src/main/java/com/muyu/controller/StructureController.java

@@ -0,0 +1,32 @@
+package com.muyu.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.muyu.domain.Structure;
+import com.muyu.service.StructureService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @PackageName:com.muyu.controller
+ * @ClassName:TextController
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/8/24 20:45
+ */
+@RestController
+@RequestMapping("/structure")
+public class StructureController {
+
+    @Resource
+    private StructureService structureService;
+
+    @GetMapping("/findThis")
+    public String findThis() {
+        return structureService.findThis();
+    }
+}

cloud-task-server/src/main/java/com/muyu/controller/TaskInputController.java

@@ -1,6 +1,7 @@
 package com.muyu.controller;
 
 import com.muyu.common.core.domain.Result;
+import com.muyu.domain.Structure;
 import com.muyu.domain.TaskInfo;
 import com.muyu.domain.TaskInputInfo;
 import com.muyu.service.TaskInputService;
@@ -28,17 +29,26 @@ public class TaskInputController {
     @Autowired
     private TaskInputService taskInputService;
 
-    @RequestMapping(path = "/list", method = RequestMethod.POST)
+    @RequestMapping(path = "/list", method = RequestMethod.GET)
     @Operation(summary = "查看任务节点详情", description = "根据任务的名称或者状态 ，进行模糊查询")
-    public Result<List<TaskInputInfo>> selectList(
+    public Result<List<TaskInputInfo>> selectList() {
-            @Validated @RequestBody TaskInfo taskInfo) {
         startPage();
-        List<TaskInputInfo> taskInputInfos = taskInputService.selectList(taskInfo);
+        List<TaskInputInfo> taskInputInfos = taskInputService.selectList();
         return Result.success(
                 taskInputInfos
         );
     }
 
+    @RequestMapping(path = "/findByInputId/{id}", method = RequestMethod.POST)
+    @Operation(summary = "查看任务节点详情", description = "根据任务的名称或者状态 ，进行模糊查询")
+    public Result<List<Structure>> findByInputId(@PathVariable(name = "id") Integer id) {
+        startPage();
+        List<Structure> taskInputInfo = taskInputService.findByInputId(id);
+        return Result.success(
+                taskInputInfo
+        );
+    }
+
 
 //    /**
 //     * 添加新任务

cloud-task-server/src/main/java/com/muyu/mapper/StructureMapper.java

@@ -0,0 +1,16 @@
+package com.muyu.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.domain.Structure;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @PackageName:com.muyu.mapper
+ * @ClassName:StructureMapper
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/8/24 20:48
+ */
+@Mapper
+public interface StructureMapper extends BaseMapper<Structure> {
+}

cloud-task-server/src/main/java/com/muyu/service/StructureService.java

@@ -0,0 +1,9 @@
+package com.muyu.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.domain.Structure;
+
+public interface StructureService extends IService<Structure> {
+    String findThis();
+}

cloud-task-server/src/main/java/com/muyu/service/TaskInputService.java

@@ -1,6 +1,7 @@
 package com.muyu.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.domain.Structure;
 import com.muyu.domain.TaskInfo;
 import com.muyu.domain.TaskInputInfo;
 
@@ -14,5 +15,7 @@ import java.util.List;
  * @date: 2024/8/22 20:18
  */
 public interface TaskInputService extends IService<TaskInputInfo> {
-    List<TaskInputInfo> selectList(TaskInfo taskInfo);
+    List<TaskInputInfo> selectList();
+
+    List<Structure> findByInputId(Integer id);
 }

cloud-task-server/src/main/java/com/muyu/service/impl/StructureServiceImpl.java

@@ -0,0 +1,34 @@
+package com.muyu.service.impl;
+
+import cn.hutool.json.JSON;
+import com.alibaba.fastjson2.JSONArray;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.domain.Structure;
+import com.muyu.domain.TaskInputInfo;
+import com.muyu.mapper.StructureMapper;
+import com.muyu.mapper.TaskInputInfoMapper;
+import com.muyu.service.StructureService;
+import com.muyu.service.TaskInputService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @PackageName:com.muyu.service.impl
+ * @ClassName:StructureServiceImpl
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/8/24 20:48
+ */
+@Service
+public class StructureServiceImpl extends ServiceImpl<StructureMapper, Structure> implements StructureService {
+
+    @Override
+    public String findThis() {
+        List<Structure> list = this.list();
+        String jsonString = JSONArray.toJSONString(list);
+        return jsonString;
+    }
+}

cloud-task-server/src/main/java/com/muyu/service/impl/TaskInputServiceImpl.java

@@ -1,9 +1,12 @@
 package com.muyu.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.utils.StringUtils;
+import com.muyu.domain.Structure;
 import com.muyu.domain.TaskInfo;
 import com.muyu.domain.TaskInputInfo;
 import com.muyu.mapper.TaskInputInfoMapper;
@@ -27,8 +30,17 @@ public class TaskInputServiceImpl extends ServiceImpl<TaskInputInfoMapper, TaskI
 
 
     @Override
-    public List<TaskInputInfo> selectList(TaskInfo taskInfo) {
+    public List<TaskInputInfo> selectList() {
         LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>();
         return this.list(queryWrapper);
     }
+
+    @Override
+    public List<Structure> findByInputId(Integer id) {
+        LambdaQueryWrapper<TaskInputInfo> queryWrapper = new LambdaQueryWrapper<>();
+        TaskInputInfo taskInputInfo = this.getOne(queryWrapper);
+        String tableField = taskInputInfo.getTableField();
+        List<Structure> structures = JSONArray.parseArray(tableField, Structure.class);
+        return structures;
+    }
 }

cloud-task-server/src/main/resources/bootstrap.yml

@@ -7,7 +7,7 @@ nacos:
   addr: 47.116.184.54:8848
   user-name: nacos
   password: nacos
-  namespace: cloud-2112
+  namespace: text
 # Spring
 spring: