东方财富网财务数据维护

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

-"""
+"""
@@ -505,31 +505,31 @@ def job(taskType):
             dic_info = get_info(social_code, com_code, info_date, delist_all, info_date_list, taskType)
             print(dic_info)
             # 将采集后的报告期存入redis
+            if len(info_date_list) != 0:
+                for date in info_date_list:
+                    date_list.append(date)
+            if len(dic_info) != 0:
+                # 调凯歌接口存储数据
+                data = json.dumps(dic_info)
+                # print(data)
+                url_baocun = 'http://114.115.236.206:8088/sync/finance/df'
+                for nnn in range(0, 3):
+                    try:
+                        res_baocun = requests.post(url_baocun, data=data)
+                        break
+                    except:
+                        time.sleep(1)
+                print(res_baocun.text)
+
+                for nnn in range(0, 3):
+                    try:
+                        add_date(com_code, date_list)
+                        break
+                    except:
+                        time.sleep(1)
             # if len(info_date_list) != 0:
             #     for date in info_date_list:
             #         date_list.append(date)
-            # if len(dic_info) != 0:
-            #     # 调凯歌接口存储数据
-            #     data = json.dumps(dic_info)
-            #     # print(data)
-            #     url_baocun = 'http://114.115.236.206:8088/sync/finance/df'
-            #     for nnn in range(0, 3):
-            #         try:
-            #             res_baocun = requests.post(url_baocun, data=data)
-            #             break
-            #         except:
-            #             time.sleep(1)
-            #     print(res_baocun.text)
-            #
-            #     for nnn in range(0, 3):
-            #         try:
-            #             add_date(com_code, date_list)
-            #             break
-            #         except:
-            #             time.sleep(1)
-            # # if len(info_date_list) != 0:
-            # #     for date in info_date_list:
-            # #         date_list.append(date)
         log.info(date_list)
         # date_list = str(date_list)
         end_time = time.time()