69 lines
2.4 KiB
Python
69 lines
2.4 KiB
Python
import json
|
||
import os
|
||
|
||
import pymysql
|
||
|
||
base_props = {
|
||
'internal_code': '内部编号',
|
||
'page_name': '标题',
|
||
'unit_name': '单位名称',
|
||
'region': '国家/地区',
|
||
'name_abbr': '名称缩写',
|
||
'nickname': '绰号',
|
||
'other_names': '其他名称',
|
||
'status': '状态',
|
||
'uic': '单位识别码（UIC）',
|
||
'base_address': '驻地',
|
||
'type_or_dept': '军种/部门',
|
||
'description': '说明',
|
||
'update_time': '更新日期',
|
||
'address': '地址',
|
||
'phone': '电话',
|
||
'twitter': 'Twitter',
|
||
'facebook': 'Facebook',
|
||
'linkedin': 'LinkedIn',
|
||
'email': '邮箱',
|
||
'website': '网址',
|
||
'other_contact_info': '其他联系方式',
|
||
}
|
||
extended_props = {
|
||
'leader_info': '领导信息',
|
||
'website_info': '网页资料',
|
||
}
|
||
|
||
result_file_path = r"E:\yuxin\nuofang-data\structure\result0512"
|
||
|
||
if __name__ == '__main__':
|
||
db = pymysql.connect(host='39.101.194.63', port=23306,
|
||
user='root', passwd='passok123A', db='nfm', charset='utf8mb4')
|
||
cursor = db.cursor()
|
||
l_item = {}
|
||
for single_json_file in os.listdir(result_file_path):
|
||
result_file = open(result_file_path + "\\" + single_json_file, "r", encoding='utf-8')
|
||
result_json = json.loads(result_file.read())
|
||
result_file.close()
|
||
|
||
t_item_content = {}
|
||
base_info = result_json['base_info']
|
||
if 'contact_info' in result_json:
|
||
for _ in result_json['contact_info']:
|
||
base_info[_] = result_json['contact_info'][_]
|
||
if 'leader_info' in result_json:
|
||
t_item_content['leader_info'] = json.dumps(result_json['leader_info'], ensure_ascii=False)
|
||
if 'website_info' in result_json:
|
||
t_item_content['website_info'] = json.dumps(result_json['website_info'], ensure_ascii=False)
|
||
|
||
for _ in base_props:
|
||
val = base_props[_]
|
||
if val in base_info:
|
||
t_item_content[_] = base_info[val]
|
||
t_item_content['page_name'] = "".join(single_json_file.replace(".json", "").split("-")[1:])
|
||
col_list = [_ for _ in t_item_content]
|
||
val_list = ["'" + t_item_content[_].replace("'", "’") + "'" for _ in t_item_content]
|
||
cols = ", ".join(col_list)
|
||
vals = ", ".join(val_list)
|
||
sql_insert = 'INSERT INTO m_struct_page (%s) VALUES (%s)' % (cols, vals)
|
||
cursor.execute(sql_insert)
|
||
db.commit()
|
||
db.close()
|