update 报告生成逻辑修改
This commit is contained in:
parent
ce952ab6a6
commit
16dc26f619
|
@ -124,7 +124,3 @@ if __name__ == '__main__':
|
||||||
db_data = get_tfse_data(info)
|
db_data = get_tfse_data(info)
|
||||||
r = CleanModel(info, db_data).storage_data()
|
r = CleanModel(info, db_data).storage_data()
|
||||||
print(r)
|
print(r)
|
||||||
|
|
||||||
"""
|
|
||||||
1.公司背景中的year_03,share_holders
|
|
||||||
"""
|
|
|
@ -9,7 +9,7 @@ client_tyc = pymongo.MongoClient('mongodb://{}:{}@{}:{}'.format(USER, PASSWORD_T
|
||||||
|
|
||||||
def find_tyc_db(**kwargs):
|
def find_tyc_db(**kwargs):
|
||||||
"""
|
"""
|
||||||
查询数据库记录
|
查询天眼查数据库记录
|
||||||
Parameters:
|
Parameters:
|
||||||
kwargs: 查询条件
|
kwargs: 查询条件
|
||||||
Returns:
|
Returns:
|
||||||
|
@ -23,7 +23,7 @@ def find_tyc_db(**kwargs):
|
||||||
|
|
||||||
def find_tfse_db(**kwargs):
|
def find_tfse_db(**kwargs):
|
||||||
"""
|
"""
|
||||||
查询数据库记录
|
查询天府股交数据库记录
|
||||||
Parameters:
|
Parameters:
|
||||||
kwargs: 查询条件
|
kwargs: 查询条件
|
||||||
Returns:
|
Returns:
|
||||||
|
@ -37,12 +37,12 @@ def find_tfse_db(**kwargs):
|
||||||
|
|
||||||
def conserve_data(**kwargs):
|
def conserve_data(**kwargs):
|
||||||
"""
|
"""
|
||||||
保存数据
|
根据评价ID保存数据
|
||||||
Parameters:
|
Parameters:
|
||||||
kwargs: 查询条件
|
kwargs: 查询条件
|
||||||
Returns:
|
Returns:
|
||||||
保存结果
|
保存结果
|
||||||
"""
|
"""
|
||||||
collection = client_tfse[kwargs['db']][kwargs['col']]
|
collection = client_tfse[kwargs['db']][kwargs['col']]
|
||||||
collection.update_one({"企业ID": kwargs['cid']}, {"$set": kwargs['insert_data']}, upsert=True)
|
collection.update_one({"评价ID": kwargs['rid']}, {"$set": kwargs['insert_data']}, upsert=True)
|
||||||
return '保存成功'
|
return '保存成功'
|
||||||
|
|
File diff suppressed because it is too large
Load Diff
Loading…
Reference in New Issue