天眼查企业动态增量采集维护

comData/tcyQydt/getTycId.py

@@ -27,7 +27,7 @@ cursor= cnx.cursor()
 
 #根据信用代码获取天眼查id 企业名字等信息
 def getTycIdByXYDM(xydm):
-    retData={'state':False,'tycData':None}
+    retData={'state':False,'tycData':None,'reput':True}
     url=f"https://capi.tianyancha.com/cloud-tempest/search/suggest/v3?_={baseCore.getNowTime(3)}"
     ip = baseCore.get_proxy()
     paramJsonData = {'keyword':xydm}
@@ -41,20 +41,21 @@ def getTycIdByXYDM(xydm):
             pass
         else:
             log.error(f"---{xydm}-未查询到该企业---")
-            return retData['tycData']
+            retData['reput'] = False
+            return retData
         matchType=retJsonData['data'][0]['matchType']
         if matchType=='信用代码匹配':
             retData['state'] = True
             retData['tycData'] = retJsonData['data'][0]
             response.close()
-            return retData['tycData']
+            return retData
         else:
             log.error(f"{xydm}------{retJsonData}")
             response.close()
-            return retData['tycData']
+            return retData
     except:
         log.error(f"---{xydm}--天眼查token失效---")
-        return retData['tycData']
+        return retData
 
 
 # 更新天眼查企业基本信息

comData/tcyQydt/tyc_qydt_add.py

@@ -282,19 +282,21 @@ def doJob():
             if tycid == None or tycid == '':
                 try:
                     retData = getTycIdByXYDM(xydm)
-                    if retData:
+                    if retData['tycData'] and retData['reput']:
                         tycid = retData['id']
                         # todo:写入数据库
                         updateSql = f"update EnterpriseInfo set TYCID = '{tycid}' where SocialCode = '{xydm}'"
                         cursor_.execute(updateSql)
                         cnx_.commit()
-                    else:
+                    elif not retData['tycData'] and retData['reput']:
                         state = 0
                         takeTime = baseCore.getTimeCost(start, time.time())
                         baseCore.recordLog(social_code, taskType, state, takeTime, '', '获取天眼查id失败')
                         log.info(f'======={social_code}====重新放入redis====')
                         baseCore.rePutIntoR('NewsEnterprise:gnqy_socialCode', social_code)
                         continue
+                    elif not retData['reput'] and not retData['tycData']:
+                        continue
                 except:
                     state = 0
                     takeTime = baseCore.getTimeCost(start, time.time())