项目初始化

datax-modules/data-market-service-parent/data-market-service/src/main/java/cn/datax/service/data/market/controller/DataApiController.java

 package cn.datax.service.data.market.controller;
 
+import cn.datax.common.core.DataConstant;
 import cn.datax.common.core.JsonPage;
 import cn.datax.common.core.R;
 import cn.datax.common.validate.ValidationGroups;
@@ -70,6 +71,7 @@ public class DataApiController extends BaseController {
     @GetMapping("/list")
     public R getDataApiList() {
         QueryWrapper<DataApiEntity> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("status", DataConstant.EnableState.ENABLE.getKey());
         List<DataApiEntity> list = dataApiService.list(queryWrapper);
         List<DataApiVo> collect = list.stream().map(dataApiMapper::toVO).collect(Collectors.toList());
         return R.ok().setData(collect);

datax-modules/data-metadata-service-parent/data-metadata-service-api/src/main/java/cn/datax/service/data/metadata/api/vo/MetadataTreeVo.java

+package cn.datax.service.data.metadata.api.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+public class MetadataTreeVo implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    private String id;
+    /**
+     * 数据类型 database、table、column
+     */
+    private String type;
+    private String label;
+    private List<MetadataTreeVo> children;
+}

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/controller/MetadataColumnController.java

@@ -7,6 +7,7 @@ import cn.datax.service.data.metadata.api.dto.MetadataColumnDto;
 import cn.datax.service.data.metadata.api.entity.MetadataColumnEntity;
 import cn.datax.service.data.metadata.api.vo.MetadataColumnVo;
 import cn.datax.service.data.metadata.api.query.MetadataColumnQuery;
+import cn.datax.service.data.metadata.api.vo.MetadataTreeVo;
 import cn.datax.service.data.metadata.mapstruct.MetadataColumnMapper;
 import cn.datax.service.data.metadata.service.MetadataColumnService;
 import cn.hutool.core.util.StrUtil;
@@ -147,4 +148,14 @@ public class MetadataColumnController extends BaseController {
         metadataColumnService.deleteMetadataColumnBatch(ids);
         return R.ok();
     }
+
+    /**
+     * 获取结构树
+     * @return
+     */
+    @GetMapping("/tree")
+    public R getDataMetadataTree() {
+        List<MetadataTreeVo> list = metadataColumnService.getDataMetadataTree();
+        return R.ok().setData(list);
+    }
 }

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/MetadataColumnService.java

@@ -3,6 +3,7 @@ package cn.datax.service.data.metadata.service;
 import cn.datax.service.data.metadata.api.dto.MetadataColumnDto;
 import cn.datax.common.base.BaseService;
 import cn.datax.service.data.metadata.api.entity.MetadataColumnEntity;
+import cn.datax.service.data.metadata.api.vo.MetadataTreeVo;
 
 import java.util.List;
 
@@ -25,4 +26,6 @@ public interface MetadataColumnService extends BaseService<MetadataColumnEntity>
     void deleteMetadataColumnById(String id);
 
     void deleteMetadataColumnBatch(List<String> ids);
+
+    List<MetadataTreeVo> getDataMetadataTree();
 }

datax-modules/data-metadata-service-parent/data-metadata-service/src/main/java/cn/datax/service/data/metadata/service/impl/MetadataColumnServiceImpl.java

 package cn.datax.service.data.metadata.service.impl;
 
+import cn.datax.common.core.DataConstant;
 import cn.datax.service.data.metadata.api.dto.MetadataColumnDto;
 import cn.datax.service.data.metadata.api.entity.MetadataColumnEntity;
+import cn.datax.service.data.metadata.api.entity.MetadataSourceEntity;
+import cn.datax.service.data.metadata.api.vo.MetadataTreeVo;
+import cn.datax.service.data.metadata.dao.MetadataSourceDao;
+import cn.datax.service.data.metadata.dao.MetadataTableDao;
 import cn.datax.service.data.metadata.service.MetadataColumnService;
 import cn.datax.service.data.metadata.mapstruct.MetadataColumnMapper;
 import cn.datax.service.data.metadata.dao.MetadataColumnDao;
 import cn.datax.common.base.BaseServiceImpl;
+import cn.datax.service.system.api.entity.UserRoleEntity;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
@@ -26,6 +35,12 @@ import java.util.List;
 public class MetadataColumnServiceImpl extends BaseServiceImpl<MetadataColumnDao, MetadataColumnEntity> implements MetadataColumnService {
 
     @Autowired
+    private MetadataSourceDao metadataSourceDao;
+
+    @Autowired
+    private MetadataTableDao metadataTableDao;
+
+    @Autowired
     private MetadataColumnDao metadataColumnDao;
 
     @Autowired
@@ -64,4 +79,15 @@ public class MetadataColumnServiceImpl extends BaseServiceImpl<MetadataColumnDao
     public void deleteMetadataColumnBatch(List<String> ids) {
         metadataColumnDao.deleteBatchIds(ids);
     }
+
+    @Override
+    public List<MetadataTreeVo> getDataMetadataTree() {
+        // 参考分布式锁
+        // https://blog.csdn.net/qq_32099833/article/details/103848016
+//        metadataSourceDao.selectList(Wrappers.<MetadataSourceEntity>lambdaQuery()
+//                .eq(MetadataSourceEntity::getStatus, DataConstant.EnableState.ENABLE.getKey()));
+        List<MetadataSourceEntity> sourceList = metadataSourceDao.selectList(Wrappers.<MetadataSourceEntity>lambdaQuery()
+                .eq(MetadataSourceEntity::getStatus, DataConstant.EnableState.ENABLE.getKey()));
+        return null;
+    }
 }