Commit b9028b0b by qiuchaofei

同步schema的标签时添加日志。

parent 744d3d59
...@@ -145,6 +145,7 @@ public class SchemaServiceImpl implements ISchemaService { ...@@ -145,6 +145,7 @@ public class SchemaServiceImpl implements ISchemaService {
* 2.获取schema的tag, * 2.获取schema的tag,
* 3.更新schema * 3.更新schema
*/ */
long time1 = System.currentTimeMillis();
List<String> layer = new ArrayList<>(); List<String> layer = new ArrayList<>();
layer.add(SchemaLayerObject.tieyuanceng); layer.add(SchemaLayerObject.tieyuanceng);
layer.add(SchemaLayerObject.jichuceng); layer.add(SchemaLayerObject.jichuceng);
...@@ -163,22 +164,29 @@ public class SchemaServiceImpl implements ISchemaService { ...@@ -163,22 +164,29 @@ public class SchemaServiceImpl implements ISchemaService {
} }
logger.info("开始调用标签接口..."); logger.info("开始调用标签接口...");
Map<String,List<Map<String,Object>>> returnResults = tagRemoteService.getTagByMetadataId(schemaIdList, "metadata", "", true); Map<String,List<Map<String,Object>>> returnResults = tagRemoteService.getTagByMetadataId(schemaIdList, "metadata", "", true);
logger.info("调用标签接口完成。。。。"); logger.info("调用标签接口完成。。。schema数量:"+schemaIdList.size());
int count =0;
for(Object obj : returnResults.keySet()){ for(Object obj : returnResults.keySet()){
String schemaId = (String)obj; String schemaId = (String)obj;
List<Map<String,Object>> mapList = returnResults.get(obj); List<Map<String,Object>> mapList = returnResults.get(obj);
for(Map<String,Object> map : mapList){ for(Map<String,Object> map : mapList){
String label =(String) map.get("name"); String label =(String) map.get("name");
if(layer.contains(label)){ if(layer.contains(label)){
count++;
Neo4jSchema neo4jSchema = neo4jSchemaMap.get(schemaId); Neo4jSchema neo4jSchema = neo4jSchemaMap.get(schemaId);
neo4jSchema.setLabel(label); neo4jSchema.setLabel(label);
neo4jSchemaRepository.save(neo4jSchema); neo4jSchemaRepository.save(neo4jSchema);
logger.info("schema:"+neo4jSchema.getName() +" 的标签是:"+label); if(count %50==0){
logger.info(count+" schema:"+neo4jSchema.getName() +" 的标签是:"+label);
}
break; break;
} }
} }
} }
logger.info("同步所有schema的标签完成。。。。");
long time2 = System.currentTimeMillis();
logger.info("同步所有schema的标签完成。。。。用时:"+(time2-time1));
return true; return true;
} }
......
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