Commit 5862597a by qiuchaofei

1,添加操作日志,2添加接口:查询字段id;3添加接口:字段级的图形分析

parent fb645246
...@@ -10,6 +10,8 @@ import java.util.List; ...@@ -10,6 +10,8 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import com.keymobile.metadata.metadataRelation.logging.LogConstants;
import com.keymobile.metadata.metadataRelation.logging.LogManager;
import com.keymobile.metadata.metadataRelation.pojo.BaseRelationship; import com.keymobile.metadata.metadataRelation.pojo.BaseRelationship;
import com.keymobile.metadata.metadataRelation.pojo.MetaData; import com.keymobile.metadata.metadataRelation.pojo.MetaData;
import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnEdge; import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnEdge;
...@@ -545,6 +547,8 @@ public class MetaDataController { ...@@ -545,6 +547,8 @@ public class MetaDataController {
@ApiOperation(tags = "", value = "同步元数据关系的接口") @ApiOperation(tags = "", value = "同步元数据关系的接口")
@RequestMapping(path = "/syschroRelationFromMongo", method = RequestMethod.POST) @RequestMapping(path = "/syschroRelationFromMongo", method = RequestMethod.POST)
public String synchroRelationFromMongo(String catalogName) { public String synchroRelationFromMongo(String catalogName) {
LogManager.logInfo(LogConstants.CTX_Relation, "同步"+catalogName+"的元数据。" );
logger.info("开始异步迁移元数据:从mongo到neo4j"); logger.info("开始异步迁移元数据:从mongo到neo4j");
String flag = "success"; String flag = "success";
asyncDataFromMongoToNeo4j.asyncDataFromMongoToNeo4j(catalogName); asyncDataFromMongoToNeo4j.asyncDataFromMongoToNeo4j(catalogName);
......
package com.keymobile.metadata.metadataRelation.controller; package com.keymobile.metadata.metadataRelation.controller;
import com.keymobile.metadata.metadataRelation.logging.LogConstants;
import com.keymobile.metadata.metadataRelation.logging.LogManager;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema;
import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnNode; import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnNode;
import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult; import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult;
...@@ -41,6 +43,8 @@ public class RelationalGraphController { ...@@ -41,6 +43,8 @@ public class RelationalGraphController {
private ITableService tableService; private ITableService tableService;
@Autowired @Autowired
private IColumnService columnService;
@Autowired
private MultiModelService multiModelService; private MultiModelService multiModelService;
@Autowired @Autowired
...@@ -237,6 +241,8 @@ public class RelationalGraphController { ...@@ -237,6 +241,8 @@ public class RelationalGraphController {
@ApiOperation(tags = "", value = "传入表的id,返回表的上下游一层关系。") @ApiOperation(tags = "", value = "传入表的id,返回表的上下游一层关系。")
@RequestMapping(path = "/getRelationTablesTableId", method = RequestMethod.GET) @RequestMapping(path = "/getRelationTablesTableId", method = RequestMethod.GET)
public Map<String,List<ReturnNode>> getRelationTablesTableId(String tableId){ public Map<String,List<ReturnNode>> getRelationTablesTableId(String tableId){
LogManager.logInfo(LogConstants.CTX_Relation, "查看"+tableId+"的全链分析" );
Map<String, List<ReturnNode>> relationTables = new HashMap<>(); Map<String, List<ReturnNode>> relationTables = new HashMap<>();
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
if(tableId.startsWith("Table=")){ if(tableId.startsWith("Table=")){
...@@ -258,6 +264,8 @@ public class RelationalGraphController { ...@@ -258,6 +264,8 @@ public class RelationalGraphController {
@ApiOperation(tags = "", value = "传入表的id,返回与表相关的模型,标准,质量,资产,作业等对象") @ApiOperation(tags = "", value = "传入表的id,返回与表相关的模型,标准,质量,资产,作业等对象")
@RequestMapping(path = "/getRelationObjectByTableId", method = RequestMethod.GET) @RequestMapping(path = "/getRelationObjectByTableId", method = RequestMethod.GET)
public Map<String,List<ReturnNode>> getRelationObjectByTableId(String tableId){ public Map<String,List<ReturnNode>> getRelationObjectByTableId(String tableId){
LogManager.logInfo(LogConstants.CTX_Relation, "查看"+tableId+"的关系分析" );
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
Map<String, List<ReturnNode>> relationObjects = tableService.getRelationObjectByTableId (tableId); Map<String, List<ReturnNode>> relationObjects = tableService.getRelationObjectByTableId (tableId);
long end = System.currentTimeMillis(); long end = System.currentTimeMillis();
...@@ -311,7 +319,7 @@ public class RelationalGraphController { ...@@ -311,7 +319,7 @@ public class RelationalGraphController {
return schemaService.updateTagFromAllSchema(); return schemaService.updateTagFromAllSchema();
} }
//同步所有schema的标签
@ApiOperation(tags = "", value = "传入环境id,系统名,schema名,表名,获取表id") @ApiOperation(tags = "", value = "传入环境id,系统名,schema名,表名,获取表id")
@RequestMapping(path = "/getTableIdByEnvironmentSystemTableName", method = RequestMethod.GET) @RequestMapping(path = "/getTableIdByEnvironmentSystemTableName", method = RequestMethod.GET)
public String getTableIdByEnvironmentSystemTableName(String environment,String system,String tableName){ public String getTableIdByEnvironmentSystemTableName(String environment,String system,String tableName){
...@@ -319,4 +327,25 @@ public class RelationalGraphController { ...@@ -319,4 +327,25 @@ public class RelationalGraphController {
return tableService.getTableId(environment,system,tableName); return tableService.getTableId(environment,system,tableName);
} }
@ApiOperation(tags = "", value = "传入质量相关的字段id,返回与该字段id有关系的字段,表,数据库,系统")
@RequestMapping(path = "/getQualityDataRelations", method = RequestMethod.GET)
public ReturnReslult getQualityDataRelations(String columnId){
logger.info("获取表id。"+columnId);
return tableService.getQualityData(columnId);
}
@ApiOperation(tags = "", value = "传入表的id,返回与该表相关的上下游的表")
@RequestMapping(path = "/getRelationAboutTables", method = RequestMethod.GET)
public ReturnReslult getRelationAboutTables(String tableId){
logger.info("获取表id。"+tableId);
return tableService.getRelationAboutTables(tableId);
}
@ApiOperation(tags = "", value = "传入字段id,返回与该字段相关的上下游的字段")
@RequestMapping(path = "/getRelationAboutColumns", method = RequestMethod.GET)
public ReturnReslult getRelationAboutColumns(String columnId){
logger.info("获取字段id。"+columnId);
return columnService.getRelationAboutColumn(columnId);
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment