更新企业基本信息采集

comData/BaseInfo_qcc/base_info.py

@@ -9,7 +9,8 @@ import json
 from kafka import KafkaProducer
 from base.BaseCore import BaseCore
 from getQccId import find_id_by_name
-
+import urllib3
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 baseCore = BaseCore()
 cnx_ = baseCore.cnx
 cursor_ = baseCore.cursor
@@ -336,8 +337,8 @@ if __name__ == '__main__':
             continue
         start_time = time.time()
         # 获取企业信息
-        social_code = baseCore.redicPullData('BaseInfoEnterprise:gnqy_socialCode')
-        # social_code = '91330000734530895W'
+        # social_code = baseCore.redicPullData('BaseInfoEnterprise:gnqy_socialCode')
+        social_code = '91130800757548430L'
         if social_code == '' or social_code is None:
             time.sleep(20)
             continue
@@ -361,7 +362,7 @@ if __name__ == '__main__':
             if company_id == 'null':
                 log.info('=====搜索不到该企业====')
                 #todo:搜不到的企业没有信用代码 传输不过去 生成一个信用代码
-                baseCore.rePutIntoR('global100:baseinfo', social_code + '：搜索不到')
+                baseCore.rePutIntoR('BaseInfoEnterprise:gnqy_socialCode', social_code + '：搜索不到')
                 continue
             if not company_id:
                 log.info(com_name + "：企业ID获取失败===重新放入redis")
@@ -406,7 +407,7 @@ if __name__ == '__main__':
             }
             name_list.append(name_compile)
             nowtime = baseCore.getNowTime(1).replace('-', '_')[:10]
-            baseCore.writerToExcel(name_list, f'企业名称对比_{nowtime}.xlsx')
+            baseCore.writerToExcel(name_list, f'企业名称对比.xlsx')
             log.info(f'采集{com_name}成功=======耗时{baseCore.getTimeCost(start_time,time.time())}')
             try:
                 producer = KafkaProducer(bootstrap_servers=['114.115.159.144:9092'], api_version=(2, 0, 2))