企业基本信息

comData/BaseInfo_qcc/base_info.py

@@ -16,7 +16,7 @@ cursor_ = baseCore.cursor
 log = baseCore.getLogger()
 
 # 通过企查查id获取企业基本信息
-def info_by_id(com_id,com_name):
+def info_by_id(com_id,com_name,social_code):
     aa_dict_list = []
 
     t = str(int(time.time()) * 1000)
@@ -30,8 +30,10 @@ def info_by_id(com_id,com_name):
     try:
         result_dict = resp_dict['result']['Company']
     except:
-        print(com_name + ":获取失败")
-    #
+        log.info(com_name + ":获取失败===========重新放入redis")
+        baseCore.rePutIntoR('BaseInfoEnterpriseFbs:gnqy_social_code',social_code)
+        return aa_dict_list
+
     company_name = result_dict['Name']
     CreditCode = result_dict['CreditCode']
     if CreditCode is None:
@@ -330,7 +332,8 @@ if __name__ == '__main__':
         name_list = []
         start_time = time.time()
         # 获取企业信息
-        social_code = baseCore.redicPullData('BaseInfoEnterprise:gnqy_socialCode')
+        # social_code = baseCore.redicPullData('BaseInfoEnterprise:gnqy_socialCode')
+        social_code = '91110000802100433B'
         if social_code == '':
             time.sleep(20)
             continue
@@ -347,24 +350,30 @@ if __name__ == '__main__':
                 company_id = find_id_by_name(start_time,token,social_code)
             else:
                 company_id = find_id_by_name(start_time,token,com_name)
-            # todo:写入数据库
-            updateSql = f"update EnterpriseInfo set QCCID = '{company_id}' where SocialCode = '{social_code}'"
-            cursor_.execute(updateSql)
-            cnx_.commit()
-            post_data_list = info_by_id(company_id, com_name)
-            if company_id == "":
-                print(com_name + "：企业ID获取失败")
+            if not company_id:
+                log.info(com_name + "：企业ID获取失败===重新放入redis")
                 list_weicha.append(com_name + "：企业ID获取失败")
+                baseCore.rePutIntoR('BaseInfoEnterprise:gnqy_socialCode',social_code)
+                time.sleep(20)
                 continue
+            else:
+                log.info(f'====={social_code}===={company_id}=====获取企业id成功=====')
+                # todo:写入数据库
+                updateSql = f"update EnterpriseInfo set QCCID = '{company_id}' where SocialCode = '{social_code}'"
+                cursor_.execute(updateSql)
+                cnx_.commit()
+        try:
+            post_data_list = info_by_id(company_id, com_name,social_code)
+        except:
+            log.info(f'====={social_code}=====获取基本信息失败，重新放入redis=====')
+            baseCore.rePutIntoR('BaseInfoEnterprise:gnqy_social_code', social_code)
+            continue
+        if post_data_list:
+            pass
         else:
-            log.info(f'====={social_code}===={company_id}=====获取企业id成功=====')
-            try:
-                post_data_list = info_by_id(company_id, com_name)
-            except:
-                log.info(f'====={social_code}=====获取基本信息失败，重新放入redis=====')
-                baseCore.rePutIntoR('BaseInfoEnterprise:gnqy_social_code', social_code)
-                continue
-
+            log.info(f'======{social_code}====企查查token失效====')
+            time.sleep(20)
+            continue
         for post_data in post_data_list:
             list_all_info.append(post_data)
             if post_data is None: