财务数据维护

comData/caiwushuju/东方财富网财务数据.py

-"""
+"""
@@ -460,6 +460,7 @@ def job(taskType):
     # 将上市企业库中的全部A股代码存入list
     # 需要提供股票代码、企业信用代码
     while True:
+        flag = 0
         # 从redis中获取企业信用代码
         social_code = baseCore.redicPullData('FinanceFromEast:finance_socialCode')
         # social_code = '91420300178856869P'
@@ -467,7 +468,19 @@ def job(taskType):
         log.info(f'==========正在采集{social_code}============')
         if social_code == None:
             time.sleep(20)
-            continue
+            if flag == 0:
+                pass
+            elif flag == 1:
+                time.sleep(5400)
+                url_ = 'http://114.115.236.206:8088/sync/finance/calculateIndex?type=1'
+                for nnn in range(0, 3):
+                    try:
+                        res_ = requests.get(url_)
+                        break
+                    except:
+                        time.sleep(1)
+                print(res_.text)
+                continue
 
         sql_sel = f'''select securities_code,exchange from sys_base_enterprise_ipo where category = '1' and social_credit_code='{social_code}' '''
         cursor.execute(sql_sel)
@@ -534,6 +547,7 @@ def job(taskType):
         # date_list = str(date_list)
         end_time = time.time()
         log.info(f'===={com_code}====该企业耗时{end_time - start_time}===')
+        flag = 1
     cnx.close()
     cursor.close()
     baseCore.close()