新三板上市信息

comData/dfcfwGpdm/NQenterprise/NQipoInfo.py

@@ -22,7 +22,29 @@ list_all_info = []
 # 需要提供股票代码、企业信用代码
 while True:
     #从表中读取企业
-    # com_code1 = baseCore.redicPullData('EnterpriseIpo:nq_gpdm')
+    flag = 0
+    com_code1 = baseCore.redicPullData('EnterpriseIpo:nq_gpdm')
+    if com_code1 is None:
+        time.sleep(20)
+        if flag==1:
+            continue
+        elif flag==0:
+            # 通过接口将数据保存进数据库
+            for num in range(0, len(list_all_info), 100):
+
+                json_updata = json.dumps(list_all_info[num:num + 100])
+                # print(json_updata)
+                try:
+                    response = requests.post('http://114.115.236.206:8088/sync/enterpriseIpo', data=json_updata,
+                                             timeout=300,
+                                             verify=False)
+                except Exception as e:
+                    print(e)
+                print("{}：到：{}".format(num, num + 100))
+                print(response.text)
+            continue
+        break
+
     com_code = '838616'
     short_name = ''
     social_code = ''
@@ -74,34 +96,11 @@ while True:
         "csrcIndustry": ''
     }
     print(dic_cwsj)
+    list_all_info.append(dic_cwsj)
+    log.info(f'======{com_code}====采集成功=====')
+    flag = 1
+
+
+
     break
 
-#     dic_cwsj = {
-#         "exchange": jys_code,
-#         "category": '1',  # 股票类型(1-A股;2-B股;3-新三板;4-H股)
-#         'listed':'1',
-#         "listingDate": shangshishijian,
-#         "securitiesCode": com_code[2:],
-#         "securitiesShortName": short_name,
-#         "securitiesType": '新三板',
-#         "socialCreditCode": id_code,
-#         "businessScope": zhuyingfanwei,
-#         "eastIndustry": dongcai,
-#         "csrcIndustry": zhengjian
-#     }
-#
-#     list_all_info.append(dic_cwsj)
-#     log.info(f'======{com_code}====采集成功=====')
-#
-# # 通过接口将数据保存进数据库
-# for num in range(0, len(list_all_info),100):
-#
-#     json_updata = json.dumps(list_all_info[num:num+100])
-#     # print(json_updata)
-#     try:
-#         response = requests.post('http://114.115.236.206:8088/sync/enterpriseIpo', data=json_updata, timeout=300,
-#                                  verify=False)
-#     except Exception as e:
-#         print(e)
-#     print("{}：到：{}".format(num, num + 100))
-#     print(response.text)