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

tmp

This commit is contained in:
王思川 2022-04-29 17:04:50 +08:00
parent 070bcadce7
commit c4ea3dd389
2 changed files with 33 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
CompanyData/CompanyDataImpl.py
View File

@ -56,12 +56,19 @@ class CompanyDataImpl(CompanyData):
self.basic_info = basic_info
self.db_tfse.upsert_single_data(
"企业数据",
"企业数据_更新汇总",
{"企业ID": self.cid},
self.dict_to_save()
)
# self.db_tfse.upsert_single_data(
# "企业数据",
# "企业数据_更新汇总",
# {"企业ID": self.cid},
# self.dict_to_save()
# )
#
# self.db_tfse.upsert_single_data(
# "企业数据",
# "基本工商信息",
# {"企业ID": self.cid},
# self.dict_to_save()
# )
def prepare_share_holders():
""""""
@ -142,6 +149,13 @@ class CompanyDataImpl(CompanyData):
self.dict_to_save()
)
self.db_tfse.upsert_single_data(
"企业数据",
"企业数据_更新汇总",
{"企业ID": self.cid},
self.dict_to_save()
)
def prepare_main_members():
""""""

33
CompanyData/CompanyDataRoutes.py
View File

@ -15,26 +15,19 @@ def basic_info():
"""
初始化企业数据
"""
req = request.json
company_data = CompanyDataImpl()
company_data.cid = req['cid']
company_data.name = req['company_name']
company_data.drag_data_from_tyc_api()
company_data.prepare_company_init_data()
return {"info": "企业数据初始化成功"}, 200
# try:
# req = request.json
# company_data = CompanyDataImpl()
# company_data.cid = req['cid']
# company_data.name = req['company_name']
# company_data.drag_data_from_tyc_api()
# company_data.prepare_company_init_data()
# return {"info": "企业数据初始化成功"}, 200
# except ReturnConditionCheckFailed as e:
# e.log_error()
# return {"info": e.failed_info}, e.status_code
# except KeyError:
# return {"info": "参数错误"}, 400
try:
req = request.json
company_data = CompanyDataImpl()
company_data.cid = req['cid']
company_data.name = req['company_name']
# company_data.drag_data_from_tyc_api()
company_data.prepare_company_init_data()
return {"info": "企业数据初始化成功"}, 200
except ReturnConditionCheckFailed as e:
e.log_error()
return {"info": e.failed_info}, e.status_code
except KeyError:
return {"info": "参数错误"}, 400
@company_route.route('/company_index_etl', methods=['POST'])