Merge branch 'Ps' into 'master'

update 变更记录放入经营风险

See merge request pengsen/etl_tfse!11
This commit is contained in:
彭森 2022-01-21 08:48:50 +00:00
commit 2c2c67cca4
2 changed files with 7 additions and 3 deletions

View File

@ -41,6 +41,11 @@ def company_background(param1, param2):
part_01['share_holders'] = '-' part_01['share_holders'] = '-'
# 股份 # 股份
part_01['share_rates'] = '-' part_01['share_rates'] = '-'
except IndexError:
# 股份持有人
part_01['share_holders'] = data_02['result'][0]['name']
# 股份
part_01['share_rates'] = '-'
# 实际控制人 # 实际控制人
part_01['real_boss'] = part_01['share_holders'] part_01['real_boss'] = part_01['share_holders']
# 经营范围 # 经营范围

View File

@ -34,15 +34,14 @@ def risk_data_etl(param1, param2, param3):
business_risk['诉讼'] = lawsuit(param1) business_risk['诉讼'] = lawsuit(param1)
business_risk['送达公告'] = service_notice(param1) business_risk['送达公告'] = service_notice(param1)
business_risk['股权出质'] = equity_pledge(param1) business_risk['股权出质'] = equity_pledge(param1)
business_risk['法人变更'] = change_record(param1, '法人变更')
business_risk['主要成员变更'] = change_record(param1, '主要成员变更')
# 关联风险 # 关联风险
relation_risk = dict() relation_risk = dict()
relation_risk['周边风险'] = dict() relation_risk['周边风险'] = dict()
relation_risk['周边风险']['高风险'] = periphery_risk(param1, '高风险') relation_risk['周边风险']['高风险'] = periphery_risk(param1, '高风险')
relation_risk['周边风险']['警示'] = periphery_risk(param1, '警示') relation_risk['周边风险']['警示'] = periphery_risk(param1, '警示')
relation_risk['变更记录'] = dict()
relation_risk['变更记录']['法人变更'] = change_record(param1, '法人变更')
relation_risk['变更记录']['主要成员变更'] = change_record(param1, '主要成员变更')
# 合并数据 # 合并数据
insert_data = dict() insert_data = dict()