项目初始化

datax-modules/data-standard-service-parent/data-standard-service/src/main/java/cn/datax/service/data/standard/controller/ContrastController.java

@@ -5,6 +5,7 @@ import cn.datax.common.core.R;
 import cn.datax.common.validate.ValidationGroups;
 import cn.datax.service.data.standard.api.dto.ContrastDto;
 import cn.datax.service.data.standard.api.entity.ContrastEntity;
+import cn.datax.service.data.standard.api.vo.ContrastTreeVo;
 import cn.datax.service.data.standard.api.vo.ContrastVo;
 import cn.datax.service.data.standard.api.query.ContrastQuery;
 import cn.datax.service.data.standard.mapstruct.ContrastMapper;
@@ -134,7 +135,7 @@ public class ContrastController extends BaseController {
 
     @GetMapping("/tree")
     public R getContrastTree() {
-        contrastService.getContrastTree();
-        return R.ok().setData(null);
+        List<ContrastTreeVo> list = contrastService.getContrastTree();
+        return R.ok().setData(list);
     }
 }

datax-modules/data-standard-service-parent/data-standard-service/src/main/java/cn/datax/service/data/standard/service/ContrastService.java

@@ -3,6 +3,7 @@ package cn.datax.service.data.standard.service;
 import cn.datax.service.data.standard.api.entity.ContrastEntity;
 import cn.datax.service.data.standard.api.dto.ContrastDto;
 import cn.datax.common.base.BaseService;
+import cn.datax.service.data.standard.api.vo.ContrastTreeVo;
 
 import java.util.List;
 
@@ -26,5 +27,5 @@ public interface ContrastService extends BaseService<ContrastEntity> {
 
     void deleteContrastBatch(List<String> ids);
 
-    void getContrastTree();
+    List<ContrastTreeVo> getContrastTree();
 }

datax-modules/data-standard-service-parent/data-standard-service/src/main/java/cn/datax/service/data/standard/service/impl/ContrastServiceImpl.java

@@ -2,16 +2,20 @@ package cn.datax.service.data.standard.service.impl;
 
 import cn.datax.service.data.standard.api.entity.ContrastEntity;
 import cn.datax.service.data.standard.api.dto.ContrastDto;
+import cn.datax.service.data.standard.api.vo.ContrastTreeVo;
 import cn.datax.service.data.standard.service.ContrastService;
 import cn.datax.service.data.standard.mapstruct.ContrastMapper;
 import cn.datax.service.data.standard.dao.ContrastDao;
 import cn.datax.common.base.BaseServiceImpl;
+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;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -66,7 +70,9 @@ public class ContrastServiceImpl extends BaseServiceImpl<ContrastDao, ContrastEn
     }
 
     @Override
-    public void getContrastTree() {
-
+    public List<ContrastTreeVo> getContrastTree() {
+        List<ContrastEntity> contrastEntityList = contrastDao.selectList(Wrappers.emptyWrapper());
+        Map<String, List<ContrastEntity>> sourceListMap = contrastEntityList.stream().collect(Collectors.groupingBy(ContrastEntity::getSourceId));
+        return null;
     }
 }