添加表与数据质量报告的关系

src/main/java/com/keymobile/metadata/metadataRelation/remote/DataQualityReportRemoteService.java

+package com.keymobile.metadata.metadataRelation.remote;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(name = "dataQ")
+public interface DataQualityReportRemoteService {
+
+    @RequestMapping(value = "/dqReport/getByMetaId", method = RequestMethod.GET)
+    Map<String,String> getDataAssetGraphInfoByMetadataId(@RequestParam("metaId") String metaId);
+
+
+}

src/main/java/com/keymobile/metadata/metadataRelation/service/impl/SchemaServiceImpl.java

@@ -124,6 +124,7 @@ public class SchemaServiceImpl implements ISchemaService {
                     String label =(String) map.get("name");
                     if(layer.contains(label)){
                         returnLabel = label;
+                        break;
                     }
                 }
             }
@@ -168,6 +169,7 @@ public class SchemaServiceImpl implements ISchemaService {
                     Neo4jSchema neo4jSchema = neo4jSchemaMap.get(schemaId);
                     neo4jSchema.setLabel(label);
                     neo4jSchemaRepository.save(neo4jSchema);
+                    break;
                 }
             }
         }

src/main/java/com/keymobile/metadata/metadataRelation/service/impl/TableServiceImpl.java

@@ -6,6 +6,7 @@ import com.keymobile.metadata.metadataRelation.pojo.MetaData;
 import com.keymobile.metadata.metadataRelation.pojo.metadata.*;
 import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnNode;
 import com.keymobile.metadata.metadataRelation.remote.DataAssertRemoteService;
+import com.keymobile.metadata.metadataRelation.remote.DataQualityReportRemoteService;
 import com.keymobile.metadata.metadataRelation.remote.DataStandardRemoteService;
 import com.keymobile.metadata.metadataRelation.remote.MetadataRepoRemoteService;
 import com.keymobile.metadata.metadataRelation.respository.metadata.*;
@@ -38,6 +39,8 @@ public class TableServiceImpl implements ITableService {
 
     @Autowired
     private DataAssertRemoteService dataAssertRemoteService;
+    @Autowired
+    private DataQualityReportRemoteService dataQualityReportRemoteService;
 
     @Autowired
     private   MetadataRepoRemoteService metadataRepoRemoteService;
@@ -70,8 +73,36 @@ public class TableServiceImpl implements ITableService {
         }
         relationObjects.put("作业",etlJobs);
 
-        //质量
+        //质量报告
         List<ReturnNode> qualityList = new ArrayList<>();
+        try{
+            //从表获取字段：
+            List<Neo4jColumn> neo4jColumnList = neo4jTableRepository.getColumnByTableId(tableId);
+            List<String> reportIdList = new ArrayList<>();
+
+            for(Neo4jColumn neo4jColumn :neo4jColumnList ){
+                //
+                String metaId =neo4jColumn.getMetadataId();
+//                metaId = "Column=1=55d151b1ba484d0cbe3ccd7e9e2f0bfe";
+                Map<String, String> dataQualityRepost = dataQualityReportRemoteService.getDataAssetGraphInfoByMetadataId(metaId);
+                if(dataQualityRepost ==null || dataQualityRepost.size()==0){
+                    continue;
+                }
+                String reportId = dataQualityRepost.get("id");
+                if(reportIdList.contains(reportId)){
+                    continue;
+                }
+                reportIdList.add(reportId);
+                ReturnNode returnNode = new ReturnNode();
+                returnNode.setId(reportId);
+                returnNode.setName(dataQualityRepost.get("jobAnalyzer"));
+                returnNode.setCnName(dataQualityRepost.get("jobAnalyzer"));
+                returnNode.setAttributeMaps(dataQualityRepost);
+                qualityList.add(returnNode);
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
 
         relationObjects.put("质量",qualityList);
         //模型
@@ -83,6 +114,7 @@ public class TableServiceImpl implements ITableService {
             List<Map<String, String>> dataAssetGraphInfos = dataAssertRemoteService.getDataAssetGraphInfoByMetadataId(tableId);
             for(Map<String, String> map : dataAssetGraphInfos){
                 ReturnNode returnNode = new ReturnNode();
+
                 returnNode.setId(map.get("dataAssetId"));
                 returnNode.setName(map.get("enName"));
                 returnNode.setCnName(map.get("cnName"));