新增企业自动化

comData/BaseInfo_qcc/baseinfo1113.py

@@ -430,10 +430,7 @@ def spiderinfo(company_url, securitiesCode, securitiesShortName, listingDate, ca
                         data_businfo[list(data_businfo.keys())[-1]] = value
 
                     else:
-                        data_businfo[list(data_businfo.keys())[-1]] = td.text.replace('复制', '').replace('\n',
-                                                                                                        '').replace(
-                            ' ',
-                            '')
+                        data_businfo[list(data_businfo.keys())[-1]] = td.text.replace('复制', '').replace('\n','').replace(' ','')
 
         result_dict = getinfo(data_businfo, data_baseinfo)
 
@@ -576,26 +573,33 @@ if __name__ == '__main__':
         if company_field == '' or company_field is None:
             # 本轮结束后没有新增的企业要采集
             file.deleteFile(file_name)
-            time.sleep(20)
+            flag = True
+            while flag:
+                time.sleep(5400)
+                company_field = baseCore.redicPullData('BaseInfoEnterprise:gnqy_socialCode')
+                if company_field:
+                    flag = False
+                    baseCore.r.lpush('BaseInfoEnterprise:gnqy_socialCode', company_field)
+                    continue
             continue
 
         social_code = company_field.split('|')[0]
         com_name = company_field.split('|')[2]
 
-        # ynDomestic = company_field.split('|')[15]
-        # countryName = company_field.split('|')[16]
-        # securitiesCode = company_field.split('|')[17]
-        # securitiesShortName = company_field.split('|')[18]
-        # listingDate = company_field.split('|')[21]
-        # category = company_field.split('|')[19]
-        # exchange = company_field.split('|')[20]
-        ynDomestic = ''
-        countryName = ''
-        securitiesCode = ''
-        securitiesShortName = ''
-        listingDate = ''
-        category = ''
-        exchange = ''
+        ynDomestic = company_field.split('|')[15]
+        countryName = company_field.split('|')[16]
+        securitiesCode = company_field.split('|')[17]
+        securitiesShortName = company_field.split('|')[18]
+        listingDate = company_field.split('|')[21]
+        category = company_field.split('|')[19]
+        exchange = company_field.split('|')[20]
+        # ynDomestic = ''
+        # countryName = ''
+        # securitiesCode = ''
+        # securitiesShortName = ''
+        # listingDate = ''
+        # category = ''
+        # exchange = ''
 
 
         count = redaytowork(com_name, social_code, securitiesCode, securitiesShortName, listingDate, category, exchange,ynDomestic, countryName, file_name)