93 lines
2.3 KiB
Python
93 lines
2.3 KiB
Python
from flask import Blueprint, request
|
|
from Utils.CommonUtil import verify_token
|
|
from RatingData.EsgReportEtl import EsgCleanModel
|
|
from RatingData.ReportEtl import CleanModel
|
|
from RatingData.scripts.common import get_tfse_data, get_esg_data
|
|
from RatingData.scripts.risk_count import *
|
|
|
|
rating_route = Blueprint('rating', __name__)
|
|
|
|
|
|
@rating_route.route('/risk_data', methods=['POST'])
|
|
@verify_token
|
|
def risk_data():
|
|
"""
|
|
风险数据清洗
|
|
Parameters:
|
|
company_name 企业名称
|
|
company_id 企业ID
|
|
evaluation_id 评价ID
|
|
Returns:
|
|
res: desc
|
|
"""
|
|
company_name = request.json['company_name']
|
|
company_id = request.json['company_id']
|
|
evaluation_id = request.json['evaluation_id']
|
|
risk_data_etl(company_name, company_id, evaluation_id)
|
|
return {"info": "执行成功"}, 200
|
|
|
|
|
|
@rating_route.route('/esg_risk_data', methods=['POST'])
|
|
@verify_token
|
|
def esg_risk_data():
|
|
"""
|
|
风险数据清洗
|
|
Parameters:
|
|
company_name 企业名称
|
|
company_id 企业ID
|
|
evaluation_id 评价ID
|
|
Returns:
|
|
res: 清洗后的满足要求的风险数据
|
|
"""
|
|
company_name = request.json['company_name']
|
|
company_id = request.json['company_id']
|
|
evaluation_id = request.json['evaluation_id']
|
|
esg_risk_data_etl(company_name, company_id, evaluation_id)
|
|
return {"info": "执行完成"}, 200
|
|
|
|
|
|
@rating_route.route('/report_data', methods=['POST'])
|
|
@verify_token
|
|
def report_data():
|
|
"""
|
|
清洗报告数据
|
|
Parameters:
|
|
rid str 评价ID
|
|
cid str 企业ID
|
|
company str 企业名称
|
|
Returns:
|
|
-
|
|
"""
|
|
info = request.json
|
|
|
|
# 准备需要清洗的数据
|
|
db_data = get_tfse_data(info)
|
|
|
|
# 调用清洗数据模型
|
|
data = CleanModel(info, db_data).storage_data()
|
|
|
|
return {"data": data}, 200
|
|
|
|
|
|
@rating_route.route('/esg_report_data', methods=['POST'])
|
|
@verify_token
|
|
def esg_report_data():
|
|
"""
|
|
清洗ESG报告数据
|
|
Parameters:
|
|
rid str 评价ID
|
|
cid str 企业ID
|
|
company str 企业名称
|
|
Returns:
|
|
-
|
|
"""
|
|
info = request.json
|
|
|
|
# 准备需要清洗的数据
|
|
db_data = get_esg_data(info)
|
|
|
|
# 调用清洗数据模型
|
|
data = EsgCleanModel(db_data).storage_data()
|
|
|
|
return {"data": data}, 200
|