Commit 8a628cf8 by mahx

修改代码错误

parent 7d2eacc4
package com.keymobile.metadata.metadataRelation.auth; package com.keymobile.metadata.metadataRelation.auth;
import com.keymobile.auth.common.security.GrantedAuthHelper; import com.keymobile.authservice.common.security.GrantedAuthHelper;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.MongoTemplate;
......
...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.auth; ...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.auth;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.keymobile.auth.common.security.GrantedAuthHelper; import com.keymobile.authservice.common.security.GrantedAuthHelper;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.bson.BsonRegularExpression; import org.bson.BsonRegularExpression;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
......
package com.keymobile.metadata.metadataRelation.auth; package com.keymobile.metadata.metadataRelation.auth;
import com.keymobile.auth.common.conf.Option; import com.keymobile.authservice.common.conf.Option;
import com.keymobile.auth.common.conf.OptionProperty; import com.keymobile.authservice.common.conf.OptionProperty;
public class OptionImpl implements Option { public class OptionImpl implements Option {
private String id; private String id;
......
package com.keymobile.metadata.metadataRelation.auth; package com.keymobile.metadata.metadataRelation.auth;
import com.keymobile.auth.common.conf.OptionProperty; import com.keymobile.authservice.common.conf.OptionDataFilter;
import com.keymobile.authservice.common.conf.OptionProperty;
public class OptionPropertyDataImpl implements OptionProperty { public class OptionPropertyDataImpl implements OptionProperty {
...@@ -55,4 +56,19 @@ public class OptionPropertyDataImpl implements OptionProperty { ...@@ -55,4 +56,19 @@ public class OptionPropertyDataImpl implements OptionProperty {
public String getOptionPropertyType() { public String getOptionPropertyType() {
return optionPropertyType; return optionPropertyType;
} }
@Override
public boolean isSupportDomain() {
return false;
}
@Override
public boolean isWithFilters() {
return false;
}
@Override
public OptionDataFilter[] getFilters() {
return new OptionDataFilter[0];
}
} }
package com.keymobile.metadata.metadataRelation.controller; package com.keymobile.metadata.metadataRelation.controller;
import com.keymobile.auth.common.conf.OptionProvider; import com.keymobile.authservice.common.conf.OptionDataFilter;
import com.keymobile.authservice.common.conf.OptionProvider;
import com.keymobile.metadata.metadataRelation.auth.AuthorityService; import com.keymobile.metadata.metadataRelation.auth.AuthorityService;
import com.keymobile.metadata.metadataRelation.auth.Feature; import com.keymobile.metadata.metadataRelation.auth.Feature;
import com.keymobile.metadata.metadataRelation.auth.OptionImpl; import com.keymobile.metadata.metadataRelation.auth.OptionImpl;
import com.keymobile.metadata.metadataRelation.auth.OptionPropertyDataImpl; import com.keymobile.metadata.metadataRelation.auth.OptionPropertyDataImpl;
import io.swagger.annotations.Api; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.annotations.ApiOperation; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@Api(value = "授权信息相关", tags = "授权信息相关") @Tag(name = "授权信息相关", description = "授权信息相关")
@RestController @RestController
@RequestMapping(value = "/rest/auth") @RequestMapping(value = "/rest/auth")
public class AuthorityApi implements OptionProvider<OptionImpl, OptionPropertyDataImpl> { public class AuthorityApi implements OptionProvider<OptionImpl, OptionPropertyDataImpl> {
...@@ -22,37 +23,43 @@ public class AuthorityApi implements OptionProvider<OptionImpl, OptionPropertyDa ...@@ -22,37 +23,43 @@ public class AuthorityApi implements OptionProvider<OptionImpl, OptionPropertyDa
private AuthorityService authorityService; private AuthorityService authorityService;
@Override @Override
@ApiOperation(value = "获取权限属性", notes = "获取权限属性") @Operation(summary = "获取权限属性", description = "获取权限属性")
@GetMapping(value = "/getOptionProperties") @GetMapping(value = "/getOptionProperties")
public List<OptionPropertyDataImpl> getOptionProperties(@RequestParam String range) { public List<OptionPropertyDataImpl> getOptionProperties(@RequestParam String range) {
return authorityService.getOptionProperties(range); return authorityService.getOptionProperties(range);
} }
@Override @Override
@ApiOperation(value = "获取权限数据", notes = "获取权限数据") public void dataRoleRemovalCallback(Long dataRoleId) {
}
@Override
@Operation(summary = "获取权限数据", description = "获取权限数据")
@GetMapping(value = "/getOptions") @GetMapping(value = "/getOptions")
public List<OptionImpl> getOptions(@RequestParam Long dataRoleId, @RequestParam String range, @RequestParam(required = false) Long domainId) { public List<OptionImpl> getOptions(@RequestParam Long dataRoleId, @RequestParam String range, @RequestParam(required = false) Long domainId,
@RequestBody(required = false) OptionDataFilter filter) {
return authorityService.getOptions(dataRoleId, range,domainId); return authorityService.getOptions(dataRoleId, range,domainId);
} }
@Override @Override
@ApiOperation(value = "保存权限数据", notes = "保存权限数据") @Operation(summary = "保存权限数据", description = "保存权限数据")
@PostMapping(value = "/saveOptions") @PostMapping(value = "/saveOptions")
public List<OptionImpl> saveOptions(@RequestParam Long dataRoleId, @RequestParam String range, @RequestBody List<OptionImpl> optionList,@RequestParam(required = false) Long domainId) { public List<OptionImpl> saveOptions(@RequestParam Long dataRoleId, @RequestParam String range, @RequestParam(required = false) Long domainId, @RequestBody List<OptionImpl> optionList) {
return authorityService.saveOptions(dataRoleId, range, optionList,domainId); return authorityService.saveOptions(dataRoleId, range, optionList,domainId);
} }
@ApiOperation(value = "获取所有的range", notes = "获取所有的range") @Operation(summary = "获取所有的range", description = "获取所有的range")
@GetMapping(value = "/listAllRanges") @GetMapping(value = "/listAllRanges")
public List<Map<String, Object>> listAllRanges() { public List<Map<String, Object>> listAllRanges() {
return authorityService.listAllRanges(); return authorityService.listAllRanges();
} }
@ApiOperation(value = "返回可操作按钮权限", notes = "返回可操作按钮权限") @Operation(summary = "返回可操作按钮权限", description = "返回可操作按钮权限")
@GetMapping(value = "/getAllowButtons") @GetMapping(value = "/getAllowButtons")
public List<Feature> getAllowButtons(@RequestParam String range, @RequestParam String optionId, @RequestParam(required = false) Long domainId) { public List<Feature> getAllowButtons(@RequestParam String range, @RequestParam String optionId, @RequestParam(required = false) Long domainId) {
return authorityService.getAllowButtons(range,optionId,domainId); return authorityService.getAllowButtons(range,optionId,domainId);
......
...@@ -3,8 +3,9 @@ package com.keymobile.metadata.metadataRelation.controller; ...@@ -3,8 +3,9 @@ package com.keymobile.metadata.metadataRelation.controller;
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;
import com.keymobile.metadata.metadataRelation.service.*; import com.keymobile.metadata.metadataRelation.service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -19,7 +20,7 @@ import java.util.List; ...@@ -19,7 +20,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
@RestController @RestController
@Api(value = "元数据的分析", tags = "metadata analysis") @Tag(name = "元数据的分析", description = "metadata analysis")
public class DataRelationAnalyController { public class DataRelationAnalyController {
private static final Logger logger = LoggerFactory.getLogger(DataRelationAnalyController.class); private static final Logger logger = LoggerFactory.getLogger(DataRelationAnalyController.class);
...@@ -39,7 +40,7 @@ public class DataRelationAnalyController { ...@@ -39,7 +40,7 @@ public class DataRelationAnalyController {
private ISystemService systemService; private ISystemService systemService;
@ApiOperation(tags = "", value = "获取指定表的上下游关系及其字段的上下游关系。") @Operation(summary= "获取指定表的上下游关系及其字段的上下游关系。")
@RequestMapping(path = "/getTableAndColumnRelation", method = RequestMethod.GET) @RequestMapping(path = "/getTableAndColumnRelation", method = RequestMethod.GET)
public ReturnReslult getTableAndColumnRelation(String tableId) { public ReturnReslult getTableAndColumnRelation(String tableId) {
logger.info("获取指定表的上下游关系及其字段的上下游关系。tableId="+tableId); logger.info("获取指定表的上下游关系及其字段的上下游关系。tableId="+tableId);
...@@ -55,20 +56,20 @@ public class DataRelationAnalyController { ...@@ -55,20 +56,20 @@ public class DataRelationAnalyController {
* @return * @return
* *
*/ */
@ApiOperation(tags = "", value = "指定环境id获取系统") @Operation(summary= "指定环境id获取系统")
@RequestMapping(path = "/getSystemByEnvId", method = RequestMethod.GET) @RequestMapping(path = "/getSystemByEnvId", method = RequestMethod.GET)
public Map<String, ReturnNode> getSystemByEnvId(String envId) { public Map<String, ReturnNode> getSystemByEnvId(String envId) {
logger.info("指定环境id获取系统:"+envId); logger.info("指定环境id获取系统:"+envId);
return systemService.getSystemByEnvId(envId); return systemService.getSystemByEnvId(envId);
} }
@ApiOperation(tags = "", value = "指定系统id获取schema") @Operation(summary= "指定系统id获取schema")
@RequestMapping(path = "/getSystemBySystemId", method = RequestMethod.GET) @RequestMapping(path = "/getSystemBySystemId", method = RequestMethod.GET)
public Map<String, ReturnNode> getSchemaBySystemId(String systemId) { public Map<String, ReturnNode> getSchemaBySystemId(String systemId) {
logger.info("指定系统id获取schema{}",systemId); logger.info("指定系统id获取schema{}",systemId);
return schemaService.getSchemaBySystemId(systemId); return schemaService.getSchemaBySystemId(systemId);
} }
@ApiOperation(tags = "", value = "全量查找指定节点下面的孤立点。parentId参数可以为schemaId,sysemId,evnId") @Operation(summary= "全量查找指定节点下面的孤立点。parentId参数可以为schemaId,sysemId,evnId")
@RequestMapping(path = "/getIsolatedNode", method = RequestMethod.GET) @RequestMapping(path = "/getIsolatedNode", method = RequestMethod.GET)
public Map<String, ReturnNode> getIsolatedTableBySchema(String parentId,String keyWord) { public Map<String, ReturnNode> getIsolatedTableBySchema(String parentId,String keyWord) {
...@@ -83,7 +84,7 @@ public class DataRelationAnalyController { ...@@ -83,7 +84,7 @@ public class DataRelationAnalyController {
} }
//搜索 //搜索
@ApiOperation(tags = "", value = "搜索孤立点") @Operation(summary= "搜索孤立点")
@RequestMapping(path = "/findIsolatedTableByName", method = RequestMethod.GET) @RequestMapping(path = "/findIsolatedTableByName", method = RequestMethod.GET)
public Map<String, ReturnNode> findIsolatedTableByName(String parentId,String keyWord) { public Map<String, ReturnNode> findIsolatedTableByName(String parentId,String keyWord) {
logger.info("分页查找孤立点的总数:"+parentId); logger.info("分页查找孤立点的总数:"+parentId);
...@@ -97,7 +98,7 @@ public class DataRelationAnalyController { ...@@ -97,7 +98,7 @@ public class DataRelationAnalyController {
} }
//总数 //总数
@ApiOperation(tags = "", value = "查找孤立点的总数") @Operation(summary= "查找孤立点的总数")
@RequestMapping(path = "/getIsolatedTableTotal", method = RequestMethod.GET) @RequestMapping(path = "/getIsolatedTableTotal", method = RequestMethod.GET)
public Integer getIsolatedTableTotal(String parentId,String keyWord) { public Integer getIsolatedTableTotal(String parentId,String keyWord) {
logger.info("分页查找孤立点的总数:"+parentId); logger.info("分页查找孤立点的总数:"+parentId);
...@@ -110,7 +111,7 @@ public class DataRelationAnalyController { ...@@ -110,7 +111,7 @@ public class DataRelationAnalyController {
return dataRelationAnalyService.findTableWithoutRelationsTotal(parentId,keyWord); return dataRelationAnalyService.findTableWithoutRelationsTotal(parentId,keyWord);
} }
@ApiOperation(tags = "", value = "分页查找指定节点的孤立点。parentId参数可以为schemaId,sysemId,evnId") @Operation(summary= "分页查找指定节点的孤立点。parentId参数可以为schemaId,sysemId,evnId")
@RequestMapping(path = "/getIsolatedTableByPage", method = RequestMethod.GET) @RequestMapping(path = "/getIsolatedTableByPage", method = RequestMethod.GET)
public Map<String, ReturnNode> getIsolatedTableByPage(String parentId,int start,int size,String keyWord) { public Map<String, ReturnNode> getIsolatedTableByPage(String parentId,int start,int size,String keyWord) {
logger.info("查找指定schema下面的孤立点:"+parentId); logger.info("查找指定schema下面的孤立点:"+parentId);
...@@ -123,14 +124,14 @@ public class DataRelationAnalyController { ...@@ -123,14 +124,14 @@ public class DataRelationAnalyController {
return dataRelationAnalyService.findTableWithoutRelations(parentId,start,size,keyWord); return dataRelationAnalyService.findTableWithoutRelations(parentId,start,size,keyWord);
} }
@ApiOperation(tags = "", value = "搜索指定table下面的字段。") @Operation(summary= "搜索指定table下面的字段。")
@RequestMapping(path = "/findColumnByTableIdAndName", method = RequestMethod.GET) @RequestMapping(path = "/findColumnByTableIdAndName", method = RequestMethod.GET)
public Map<String, List<ReturnNode>> findColumnByTableIdAndName(String tableId, String columnName) { public Map<String, List<ReturnNode>> findColumnByTableIdAndName(String tableId, String columnName) {
logger.info("查找指定。表id:"+tableId +" ,给定名字:"+ columnName); logger.info("查找指定。表id:"+tableId +" ,给定名字:"+ columnName);
return tableService.autoMatchBySchemaIdAndInputWord(tableId,columnName); return tableService.autoMatchBySchemaIdAndInputWord(tableId,columnName);
} }
@ApiOperation(tags = "", value = "子节点id找出父节点。") @Operation(summary= "子节点id找出父节点。")
@RequestMapping(path = "/findParentNodeByChildNodeId", method = RequestMethod.GET) @RequestMapping(path = "/findParentNodeByChildNodeId", method = RequestMethod.GET)
public Map<String, ReturnNode> findParentNodeByChildNodeId(String childId) { public Map<String, ReturnNode> findParentNodeByChildNodeId(String childId) {
logger.info("子节点id找出父节点。子节点id:"+childId ); logger.info("子节点id找出父节点。子节点id:"+childId );
...@@ -138,7 +139,7 @@ public class DataRelationAnalyController { ...@@ -138,7 +139,7 @@ public class DataRelationAnalyController {
} }
//解析excel,存入neo4j //解析excel,存入neo4j
@ApiOperation(tags = "", value = "从excel生成neo4j的节点与关系。") @Operation(summary= "从excel生成neo4j的节点与关系。")
@RequestMapping(path = "/generalRelationFromExcel", method = RequestMethod.GET) @RequestMapping(path = "/generalRelationFromExcel", method = RequestMethod.GET)
public String generalRelationFromExcel(String filePath) { public String generalRelationFromExcel(String filePath) {
logger.info("从excel生成neo4j的节点与关系:"+filePath ); logger.info("从excel生成neo4j的节点与关系:"+filePath );
...@@ -152,7 +153,7 @@ public class DataRelationAnalyController { ...@@ -152,7 +153,7 @@ public class DataRelationAnalyController {
} }
//解析excel,存入neo4j //解析excel,存入neo4j
@ApiOperation(tags = "", value = "从excel生成neo4j的节点与关系。") @Operation(summary= "从excel生成neo4j的节点与关系。")
@RequestMapping(path = "/uploadExcelToNeo4j", method = RequestMethod.POST) @RequestMapping(path = "/uploadExcelToNeo4j", method = RequestMethod.POST)
public String uploadExcelToNeo4j(@RequestParam(value = "excelFile") MultipartFile file) { public String uploadExcelToNeo4j(@RequestParam(value = "excelFile") MultipartFile file) {
logger.info("上传excel文件节点与关系:"+file.getOriginalFilename() ); logger.info("上传excel文件节点与关系:"+file.getOriginalFilename() );
......
...@@ -18,9 +18,11 @@ import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnNode; ...@@ -18,9 +18,11 @@ import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnNode;
import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult; import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult;
import com.keymobile.metadata.metadataRelation.service.*; import com.keymobile.metadata.metadataRelation.service.*;
import com.keymobile.metadata.metadataRelation.service.impl.MongoDbServiceImpl; import com.keymobile.metadata.metadataRelation.service.impl.MongoDbServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.annotations.ApiParam; import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.bson.Document; import org.bson.Document;
import org.slf4j.Logger; import org.slf4j.Logger;
...@@ -35,10 +37,9 @@ import org.springframework.web.context.request.RequestContextHolder; ...@@ -35,10 +37,9 @@ import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes; import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
@RestController @RestController
@Api(value = "把metadata写入neo4j数据库", tags = "metadata to neo4j") @Tag(name = "把metadata写入neo4j数据库", description = "metadata to neo4j")
public class MetaDataController { public class MetaDataController {
...@@ -89,7 +90,7 @@ public class MetaDataController { ...@@ -89,7 +90,7 @@ public class MetaDataController {
* 如果是etljob,则查找job的拥有的节点,job的前后关系 * 如果是etljob,则查找job的拥有的节点,job的前后关系
*/ */
// //
@ApiOperation(tags = "", value = "按照元数据名称生成图形") @Operation(summary= "按照元数据名称生成图形")
@RequestMapping(path = "/searchGraphByName", method = RequestMethod.GET) @RequestMapping(path = "/searchGraphByName", method = RequestMethod.GET)
public ReturnReslult searchGraphByName(String metadataName,String layer){ public ReturnReslult searchGraphByName(String metadataName,String layer){
int layerLong = Integer.valueOf(layer); int layerLong = Integer.valueOf(layer);
...@@ -108,7 +109,7 @@ public class MetaDataController { ...@@ -108,7 +109,7 @@ public class MetaDataController {
return returnReslult ; return returnReslult ;
} }
@ApiOperation(tags = "", value = "按照元数据Id生成图形") @Operation(summary= "按照元数据Id生成图形")
@RequestMapping(path = "/searchGraphByMetadataId", method = RequestMethod.GET) @RequestMapping(path = "/searchGraphByMetadataId", method = RequestMethod.GET)
public ReturnReslult searchGraphByMetadataId(String metadataId,String layer){ public ReturnReslult searchGraphByMetadataId(String metadataId,String layer){
int layerLong = Integer.valueOf(layer); int layerLong = Integer.valueOf(layer);
...@@ -127,7 +128,7 @@ public class MetaDataController { ...@@ -127,7 +128,7 @@ public class MetaDataController {
* 显示节点的属性,传入元数据id,返回元数据的主要属性(5个),需要调用元数据服务的接口。 * 显示节点的属性,传入元数据id,返回元数据的主要属性(5个),需要调用元数据服务的接口。
* 路径,别名,描述 * 路径,别名,描述
*/ */
@ApiOperation(tags = "", value = "根据元数据id获取元数据属性") @Operation(summary= "根据元数据id获取元数据属性")
@RequestMapping(path = "/getPropertiesById", method = RequestMethod.GET) @RequestMapping(path = "/getPropertiesById", method = RequestMethod.GET)
public Map<String,String> getPropertiesById(String metadataId) { public Map<String,String> getPropertiesById(String metadataId) {
Map<String,String> attributeMap = new HashMap<>(); Map<String,String> attributeMap = new HashMap<>();
...@@ -147,7 +148,7 @@ public class MetaDataController { ...@@ -147,7 +148,7 @@ public class MetaDataController {
/** /**
* 搜索的自动匹配接口,按照输入的字符,自动匹配名字,返回前10个匹配到的。 * 搜索的自动匹配接口,按照输入的字符,自动匹配名字,返回前10个匹配到的。
*/ */
@ApiOperation(tags = "", value = "模糊匹配输入结果,不区分大小写") @Operation(summary= "模糊匹配输入结果,不区分大小写")
@RequestMapping(path = "/autoMatchByInput", method = RequestMethod.GET) @RequestMapping(path = "/autoMatchByInput", method = RequestMethod.GET)
public Map<String,String> getAutoMatchByInput(String name,String count,String offset) { public Map<String,String> getAutoMatchByInput(String name,String count,String offset) {
if(count == null || count .equals("")){ if(count == null || count .equals("")){
...@@ -162,7 +163,7 @@ public class MetaDataController { ...@@ -162,7 +163,7 @@ public class MetaDataController {
/** /**
* 返回一个系统级的大图 * 返回一个系统级的大图
*/ */
@ApiOperation(tags = "", value = "系统级的大图") @Operation(summary= "系统级的大图")
@RequestMapping(path = "/result", method = RequestMethod.GET) @RequestMapping(path = "/result", method = RequestMethod.GET)
public ReturnReslult getBigGraph(String modelName0,String size) { public ReturnReslult getBigGraph(String modelName0,String size) {
logger.info("传入的元模型名称是:"+modelName0); logger.info("传入的元模型名称是:"+modelName0);
...@@ -359,7 +360,7 @@ public class MetaDataController { ...@@ -359,7 +360,7 @@ public class MetaDataController {
} }
@ApiOperation(tags = "", value = "系统总图") @Operation(summary= "系统总图")
@RequestMapping(path = "/getSystemGraph", method = RequestMethod.GET) @RequestMapping(path = "/getSystemGraph", method = RequestMethod.GET)
public ReturnReslult getSystemGraph(){ public ReturnReslult getSystemGraph(){
int size = 300; int size = 300;
...@@ -367,14 +368,14 @@ public class MetaDataController { ...@@ -367,14 +368,14 @@ public class MetaDataController {
} }
@ApiOperation(tags = "", value = "获取系统总图") @Operation(summary= "获取系统总图")
@RequestMapping(path = "/getSystemAllGraph", method = RequestMethod.GET) @RequestMapping(path = "/getSystemAllGraph", method = RequestMethod.GET)
public ReturnReslult getSystemAllGraph(){ public ReturnReslult getSystemAllGraph(){
return metadataService.getAllSystemGraph(); return metadataService.getAllSystemGraph();
} }
@ApiOperation(tags = "", value = "获取系统总图") @Operation(summary= "获取系统总图")
@RequestMapping(path = "/getSystemGraphBySystemId", method = RequestMethod.GET) @RequestMapping(path = "/getSystemGraphBySystemId", method = RequestMethod.GET)
public ReturnReslult getSystemGraphBySystemId(String systemId){ public ReturnReslult getSystemGraphBySystemId(String systemId){
return systemService.getSystemBySystemId(systemId); return systemService.getSystemBySystemId(systemId);
...@@ -396,7 +397,7 @@ public class MetaDataController { ...@@ -396,7 +397,7 @@ public class MetaDataController {
* 传入一个节点与层数,返回指定节点的直接下层节点 * 传入一个节点与层数,返回指定节点的直接下层节点
*/ */
@ApiOperation(tags = "", value = "开始获取直接下层节点") @Operation(summary= "开始获取直接下层节点")
@RequestMapping(path = "/getNextDrill", method = RequestMethod.GET) @RequestMapping(path = "/getNextDrill", method = RequestMethod.GET)
public ReturnReslult getNextDrill(String dataId,String layer) { public ReturnReslult getNextDrill(String dataId,String layer) {
...@@ -444,9 +445,9 @@ public class MetaDataController { ...@@ -444,9 +445,9 @@ public class MetaDataController {
* 修改图片的接口,传入元模型id,新图标 * 修改图片的接口,传入元模型id,新图标
*/ */
@ApiOperation(tags = "", value = "修改元模型图标的接口") @Operation(summary= "修改元模型图标的接口")
@PostMapping(value = "/modifyIcon", consumes = "multipart/*", headers = "content-type=multipart/form-date") @PostMapping(value = "/modifyIcon", consumes = "multipart/*", headers = "content-type=multipart/form-date")
public String modifyIcon(String modelId, @ApiParam(value = "上传的文件", required = true) public String modifyIcon(String modelId, @Parameter(name = "上传的文件", required = true)
MultipartFile file) { MultipartFile file) {
if (file.isEmpty()) { if (file.isEmpty()) {
logger.info("文件为空空"); logger.info("文件为空空");
...@@ -490,7 +491,7 @@ public class MetaDataController { ...@@ -490,7 +491,7 @@ public class MetaDataController {
/** /**
* 获取元模型的图标, * 获取元模型的图标,
*/ */
@ApiOperation(tags = "", value = "获取元模型的图标") @Operation(summary= "获取元模型的图标")
@RequestMapping(value = "/getIconByModelId", method = RequestMethod.GET) @RequestMapping(value = "/getIconByModelId", method = RequestMethod.GET)
public String getIconByModelId(String modelId) { public String getIconByModelId(String modelId) {
ApplicationHome applicationHome = new ApplicationHome(getClass()); ApplicationHome applicationHome = new ApplicationHome(getClass());
...@@ -533,7 +534,7 @@ public class MetaDataController { ...@@ -533,7 +534,7 @@ public class MetaDataController {
/** /**
* 查询所有的关系类型 * 查询所有的关系类型
*/ */
@ApiOperation(tags = "", value = "查询所有的关系类型") @Operation(summary= "查询所有的关系类型")
@RequestMapping(path = "/listAllRelationType", method = RequestMethod.GET) @RequestMapping(path = "/listAllRelationType", method = RequestMethod.GET)
public List<String> getAllRelationType() { public List<String> getAllRelationType() {
...@@ -553,7 +554,7 @@ public class MetaDataController { ...@@ -553,7 +554,7 @@ public class MetaDataController {
/** /**
* 查询所有的节点类型 * 查询所有的节点类型
*/ */
@ApiOperation(tags = "", value = "查询所有的节点元模型") @Operation(summary= "查询所有的节点元模型")
@RequestMapping(path = "/listAllNodeType", method = RequestMethod.GET) @RequestMapping(path = "/listAllNodeType", method = RequestMethod.GET)
public List<String> getAllNodeType() { public List<String> getAllNodeType() {
...@@ -580,7 +581,7 @@ public class MetaDataController { ...@@ -580,7 +581,7 @@ public class MetaDataController {
/** /**
* 传入元数据id,显示的层数,查找出与该元数据有关系的数据 * 传入元数据id,显示的层数,查找出与该元数据有关系的数据
*/ */
@ApiOperation(tags = "", value = "传入元数据id,显示的层数,查找出与该元数据有关系的数据") @Operation(summary= "传入元数据id,显示的层数,查找出与该元数据有关系的数据")
@RequestMapping(path = "/getNodeByDataId", method = RequestMethod.GET) @RequestMapping(path = "/getNodeByDataId", method = RequestMethod.GET)
public ReturnReslult getNodeByDataId(String metadataId, int depth) { public ReturnReslult getNodeByDataId(String metadataId, int depth) {
return metadataService.findNodeByDataId(metadataId, depth); return metadataService.findNodeByDataId(metadataId, depth);
...@@ -602,7 +603,7 @@ public class MetaDataController { ...@@ -602,7 +603,7 @@ public class MetaDataController {
* 异步处理, * 异步处理,
* @return * @return
*/ */
@ApiOperation(tags = "", value = "同步元数据关系的接口") @Operation(summary= "同步元数据关系的接口")
@RequestMapping(path = "/syschroRelationFromMongo", method = RequestMethod.POST) @RequestMapping(path = "/syschroRelationFromMongo", method = RequestMethod.POST)
public String synchroRelationFromMongo(String catalogName) { public String synchroRelationFromMongo(String catalogName) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
...@@ -615,7 +616,7 @@ public class MetaDataController { ...@@ -615,7 +616,7 @@ public class MetaDataController {
return flag; return flag;
} }
@ApiOperation(tags = "", value = "根据环境id与jobId同步元数据关系的接口") @Operation(summary= "根据环境id与jobId同步元数据关系的接口")
@RequestMapping(path = "/synchroRelationByJobId", method = RequestMethod.POST) @RequestMapping(path = "/synchroRelationByJobId", method = RequestMethod.POST)
public String synchroRelationByJobId(String catalogName,String jobId) { public String synchroRelationByJobId(String catalogName,String jobId) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
......
...@@ -7,8 +7,10 @@ import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult; ...@@ -7,8 +7,10 @@ import com.keymobile.metadata.metadataRelation.pojo.returnBean.ReturnReslult;
import com.keymobile.metadata.metadataRelation.remote.DataStandardRemoteService; import com.keymobile.metadata.metadataRelation.remote.DataStandardRemoteService;
import com.keymobile.metadata.metadataRelation.remote.TagRemoteService; import com.keymobile.metadata.metadataRelation.remote.TagRemoteService;
import com.keymobile.metadata.metadataRelation.service.*; import com.keymobile.metadata.metadataRelation.service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletRequest;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -20,14 +22,11 @@ import org.springframework.web.bind.annotation.RestController; ...@@ -20,14 +22,11 @@ import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes; import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
@RestController @RestController
@Api(value = "关系图谱的接口", tags = "relational graph controller") @Tag(name = "关系图谱的接口", description = "relational graph controller")
public class RelationalGraphController { public class RelationalGraphController {
private static final Logger logger = LoggerFactory.getLogger(RelationalGraphController.class); private static final Logger logger = LoggerFactory.getLogger(RelationalGraphController.class);
...@@ -66,7 +65,7 @@ public class RelationalGraphController { ...@@ -66,7 +65,7 @@ public class RelationalGraphController {
private String tableModelName = "Table="; private String tableModelName = "Table=";
private String etlScriptModelName = "ETLScript="; private String etlScriptModelName = "ETLScript=";
//测试标准的接口 //测试标准的接口
@ApiOperation(tags = "", value = "测试标准的接口") @Operation(summary= "测试标准的接口")
@RequestMapping(path = "/testDataAssertRemoteService", method = RequestMethod.GET) @RequestMapping(path = "/testDataAssertRemoteService", method = RequestMethod.GET)
public void testDataAssertRemoteService(String metadataId){ public void testDataAssertRemoteService(String metadataId){
int size = 300; int size = 300;
...@@ -85,13 +84,13 @@ public class RelationalGraphController { ...@@ -85,13 +84,13 @@ public class RelationalGraphController {
} }
//查找孤立点 //查找孤立点
@ApiOperation(tags = "", value = "查找指定节点下的孤立点") @Operation(summary= "查找指定节点下的孤立点")
@RequestMapping(path = "/getNodeWithoutRelations", method = RequestMethod.GET) @RequestMapping(path = "/getNodeWithoutRelations", method = RequestMethod.GET)
public ReturnReslult getNodeWithoutRelations(String metadataId,String retlationType){ public ReturnReslult getNodeWithoutRelations(String metadataId,String retlationType){
return multiModelService.getNodeWithoutRelations(metadataId,retlationType); return multiModelService.getNodeWithoutRelations(metadataId,retlationType);
} }
@ApiOperation(tags = "", value = "表的重要性分析") @Operation(summary= "表的重要性分析")
@RequestMapping(path = "/getImportantTable", method = RequestMethod.GET) @RequestMapping(path = "/getImportantTable", method = RequestMethod.GET)
public ReturnReslult getImportantTable(String schemaId){ public ReturnReslult getImportantTable(String schemaId){
return multiModelService.getImportantTable(schemaId); return multiModelService.getImportantTable(schemaId);
...@@ -101,7 +100,7 @@ public class RelationalGraphController { ...@@ -101,7 +100,7 @@ public class RelationalGraphController {
* 获取所有neo4j算法 * 获取所有neo4j算法
* @return * @return
*/ */
@ApiOperation(tags = "", value = "获取所有neo4j算法") @Operation(summary= "获取所有neo4j算法")
@RequestMapping(path = "/getAllAlgorithm", method = RequestMethod.GET) @RequestMapping(path = "/getAllAlgorithm", method = RequestMethod.GET)
public Map<String,List<String>> getAllAlgorithm(){ public Map<String,List<String>> getAllAlgorithm(){
Map<String,List<String>> allAlgorithmMap = new HashMap<>(); Map<String,List<String>> allAlgorithmMap = new HashMap<>();
...@@ -144,7 +143,7 @@ public class RelationalGraphController { ...@@ -144,7 +143,7 @@ public class RelationalGraphController {
//系统总图的接口 //系统总图的接口
@ApiOperation(tags = "", value = "按照环境参数返回系统总图") @Operation(summary= "按照环境参数返回系统总图")
@RequestMapping(path = "/getAllSystemGraph", method = RequestMethod.GET) @RequestMapping(path = "/getAllSystemGraph", method = RequestMethod.GET)
public ReturnReslult getAllSystemGraph(String environment){ public ReturnReslult getAllSystemGraph(String environment){
int size = 300; int size = 300;
...@@ -154,7 +153,7 @@ public class RelationalGraphController { ...@@ -154,7 +153,7 @@ public class RelationalGraphController {
// //系统总图的接口 // //系统总图的接口
// @ApiOperation(tags = "", value = "按照环境参数返回系统总图") // @Operation(summary= "按照环境参数返回系统总图")
// @RequestMapping(path = "/getAllSystemGraphByEnvironment", method = RequestMethod.GET) // @RequestMapping(path = "/getAllSystemGraphByEnvironment", method = RequestMethod.GET)
// public ReturnReslult getAllSystemGraphByEnvironment(String environment){ // public ReturnReslult getAllSystemGraphByEnvironment(String environment){
// int size = 300; // int size = 300;
...@@ -163,7 +162,7 @@ public class RelationalGraphController { ...@@ -163,7 +162,7 @@ public class RelationalGraphController {
// } // }
//schema的分层,图的形式,由里到外,同上面的分层接口 //schema的分层,图的形式,由里到外,同上面的分层接口
//系统总图下钻获取schema,schema要分层 //系统总图下钻获取schema,schema要分层
@ApiOperation(tags = "", value = "按照系统获取schema,要分层") @Operation(summary= "按照系统获取schema,要分层")
@RequestMapping(path = "/getSchemaBySystemId", method = RequestMethod.GET) @RequestMapping(path = "/getSchemaBySystemId", method = RequestMethod.GET)
public Map<String, List<ReturnNode>> getSchemaBySystem(String systemId){ public Map<String, List<ReturnNode>> getSchemaBySystem(String systemId){
//传入一个系统名称/id,返回系统下的所有schema,注意分层 //传入一个系统名称/id,返回系统下的所有schema,注意分层
...@@ -173,7 +172,7 @@ public class RelationalGraphController { ...@@ -173,7 +172,7 @@ public class RelationalGraphController {
return stringListMap; return stringListMap;
} }
@ApiOperation(tags = "", value = "根据系统id,获取etljob的接口") @Operation(summary= "根据系统id,获取etljob的接口")
@RequestMapping(path = "/getEtlJobBySystem", method = RequestMethod.GET) @RequestMapping(path = "/getEtlJobBySystem", method = RequestMethod.GET)
public Map<String,List<ReturnNode>> getEtlJobBySystem(String systemId){ public Map<String,List<ReturnNode>> getEtlJobBySystem(String systemId){
...@@ -182,7 +181,7 @@ public class RelationalGraphController { ...@@ -182,7 +181,7 @@ public class RelationalGraphController {
} }
//单个schema的数据,包括表,视图,函数,过程等,列表形势 //单个schema的数据,包括表,视图,函数,过程等,列表形势
@ApiOperation(tags = "", value = "传入schemaId,返回表,视图,函数,存储过程") @Operation(summary= "传入schemaId,返回表,视图,函数,存储过程")
@RequestMapping(path = "/getTableBySchemaId", method = RequestMethod.GET) @RequestMapping(path = "/getTableBySchemaId", method = RequestMethod.GET)
public Map<String, List<ReturnNode>> getTableBySchemaId(String schemaId){ public Map<String, List<ReturnNode>> getTableBySchemaId(String schemaId){
//传入一个系统名称/id,返回系统下的所有schema,注意分层 //传入一个系统名称/id,返回系统下的所有schema,注意分层
...@@ -192,7 +191,7 @@ public class RelationalGraphController { ...@@ -192,7 +191,7 @@ public class RelationalGraphController {
} }
//传入metadataId,详细属性 //传入metadataId,详细属性
@ApiOperation(tags = "", value = "传入metadataId,返回详细属性") @Operation(summary= "传入metadataId,返回详细属性")
@RequestMapping(path = "/getAttributeByMetadataId", method = RequestMethod.GET) @RequestMapping(path = "/getAttributeByMetadataId", method = RequestMethod.GET)
public Map<String,String> getAttributeByMetadataId(String metadataId){ public Map<String,String> getAttributeByMetadataId(String metadataId){
Map<String,String> attributeMap = new HashMap<>(); Map<String,String> attributeMap = new HashMap<>();
...@@ -212,7 +211,7 @@ public class RelationalGraphController { ...@@ -212,7 +211,7 @@ public class RelationalGraphController {
//展开当前节点 //展开当前节点
@ApiOperation(tags = "", value = "传入一个节点id,返回改节点的子节点,比如表--字段") @Operation(summary= "传入一个节点id,返回改节点的子节点,比如表--字段")
@RequestMapping(path = "/getChildren", method = RequestMethod.GET) @RequestMapping(path = "/getChildren", method = RequestMethod.GET)
public Map<String, List<ReturnNode>> getChildren(String metadataId,String size) { public Map<String, List<ReturnNode>> getChildren(String metadataId,String size) {
logger.info("传入的元数据Id是:"+metadataId); logger.info("传入的元数据Id是:"+metadataId);
...@@ -226,7 +225,7 @@ public class RelationalGraphController { ...@@ -226,7 +225,7 @@ public class RelationalGraphController {
} }
//展开当前节点 //展开当前节点
@ApiOperation(tags = "", value = "传入一个节点的元数据id与方向(向前forward ,向后backward),返回当前节点的关系") @Operation(summary= "传入一个节点的元数据id与方向(向前forward ,向后backward),返回当前节点的关系")
@RequestMapping(path = "/expandNode", method = RequestMethod.GET) @RequestMapping(path = "/expandNode", method = RequestMethod.GET)
public ReturnReslult expandNode(String dataId ,String direction) { public ReturnReslult expandNode(String dataId ,String direction) {
logger.info("传入的元模型名称是:"+dataId); logger.info("传入的元模型名称是:"+dataId);
...@@ -234,7 +233,7 @@ public class RelationalGraphController { ...@@ -234,7 +233,7 @@ public class RelationalGraphController {
return returnReslult; return returnReslult;
} }
@ApiOperation(tags = "", value = "传入前端的json,过滤的模型,保留的模型,返回在json中过滤后的节点与关系") @Operation(summary= "传入前端的json,过滤的模型,保留的模型,返回在json中过滤后的节点与关系")
@RequestMapping(path = "/filterNode", method = RequestMethod.POST) @RequestMapping(path = "/filterNode", method = RequestMethod.POST)
public ReturnReslult filterNode(String resultJson,String filterModel,String retainModel) { public ReturnReslult filterNode(String resultJson,String filterModel,String retainModel) {
logger.info("需要过滤的模型是:"+filterModel+",需要保留的模型是:"+retainModel); logger.info("需要过滤的模型是:"+filterModel+",需要保留的模型是:"+retainModel);
...@@ -243,7 +242,7 @@ public class RelationalGraphController { ...@@ -243,7 +242,7 @@ public class RelationalGraphController {
return returnReslult; return returnReslult;
} }
//表的分析,链路分析,表与其他表的上下游关系,其他表可以继续下钻,并且可以收缩。 //表的分析,链路分析,表与其他表的上下游关系,其他表可以继续下钻,并且可以收缩。
@ApiOperation(tags = "", value = "全链分析,传入表的id,返回表的上下游一层关系。") @Operation(summary= "全链分析,传入表的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){
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
...@@ -301,7 +300,7 @@ public class RelationalGraphController { ...@@ -301,7 +300,7 @@ public class RelationalGraphController {
return username; return username;
} }
@ApiOperation(tags = "", value = "获取IP地址") @Operation(summary= "获取IP地址")
@RequestMapping(path = "/getIp", method = RequestMethod.GET) @RequestMapping(path = "/getIp", method = RequestMethod.GET)
public String getIp(Integer numbers) { public String getIp(Integer numbers) {
String ip = getIp(); String ip = getIp();
...@@ -310,7 +309,7 @@ public class RelationalGraphController { ...@@ -310,7 +309,7 @@ public class RelationalGraphController {
} }
//表的分析,关系分析--表与模型,表与质量,表与标准,表与作业的关系 //表的分析,关系分析--表与模型,表与质量,表与标准,表与作业的关系
@ApiOperation(tags = "", value = "关系分析,传入表的id,返回与表相关的模型,标准,质量,资产,作业等对象") @Operation(summary= "关系分析,传入表的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){
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
...@@ -325,7 +324,7 @@ public class RelationalGraphController { ...@@ -325,7 +324,7 @@ public class RelationalGraphController {
} }
//搜索接口,多个搜索结果,则先弹出列表(对象的全路径),再进行选择哪个对象 //搜索接口,多个搜索结果,则先弹出列表(对象的全路径),再进行选择哪个对象
@ApiOperation(tags = "", value = "传入表的id,返回对象的图形") @Operation(summary= "传入表的id,返回对象的图形")
@RequestMapping(path = "/searchByMetadataId", method = RequestMethod.GET) @RequestMapping(path = "/searchByMetadataId", method = RequestMethod.GET)
public Map<String,List<ReturnNode>> searchByMetadataId(String tableId){ public Map<String,List<ReturnNode>> searchByMetadataId(String tableId){
return tableService.getRelationObjectByTableId (tableId); return tableService.getRelationObjectByTableId (tableId);
...@@ -333,7 +332,7 @@ public class RelationalGraphController { ...@@ -333,7 +332,7 @@ public class RelationalGraphController {
/** /**
* 搜索的自动匹配接口,按照输入的字符,自动匹配名字,返回前10个匹配到的。 * 搜索的自动匹配接口,按照输入的字符,自动匹配名字,返回前10个匹配到的。
*/ */
@ApiOperation(tags = "", value = "模糊匹配输入结果,不区分大小写") @Operation(summary= "模糊匹配输入结果,不区分大小写")
@RequestMapping(path = "/autoMatchByInputWord", method = RequestMethod.GET) @RequestMapping(path = "/autoMatchByInputWord", method = RequestMethod.GET)
public List<ReturnNode> autoMatchByInputWord(String name,String count,String offset) { public List<ReturnNode> autoMatchByInputWord(String name,String count,String offset) {
if(count == null || count .equals("")){ if(count == null || count .equals("")){
...@@ -345,7 +344,7 @@ public class RelationalGraphController { ...@@ -345,7 +344,7 @@ public class RelationalGraphController {
} }
//单个schema的数据,包括表,视图,函数,过程等,列表形势 //单个schema的数据,包括表,视图,函数,过程等,列表形势
@ApiOperation(tags = "", value = "传入schemaId 关键词,返回表,视图,函数,存储过程") @Operation(summary= "传入schemaId 关键词,返回表,视图,函数,存储过程")
@RequestMapping(path = "/getTableBySchemaIdAndKeyWord", method = RequestMethod.GET) @RequestMapping(path = "/getTableBySchemaIdAndKeyWord", method = RequestMethod.GET)
public Map<String, List<ReturnNode>> getTableBySchemaIdAndKeyWord(String schemaId,String keyword){ public Map<String, List<ReturnNode>> getTableBySchemaIdAndKeyWord(String schemaId,String keyword){
//传入一个系统名称/id,返回系统下的所有schema,注意分层 //传入一个系统名称/id,返回系统下的所有schema,注意分层
...@@ -355,14 +354,14 @@ public class RelationalGraphController { ...@@ -355,14 +354,14 @@ public class RelationalGraphController {
//同步单个schema的标签 //同步单个schema的标签
@ApiOperation(tags = "", value = "传入schemaId 获取schema的标签") @Operation(summary= "传入schemaId 获取schema的标签")
@RequestMapping(path = "/updateTagFromOneSchema", method = RequestMethod.GET) @RequestMapping(path = "/updateTagFromOneSchema", method = RequestMethod.GET)
public boolean updateTagFromOneSchema(String schemaId){ public boolean updateTagFromOneSchema(String schemaId){
return schemaService.updateTagFromSchema(schemaId); return schemaService.updateTagFromSchema(schemaId);
} }
//同步所有schema的标签 //同步所有schema的标签
@ApiOperation(tags = "", value = "更新所有schema的标签") @Operation(summary= "更新所有schema的标签")
@RequestMapping(path = "/updateAllTagFromSchema", method = RequestMethod.GET) @RequestMapping(path = "/updateAllTagFromSchema", method = RequestMethod.GET)
public boolean updateTagFromAllSchema(){ public boolean updateTagFromAllSchema(){
logger.info("开始同步所有schema的标签。"); logger.info("开始同步所有schema的标签。");
...@@ -370,28 +369,28 @@ public class RelationalGraphController { ...@@ -370,28 +369,28 @@ public class RelationalGraphController {
} }
@ApiOperation(tags = "", value = "传入环境id,系统名,schema名,表名,获取表id") @Operation(summary= "传入环境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){
logger.info("获取环境id:"+environment +" ;系统:" + system+ " ;table:"+tableName); logger.info("获取环境id:"+environment +" ;系统:" + system+ " ;table:"+tableName);
return tableService.getTableId(environment,system,tableName); return tableService.getTableId(environment,system,tableName);
} }
@ApiOperation(tags = "", value = "传入质量相关的字段id,返回与该字段id有关系的字段,表,数据库,系统") @Operation(summary= "传入质量相关的字段id,返回与该字段id有关系的字段,表,数据库,系统")
@RequestMapping(path = "/getQualityDataRelations", method = RequestMethod.GET) @RequestMapping(path = "/getQualityDataRelations", method = RequestMethod.GET)
public ReturnReslult getQualityDataRelations(String columnId){ public ReturnReslult getQualityDataRelations(String columnId){
logger.info("传入的字段id:"+columnId); logger.info("传入的字段id:"+columnId);
return tableService.getQualityData(columnId); return tableService.getQualityData(columnId);
} }
@ApiOperation(tags = "", value = "传入表的id,返回与该表相关的上下游的表") @Operation(summary= "传入表的id,返回与该表相关的上下游的表")
@RequestMapping(path = "/getRelationAboutTables", method = RequestMethod.GET) @RequestMapping(path = "/getRelationAboutTables", method = RequestMethod.GET)
public ReturnReslult getRelationAboutTables(String tableId){ public ReturnReslult getRelationAboutTables(String tableId){
logger.info("获取表id。"+tableId); logger.info("获取表id。"+tableId);
return tableService.getRelationAboutTables(tableId); return tableService.getRelationAboutTables(tableId);
} }
@ApiOperation(tags = "", value = "传入字段id,返回与该字段相关的上下游的字段") @Operation(summary= "传入字段id,返回与该字段相关的上下游的字段")
@RequestMapping(path = "/getRelationAboutColumns", method = RequestMethod.GET) @RequestMapping(path = "/getRelationAboutColumns", method = RequestMethod.GET)
public ReturnReslult getRelationAboutColumns(String columnId){ public ReturnReslult getRelationAboutColumns(String columnId){
logger.info("获取字段id。"+columnId); logger.info("获取字段id。"+columnId);
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.BaseRelationship; import com.keymobile.metadata.metadataRelation.pojo.BaseRelationship;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.util.List; import java.util.List;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.CompositionRelation; import com.keymobile.metadata.metadataRelation.pojo.CompositionRelation;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.ExecuteRelation; import com.keymobile.metadata.metadataRelation.pojo.ExecuteRelation;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.InputRelation; import com.keymobile.metadata.metadataRelation.pojo.InputRelation;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.MetaData; import com.keymobile.metadata.metadataRelation.pojo.MetaData;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.OutputRelation; import com.keymobile.metadata.metadataRelation.pojo.OutputRelation;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository; ...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.PostRelation; import com.keymobile.metadata.metadataRelation.pojo.PostRelation;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.PreRelation; import com.keymobile.metadata.metadataRelation.pojo.PreRelation;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
......
...@@ -3,12 +3,12 @@ package com.keymobile.metadata.metadataRelation.respository; ...@@ -3,12 +3,12 @@ package com.keymobile.metadata.metadataRelation.respository;
import java.util.List; import java.util.List;
import com.keymobile.metadata.metadataRelation.pojo.TempNode; import com.keymobile.metadata.metadataRelation.pojo.TempNode;
import jakarta.transaction.Transactional;
import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import javax.transaction.Transactional;
/** /**
* @author mahx * @author mahx
......
package com.keymobile.metadata.metadataRelation.respository; package com.keymobile.metadata.metadataRelation.respository;
import com.keymobile.metadata.metadataRelation.pojo.TempRelation; import com.keymobile.metadata.metadataRelation.pojo.TempRelation;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
......
...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jColumn; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jColumn;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLJob; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLJob;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jFunction; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jFunction;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLScript; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLScript;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLScript; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLScript;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jFile; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jFile;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
......
...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -2,7 +2,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -3,7 +3,7 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLJob; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jETLJob;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSchema;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSystem; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jSystem;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
......
...@@ -3,12 +3,11 @@ package com.keymobile.metadata.metadataRelation.respository.metadata; ...@@ -3,12 +3,11 @@ package com.keymobile.metadata.metadataRelation.respository.metadata;
import com.keymobile.metadata.metadataRelation.pojo.BaseNode; import com.keymobile.metadata.metadataRelation.pojo.BaseNode;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jColumn; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jColumn;
import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jTable; import com.keymobile.metadata.metadataRelation.pojo.metadata.Neo4jTable;
import org.springframework.data.neo4j.annotation.Query; import org.springframework.data.neo4j.repository.query.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository; import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param; import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import javax.persistence.Column;
import java.util.List; import java.util.List;
@Repository @Repository
......
...@@ -21,6 +21,7 @@ import net.sf.json.JSONArray; ...@@ -21,6 +21,7 @@ import net.sf.json.JSONArray;
import net.sf.json.JSONObject; import net.sf.json.JSONObject;
import org.bson.Document; import org.bson.Document;
import org.neo4j.driver.v1.*; import org.neo4j.driver.v1.*;
import org.neo4j.driver.v1.Record;
import org.neo4j.driver.v1.types.Node; import org.neo4j.driver.v1.types.Node;
import org.neo4j.driver.v1.types.Path; import org.neo4j.driver.v1.types.Path;
import org.neo4j.driver.v1.types.Relationship; import org.neo4j.driver.v1.types.Relationship;
......
...@@ -25,6 +25,7 @@ import com.mongodb.client.MongoCursor; ...@@ -25,6 +25,7 @@ import com.mongodb.client.MongoCursor;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.bson.Document; import org.bson.Document;
import org.neo4j.driver.v1.*; import org.neo4j.driver.v1.*;
import org.neo4j.driver.v1.Record;
import org.neo4j.driver.v1.types.Node; import org.neo4j.driver.v1.types.Node;
import org.neo4j.driver.v1.types.Path; import org.neo4j.driver.v1.types.Path;
import org.neo4j.driver.v1.types.Relationship; import org.neo4j.driver.v1.types.Relationship;
...@@ -1124,7 +1125,7 @@ public class MetadataServiceImpl implements IMetadataService { ...@@ -1124,7 +1125,7 @@ public class MetadataServiceImpl implements IMetadataService {
} }
} }
private void getResultFromNeo4jRecord(Map<String, MetaModel> metaModelMap, Map<String, ReturnNode> returnNodeMap, Map<String, ReturnEdge> returnEdgeMap, Record record) { private void getResultFromNeo4jRecord(Map<String, MetaModel> metaModelMap, Map<String, ReturnNode> returnNodeMap, Map<String, ReturnEdge> returnEdgeMap, org.neo4j.driver.v1.Record record) {
List<Value> values = record.values(); List<Value> values = record.values();
for (Value value : values) { for (Value value : values) {
if(value.type().name().equals("PATH")){ if(value.type().name().equals("PATH")){
......
...@@ -11,6 +11,7 @@ import com.keymobile.metadata.metadataRelation.respository.*; ...@@ -11,6 +11,7 @@ import com.keymobile.metadata.metadataRelation.respository.*;
import com.keymobile.metadata.metadataRelation.service.MultiModelService; import com.keymobile.metadata.metadataRelation.service.MultiModelService;
import com.keymobile.metadata.metadataRelation.util.Neo4jTool; import com.keymobile.metadata.metadataRelation.util.Neo4jTool;
import org.neo4j.driver.v1.*; import org.neo4j.driver.v1.*;
import org.neo4j.driver.v1.Record;
import org.neo4j.driver.v1.types.Node; import org.neo4j.driver.v1.types.Node;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
......
...@@ -9,7 +9,6 @@ import com.keymobile.metadata.metadataRelation.respository.metadata.Neo4jSchemaR ...@@ -9,7 +9,6 @@ import com.keymobile.metadata.metadataRelation.respository.metadata.Neo4jSchemaR
import com.keymobile.metadata.metadataRelation.respository.metadata.Neo4jSystemRepository; import com.keymobile.metadata.metadataRelation.respository.metadata.Neo4jSystemRepository;
import com.keymobile.metadata.metadataRelation.service.ISchemaService; import com.keymobile.metadata.metadataRelation.service.ISchemaService;
import com.keymobile.metadata.metadataRelation.util.SchemaLayerObject; import com.keymobile.metadata.metadataRelation.util.SchemaLayerObject;
import org.hibernate.loader.custom.Return;
import org.neo4j.driver.v1.Record; import org.neo4j.driver.v1.Record;
import org.neo4j.driver.v1.Session; import org.neo4j.driver.v1.Session;
import org.neo4j.driver.v1.StatementResult; import org.neo4j.driver.v1.StatementResult;
......
...@@ -15,6 +15,7 @@ import com.keymobile.metadata.metadataRelation.respository.metadata.*; ...@@ -15,6 +15,7 @@ import com.keymobile.metadata.metadataRelation.respository.metadata.*;
import com.keymobile.metadata.metadataRelation.service.ITableService; import com.keymobile.metadata.metadataRelation.service.ITableService;
import com.keymobile.metadata.metadataRelation.util.Neo4jTool; import com.keymobile.metadata.metadataRelation.util.Neo4jTool;
import org.neo4j.driver.v1.*; import org.neo4j.driver.v1.*;
import org.neo4j.driver.v1.Record;
import org.neo4j.driver.v1.types.Node; import org.neo4j.driver.v1.types.Node;
import org.neo4j.driver.v1.types.Path; import org.neo4j.driver.v1.types.Path;
import org.neo4j.driver.v1.types.Relationship; import org.neo4j.driver.v1.types.Relationship;
......
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