'commit'

Apps/TeLaiDian/Crawler.py

@@ -48,7 +48,35 @@ class TeLaiDianCrawler(BaseCrawler):
         from Apps.TeLaiDian import Opener
         return await Opener.open_mini_program()
 
+    async def clear_ads(self, d, max_rounds=3):
+        """
+        清理页面上的广告弹窗
+        """
+        logger.info(f"开始清理广告弹窗，最多尝试 {max_rounds} 轮...")
+        for i in range(max_rounds):
+            ad_screen = take_screenshot(d, f"tld_ad_check_{int(time.time())}.jpg")
+            res = await self.read_image_kit.find_close_button_vlm(ad_screen)
+            
+            if res.get("has_ad") and res.get("close_point"):
+                close_point = res.get("close_point")
+                w, h = d.window_size()
+                target_x = int(close_point[0] * w / 1000)
+                target_y = int(close_point[1] * h / 1000)
+                
+                logger.info(f"第 {i+1} 轮发现广告: {res.get('reason')}，点击关闭: ({target_x}, {target_y})")
+                d.click(target_x, target_y)
+                await asyncio.sleep(1.5)
+            else:
+                logger.info(f"第 {i+1} 轮未发现明显广告，清理结束。")
+                if os.path.exists(ad_screen): os.remove(ad_screen)
+                break
+            
+            if os.path.exists(ad_screen): os.remove(ad_screen)
+
     async def crawl_list_logic(self, d):
+        # 进入列表页先清理广告
+        await self.clear_ads(d)
+        
         processed_count = 0
         last_md5 = None
         
@@ -98,6 +126,8 @@ class TeLaiDianCrawler(BaseCrawler):
                 # 返回列表
                 d.press("back")
                 await asyncio.sleep(WAIT_BACK_TO_LIST)
+                # 返回列表后也检查一下是否有新广告弹出
+                await self.clear_ads(d, max_rounds=1)
                 processed_count += 1
             
             # 滑动到下一页