获取天眼查id脚本维护

comData/tcyQydt/getTycId.py

@@ -7,6 +7,8 @@ import pymysql
 import requests
 
 from base.BaseCore import BaseCore
+import urllib3
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 requests.adapters.DEFAULT_RETRIES = 5
 baseCore = BaseCore()
 log = baseCore.getLogger()
@@ -64,8 +66,8 @@ def getTycIdByXYDM(xydm):
 def updateTycInfo():
     while True:
         # 根据从Redis中拿到的社会信用代码,在数据库中获取对应基本信息
-        social_code = baseCore.redicPullData('NewsEnterprise:gnqy_socialCode')
-        # social_code = '912301001275921118'
+        # social_code = baseCore.redicPullData('NewsEnterprise:gnqy_socialCode')
+        social_code = '9111000066990444XF'
         # 判断 如果Redis中已经没有数据，则等待
         if social_code == None:
             time.sleep(20)
@@ -86,7 +88,7 @@ def updateTycInfo():
             try:
                 retData = getTycIdByXYDM(xydm)
                 if retData['tycData'] and retData['reput']:
-                    tycid = retData['id']
+                    tycid = retData['tycData']['id']
                     # todo:写入数据库
                     updateSql = f"update EnterpriseInfo set TYCID = '{tycid}' where SocialCode = '{xydm}'"
                     cursor_.execute(updateSql)
@@ -100,7 +102,8 @@ def updateTycInfo():
                     continue
                 elif not retData['reput'] and not retData['tycData']:
                     continue
-            except:
+            except Exception as e:
+                log.error(e)
                 state = 0
                 takeTime = baseCore.getTimeCost(start, time.time())
                 baseCore.recordLog(social_code, taskType, state, takeTime, '', '获取天眼查id失败')

comData/tcyQydt/tyc_qydt_add.py

@@ -283,7 +283,7 @@ def doJob():
                 try:
                     retData = getTycIdByXYDM(xydm)
                     if retData['tycData'] and retData['reput']:
-                        tycid = retData['id']
+                        tycid = retData['tycData']['id']
                         # todo:写入数据库
                         updateSql = f"update EnterpriseInfo set TYCID = '{tycid}' where SocialCode = '{xydm}'"
                         cursor_.execute(updateSql)