提交 c62b26ea 作者: 薛凌堃

财务数据调用对比指标接口调整

上级 0d18118d
"""
"""
......@@ -465,8 +465,9 @@ def getReportTime():
def job(taskType):
# 将上市企业库中的全部A股代码存入list
# 需要提供股票代码、企业信用代码
while True:
flag = 0
while True:
# 从redis中获取企业信用代码
social_code = baseCore.redicPullData('FinanceFromEast:finance_socialCode')
# social_code = '91420300178856869P'
......@@ -487,6 +488,7 @@ def job(taskType):
except:
time.sleep(1)
print(res_.text)
flag = 0
continue
log.info(f'==========正在采集{social_code}============')
sql_sel = f'''select securities_code,exchange from sys_base_enterprise_ipo where category = '1' and social_credit_code='{social_code}' '''
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论