From c16925cb678c86ea2530879ac43a1f3841a47777 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E6=80=9D=E5=B7=9D?= Date: Tue, 29 Mar 2022 05:35:40 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E6=96=87=E4=BB=B6=E8=B7=AF=E5=BE=84?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CompanyData/job_scripts.py | 4 ++-- DBInitial/demo.py | 22 ++++++++++++++-------- RatingData/scripts/report/abstract.py | 4 ++-- 3 files changed, 18 insertions(+), 12 deletions(-) diff --git a/CompanyData/job_scripts.py b/CompanyData/job_scripts.py index 10d3471..3afade5 100644 --- a/CompanyData/job_scripts.py +++ b/CompanyData/job_scripts.py @@ -44,7 +44,7 @@ def basic_info_etl(cid, company_name): member_info = FIND_DATA_IN_TYC('公司背景', '主要人员', {"企业名称": company_name}) # Returns - data = read_json_file('/company/static/template/基本信息.json') + data = read_json_file('/CompanyData/static/template/基本信息.json') # 处理工商信息 def business_data(): @@ -165,7 +165,7 @@ def cc_rating_etl(rid): result['综合信用表现'] = dict() result['综合信用表现']['指标雷达'] = dict() result['综合信用表现']['指标雷达']['指标得分'] = rating_score - result['综合信用表现']['指标雷达']['最大分数'] = read_json_file('/company/static/refers/general.json')['radar'] + result['综合信用表现']['指标雷达']['最大分数'] = read_json_file('/CompanyData/static/refers/general.json')['radar'] def credit_analysis_content(): """ diff --git a/DBInitial/demo.py b/DBInitial/demo.py index 06e4b3a..8c2bf88 100644 --- a/DBInitial/demo.py +++ b/DBInitial/demo.py @@ -9,19 +9,25 @@ mongo_client = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format(USER, PASS, HO def all_data(): - collection = mongo_client['模型端']['天眼查公司行业分类'] + collection = mongo_client['应用端']['企业用户'] + col_basic_info = mongo_client['企业数据']['基本工商信息'] + col_tyc_industry = mongo_client['模型端']['天眼查公司行业分类'] data = list(collection.find({}, {'_id': False})) ### - pass for d in data: - if d['一级行业'] == '制造业': - d['远东_一级行业'] = '制造业' - if d['一级行业'] == '信息传输、软件和信息技术服务业': - d['远东_一级行业'] = '信息技术业' - collection.update_one({"三级行业": d['三级行业']}, {"$set": d}) + cid = d['企业ID'] + try: + tyc_industry_l2 = list(col_basic_info.find({"企业ID": cid}, {'_id': False, "工商信息.行业": 1}))[0]["工商信息"]['行业'] + yd_industry_l1 = list(col_tyc_industry.find({"二级行业": tyc_industry_l2}, {'_id': False, "远东_一级行业": 1}))[0][ + "远东_一级行业"] + + collection.update_one({"企业ID": cid}, {"$set": {"一级行业": yd_industry_l1}}, upsert=True) + except Exception: + pass + ### if __name__ == '__main__': - all_data() \ No newline at end of file + all_data() diff --git a/RatingData/scripts/report/abstract.py b/RatingData/scripts/report/abstract.py index 8773a7f..4558f75 100644 --- a/RatingData/scripts/report/abstract.py +++ b/RatingData/scripts/report/abstract.py @@ -459,8 +459,8 @@ def attention(param): Returns: result: 关注结果 """ - weight = read_json_file('/rating/static/attention/weights.json') - describe = read_json_file('/rating/static/attention/describe.json') + weight = read_json_file('/RatingData/static/attention/weights.json') + describe = read_json_file('/RatingData/static/attention/describe.json') data = param['评价结果']['财务评分'] del param['评价结果']['财务评分']['合计'] for k, v in data.items(): From 4773fbd9ce5b63bccc984cd6026bacd35a6b9485 Mon Sep 17 00:00:00 2001 From: P3ngSaM <61768364+P3ngSaM@users.noreply.github.com> Date: Tue, 29 Mar 2022 14:20:39 +0800 Subject: [PATCH 2/4] =?UTF-8?q?update=20=E6=96=B0=E5=A2=9E=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E6=95=B0=E6=8D=AE=E5=BA=93=E8=BF=94=E5=9B=9E=E5=AD=97?= =?UTF-8?q?=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- RatingData/scripts/common.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/RatingData/scripts/common.py b/RatingData/scripts/common.py index bf980cc..9d1ab6f 100644 --- a/RatingData/scripts/common.py +++ b/RatingData/scripts/common.py @@ -151,11 +151,11 @@ def get_tfse_data(param): report_data = dict() # 评价结果 - es = FIND_SINGLE_DATA_BY_REQ('综信评价数据', '评价结果', {'评价ID': rid}, ["评价年度", "财务评分"]) + es = FIND_SINGLE_DATA_BY_REQ('综信评价数据', '评价结果', {'评价ID': rid}, ["企业名称", "评价年度", "财务评分", "经营评分", "信用等级", "评价时间"]) # 综合评价填报 cef = FIND_SINGLE_DATA_BY_REQ('综信评价数据', '填报数据', {'评价ID': rid}, ["财务填报", "行业选择"]) # 指标明细 - fid = FIND_ALL_DATA_BY_REQ('综信评价数据', '财指结果', {'企业ID': rid}, + fid = FIND_ALL_DATA_BY_REQ('综信评价数据', '财指结果', {'企业ID': cid}, ['报告期', '净资产收益率', '存货周转率', '已获利息倍数', '应收账款周转率', '总资产周转率', '总资产增长率', '总资产报酬率', '技术投入比率', '营业增长率', '资产负债率', '速动比率']) # 基本信息 cbd = FIND_DATA_N_TYC(db='公司背景', col='基本信息', query={'企业名称': company})[0] @@ -177,7 +177,7 @@ def get_tfse_data(param): # 融资历史 fh = FIND_DATA_N_TYC(db='公司发展', col='融资历史', query={'企业名称': company})[0] # 风险数据 - rd = FIND_SINGLE_DATA_BY_REQ('综信评价数据', '风险数据', {'评价ID': rid}, ["合规风险", "经营风险"]) + rd = FIND_SINGLE_DATA_BY_REQ('综信评价数据', '风险数据', {'评价ID': rid}, ["合规风险", "经营风险", "关联风险"]) # 周边风险 pr = FIND_DATA_N_TYC(db='天眼风险', col='周边风险', query={'企业名称': company})[0] report_data['评价结果'] = es From a43397b54126c4870151cf94d0452f53939bbd76 Mon Sep 17 00:00:00 2001 From: P3ngSaM <61768364+P3ngSaM@users.noreply.github.com> Date: Fri, 1 Apr 2022 14:58:29 +0800 Subject: [PATCH 3/4] =?UTF-8?q?update=20=E6=96=B0=E5=A2=9E=E6=8A=A5?= =?UTF-8?q?=E5=91=8A=E5=AD=97=E6=AE=B5=EF=BC=88=E4=BF=AE=E6=94=B9=E5=90=8E?= =?UTF-8?q?=E6=8A=A5=E5=91=8A=E7=89=88=E6=9C=AC=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- RatingData/scripts/report/abstract.py | 2 ++ RatingData/scripts/report/company_profile.py | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/RatingData/scripts/report/abstract.py b/RatingData/scripts/report/abstract.py index 4558f75..f2eded6 100644 --- a/RatingData/scripts/report/abstract.py +++ b/RatingData/scripts/report/abstract.py @@ -139,6 +139,8 @@ def evaluation_view_manufacturing(param1, param2): # 执行子方法 scale() advantage_area() + part_01['year'] = None + part_01['place'] = None return part_01 def para_02(): diff --git a/RatingData/scripts/report/company_profile.py b/RatingData/scripts/report/company_profile.py index e0406d0..a2c4dae 100644 --- a/RatingData/scripts/report/company_profile.py +++ b/RatingData/scripts/report/company_profile.py @@ -449,10 +449,15 @@ def import_export(param): part_01 = dict() if data_01: part_01['import_export_power'] = '拥有' + data_01['baseInfo']['creditRating'] + part_01['influence'] = '大' else: part_01['import_export_power'] = '无' + part_01['year_03'] = None + part_01['amount'] = None + part_01['proportion'] = None part_01['influence'] = '小' + result.append(part_01) return result From 72fc6dd6649131a44c78c0a1baa3a9456aa61169 Mon Sep 17 00:00:00 2001 From: P3ngSaM <61768364+P3ngSaM@users.noreply.github.com> Date: Fri, 1 Apr 2022 15:02:08 +0800 Subject: [PATCH 4/4] =?UTF-8?q?update=20=E6=96=B0=E5=A2=9E=E6=8A=A5?= =?UTF-8?q?=E5=91=8A=E5=AD=97=E6=AE=B5=EF=BC=88=E4=BF=AE=E6=94=B9=E5=90=8E?= =?UTF-8?q?=E6=8A=A5=E5=91=8A=E7=89=88=E6=9C=AC=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- RatingData/scripts/report/company_profile.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/RatingData/scripts/report/company_profile.py b/RatingData/scripts/report/company_profile.py index a2c4dae..02059ef 100644 --- a/RatingData/scripts/report/company_profile.py +++ b/RatingData/scripts/report/company_profile.py @@ -449,7 +449,9 @@ def import_export(param): part_01 = dict() if data_01: part_01['import_export_power'] = '拥有' + data_01['baseInfo']['creditRating'] - + part_01['year_03'] = None + part_01['amount'] = None + part_01['proportion'] = None part_01['influence'] = '大' else: part_01['import_export_power'] = '无'