From 4bdf1fb86a1c71c1f7c07377374b99d3e8ab4998 Mon Sep 17 00:00:00 2001 From: P3ngSaM <61768364+P3ngSaM@users.noreply.github.com> Date: Wed, 18 May 2022 19:55:07 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=96=B0=E6=B5=81=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Implements/Rating/CreditImpl.py | 24 ++++++++++++------------ Implements/Rating/EsgImpl.py | 18 ++++++++---------- 2 files changed, 20 insertions(+), 22 deletions(-) diff --git a/Implements/Rating/CreditImpl.py b/Implements/Rating/CreditImpl.py index acb7530..cadb0a2 100644 --- a/Implements/Rating/CreditImpl.py +++ b/Implements/Rating/CreditImpl.py @@ -295,7 +295,7 @@ class CreditRating(CreditInputData, CreditUtils): data = json.dumps({"company_id": self.cid, "company_name": company_name, "evaluation_id": new_rid}) requests.post(url, headers=headers, data=data) # 风险数据清洗完成后更新流程状态 - self.update_process_status(new_rid, {"评价流程.风险数据": 1}) + self.update_process_status(new_rid, {"评价流程.数据准备.风险数据": 1}) def __main__(): prepare_input_template() @@ -471,7 +471,7 @@ class CreditRating(CreditInputData, CreditUtils): ['评价流程'] ) if process: - self.update_process_status(rid['评价ID'], {"评价流程.填报数据": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据准备.填报数据": 1}) handle_input_form() rating_input() @@ -543,9 +543,9 @@ class CreditRating(CreditInputData, CreditUtils): "报告fid": json.loads(res.text)['result']['FileID'] } self.db.update_single_data("企业数据", "评价记录", rid, update_data) - self.update_process_status(rid['评价ID'], {"评价流程.报告生成": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.综信报告": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.报告生成": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.综信报告": -1}) raise ReturnConditionCheckFailed("生成报告失败", 200) def gen_certified(): @@ -565,9 +565,9 @@ class CreditRating(CreditInputData, CreditUtils): "证书fid": json.loads(res.text)['result']['FileID'] } self.db.update_single_data("企业数据", "评价记录", rid, update_data) - self.update_process_status(rid['评价ID'], {"评价流程.证书生成": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.综信证书": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.证书生成": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.综信证书": -1}) raise ReturnConditionCheckFailed("生成证书失败", 200) def company_index(): @@ -580,13 +580,13 @@ class CreditRating(CreditInputData, CreditUtils): } res = requests.post(url, headers=headers, data=json.dumps(data)) if res.status_code == 200: - self.update_process_status(rid['评价ID'], {"评价流程.综合信用分析": 1}) - self.update_process_status(rid['评价ID'], {"评价流程.经营风险分析": 1}) - self.update_process_status(rid['评价ID'], {"评价流程.财务要素分析": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.综合信用分析": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.经营风险分析": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.财务要素分析": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.综合信用分析": -1}) - self.update_process_status(rid['评价ID'], {"评价流程.经营风险分析": -1}) - self.update_process_status(rid['评价ID'], {"评价流程.财务要素分析": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.综合信用分析": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.经营风险分析": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.财务要素分析": -1}) raise ReturnConditionCheckFailed("生成主页数据失败", 200) def update_rating_records(): diff --git a/Implements/Rating/EsgImpl.py b/Implements/Rating/EsgImpl.py index c703f53..b145845 100644 --- a/Implements/Rating/EsgImpl.py +++ b/Implements/Rating/EsgImpl.py @@ -302,7 +302,7 @@ class EsgRating(EsgInputData, CreditUtils): data = json.dumps({"company_id": self.cid, "company_name": company_name, "evaluation_id": new_rid}) requests.post(url, headers=headers, data=data) # 风险数据清洗完成后更新流程状态 - self.update_process_status(new_rid, {"评价流程.风险数据": 1}) + self.update_process_status(new_rid, {"评价流程.数据准备.风险数据": 1}) def __main__(): prepare_input_template() @@ -501,7 +501,7 @@ class EsgRating(EsgInputData, CreditUtils): rid, input_data ) - self.update_process_status(rid['评价ID'], {"评价流程.填报数据": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据准备.填报数据": 1}) def __main__(): handle_input_form() @@ -552,9 +552,7 @@ class EsgRating(EsgInputData, CreditUtils): "评价结果": json.loads(res.text)['result'], } self.db.update_single_data("企业数据", "评价记录", rid, update_data) - self.update_process_status(rid['评价ID'], {"评价流程.模型打分": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.模型打分": -1}) raise ReturnConditionCheckFailed("模型打分失败", 200) def gen_report(): @@ -573,9 +571,9 @@ class EsgRating(EsgInputData, CreditUtils): "报告fid": json.loads(res.text)['result']['FileID'] } self.db.update_single_data("企业数据", "评价记录", rid, update_data) - self.update_process_status(rid['评价ID'], {"评价流程.报告生成": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.ESG报告": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.报告生成": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.ESG报告": -1}) raise ReturnConditionCheckFailed("报告生成失败", 200) def gen_certified(): @@ -595,9 +593,9 @@ class EsgRating(EsgInputData, CreditUtils): "证书fid": json.loads(res.text)['result']['FileID'] } self.db.update_single_data("企业数据", "评价记录", rid, update_data) - self.update_process_status(rid['评价ID'], {"评价流程.证书生成": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.ESG证书": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.证书生成": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.文档生成.ESG证书": -1}) raise ReturnConditionCheckFailed("证书生成失败", 200) def esg_index(): @@ -609,9 +607,9 @@ class EsgRating(EsgInputData, CreditUtils): } res = requests.post(url, headers=headers, data=json.dumps(data)) if res.status_code == 200: - self.update_process_status(rid['评价ID'], {"评价流程.ESG评价分析": 1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.ESG评价分析": 1}) else: - self.update_process_status(rid['评价ID'], {"评价流程.ESG评价分析": -1}) + self.update_process_status(rid['评价ID'], {"评价流程.数据清洗.ESG评价分析": -1}) raise ReturnConditionCheckFailed("主页ESG数据生成失败", 200) def update_rating_records():