DigitalMgnt
/
tfse-app-api-v0.2
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update 新流程

This commit is contained in:
P3ngSaM 2022-05-18 19:55:07 +08:00
parent c74f88b67a
commit 4bdf1fb86a
2 changed files with 20 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
Implements/Rating/CreditImpl.py
View File

@ -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():

18
Implements/Rating/EsgImpl.py
View File

@ -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():