雪球网新三板企业

comData/NQenterprise/finance_xq.py

@@ -90,6 +90,7 @@ def getinfo(info_date,com_code,social_code):
     for nnn in range(0, 3):
         try:
             panduan = check_date(com_code, info_date)
+            break
         except:
             time.sleep(1)
     if panduan:
@@ -183,40 +184,41 @@ def getinfo(info_date,com_code,social_code):
     # #现金流量表
     # reportXjllbdata = c_infoData[k]
     # list_Xjllb = getdetail(reportXjllbdata,xjllb_name_map,listXjllb,xjllb_name)
-
-    dic_info = {
-        "socialCreditCode": social_code,
-        "securitiesCode": com_code[2:],
-        "date": info_date,
-        "debt": listZcfzb,
-        "profit": listLrb,
-        "cash": listXjllb,
-        "ynFirst": ynFirst,
-    }
-    # print(dic_info)
-    #一个报告期结束
-    log.info(f'----{com_code}--{info_date}----结束')
-    if dic_info:
-        # 调凯歌接口存储数据
-        data = json.dumps(dic_info)
-        # print(data)
-        url_baocun = 'http://114.115.236.206:8088/sync/finance/xq'
-        for nnn in range(0, 3):
-            try:
-                res_baocun = requests.post(url_baocun, data=data)
-                break
-            except:
-                time.sleep(1)
-        log.info(f'----{com_code}--{info_date}--------数据发送接口完毕------------')
-        for nnn in range(0, 3):
-            try:
-                add_date(com_code, info_date)
-                break
-            except:
-                time.sleep(1)
+    if listLrb and listZcfzb and listXjllb:
+        dic_info = {
+            "socialCreditCode": social_code,
+            "securitiesCode": com_code[2:],
+            "date": info_date,
+            "debt": listZcfzb,
+            "profit": listLrb,
+            "cash": listXjllb,
+            "ynFirst": ynFirst,
+        }
+        # print(dic_info)
+        #一个报告期结束
+        log.info(f'----{com_code}--{info_date}----结束')
+        if dic_info:
+            # 调凯歌接口存储数据
+            data = json.dumps(dic_info)
+            # print(data)
+            url_baocun = 'http://114.115.236.206:8088/sync/finance/xq'
+            for nnn in range(0, 3):
+                try:
+                    res_baocun = requests.post(url_baocun, data=data)
+                    break
+                except:
+                    time.sleep(1)
+            log.info(f'----{com_code}--{info_date}--------数据发送接口完毕------------')
+            for nnn in range(0, 3):
+                try:
+                    add_date(com_code, info_date)
+                    break
+                except:
+                    time.sleep(1)
+        else:
+            log.error(f'---{com_code}--{info_date}--')
     else:
-        log.error(f'---{com_code}--{info_date}--')
-
+        log.info(f'{com_code}---{info_date}---无数据')
 
 if __name__ == '__main__':
     info_date_list = []