Commit a3ebcc2b by qiuchaofei

1,返回的结果大图添加数量限制。

parent 7e75ccec
......@@ -128,15 +128,17 @@ public class MetaDataController {
*/
@ApiOperation(tags = "", value = "系统级的大图")
@RequestMapping(path = "/result", method = RequestMethod.GET)
public ReturnReslult getBigGraph(String modelName0) {
public ReturnReslult getBigGraph(String modelName0,String size) {
logger.info("传入的元模型名称是:"+modelName0);
ReturnReslult returnReslult = new ReturnReslult();
int sizeInt = Integer.valueOf(size);
if (modelName0 == null || modelName0.equals("")) {
modelName0 = "Table";
}
if(!modelName0.toLowerCase().equals("all")){
returnReslult = metadataService.findResultByModelName(modelName0);
returnReslult = metadataService.findResultByModelName(modelName0,sizeInt);
}else {
List<MetaData> metaDataList = metadataService.finAllMetaData();
Map<String, Node> nodeMap = new HashMap<>();
......@@ -147,8 +149,13 @@ public class MetaDataController {
Map<String, List<String>> target2Source = new HashMap<>();
Map<String, MetaModel> metaModelMap = new HashMap<>();
int count= 0;
for (MetaData metaData : metaDataList) {
if(count>=sizeInt){
break;
}
count++;
Node node = new Node();
String[] strings = metaData.getMetadataId().split("=");
String modelName = strings[0];
......
......@@ -14,7 +14,7 @@ public interface IMetadataService {
ReturnReslult findNodeByDataId(String metadataId, int depth);
ReturnReslult findResultByModelName(String modelName);
ReturnReslult findResultByModelName(String modelName,int count );
ReturnReslult getSystemGraph();
......
......@@ -168,7 +168,7 @@ public class MetadataServiceImpl implements IMetadataService {
}
@Override
public ReturnReslult findResultByModelName(String modelName) {
public ReturnReslult findResultByModelName(String modelName,int size) {
ReturnReslult returnReslult = new ReturnReslult();
// 先获取modelname的元数据,按每两个元数据去查找,查看是否有关系,注意关系方向
Neo4jConfig neo4jConfig = new Neo4jConfig();
......@@ -185,7 +185,14 @@ public class MetadataServiceImpl implements IMetadataService {
List<String> metadataIdList = new ArrayList<>();
int count0 = 0;
while (result.hasNext()) {
if(count0>=size){
break;
}
count0++;
Record record = result.next();
List<Value> values = record.values();
for (Value value : values) {
......@@ -222,9 +229,8 @@ public class MetadataServiceImpl implements IMetadataService {
}
int nodeSize = returnReslult.getNodes().size();
logger.info("得到的节点数是:"+nodeSize);
List<String> analysisId = new ArrayList<>();
int count = 0;
// 默认是5个线程
int threadCount = 5;
if(nodeSize<5){
threadCount = nodeSize;
......
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