update 修改报告bug

This commit is contained in:
彭森 2022-01-07 16:53:51 +08:00
parent ad6691936d
commit 4194993adc
3 changed files with 88 additions and 69 deletions

View File

@ -30,7 +30,7 @@ def risk_data():
@verify_token
def report_data():
"""
保存报告数据
清洗报告数据
Parameters:
rid str 评价ID
cid str 企业ID

View File

@ -5,6 +5,18 @@ from rating.static.province_map import p_map
import pandas as pd
def modify_unit(param):
"""
金额单位从元改为万元
Parameters:
param: 金额数据
Returns:
result: 单位为万元的金额数据
"""
money = round(param/10000, 2)
return str(money)
def judge_list(param):
"""
判断列表中是否有None
@ -16,7 +28,8 @@ def judge_list(param):
"""
df = pd.DataFrame(param)
df = df.fillna('-')
df = df[0].to_list()
df = df[0].apply(lambda x: round(x/10000, 2) if isinstance(x, float) else x)
df = df.to_list()
df = [str(x) for x in df]
return df
@ -126,11 +139,11 @@ def get_tfse_data(param):
# 进出口信用
ip = find_tyc_db(db='经营状况', col='进出口信用', query={'企业名称': company})[0]
# 专利
ip_02 = find_tyc_db(db='知识产权', col='专利', query={'企业名称': '紫金诚征信有限公司'})[0]
ip_02 = find_tyc_db(db='知识产权', col='专利', query={'企业名称': company})[0]
# 软件著作权
sc = find_tyc_db(db='知识产权', col='软件著作权', query={'企业名称': '紫金诚征信有限公司'})[0]
sc = find_tyc_db(db='知识产权', col='软件著作权', query={'企业名称': company})[0]
# 资质证书
qh = find_tyc_db(db='经营状况', col='资质证书', query={'企业名称': '四川麦克福瑞制药有限公司'})[0]
qh = find_tyc_db(db='经营状况', col='资质证书', query={'企业名称': company})[0]
# 融资历史
fh = find_tyc_db(db='公司发展', col='融资历史', query={'企业名称': company})[0]
# 风险数据

View File

@ -48,28 +48,28 @@ def company_background(param1, param2):
total_assets_01 = data_03['资产负债表'][0]['资产总计']
total_assets_02 = data_03['资产负债表'][1]['资产总计']
# 公司总资产
part_02['total_assets'] = str(total_assets_01)
part_02['total_assets'] = modify_unit(total_assets_01)
# 总资产同比增长
part_02['year_03_total_assets_variety'] = str(calculate_growth_rate(total_assets_01, total_assets_02))
net_assets_01 = data_03['资产负债表'][0]['所有者权益合计']
net_assets_02 = data_03['资产负债表'][1]['所有者权益合计']
# 净资产(所有者权益)
part_02['net_assets'] = str(net_assets_01)
part_02['net_assets'] = modify_unit(net_assets_01)
# 净资产同比增长
part_02['year_03_net_assets_variety'] = str(calculate_growth_rate(net_assets_01, net_assets_02))
income_01 = data_03['利润表'][0]['营业收入']
income_02 = data_03['利润表'][1]['营业收入']
# 营业收入
part_02['income'] = str(income_01)
part_02['income'] = modify_unit(income_01)
# 营业收入同比增长
part_02['year_03_income_variety'] = str(calculate_growth_rate(income_01, income_02))
profit_01 = data_03['利润表'][0]['净利润']
profit_02 = data_03['利润表'][1]['净利润']
# 净利润
part_02['profit'] = str(profit_01)
part_02['profit'] = modify_unit(profit_01)
# 净利润同比增长
part_02['year_03_profit_variety'] = str(calculate_growth_rate(profit_01, profit_02))
return part_02
@ -204,6 +204,11 @@ def outbound_investment(param):
# Returns
result = list()
if data_01 is None:
part_01 = dict()
part_01['desribe'] = '截至{}年,未查询到该公司对外投资相关信息。'.format(data_02['资产负债表'][0]['报告期'][:4])
result.append(part_01)
else:
def para_01():
part_01 = dict()
# 年限
@ -248,6 +253,7 @@ def outbound_investment(param):
'region')
part_01['top_3_region'] = region_result['industry']
part_01['Regional_concentration'] = region_result['concentration']
# 执行子方法
subsidiary_number()
return part_01