1.修改并整理关系导出文件夹，将公司核心图的连接信息导出；

2.导修改部分文件的函数调用依赖。

Author: S-I-X

Data/Encoding/all_edge.edgelist

@@ -76,7 +76,7 @@ def com_data_pre3():  # 整合并排序多个文件中的公司数据
 
 
 def node_encoding():  # 编码所有节点
-    with open('../Data/Encoding/com_node.csv', 'w', encoding='utf-8', newline='') as csvfile:
+    with open('../Data/Export/com_node.csv', 'w', encoding='utf-8', newline='') as csvfile:
         writer = csv.writer(csvfile, delimiter='\t')
         writer.writerow(['节点类型', '原标识', '编码'])
         # nodes = graph.find(label='USER')
@@ -126,14 +126,14 @@ def node_encoding():  # 编码所有节点
 def edge_formatting():  # 抽取所有边，并依照节点编码格式化
     d = dict()
     k = 0
-    with open('../Data/Encoding/com_node.csv', 'r', encoding='utf-8', newline='') as csvfile:
+    with open('../Data/Export/com_node.csv', 'r', encoding='utf-8', newline='') as csvfile:
         rows = csv.reader(csvfile, delimiter='\t')
         for index, row in enumerate(rows):
             if index == 0:
                 continue
             d[row[1]] = row[2]
 
-    with open('../Data/Encoding/com_edge_with_edgetype.edgelist', 'w', encoding='utf-8', newline='') as edgelist:
+    with open('../Data/Export/com_edge_with_edgetype.edgelist', 'w', encoding='utf-8', newline='') as edgelist:
         edgewriter = csv.writer(edgelist, delimiter='\t')
         with open('../Data/com_industry_tags.csv', 'r', encoding='utf-8', newline='') as csvfile:
             rows = csv.reader(csvfile)
@@ -284,8 +284,8 @@ def edge_formatting():  # 抽取所有边，并依照节点编码格式化
 
 
 def edgelist_process():  # 边列表处理
-    with open('../Data/Encoding/com_edge_with_edgetype.edgelist', 'r', encoding='utf-8', newline='') as edgelist1, \
-            open('../Data/Encoding/com_edge.edgelist', 'w', encoding='utf-8', newline='') as edgelist2:
+    with open('../Data/Export/com_edge_with_edgetype.edgelist', 'r', encoding='utf-8', newline='') as edgelist1, \
+            open('../Data/Export/com_edge.edgelist', 'w', encoding='utf-8', newline='') as edgelist2:
         edgewreader = csv.reader(edgelist1, delimiter='\t')
         edgewriter = csv.writer(edgelist2, delimiter='\t')
         for row in edgewreader:

Data/Encoding/all_edge_with_edgetype.edgelist

@@ -1,12 +1,12 @@
-from Graph.process import Con_Neo4j
-from py2neo import Relationship, Node
+from py2neo import Graph, Node, Relationship
 import csv
 from Data_process.data_extraction import file_name
 import re
 import time
 
 
-graph = Con_Neo4j(http='http://127.0.0.1:7474', username='neo4j', password='123456')
+# 连接图数据库
+graph = Graph('http://127.0.0.1:7474', username='neo4j', password='123456', bolt=True, secure=False)
 
 
 def com_type(code):  # 识别公司代码所属类别，包括：深A、沪A、深B、沪B、三板、其它、非上市