外国企业动态自动化

comData/yhcj/雅虎财经_企业动态.py

-# 雅虎财经企业动态获取
+# 雅虎财经企业动态获取
@@ -100,14 +100,17 @@ while True:
     enname = data[5]
     gpdm = data[3]
     xydm = data[2]
-
+    taskType = '企业动态'
     # 获取该企业对应项目的采集次数
     count = data[17]
     start_time = time.time()
     if(gpdm==''):
         log.error(f"{name}--股票代码为空 跳过")
-    if (xydm == ''):
-        log.error(f"{name}--信用代码为空 跳过")
+        e = '.......股票代码为空 跳过'
+        state = 0
+        takeTime = baseCore.getTimeCost(start_time,time.time())
+        baseCore.recordLog(xydm,taskType,state,takeTime,'',e)
+        continue
     url=f"https://finance.yahoo.com/quote/{gpdm}/press-releases?p={gpdm}"
     driver.get(url)
     scroll(driver)
@@ -116,7 +119,6 @@ while True:
     except Exception as e:
         log.error(f"{name}--{gpdm}--没找到新闻元素")
         e = str(e) + '.......没找到新闻元素'
-        taskType = '企业动态'
         state = 0
         takeTime = baseCore.getTimeCost(start_time,time.time())
         baseCore.recordLog(xydm,taskType,state,takeTime,url,e)
@@ -129,7 +131,6 @@ while True:
         except Exception as e:
             log.error(f"{name}--{gpdm}--{i}----a标签没找到")
             e = str(e) + '.......a标签没找到'
-            taskType = '企业动态'
             state = 0
             takeTime = baseCore.getTimeCost(start_time,time.time())
             baseCore.recordLog(xydm,taskType,state,takeTime,url,e)
@@ -147,14 +148,12 @@ while True:
             if selects:
                 log.error(f"{name}--{gpdm}--网址已经存在----{news_url}")
                 e = '网址已存在'
-                taskType = '企业动态'
                 state = 0
                 takeTime = baseCore.getTimeCost(start_time,time.time())
                 baseCore.recordLog(xydm,taskType,state,takeTime,news_url,e)
                 continue
         title = a_ele.text.lstrip().strip().replace("'","''")
         e = getZx(xydm,news_url,title,cnx)
-        taskType = '企业动态'
         if e == '':
             state = 1
         else: