我也不知道呢

.gitignore

@@ -54,3 +54,7 @@ logs.txt
 *.cache
 
 browser_data
+
+data
+config/setting.toml
+config/setting_warp.toml

Dockerfile

@@ -1,20 +1,44 @@
-# Use an official Python runtime as a parent image
-FROM python:3.10-slim
+FROM python:3.11-slim
 
-# Set the working directory in the container
 WORKDIR /app
 
-# Copy the current directory contents into the container at /app
-COPY . /app
+# 使用清华镜像源加速 apt (Debian bookworm)
+RUN sed -i 's|deb.debian.org|mirrors.tuna.tsinghua.edu.cn|g' /etc/apt/sources.list.d/debian.sources \
+    && sed -i 's|security.debian.org|mirrors.tuna.tsinghua.edu.cn|g' /etc/apt/sources.list.d/debian.sources
 
-# Install any needed packages specified in requirements.txt
-RUN pip install --no-cache-dir -r requirements.txt
+# 安装 Playwright 所需的系统依赖
+RUN apt-get update && apt-get install -y \
+    libnss3 \
+    libnspr4 \
+    libatk1.0-0 \
+    libatk-bridge2.0-0 \
+    libcups2 \
+    libdrm2 \
+    libxkbcommon0 \
+    libxcomposite1 \
+    libxdamage1 \
+    libxfixes3 \
+    libxrandr2 \
+    libgbm1 \
+    libasound2 \
+    libpango-1.0-0 \
+    libcairo2 \
+    && rm -rf /var/lib/apt/lists/*
 
-# Make port 7860 available to the world outside this container
-EXPOSE 7860
+# 安装 Python 依赖（使用清华 PyPI 镜像）
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt \
+    -i https://pypi.tuna.tsinghua.edu.cn/simple/ \
+    --trusted-host pypi.tuna.tsinghua.edu.cn
 
-# Define environment variable
-ENV PORT=7860
+# 设置 Playwright 下载镜像（使用 npmmirror）
+ENV PLAYWRIGHT_DOWNLOAD_HOST=https://registry.npmmirror.com/-/binary/playwright
 
-# Run app.py when the container launches
-CMD ["python", "app.py"]
+# 安装 Playwright 浏览器
+RUN playwright install chromium
+
+COPY . .
+
+EXPOSE 8000
+
+CMD ["python", "main.py"]

README.md

@@ -1,14 +1,3 @@
----
-title: Flow2API
-emoji: 🚀
-colorFrom: blue
-colorTo: green
-sdk: docker
-sdk_version: '1.0'
-app_file: app.py
-pinned: false
----
-
 # Flow2API
 
 <div align="center">
@@ -27,7 +16,7 @@ pinned: false
 - 🎨 **文生图** / **图生图**
 - 🎬 **文生视频** / **图生视频**
 - 🎞️ **首尾帧视频**
-- 🔄 **AT自动刷新**
+- 🔄 **AT/ST自动刷新** - AT 过期自动刷新，ST 过期时自动通过浏览器更新（personal 模式）
 - 📊 **余额显示** - 实时查询和显示 VideoFX Credits
 - 🚀 **负载均衡** - 多 Token 轮询和并发控制
 - 🌐 **代理支持** - 支持 HTTP/SOCKS5 代理
@@ -77,7 +66,7 @@ docker-compose -f docker-compose.warp.yml logs -f
 ```bash
 # 克隆项目
 git clone https://github.com/TheSmallHanCat/flow2api.git
-cd flow2api
+cd sora2api
 
 # 创建虚拟环境
 python -m venv venv
@@ -95,35 +84,6 @@ pip install -r requirements.txt
 python main.py
 ```
 
-### 方式三：Hugging Face 部署
-
-1. **准备工作**
-   - 注册并登录 [Hugging Face](https://huggingface.co/)
-   - 创建一个新的 Space
-   - 选择 "Docker" 作为 Space 类型
-
-2. **配置 Space**
-   - **Repository name**: 输入一个名称（例如 `flow2api`）
-   - **Visibility**: 选择 "Public" 或 "Private"
-   - **Hardware**: 选择适当的硬件配置（最低推荐 2GB RAM）
-
-3. **部署步骤**
-   - 在 Space 的 "Files" 标签页中，上传项目的所有文件
-   - 确保 `app.py` 文件存在（Hugging Face 的部署入口）
-   - 确保 `requirements.txt` 文件包含所有必要的依赖
-   - 点击 "Build" 按钮开始部署
-
-4. **访问服务**
-   - 部署完成后，通过 Space 提供的 URL 访问服务
-   - 默认登录地址: `https://<your-space-name>.hf.space/`
-   - 首次登录用户名: `admin`，密码: `admin`
-
-5. **注意事项**
-   - Hugging Face Spaces 使用端口 7860，配置已自动适配
-   - 由于 Hugging Face 的网络环境，可能需要配置代理
-   - 建议在管理界面中修改默认的管理员密码
-   - 对于视频生成等耗时操作，可能会受到 Hugging Face 的资源限制
-
 ### 首次访问
 
 服务启动后,访问管理后台: **http://localhost:8000**,首次登录后请立即修改密码!
@@ -159,7 +119,11 @@ python main.py
 | `veo_2_0_t2v_landscape` | 文生视频 | 横屏 |
 
 #### 首尾帧模型 (I2V - Image to Video)
-📸 **支持1-2张图片：首尾帧**
+📸 **支持1-2张图片：1张作为首帧，2张作为首尾帧**
+
+> 💡 **自动适配**：系统会根据图片数量自动选择对应的 model_key
+> - **单帧模式**（1张图）：使用首帧生成视频
+> - **双帧模式**（2张图）：使用首帧+尾帧生成过渡视频
 
 | 模型名称 | 说明| 尺寸 |
 |---------|---------|--------|

docker-compose.local.yml

@@ -0,0 +1,17 @@
+version: '3.8'
+
+services:
+  flow2api:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    image: flow2api:local
+    container_name: flow2api
+    ports:
+      - "38000:8000"
+    volumes:
+      - ./data:/app/data
+      - ./config/setting.toml:/app/config/setting.toml
+    environment:
+      - PYTHONUNBUFFERED=1
+    restart: unless-stopped

docker-compose.proxy.yml

@@ -5,7 +5,7 @@ services:
     image: thesmallhancat/flow2api:latest
     container_name: flow2api
     ports:
-      - "8000:8000"
+      - "38000:8000"
     volumes:
       - ./data:/app/data
       - ./config/setting_warp.toml:/app/config/setting.toml
@@ -22,7 +22,7 @@ services:
     devices:
       - /dev/net/tun:/dev/net/tun
     ports:
-      - "1080:1080"
+      - "31080:1080"
     environment:
       - WARP_SLEEP=2
     cap_add:
@@ -33,4 +33,4 @@ services:
       - net.ipv6.conf.all.disable_ipv6=0
       - net.ipv4.conf.all.src_valid_mark=1
     volumes:
-      - ./data:/var/lib/cloudflare-warp
+      - ./data:/var/lib/cloudflare-warp

docker-compose.yml

@@ -5,7 +5,7 @@ services:
     image: thesmallhancat/flow2api:latest
     container_name: flow2api
     ports:
-      - "8000:8000"
+      - "38000:8000"
     volumes:
       - ./data:/app/data
       - ./config/setting.toml:/app/config/setting.toml

requirements.txt

@@ -7,3 +7,5 @@ tomli==2.2.1
 bcrypt==4.2.1
 python-multipart==0.0.20
 python-dateutil==2.8.2
+playwright==1.53.0
+nodriver>=0.48.0

src/api/admin.py

@@ -354,17 +354,32 @@ async def refresh_at(
     token_id: int,
     token: str = Depends(verify_admin_token)
 ):
-    """手动刷新Token的AT (使用ST转换) 🆕"""
+    """手动刷新Token的AT (使用ST转换) 🆕
+    
+    如果 AT 刷新失败且处于 personal 模式，会自动尝试通过浏览器刷新 ST
+    """
+    from ..core.logger import debug_logger
+    from ..core.config import config
+    
+    debug_logger.log_info(f"[API] 手动刷新 AT 请求: token_id={token_id}, captcha_method={config.captcha_method}")
+    
     try:
-        # 调用token_manager的内部刷新方法
+        # 调用token_manager的内部刷新方法（包含 ST 自动刷新逻辑）
         success = await token_manager._refresh_at(token_id)
 
         if success:
             # 获取更新后的token信息
             updated_token = await token_manager.get_token(token_id)
+            
+            message = "AT刷新成功"
+            if config.captcha_method == "personal":
+                message += "（支持ST自动刷新）"
+            
+            debug_logger.log_info(f"[API] AT 刷新成功: token_id={token_id}")
+            
             return {
                 "success": True,
-                "message": "AT刷新成功",
+                "message": message,
                 "token": {
                     "id": updated_token.id,
                     "email": updated_token.email,
@@ -372,8 +387,17 @@ async def refresh_at(
                 }
             }
         else:
-            raise HTTPException(status_code=500, detail="AT刷新失败")
+            debug_logger.log_error(f"[API] AT 刷新失败: token_id={token_id}")
+            
+            error_detail = "AT刷新失败"
+            if config.captcha_method != "personal":
+                error_detail += f"（当前打码模式: {config.captcha_method}，ST自动刷新仅在 personal 模式下可用）"
+            
+            raise HTTPException(status_code=500, detail=error_detail)
+    except HTTPException:
+        raise
     except Exception as e:
+        debug_logger.log_error(f"[API] 刷新AT异常: {str(e)}")
         raise HTTPException(status_code=500, detail=f"刷新AT失败: {str(e)}")
 
 
@@ -519,13 +543,8 @@ async def update_proxy_config_alias(
     token: str = Depends(verify_admin_token)
 ):
     """Update proxy configuration (alias for frontend compatibility)"""
-    try:
-        await proxy_manager.update_proxy_config(request.proxy_enabled, request.proxy_url)
-        return {"success": True, "message": "代理配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating proxy config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    await proxy_manager.update_proxy_config(request.proxy_enabled, request.proxy_url)
+    return {"success": True, "message": "代理配置更新成功"}
 
 
 @router.post("/api/config/proxy")
@@ -534,13 +553,8 @@ async def update_proxy_config(
     token: str = Depends(verify_admin_token)
 ):
     """Update proxy configuration"""
-    try:
-        await proxy_manager.update_proxy_config(request.proxy_enabled, request.proxy_url)
-        return {"success": True, "message": "代理配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating proxy config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    await proxy_manager.update_proxy_config(request.proxy_enabled, request.proxy_url)
+    return {"success": True, "message": "代理配置更新成功"}
 
 
 @router.get("/api/config/generation")
@@ -692,18 +706,10 @@ async def update_admin_config(
     token: str = Depends(verify_admin_token)
 ):
     """Update admin configuration (error_ban_threshold)"""
-    try:
-        # Update error_ban_threshold in database
-        await db.update_admin_config(error_ban_threshold=request.error_ban_threshold)
+    # Update error_ban_threshold in database
+    await db.update_admin_config(error_ban_threshold=request.error_ban_threshold)
 
-        # 🔥 Hot reload: sync database config to memory
-        await db.reload_config_to_memory()
-
-        return {"success": True, "message": "配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating admin config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {"success": True, "message": "配置更新成功"}
 
 
 @router.post("/api/admin/password")
@@ -759,17 +765,12 @@ async def update_generation_timeout(
     token: str = Depends(verify_admin_token)
 ):
     """Update generation timeout configuration"""
-    try:
-        await db.update_generation_config(request.image_timeout, request.video_timeout)
+    await db.update_generation_config(request.image_timeout, request.video_timeout)
 
-        # 🔥 Hot reload: sync database config to memory
-        await db.reload_config_to_memory()
+    # 🔥 Hot reload: sync database config to memory
+    await db.reload_config_to_memory()
 
-        return {"success": True, "message": "生成配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating generation timeout: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {"success": True, "message": "生成配置更新成功"}
 
 
 # ========== AT Auto Refresh Config ==========
@@ -838,21 +839,16 @@ async def update_cache_config_full(
     token: str = Depends(verify_admin_token)
 ):
     """Update complete cache configuration"""
-    try:
-        enabled = request.get("enabled")
-        timeout = request.get("timeout")
-        base_url = request.get("base_url")
+    enabled = request.get("enabled")
+    timeout = request.get("timeout")
+    base_url = request.get("base_url")
 
-        await db.update_cache_config(enabled=enabled, timeout=timeout, base_url=base_url)
+    await db.update_cache_config(enabled=enabled, timeout=timeout, base_url=base_url)
 
-        # 🔥 Hot reload: sync database config to memory
-        await db.reload_config_to_memory()
+    # 🔥 Hot reload: sync database config to memory
+    await db.reload_config_to_memory()
 
-        return {"success": True, "message": "缓存配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating cache config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {"success": True, "message": "缓存配置更新成功"}
 
 
 @router.post("/api/cache/base-url")
@@ -861,18 +857,13 @@ async def update_cache_base_url(
     token: str = Depends(verify_admin_token)
 ):
     """Update cache base URL"""
-    try:
-        base_url = request.get("base_url", "")
-        await db.update_cache_config(base_url=base_url)
+    base_url = request.get("base_url", "")
+    await db.update_cache_config(base_url=base_url)
 
-        # 🔥 Hot reload: sync database config to memory
-        await db.reload_config_to_memory()
+    # 🔥 Hot reload: sync database config to memory
+    await db.reload_config_to_memory()
 
-        return {"success": True, "message": "缓存Base URL更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating cache base URL: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {"success": True, "message": "缓存Base URL更新成功"}
 
 
 @router.post("/api/captcha/config")
@@ -881,37 +872,44 @@ async def update_captcha_config(
     token: str = Depends(verify_admin_token)
 ):
     """Update captcha configuration"""
-    try:
-        from ..services.browser_captcha import validate_browser_proxy_url
-
-        captcha_method = request.get("captcha_method")
-        yescaptcha_api_key = request.get("yescaptcha_api_key")
-        yescaptcha_base_url = request.get("yescaptcha_base_url")
-        browser_proxy_enabled = request.get("browser_proxy_enabled", False)
-        browser_proxy_url = request.get("browser_proxy_url", "")
-
-        # 验证浏览器代理URL格式
-        if browser_proxy_enabled and browser_proxy_url:
-            is_valid, error_msg = validate_browser_proxy_url(browser_proxy_url)
-            if not is_valid:
-                return {"success": False, "message": error_msg}
-
-        await db.update_captcha_config(
-            captcha_method=captcha_method,
-            yescaptcha_api_key=yescaptcha_api_key,
-            yescaptcha_base_url=yescaptcha_base_url,
-            browser_proxy_enabled=browser_proxy_enabled,
-            browser_proxy_url=browser_proxy_url if browser_proxy_enabled else None
-        )
+    from ..services.browser_captcha import validate_browser_proxy_url
+
+    captcha_method = request.get("captcha_method")
+    yescaptcha_api_key = request.get("yescaptcha_api_key")
+    yescaptcha_base_url = request.get("yescaptcha_base_url")
+    capmonster_api_key = request.get("capmonster_api_key")
+    capmonster_base_url = request.get("capmonster_base_url")
+    ezcaptcha_api_key = request.get("ezcaptcha_api_key")
+    ezcaptcha_base_url = request.get("ezcaptcha_base_url")
+    capsolver_api_key = request.get("capsolver_api_key")
+    capsolver_base_url = request.get("capsolver_base_url")
+    browser_proxy_enabled = request.get("browser_proxy_enabled", False)
+    browser_proxy_url = request.get("browser_proxy_url", "")
+
+    # 验证浏览器代理URL格式
+    if browser_proxy_enabled and browser_proxy_url:
+        is_valid, error_msg = validate_browser_proxy_url(browser_proxy_url)
+        if not is_valid:
+            return {"success": False, "message": error_msg}
+
+    await db.update_captcha_config(
+        captcha_method=captcha_method,
+        yescaptcha_api_key=yescaptcha_api_key,
+        yescaptcha_base_url=yescaptcha_base_url,
+        capmonster_api_key=capmonster_api_key,
+        capmonster_base_url=capmonster_base_url,
+        ezcaptcha_api_key=ezcaptcha_api_key,
+        ezcaptcha_base_url=ezcaptcha_base_url,
+        capsolver_api_key=capsolver_api_key,
+        capsolver_base_url=capsolver_base_url,
+        browser_proxy_enabled=browser_proxy_enabled,
+        browser_proxy_url=browser_proxy_url if browser_proxy_enabled else None
+    )
 
-        # 🔥 Hot reload: sync database config to memory
-        await db.reload_config_to_memory()
+    # 🔥 Hot reload: sync database config to memory
+    await db.reload_config_to_memory()
 
-        return {"success": True, "message": "验证码配置更新成功"}
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating captcha config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {"success": True, "message": "验证码配置更新成功"}
 
 
 @router.get("/api/captcha/config")
@@ -922,6 +920,12 @@ async def get_captcha_config(token: str = Depends(verify_admin_token)):
         "captcha_method": captcha_config.captcha_method,
         "yescaptcha_api_key": captcha_config.yescaptcha_api_key,
         "yescaptcha_base_url": captcha_config.yescaptcha_base_url,
+        "capmonster_api_key": captcha_config.capmonster_api_key,
+        "capmonster_base_url": captcha_config.capmonster_base_url,
+        "ezcaptcha_api_key": captcha_config.ezcaptcha_api_key,
+        "ezcaptcha_base_url": captcha_config.ezcaptcha_base_url,
+        "capsolver_api_key": captcha_config.capsolver_api_key,
+        "capsolver_base_url": captcha_config.capsolver_base_url,
         "browser_proxy_enabled": captcha_config.browser_proxy_enabled,
         "browser_proxy_url": captcha_config.browser_proxy_url or ""
     }
@@ -969,29 +973,24 @@ async def update_plugin_config(
     token: str = Depends(verify_admin_token)
 ):
     """Update plugin configuration"""
-    try:
-        connection_token = request.get("connection_token", "")
-        auto_enable_on_update = request.get("auto_enable_on_update", True)  # 默认开启
+    connection_token = request.get("connection_token", "")
+    auto_enable_on_update = request.get("auto_enable_on_update", True)  # 默认开启
 
-        # Generate random token if empty
-        if not connection_token:
-            connection_token = secrets.token_urlsafe(32)
+    # Generate random token if empty
+    if not connection_token:
+        connection_token = secrets.token_urlsafe(32)
 
-        await db.update_plugin_config(
-            connection_token=connection_token,
-            auto_enable_on_update=auto_enable_on_update
-        )
+    await db.update_plugin_config(
+        connection_token=connection_token,
+        auto_enable_on_update=auto_enable_on_update
+    )
 
-        return {
-            "success": True,
-            "message": "插件配置更新成功",
-            "connection_token": connection_token,
-            "auto_enable_on_update": auto_enable_on_update
-        }
-    except Exception as e:
-        # 捕获所有异常，确保返回有效的 JSON 响应
-        print(f"Error updating plugin config: {e}")
-        return {"success": False, "message": f"保存失败: {str(e)}"}
+    return {
+        "success": True,
+        "message": "插件配置更新成功",
+        "connection_token": connection_token,
+        "auto_enable_on_update": auto_enable_on_update
+    }
 
 
 @router.post("/api/plugin/update-token")

src/api/routes.py

@@ -111,7 +111,7 @@ async def create_chat_completion(
                 if item.get("type") == "text":
                     prompt = item.get("text", "")
                 elif item.get("type") == "image_url":
-                    # Extract base64 image
+                    # Extract image from URL or base64
                     image_url = item.get("image_url", {}).get("url", "")
                     if image_url.startswith("data:image"):
                         # Parse base64
@@ -120,6 +120,18 @@ async def create_chat_completion(
                             image_base64 = match.group(1)
                             image_bytes = base64.b64decode(image_base64)
                             images.append(image_bytes)
+                    elif image_url.startswith("http://") or image_url.startswith("https://"):
+                        # Download remote image URL
+                        debug_logger.log_info(f"[IMAGE_URL] 下载远程图片: {image_url}")
+                        try:
+                            downloaded_bytes = await retrieve_image_data(image_url)
+                            if downloaded_bytes and len(downloaded_bytes) > 0:
+                                images.append(downloaded_bytes)
+                                debug_logger.log_info(f"[IMAGE_URL] ✅ 远程图片下载成功: {len(downloaded_bytes)} 字节")
+                            else:
+                                debug_logger.log_warning(f"[IMAGE_URL] ⚠️ 远程图片下载失败或为空: {image_url}")
+                        except Exception as e:
+                            debug_logger.log_error(f"[IMAGE_URL] ❌ 远程图片下载异常: {str(e)}")
 
         # Fallback to deprecated image parameter
         if request.image and not images:

src/core/config.py

@@ -213,6 +213,72 @@ class Config:
             self._config["captcha"] = {}
         self._config["captcha"]["yescaptcha_base_url"] = base_url
 
+    @property
+    def capmonster_api_key(self) -> str:
+        """Get CapMonster API key"""
+        return self._config.get("captcha", {}).get("capmonster_api_key", "")
+
+    def set_capmonster_api_key(self, api_key: str):
+        """Set CapMonster API key"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["capmonster_api_key"] = api_key
+
+    @property
+    def capmonster_base_url(self) -> str:
+        """Get CapMonster base URL"""
+        return self._config.get("captcha", {}).get("capmonster_base_url", "https://api.capmonster.cloud")
+
+    def set_capmonster_base_url(self, base_url: str):
+        """Set CapMonster base URL"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["capmonster_base_url"] = base_url
+
+    @property
+    def ezcaptcha_api_key(self) -> str:
+        """Get EzCaptcha API key"""
+        return self._config.get("captcha", {}).get("ezcaptcha_api_key", "")
+
+    def set_ezcaptcha_api_key(self, api_key: str):
+        """Set EzCaptcha API key"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["ezcaptcha_api_key"] = api_key
+
+    @property
+    def ezcaptcha_base_url(self) -> str:
+        """Get EzCaptcha base URL"""
+        return self._config.get("captcha", {}).get("ezcaptcha_base_url", "https://api.ez-captcha.com")
+
+    def set_ezcaptcha_base_url(self, base_url: str):
+        """Set EzCaptcha base URL"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["ezcaptcha_base_url"] = base_url
+
+    @property
+    def capsolver_api_key(self) -> str:
+        """Get CapSolver API key"""
+        return self._config.get("captcha", {}).get("capsolver_api_key", "")
+
+    def set_capsolver_api_key(self, api_key: str):
+        """Set CapSolver API key"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["capsolver_api_key"] = api_key
+
+    @property
+    def capsolver_base_url(self) -> str:
+        """Get CapSolver base URL"""
+        return self._config.get("captcha", {}).get("capsolver_base_url", "https://api.capsolver.com")
+
+    def set_capsolver_base_url(self, base_url: str):
+        """Set CapSolver base URL"""
+        if "captcha" not in self._config:
+            self._config["captcha"] = {}
+        self._config["captcha"]["capsolver_base_url"] = base_url
+
 
 # Global config instance
 config = Config()

src/core/database.py

@@ -172,8 +172,8 @@ class Database:
         count = await cursor.fetchone()
         if count[0] == 0:
             await db.execute("""
-                INSERT INTO plugin_config (id, connection_token, auto_enable_on_update)
-                VALUES (1, '', 1)
+                INSERT INTO plugin_config (id, connection_token)
+                VALUES (1, '')
             """)
 
     async def check_and_migrate_db(self, config_dict: dict = None):
@@ -216,6 +216,12 @@ class Database:
                         captcha_method TEXT DEFAULT 'browser',
                         yescaptcha_api_key TEXT DEFAULT '',
                         yescaptcha_base_url TEXT DEFAULT 'https://api.yescaptcha.com',
+                        capmonster_api_key TEXT DEFAULT '',
+                        capmonster_base_url TEXT DEFAULT 'https://api.capmonster.cloud',
+                        ezcaptcha_api_key TEXT DEFAULT '',
+                        ezcaptcha_base_url TEXT DEFAULT 'https://api.ez-captcha.com',
+                        capsolver_api_key TEXT DEFAULT '',
+                        capsolver_base_url TEXT DEFAULT 'https://api.capsolver.com',
                         website_key TEXT DEFAULT '6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV',
                         page_action TEXT DEFAULT 'FLOW_GENERATION',
                         browser_proxy_enabled BOOLEAN DEFAULT 0,
@@ -232,7 +238,6 @@ class Database:
                     CREATE TABLE plugin_config (
                         id INTEGER PRIMARY KEY DEFAULT 1,
                         connection_token TEXT DEFAULT '',
-                        auto_enable_on_update BOOLEAN DEFAULT 1,
                         created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
                         updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
                     )
@@ -278,6 +283,12 @@ class Database:
                 captcha_columns_to_add = [
                     ("browser_proxy_enabled", "BOOLEAN DEFAULT 0"),
                     ("browser_proxy_url", "TEXT"),
+                    ("capmonster_api_key", "TEXT DEFAULT ''"),
+                    ("capmonster_base_url", "TEXT DEFAULT 'https://api.capmonster.cloud'"),
+                    ("ezcaptcha_api_key", "TEXT DEFAULT ''"),
+                    ("ezcaptcha_base_url", "TEXT DEFAULT 'https://api.ez-captcha.com'"),
+                    ("capsolver_api_key", "TEXT DEFAULT ''"),
+                    ("capsolver_base_url", "TEXT DEFAULT 'https://api.capsolver.com'"),
                 ]
 
                 for col_name, col_type in captcha_columns_to_add:
@@ -490,6 +501,12 @@ class Database:
                     captcha_method TEXT DEFAULT 'browser',
                     yescaptcha_api_key TEXT DEFAULT '',
                     yescaptcha_base_url TEXT DEFAULT 'https://api.yescaptcha.com',
+                    capmonster_api_key TEXT DEFAULT '',
+                    capmonster_base_url TEXT DEFAULT 'https://api.capmonster.cloud',
+                    ezcaptcha_api_key TEXT DEFAULT '',
+                    ezcaptcha_base_url TEXT DEFAULT 'https://api.ez-captcha.com',
+                    capsolver_api_key TEXT DEFAULT '',
+                    capsolver_base_url TEXT DEFAULT 'https://api.capsolver.com',
                     website_key TEXT DEFAULT '6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV',
                     page_action TEXT DEFAULT 'FLOW_GENERATION',
                     browser_proxy_enabled BOOLEAN DEFAULT 0,
@@ -504,7 +521,6 @@ class Database:
                 CREATE TABLE IF NOT EXISTS plugin_config (
                     id INTEGER PRIMARY KEY DEFAULT 1,
                     connection_token TEXT DEFAULT '',
-                    auto_enable_on_update BOOLEAN DEFAULT 1,
                     created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
                     updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
                 )
@@ -937,32 +953,23 @@ class Database:
 
     async def get_generation_config(self) -> Optional[GenerationConfig]:
         """Get generation configuration"""
-        try:
-            async with aiosqlite.connect(self.db_path) as db:
-                db.row_factory = aiosqlite.Row
-                cursor = await db.execute("SELECT * FROM generation_config WHERE id = 1")
-                row = await cursor.fetchone()
-                if row:
-                    return GenerationConfig(**dict(row))
-                return None
-        except Exception as e:
-            print(f"Error getting generation config: {e}")
-            # 返回默认配置，避免异常传播
-            return GenerationConfig(image_timeout=300, video_timeout=1500)
+        async with aiosqlite.connect(self.db_path) as db:
+            db.row_factory = aiosqlite.Row
+            cursor = await db.execute("SELECT * FROM generation_config WHERE id = 1")
+            row = await cursor.fetchone()
+            if row:
+                return GenerationConfig(**dict(row))
+            return None
 
     async def update_generation_config(self, image_timeout: int, video_timeout: int):
         """Update generation configuration"""
-        try:
-            async with aiosqlite.connect(self.db_path) as db:
-                await db.execute("""
-                    UPDATE generation_config
-                    SET image_timeout = ?, video_timeout = ?, updated_at = CURRENT_TIMESTAMP
-                    WHERE id = 1
-                """, (image_timeout, video_timeout))
-                await db.commit()
-        except Exception as e:
-            print(f"Error updating generation config: {e}")
-            raise
+        async with aiosqlite.connect(self.db_path) as db:
+            await db.execute("""
+                UPDATE generation_config
+                SET image_timeout = ?, video_timeout = ?, updated_at = CURRENT_TIMESTAMP
+                WHERE id = 1
+            """, (image_timeout, video_timeout))
+            await db.commit()
 
     # Request log operations
     async def add_request_log(self, log: RequestLog):
@@ -1057,43 +1064,39 @@ class Database:
         - Generation config (image_timeout, video_timeout)
         - Proxy config will be handled by ProxyManager
         """
-        try:
-            from .config import config
-
-            # Reload admin config
-            admin_config = await self.get_admin_config()
-            if admin_config:
-                config.set_admin_username_from_db(admin_config.username)
-                config.set_admin_password_from_db(admin_config.password)
-                config.api_key = admin_config.api_key
-
-            # Reload cache config
-            cache_config = await self.get_cache_config()
-            if cache_config:
-                config.set_cache_enabled(cache_config.cache_enabled)
-                config.set_cache_timeout(cache_config.cache_timeout)
-                config.set_cache_base_url(cache_config.cache_base_url or "")
-
-            # Reload generation config
-            generation_config = await self.get_generation_config()
-            if generation_config:
-                config.set_image_timeout(generation_config.image_timeout)
-                config.set_video_timeout(generation_config.video_timeout)
-
-            # Reload debug config
-            debug_config = await self.get_debug_config()
-            if debug_config:
-                config.set_debug_enabled(debug_config.enabled)
-
-            # Reload captcha config
-            captcha_config = await self.get_captcha_config()
-            if captcha_config:
-                config.set_captcha_method(captcha_config.captcha_method)
-                config.set_yescaptcha_api_key(captcha_config.yescaptcha_api_key)
-                config.set_yescaptcha_base_url(captcha_config.yescaptcha_base_url)
-        except Exception as e:
-            print(f"Error reloading config to memory: {e}")
-            # 不要让异常传播，避免返回 500 错误
+        from .config import config
+
+        # Reload admin config
+        admin_config = await self.get_admin_config()
+        if admin_config:
+            config.set_admin_username_from_db(admin_config.username)
+            config.set_admin_password_from_db(admin_config.password)
+            config.api_key = admin_config.api_key
+
+        # Reload cache config
+        cache_config = await self.get_cache_config()
+        if cache_config:
+            config.set_cache_enabled(cache_config.cache_enabled)
+            config.set_cache_timeout(cache_config.cache_timeout)
+            config.set_cache_base_url(cache_config.cache_base_url or "")
+
+        # Reload generation config
+        generation_config = await self.get_generation_config()
+        if generation_config:
+            config.set_image_timeout(generation_config.image_timeout)
+            config.set_video_timeout(generation_config.video_timeout)
+
+        # Reload debug config
+        debug_config = await self.get_debug_config()
+        if debug_config:
+            config.set_debug_enabled(debug_config.enabled)
+
+        # Reload captcha config
+        captcha_config = await self.get_captcha_config()
+        if captcha_config:
+            config.set_captcha_method(captcha_config.captcha_method)
+            config.set_yescaptcha_api_key(captcha_config.yescaptcha_api_key)
+            config.set_yescaptcha_base_url(captcha_config.yescaptcha_base_url)
 
     # Cache config operations
     async def get_cache_config(self) -> CacheConfig:
@@ -1214,6 +1217,12 @@ class Database:
         captcha_method: str = None,
         yescaptcha_api_key: str = None,
         yescaptcha_base_url: str = None,
+        capmonster_api_key: str = None,
+        capmonster_base_url: str = None,
+        ezcaptcha_api_key: str = None,
+        ezcaptcha_base_url: str = None,
+        capsolver_api_key: str = None,
+        capsolver_base_url: str = None,
         browser_proxy_enabled: bool = None,
         browser_proxy_url: str = None
     ):
@@ -1226,28 +1235,47 @@ class Database:
             if row:
                 current = dict(row)
                 new_method = captcha_method if captcha_method is not None else current.get("captcha_method", "yescaptcha")
-                new_api_key = yescaptcha_api_key if yescaptcha_api_key is not None else current.get("yescaptcha_api_key", "")
-                new_base_url = yescaptcha_base_url if yescaptcha_base_url is not None else current.get("yescaptcha_base_url", "https://api.yescaptcha.com")
+                new_yes_key = yescaptcha_api_key if yescaptcha_api_key is not None else current.get("yescaptcha_api_key", "")
+                new_yes_url = yescaptcha_base_url if yescaptcha_base_url is not None else current.get("yescaptcha_base_url", "https://api.yescaptcha.com")
+                new_cap_key = capmonster_api_key if capmonster_api_key is not None else current.get("capmonster_api_key", "")
+                new_cap_url = capmonster_base_url if capmonster_base_url is not None else current.get("capmonster_base_url", "https://api.capmonster.cloud")
+                new_ez_key = ezcaptcha_api_key if ezcaptcha_api_key is not None else current.get("ezcaptcha_api_key", "")
+                new_ez_url = ezcaptcha_base_url if ezcaptcha_base_url is not None else current.get("ezcaptcha_base_url", "https://api.ez-captcha.com")
+                new_cs_key = capsolver_api_key if capsolver_api_key is not None else current.get("capsolver_api_key", "")
+                new_cs_url = capsolver_base_url if capsolver_base_url is not None else current.get("capsolver_base_url", "https://api.capsolver.com")
                 new_proxy_enabled = browser_proxy_enabled if browser_proxy_enabled is not None else current.get("browser_proxy_enabled", False)
                 new_proxy_url = browser_proxy_url if browser_proxy_url is not None else current.get("browser_proxy_url")
 
                 await db.execute("""
                     UPDATE captcha_config
                     SET captcha_method = ?, yescaptcha_api_key = ?, yescaptcha_base_url = ?,
+                        capmonster_api_key = ?, capmonster_base_url = ?,
+                        ezcaptcha_api_key = ?, ezcaptcha_base_url = ?,
+                        capsolver_api_key = ?, capsolver_base_url = ?,
                         browser_proxy_enabled = ?, browser_proxy_url = ?, updated_at = CURRENT_TIMESTAMP
                     WHERE id = 1
-                """, (new_method, new_api_key, new_base_url, new_proxy_enabled, new_proxy_url))
+                """, (new_method, new_yes_key, new_yes_url, new_cap_key, new_cap_url,
+                      new_ez_key, new_ez_url, new_cs_key, new_cs_url, new_proxy_enabled, new_proxy_url))
             else:
                 new_method = captcha_method if captcha_method is not None else "yescaptcha"
-                new_api_key = yescaptcha_api_key if yescaptcha_api_key is not None else ""
-                new_base_url = yescaptcha_base_url if yescaptcha_base_url is not None else "https://api.yescaptcha.com"
+                new_yes_key = yescaptcha_api_key if yescaptcha_api_key is not None else ""
+                new_yes_url = yescaptcha_base_url if yescaptcha_base_url is not None else "https://api.yescaptcha.com"
+                new_cap_key = capmonster_api_key if capmonster_api_key is not None else ""
+                new_cap_url = capmonster_base_url if capmonster_base_url is not None else "https://api.capmonster.cloud"
+                new_ez_key = ezcaptcha_api_key if ezcaptcha_api_key is not None else ""
+                new_ez_url = ezcaptcha_base_url if ezcaptcha_base_url is not None else "https://api.ez-captcha.com"
+                new_cs_key = capsolver_api_key if capsolver_api_key is not None else ""
+                new_cs_url = capsolver_base_url if capsolver_base_url is not None else "https://api.capsolver.com"
                 new_proxy_enabled = browser_proxy_enabled if browser_proxy_enabled is not None else False
                 new_proxy_url = browser_proxy_url
 
                 await db.execute("""
-                    INSERT INTO captcha_config (id, captcha_method, yescaptcha_api_key, yescaptcha_base_url, browser_proxy_enabled, browser_proxy_url)
-                    VALUES (1, ?, ?, ?, ?, ?)
-                """, (new_method, new_api_key, new_base_url, new_proxy_enabled, new_proxy_url))
+                    INSERT INTO captcha_config (id, captcha_method, yescaptcha_api_key, yescaptcha_base_url,
+                        capmonster_api_key, capmonster_base_url, ezcaptcha_api_key, ezcaptcha_base_url,
+                        capsolver_api_key, capsolver_base_url, browser_proxy_enabled, browser_proxy_url)
+                    VALUES (1, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+                """, (new_method, new_yes_key, new_yes_url, new_cap_key, new_cap_url,
+                      new_ez_key, new_ez_url, new_cs_key, new_cs_url, new_proxy_enabled, new_proxy_url))
 
             await db.commit()
 

src/core/models.py

@@ -147,9 +147,15 @@ class DebugConfig(BaseModel):
 class CaptchaConfig(BaseModel):
     """Captcha configuration"""
     id: int = 1
-    captcha_method: str = "browser"  # yescaptcha 或 browser
+    captcha_method: str = "browser"  # yescaptcha, capmonster, ezcaptcha, capsolver 或 browser
     yescaptcha_api_key: str = ""
     yescaptcha_base_url: str = "https://api.yescaptcha.com"
+    capmonster_api_key: str = ""
+    capmonster_base_url: str = "https://api.capmonster.cloud"
+    ezcaptcha_api_key: str = ""
+    ezcaptcha_base_url: str = "https://api.ez-captcha.com"
+    capsolver_api_key: str = ""
+    capsolver_base_url: str = "https://api.capsolver.com"
     website_key: str = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV"
     page_action: str = "FLOW_GENERATION"
     browser_proxy_enabled: bool = False  # 浏览器打码是否启用代理

src/main.py

@@ -68,66 +68,48 @@ async def lifespan(app: FastAPI):
 
     # Load captcha configuration from database
     captcha_config = await db.get_captcha_config()
+    
     config.set_captcha_method(captcha_config.captcha_method)
     config.set_yescaptcha_api_key(captcha_config.yescaptcha_api_key)
     config.set_yescaptcha_base_url(captcha_config.yescaptcha_base_url)
+    config.set_capmonster_api_key(captcha_config.capmonster_api_key)
+    config.set_capmonster_base_url(captcha_config.capmonster_base_url)
+    config.set_ezcaptcha_api_key(captcha_config.ezcaptcha_api_key)
+    config.set_ezcaptcha_base_url(captcha_config.ezcaptcha_base_url)
+    config.set_capsolver_api_key(captcha_config.capsolver_api_key)
+    config.set_capsolver_base_url(captcha_config.capsolver_base_url)
 
     # Initialize browser captcha service if needed
     browser_service = None
     if captcha_config.captcha_method == "personal":
-        try:
-            from .services.browser_captcha_personal import PLAYWRIGHT_AVAILABLE
-            if PLAYWRIGHT_AVAILABLE:
-                from .services.browser_captcha_personal import BrowserCaptchaService
-                browser_service = await BrowserCaptchaService.get_instance(db)
-                await browser_service.open_login_window()
-                print("✓ Browser captcha service initialized (webui mode)")
-            else:
-                print("⚠️ Playwright not available. Please use YesCaptcha service instead.")
-                # 自动切换到 yescaptcha 方法
-                await db.update_captcha_config(
-                    captcha_method="yescaptcha",
-                    yescaptcha_api_key=captcha_config.yescaptcha_api_key,
-                    yescaptcha_base_url=captcha_config.yescaptcha_base_url
-                )
-                print("✓ Captcha method automatically switched to yescaptcha")
-        except ImportError:
-            print("⚠️ Playwright not available. Please use YesCaptcha service instead.")
-            # 自动切换到 yescaptcha 方法
-            await db.update_captcha_config(
-                captcha_method="yescaptcha",
-                yescaptcha_api_key=captcha_config.yescaptcha_api_key,
-                yescaptcha_base_url=captcha_config.yescaptcha_base_url
-            )
-            print("✓ Captcha method automatically switched to yescaptcha")
+        from .services.browser_captcha_personal import BrowserCaptchaService
+        browser_service = await BrowserCaptchaService.get_instance(db)
+        print("✓ Browser captcha service initialized (nodriver mode)")
+        
+        # 启动常驻模式：从第一个可用token获取project_id
+        tokens = await token_manager.get_all_tokens()
+        resident_project_id = None
+        for t in tokens:
+            if t.current_project_id and t.is_active:
+                resident_project_id = t.current_project_id
+                break
+        
+        if resident_project_id:
+            # 直接启动常驻模式（会自动导航到项目页面，cookie已持久化）
+            await browser_service.start_resident_mode(resident_project_id)
+            print(f"✓ Browser captcha resident mode started (project: {resident_project_id[:8]}...)")
+        else:
+            # 没有可用的project_id时，打开登录窗口供用户手动操作
+            await browser_service.open_login_window()
+            print("⚠ No active token with project_id found, opened login window for manual setup")
     elif captcha_config.captcha_method == "browser":
-        try:
-            from .services.browser_captcha import PLAYWRIGHT_AVAILABLE
-            if PLAYWRIGHT_AVAILABLE:
-                from .services.browser_captcha import BrowserCaptchaService
-                browser_service = await BrowserCaptchaService.get_instance(db)
-                print("✓ Browser captcha service initialized (headless mode)")
-            else:
-                print("⚠️ Playwright not available. Please use YesCaptcha service instead.")
-                # 自动切换到 yescaptcha 方法
-                await db.update_captcha_config(
-                    captcha_method="yescaptcha",
-                    yescaptcha_api_key=captcha_config.yescaptcha_api_key,
-                    yescaptcha_base_url=captcha_config.yescaptcha_base_url
-                )
-                print("✓ Captcha method automatically switched to yescaptcha")
-        except ImportError:
-            print("⚠️ Playwright not available. Please use YesCaptcha service instead.")
-            # 自动切换到 yescaptcha 方法
-            await db.update_captcha_config(
-                captcha_method="yescaptcha",
-                yescaptcha_api_key=captcha_config.yescaptcha_api_key,
-                yescaptcha_base_url=captcha_config.yescaptcha_base_url
-            )
-            print("✓ Captcha method automatically switched to yescaptcha")
+        from .services.browser_captcha import BrowserCaptchaService
+        browser_service = await BrowserCaptchaService.get_instance(db)
+        print("✓ Browser captcha service initialized (headless mode)")
 
     # Initialize concurrency manager
     tokens = await token_manager.get_all_tokens()
+
     await concurrency_manager.initialize(tokens)
 
     # Start file cache cleanup task
@@ -177,7 +159,7 @@ async def lifespan(app: FastAPI):
 # Initialize components
 db = Database()
 proxy_manager = ProxyManager(db)
-flow_client = FlowClient(proxy_manager)
+flow_client = FlowClient(proxy_manager, db)
 token_manager = TokenManager(db, flow_client)
 concurrency_manager = ConcurrencyManager()
 load_balancer = LoadBalancer(token_manager, concurrency_manager)

src/services/browser_captcha.py

@@ -6,16 +6,10 @@ import asyncio
 import time
 import re
 from typing import Optional, Dict
+from playwright.async_api import async_playwright, Browser, BrowserContext
 
 from ..core.logger import debug_logger
 
-# Conditionally import playwright
-try:
-    from playwright.async_api import async_playwright, Browser, BrowserContext
-    PLAYWRIGHT_AVAILABLE = True
-except ImportError:
-    PLAYWRIGHT_AVAILABLE = False
-
 
 def parse_proxy_url(proxy_url: str) -> Optional[Dict[str, str]]:
     """解析代理URL，分离协议、主机、端口、认证信息
@@ -111,11 +105,6 @@ class BrowserCaptchaService:
             return
 
         try:
-            # 检查 Playwright 是否可用
-            if not PLAYWRIGHT_AVAILABLE:
-                debug_logger.log_error("[BrowserCaptcha] ❌ Playwright 不可用，请使用 YesCaptcha 服务")
-                raise ImportError("Playwright 未安装，请使用 YesCaptcha 服务")
-
             # 获取浏览器专用代理配置
             proxy_url = None
             if self.db:

src/services/browser_captcha_personal.py

@@ -1,208 +1,677 @@
+"""
+浏览器自动化获取 reCAPTCHA token
+使用 nodriver (undetected-chromedriver 继任者) 实现反检测浏览器
+支持常驻模式：为每个 project_id 自动创建常驻标签页，即时生成 token
+"""
 import asyncio
 import time
-import re
 import os
-from typing import Optional, Dict
+from typing import Optional
+
+import nodriver as uc
 
 from ..core.logger import debug_logger
 
-# Conditionally import playwright
-try:
-    from playwright.async_api import async_playwright, BrowserContext, Page
-    PLAYWRIGHT_AVAILABLE = True
-except ImportError:
-    PLAYWRIGHT_AVAILABLE = False
-
-# ... (保持原来的 parse_proxy_url 和 validate_browser_proxy_url 函数不变) ...
-def parse_proxy_url(proxy_url: str) -> Optional[Dict[str, str]]:
-    """解析代理URL，分离协议、主机、端口、认证信息"""
-    proxy_pattern = r'^(socks5|http|https)://(?:([^:]+):([^@]+)@)?([^:]+):(\d+)$'
-    match = re.match(proxy_pattern, proxy_url)
-    if match:
-        protocol, username, password, host, port = match.groups()
-        proxy_config = {'server': f'{protocol}://{host}:{port}'}
-        if username and password:
-            proxy_config['username'] = username
-            proxy_config['password'] = password
-        return proxy_config
-    return None
+
+class ResidentTabInfo:
+    """常驻标签页信息结构"""
+    def __init__(self, tab, project_id: str):
+        self.tab = tab
+        self.project_id = project_id
+        self.recaptcha_ready = False
+        self.created_at = time.time()
+
 
 class BrowserCaptchaService:
-    """浏览器自动化获取 reCAPTCHA token（持久化有头模式）"""
+    """浏览器自动化获取 reCAPTCHA token（nodriver 有头模式）
+    
+    支持两种模式：
+    1. 常驻模式 (Resident Mode): 为每个 project_id 保持常驻标签页，即时生成 token
+    2. 传统模式 (Legacy Mode): 每次请求创建新标签页 (fallback)
+    """
 
     _instance: Optional['BrowserCaptchaService'] = None
     _lock = asyncio.Lock()
 
     def __init__(self, db=None):
         """初始化服务"""
-        # === 修改点 1: 设置为有头模式 ===
-        self.headless = False 
-        self.playwright = None
-        # 注意: 持久化模式下，我们操作的是 context 而不是 browser
-        self.context: Optional[BrowserContext] = None 
+        self.headless = False  # nodriver 有头模式
+        self.browser = None
         self._initialized = False
         self.website_key = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV"
         self.db = db
-        
-        # === 修改点 2: 指定本地数据存储目录 ===
-        # 这会在脚本运行目录下生成 browser_data 文件夹，用于保存你的登录状态
+        # 持久化 profile 目录
         self.user_data_dir = os.path.join(os.getcwd(), "browser_data")
+        
+        # 常驻模式相关属性 (支持多 project_id)
+        self._resident_tabs: dict[str, 'ResidentTabInfo'] = {}  # project_id -> 常驻标签页信息
+        self._resident_lock = asyncio.Lock()  # 保护常驻标签页操作
+        
+        # 兼容旧 API（保留 single resident 属性作为别名）
+        self.resident_project_id: Optional[str] = None  # 向后兼容
+        self.resident_tab = None                         # 向后兼容
+        self._running = False                            # 向后兼容
+        self._recaptcha_ready = False                    # 向后兼容
 
     @classmethod
     async def get_instance(cls, db=None) -> 'BrowserCaptchaService':
+        """获取单例实例"""
         if cls._instance is None:
             async with cls._lock:
                 if cls._instance is None:
                     cls._instance = cls(db)
-                    # 首次调用不强制初始化，等待 get_token 时懒加载，或者可以在这里await
         return cls._instance
 
     async def initialize(self):
-        """初始化持久化浏览器上下文"""
-        if self._initialized and self.context:
-            return
+        """初始化 nodriver 浏览器"""
+        if self._initialized and self.browser:
+            # 检查浏览器是否仍然存活
+            try:
+                # 尝试获取浏览器信息验证存活
+                if self.browser.stopped:
+                    debug_logger.log_warning("[BrowserCaptcha] 浏览器已停止，重新初始化...")
+                    self._initialized = False
+                else:
+                    return
+            except Exception:
+                debug_logger.log_warning("[BrowserCaptcha] 浏览器无响应，重新初始化...")
+                self._initialized = False
 
         try:
-            # 检查 Playwright 是否可用
-            if not PLAYWRIGHT_AVAILABLE:
-                debug_logger.log_error("[BrowserCaptcha] ❌ Playwright 不可用，请使用 YesCaptcha 服务")
-                raise ImportError("Playwright 未安装，请使用 YesCaptcha 服务")
-
-            proxy_url = None
-            if self.db:
-                captcha_config = await self.db.get_captcha_config()
-                if captcha_config.browser_proxy_enabled and captcha_config.browser_proxy_url:
-                    proxy_url = captcha_config.browser_proxy_url
-
-            debug_logger.log_info(f"[BrowserCaptcha] 正在启动浏览器 (用户数据目录: {self.user_data_dir})...")
-            self.playwright = await async_playwright().start()
-
-            # 配置启动参数
-            launch_options = {
-                'headless': self.headless,
-                'user_data_dir': self.user_data_dir, # 指定数据目录
-                'viewport': {'width': 1280, 'height': 720}, # 设置默认窗口大小
-                'args': [
-                    '--disable-blink-features=AutomationControlled',
-                    '--disable-infobars',
+            debug_logger.log_info(f"[BrowserCaptcha] 正在启动 nodriver 浏览器 (用户数据目录: {self.user_data_dir})...")
+
+            # 确保 user_data_dir 存在
+            os.makedirs(self.user_data_dir, exist_ok=True)
+
+            # 启动 nodriver 浏览器
+            self.browser = await uc.start(
+                headless=self.headless,
+                user_data_dir=self.user_data_dir,
+                sandbox=False,  # nodriver 需要此参数来禁用 sandbox
+                browser_args=[
                     '--no-sandbox',
+                    '--disable-dev-shm-usage',
                     '--disable-setuid-sandbox',
+                    '--disable-gpu',
+                    '--window-size=1280,720',
+                    '--profile-directory=Default',  # 跳过 Profile 选择器页面
                 ]
-            }
-
-            # 代理配置
-            if proxy_url:
-                proxy_config = parse_proxy_url(proxy_url)
-                if proxy_config:
-                    launch_options['proxy'] = proxy_config
-                    debug_logger.log_info(f"[BrowserCaptcha] 使用代理: {proxy_config['server']}")
-
-            # === 修改点 3: 使用 launch_persistent_context ===
-            # 这会启动一个带有状态的浏览器窗口
-            self.context = await self.playwright.chromium.launch_persistent_context(**launch_options)
-            
-            # 设置默认超时
-            self.context.set_default_timeout(30000)
+            )
 
             self._initialized = True
-            debug_logger.log_info(f"[BrowserCaptcha] ✅ 浏览器已启动 (Profile: {self.user_data_dir})")
-            
+            debug_logger.log_info(f"[BrowserCaptcha] ✅ nodriver 浏览器已启动 (Profile: {self.user_data_dir})")
+
         except Exception as e:
             debug_logger.log_error(f"[BrowserCaptcha] ❌ 浏览器启动失败: {str(e)}")
             raise
 
+    # ========== 常驻模式 API ==========
+
+    async def start_resident_mode(self, project_id: str):
+        """启动常驻模式
+        
+        Args:
+            project_id: 用于常驻的项目 ID
+        """
+        if self._running:
+            debug_logger.log_warning("[BrowserCaptcha] 常驻模式已在运行")
+            return
+        
+        await self.initialize()
+        
+        self.resident_project_id = project_id
+        website_url = f"https://labs.google/fx/tools/flow/project/{project_id}"
+        
+        debug_logger.log_info(f"[BrowserCaptcha] 启动常驻模式，访问页面: {website_url}")
+        
+        # 创建一个独立的新标签页（不使用 main_tab，避免被回收）
+        self.resident_tab = await self.browser.get(website_url, new_tab=True)
+        
+        debug_logger.log_info("[BrowserCaptcha] 标签页已创建，等待页面加载...")
+        
+        # 等待页面加载完成（带重试机制）
+        page_loaded = False
+        for retry in range(60):
+            try:
+                await asyncio.sleep(1)
+                ready_state = await self.resident_tab.evaluate("document.readyState")
+                debug_logger.log_info(f"[BrowserCaptcha] 页面状态: {ready_state} (重试 {retry + 1}/60)")
+                if ready_state == "complete":
+                    page_loaded = True
+                    break
+            except ConnectionRefusedError as e:
+                debug_logger.log_warning(f"[BrowserCaptcha] 标签页连接丢失: {e}，尝试重新获取...")
+                # 标签页可能已关闭，尝试重新创建
+                try:
+                    self.resident_tab = await self.browser.get(website_url, new_tab=True)
+                    debug_logger.log_info("[BrowserCaptcha] 已重新创建标签页")
+                except Exception as e2:
+                    debug_logger.log_error(f"[BrowserCaptcha] 重新创建标签页失败: {e2}")
+                await asyncio.sleep(2)
+            except Exception as e:
+                debug_logger.log_warning(f"[BrowserCaptcha] 等待页面异常: {e}，重试 {retry + 1}/15...")
+                await asyncio.sleep(2)
+        
+        if not page_loaded:
+            debug_logger.log_error("[BrowserCaptcha] 页面加载超时，常驻模式启动失败")
+            return
+        
+        # 等待 reCAPTCHA 加载
+        self._recaptcha_ready = await self._wait_for_recaptcha(self.resident_tab)
+        
+        if not self._recaptcha_ready:
+            debug_logger.log_error("[BrowserCaptcha] reCAPTCHA 加载失败，常驻模式启动失败")
+            return
+        
+        self._running = True
+        debug_logger.log_info(f"[BrowserCaptcha] ✅ 常驻模式已启动 (project: {project_id})")
+
+    async def stop_resident_mode(self, project_id: Optional[str] = None):
+        """停止常驻模式
+        
+        Args:
+            project_id: 指定要关闭的 project_id，如果为 None 则关闭所有常驻标签页
+        """
+        async with self._resident_lock:
+            if project_id:
+                # 关闭指定的常驻标签页
+                await self._close_resident_tab(project_id)
+                debug_logger.log_info(f"[BrowserCaptcha] 已关闭 project_id={project_id} 的常驻模式")
+            else:
+                # 关闭所有常驻标签页
+                project_ids = list(self._resident_tabs.keys())
+                for pid in project_ids:
+                    resident_info = self._resident_tabs.pop(pid, None)
+                    if resident_info and resident_info.tab:
+                        try:
+                            await resident_info.tab.close()
+                        except Exception:
+                            pass
+                debug_logger.log_info(f"[BrowserCaptcha] 已关闭所有常驻标签页 (共 {len(project_ids)} 个)")
+        
+        # 向后兼容：清理旧属性
+        if not self._running:
+            return
+        
+        self._running = False
+        if self.resident_tab:
+            try:
+                await self.resident_tab.close()
+            except Exception:
+                pass
+            self.resident_tab = None
+        
+        self.resident_project_id = None
+        self._recaptcha_ready = False
+
+    async def _wait_for_recaptcha(self, tab) -> bool:
+        """等待 reCAPTCHA 加载
+        
+        Returns:
+            True if reCAPTCHA loaded successfully
+        """
+        debug_logger.log_info("[BrowserCaptcha] 检测 reCAPTCHA...")
+        
+        # 检查 grecaptcha.enterprise.execute
+        is_enterprise = await tab.evaluate(
+            "typeof grecaptcha !== 'undefined' && typeof grecaptcha.enterprise !== 'undefined' && typeof grecaptcha.enterprise.execute === 'function'"
+        )
+        
+        if is_enterprise:
+            debug_logger.log_info("[BrowserCaptcha] reCAPTCHA Enterprise 已加载")
+            return True
+        
+        # 尝试注入脚本
+        debug_logger.log_info("[BrowserCaptcha] 未检测到 reCAPTCHA，注入脚本...")
+        
+        await tab.evaluate(f"""
+            (() => {{
+                if (document.querySelector('script[src*="recaptcha"]')) return;
+                const script = document.createElement('script');
+                script.src = 'https://www.google.com/recaptcha/api.js?render={self.website_key}';
+                script.async = true;
+                document.head.appendChild(script);
+            }})()
+        """)
+        
+        # 等待脚本加载
+        await tab.sleep(3)
+        
+        # 轮询等待 reCAPTCHA 加载
+        for i in range(20):
+            is_enterprise = await tab.evaluate(
+                "typeof grecaptcha !== 'undefined' && typeof grecaptcha.enterprise !== 'undefined' && typeof grecaptcha.enterprise.execute === 'function'"
+            )
+            
+            if is_enterprise:
+                debug_logger.log_info(f"[BrowserCaptcha] reCAPTCHA Enterprise 已加载（等待了 {i * 0.5} 秒）")
+                return True
+            await tab.sleep(0.5)
+        
+        debug_logger.log_warning("[BrowserCaptcha] reCAPTCHA 加载超时")
+        return False
+
+    async def _execute_recaptcha_on_tab(self, tab) -> Optional[str]:
+        """在指定标签页执行 reCAPTCHA 获取 token
+        
+        Args:
+            tab: nodriver 标签页对象
+            
+        Returns:
+            reCAPTCHA token 或 None
+        """
+        # 生成唯一变量名避免冲突
+        ts = int(time.time() * 1000)
+        token_var = f"_recaptcha_token_{ts}"
+        error_var = f"_recaptcha_error_{ts}"
+        
+        execute_script = f"""
+            (() => {{
+                window.{token_var} = null;
+                window.{error_var} = null;
+                
+                try {{
+                    grecaptcha.enterprise.ready(function() {{
+                        grecaptcha.enterprise.execute('{self.website_key}', {{action: 'FLOW_GENERATION'}})
+                            .then(function(token) {{
+                                window.{token_var} = token;
+                            }})
+                            .catch(function(err) {{
+                                window.{error_var} = err.message || 'execute failed';
+                            }});
+                    }});
+                }} catch (e) {{
+                    window.{error_var} = e.message || 'exception';
+                }}
+            }})()
+        """
+        
+        # 注入执行脚本
+        await tab.evaluate(execute_script)
+        
+        # 轮询等待结果（最多 15 秒）
+        token = None
+        for i in range(30):
+            await tab.sleep(0.5)
+            token = await tab.evaluate(f"window.{token_var}")
+            if token:
+                break
+            error = await tab.evaluate(f"window.{error_var}")
+            if error:
+                debug_logger.log_error(f"[BrowserCaptcha] reCAPTCHA 错误: {error}")
+                break
+        
+        # 清理临时变量
+        try:
+            await tab.evaluate(f"delete window.{token_var}; delete window.{error_var};")
+        except:
+            pass
+        
+        return token
+
+    # ========== 主要 API ==========
+
     async def get_token(self, project_id: str) -> Optional[str]:
-        """获取 reCAPTCHA token"""
+        """获取 reCAPTCHA token
+        
+        自动常驻模式：如果该 project_id 没有常驻标签页，则自动创建并常驻
+        
+        Args:
+            project_id: Flow项目ID
+
+        Returns:
+            reCAPTCHA token字符串，如果获取失败返回None
+        """
+        # 确保浏览器已初始化
+        await self.initialize()
+        
+        # 尝试从常驻标签页获取 token
+        async with self._resident_lock:
+            resident_info = self._resident_tabs.get(project_id)
+            
+            # 如果该 project_id 没有常驻标签页，则自动创建
+            if resident_info is None:
+                debug_logger.log_info(f"[BrowserCaptcha] project_id={project_id} 没有常驻标签页，正在创建...")
+                resident_info = await self._create_resident_tab(project_id)
+                if resident_info is None:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 无法为 project_id={project_id} 创建常驻标签页，fallback 到传统模式")
+                    return await self._get_token_legacy(project_id)
+                self._resident_tabs[project_id] = resident_info
+                debug_logger.log_info(f"[BrowserCaptcha] ✅ 已为 project_id={project_id} 创建常驻标签页 (当前共 {len(self._resident_tabs)} 个)")
+        
+        # 使用常驻标签页生成 token
+        if resident_info and resident_info.recaptcha_ready and resident_info.tab:
+            start_time = time.time()
+            debug_logger.log_info(f"[BrowserCaptcha] 从常驻标签页即时生成 token (project: {project_id})...")
+            try:
+                token = await self._execute_recaptcha_on_tab(resident_info.tab)
+                duration_ms = (time.time() - start_time) * 1000
+                if token:
+                    debug_logger.log_info(f"[BrowserCaptcha] ✅ Token生成成功（耗时 {duration_ms:.0f}ms）")
+                    return token
+                else:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 常驻标签页生成失败 (project: {project_id})，尝试重建...")
+            except Exception as e:
+                debug_logger.log_warning(f"[BrowserCaptcha] 常驻标签页异常: {e}，尝试重建...")
+            
+            # 常驻标签页失效，尝试重建
+            async with self._resident_lock:
+                await self._close_resident_tab(project_id)
+                resident_info = await self._create_resident_tab(project_id)
+                if resident_info:
+                    self._resident_tabs[project_id] = resident_info
+                    # 重建后立即尝试生成
+                    try:
+                        token = await self._execute_recaptcha_on_tab(resident_info.tab)
+                        if token:
+                            debug_logger.log_info(f"[BrowserCaptcha] ✅ 重建后 Token生成成功")
+                            return token
+                    except Exception:
+                        pass
+        
+        # 最终 Fallback: 使用传统模式
+        debug_logger.log_warning(f"[BrowserCaptcha] 所有常驻方式失败，fallback 到传统模式 (project: {project_id})")
+        return await self._get_token_legacy(project_id)
+
+    async def _create_resident_tab(self, project_id: str) -> Optional[ResidentTabInfo]:
+        """为指定 project_id 创建常驻标签页
+        
+        Args:
+            project_id: 项目 ID
+            
+        Returns:
+            ResidentTabInfo 对象，或 None（创建失败）
+        """
+        try:
+            website_url = f"https://labs.google/fx/tools/flow/project/{project_id}"
+            debug_logger.log_info(f"[BrowserCaptcha] 为 project_id={project_id} 创建常驻标签页，访问: {website_url}")
+            
+            # 创建新标签页
+            tab = await self.browser.get(website_url, new_tab=True)
+            
+            # 等待页面加载完成
+            page_loaded = False
+            for retry in range(60):
+                try:
+                    await asyncio.sleep(1)
+                    ready_state = await tab.evaluate("document.readyState")
+                    if ready_state == "complete":
+                        page_loaded = True
+                        break
+                except ConnectionRefusedError as e:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 标签页连接丢失: {e}")
+                    return None
+                except Exception as e:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 等待页面异常: {e}，重试 {retry + 1}/60...")
+                    await asyncio.sleep(1)
+            
+            if not page_loaded:
+                debug_logger.log_error(f"[BrowserCaptcha] 页面加载超时 (project: {project_id})")
+                try:
+                    await tab.close()
+                except:
+                    pass
+                return None
+            
+            # 等待 reCAPTCHA 加载
+            recaptcha_ready = await self._wait_for_recaptcha(tab)
+            
+            if not recaptcha_ready:
+                debug_logger.log_error(f"[BrowserCaptcha] reCAPTCHA 加载失败 (project: {project_id})")
+                try:
+                    await tab.close()
+                except:
+                    pass
+                return None
+            
+            # 创建常驻信息对象
+            resident_info = ResidentTabInfo(tab, project_id)
+            resident_info.recaptcha_ready = True
+            
+            debug_logger.log_info(f"[BrowserCaptcha] ✅ 常驻标签页创建成功 (project: {project_id})")
+            return resident_info
+            
+        except Exception as e:
+            debug_logger.log_error(f"[BrowserCaptcha] 创建常驻标签页异常: {e}")
+            return None
+
+    async def _close_resident_tab(self, project_id: str):
+        """关闭指定 project_id 的常驻标签页
+        
+        Args:
+            project_id: 项目 ID
+        """
+        resident_info = self._resident_tabs.pop(project_id, None)
+        if resident_info and resident_info.tab:
+            try:
+                await resident_info.tab.close()
+                debug_logger.log_info(f"[BrowserCaptcha] 已关闭 project_id={project_id} 的常驻标签页")
+            except Exception as e:
+                debug_logger.log_warning(f"[BrowserCaptcha] 关闭标签页时异常: {e}")
+
+    async def _get_token_legacy(self, project_id: str) -> Optional[str]:
+        """传统模式获取 reCAPTCHA token（每次创建新标签页）
+
+        Args:
+            project_id: Flow项目ID
+
+        Returns:
+            reCAPTCHA token字符串，如果获取失败返回None
+        """
         # 确保浏览器已启动
-        if not self._initialized or not self.context:
+        if not self._initialized or not self.browser:
             await self.initialize()
 
         start_time = time.time()
-        page: Optional[Page] = None
+        tab = None
 
         try:
-            # === 修改点 4: 在现有上下文中新建标签页，而不是新建上下文 ===
-            # 这样可以复用该上下文中已保存的 Cookie (你的登录状态)
-            page = await self.context.new_page()
-
             website_url = f"https://labs.google/fx/tools/flow/project/{project_id}"
-            debug_logger.log_info(f"[BrowserCaptcha] 访问页面: {website_url}")
+            debug_logger.log_info(f"[BrowserCaptcha] [Legacy] 访问页面: {website_url}")
 
-            # 访问页面
-            try:
-                await page.goto(website_url, wait_until="domcontentloaded")
-            except Exception as e:
-                debug_logger.log_warning(f"[BrowserCaptcha] 页面加载警告: {str(e)}")
-
-            # --- 关键点：如果需要人工介入 ---
-            # 你可以在这里加入一段逻辑，如果是第一次运行，或者检测到未登录，
-            # 可以暂停脚本，等你手动操作完再继续。
-            # 例如: await asyncio.sleep(30) 
-            
-            # ... (中间注入脚本和执行 reCAPTCHA 的代码逻辑与原版完全一致，此处省略以节省篇幅) ...
-            # ... 请将原代码中从 "检查并注入 reCAPTCHA v3 脚本" 到 token 获取部分的代码复制到这里 ...
-            
-            # 这里为了演示，简写注入逻辑（请保留你原有的完整注入逻辑）:
-            script_loaded = await page.evaluate("() => { return !!(window.grecaptcha && window.grecaptcha.execute); }")
-            if not script_loaded:
-                await page.evaluate(f"""
-                    () => {{
-                        const script = document.createElement('script');
-                        script.src = 'https://www.google.com/recaptcha/api.js?render={self.website_key}';
-                        script.async = true; script.defer = true;
-                        document.head.appendChild(script);
-                    }}
-                """)
-                # 等待加载... (保留你原有的等待循环)
-                await page.wait_for_timeout(2000) 
-
-            # 执行获取 Token (保留你原有的 execute 逻辑)
-            token = await page.evaluate(f"""
-                async () => {{
-                    try {{
-                        return await window.grecaptcha.execute('{self.website_key}', {{ action: 'FLOW_GENERATION' }});
-                    }} catch (e) {{ return null; }}
-                }}
-            """)
+            # 新建标签页并访问页面
+            tab = await self.browser.get(website_url)
+
+            # 等待页面完全加载（增加等待时间）
+            debug_logger.log_info("[BrowserCaptcha] [Legacy] 等待页面加载...")
+            await tab.sleep(3)
             
+            # 等待页面 DOM 完成
+            for _ in range(10):
+                ready_state = await tab.evaluate("document.readyState")
+                if ready_state == "complete":
+                    break
+                await tab.sleep(0.5)
+
+            # 等待 reCAPTCHA 加载
+            recaptcha_ready = await self._wait_for_recaptcha(tab)
+
+            if not recaptcha_ready:
+                debug_logger.log_error("[BrowserCaptcha] [Legacy] reCAPTCHA 无法加载")
+                return None
+
+            # 执行 reCAPTCHA
+            debug_logger.log_info("[BrowserCaptcha] [Legacy] 执行 reCAPTCHA 验证...")
+            token = await self._execute_recaptcha_on_tab(tab)
+
+            duration_ms = (time.time() - start_time) * 1000
+
             if token:
-                debug_logger.log_info(f"[BrowserCaptcha] ✅ Token获取成功")
+                debug_logger.log_info(f"[BrowserCaptcha] [Legacy] ✅ Token获取成功（耗时 {duration_ms:.0f}ms）")
                 return token
             else:
-                debug_logger.log_error("[BrowserCaptcha] Token获取失败")
+                debug_logger.log_error("[BrowserCaptcha] [Legacy] Token获取失败（返回null）")
                 return None
 
         except Exception as e:
-            debug_logger.log_error(f"[BrowserCaptcha] 异常: {str(e)}")
+            debug_logger.log_error(f"[BrowserCaptcha] [Legacy] 获取token异常: {str(e)}")
             return None
         finally:
-            # === 修改点 5: 只关闭 Page (标签页)，不关闭 Context (浏览器窗口) ===
-            if page:
+            # 关闭标签页（但保留浏览器）
+            if tab:
                 try:
-                    await page.close()
-                except:
+                    await tab.close()
+                except Exception:
                     pass
 
     async def close(self):
-        """完全关闭浏览器（清理资源时调用）"""
+        """关闭浏览器"""
+        # 先停止所有常驻模式（关闭所有常驻标签页）
+        await self.stop_resident_mode()
+        
         try:
-            if self.context:
-                await self.context.close() # 这会关闭整个浏览器窗口
-                self.context = None
-            
-            if self.playwright:
-                await self.playwright.stop()
-                self.playwright = None
-                
+            if self.browser:
+                try:
+                    self.browser.stop()
+                except Exception as e:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 关闭浏览器时出现异常: {str(e)}")
+                finally:
+                    self.browser = None
+
             self._initialized = False
-            debug_logger.log_info("[BrowserCaptcha] 浏览器服务已关闭")
+            self._resident_tabs.clear()  # 确保清空常驻字典
+            debug_logger.log_info("[BrowserCaptcha] 浏览器已关闭")
         except Exception as e:
-            debug_logger.log_error(f"[BrowserCaptcha] 关闭异常: {str(e)}")
+            debug_logger.log_error(f"[BrowserCaptcha] 关闭浏览器异常: {str(e)}")
 
-    # 增加一个辅助方法，用于手动登录
     async def open_login_window(self):
-        """调用此方法打开一个永久窗口供你登录Google"""
+        """打开登录窗口供用户手动登录 Google"""
         await self.initialize()
-        page = await self.context.new_page()
-        await page.goto("https://accounts.google.com/")
-        print("请在打开的浏览器中登录账号。登录完成后，无需关闭浏览器，脚本下次运行时会自动使用此状态。")
+        tab = await self.browser.get("https://accounts.google.com/")
+        debug_logger.log_info("[BrowserCaptcha] 请在打开的浏览器中登录账号。登录完成后，无需关闭浏览器，脚本下次运行时会自动使用此状态。")
+        print("请在打开的浏览器中登录账号。登录完成后，无需关闭浏览器，脚本下次运行时会自动使用此状态。")
+
+    # ========== Session Token 刷新 ==========
+
+    async def refresh_session_token(self, project_id: str) -> Optional[str]:
+        """从常驻标签页获取最新的 Session Token
+        
+        复用 reCAPTCHA 常驻标签页，通过刷新页面并从 cookies 中提取
+        __Secure-next-auth.session-token
+        
+        Args:
+            project_id: 项目ID，用于定位常驻标签页
+            
+        Returns:
+            新的 Session Token，如果获取失败返回 None
+        """
+        # 确保浏览器已初始化
+        await self.initialize()
+        
+        start_time = time.time()
+        debug_logger.log_info(f"[BrowserCaptcha] 开始刷新 Session Token (project: {project_id})...")
+        
+        # 尝试获取或创建常驻标签页
+        async with self._resident_lock:
+            resident_info = self._resident_tabs.get(project_id)
+            
+            # 如果该 project_id 没有常驻标签页，则创建
+            if resident_info is None:
+                debug_logger.log_info(f"[BrowserCaptcha] project_id={project_id} 没有常驻标签页，正在创建...")
+                resident_info = await self._create_resident_tab(project_id)
+                if resident_info is None:
+                    debug_logger.log_warning(f"[BrowserCaptcha] 无法为 project_id={project_id} 创建常驻标签页")
+                    return None
+                self._resident_tabs[project_id] = resident_info
+        
+        if not resident_info or not resident_info.tab:
+            debug_logger.log_error(f"[BrowserCaptcha] 无法获取常驻标签页")
+            return None
+        
+        tab = resident_info.tab
+        
+        try:
+            # 刷新页面以获取最新的 cookies
+            debug_logger.log_info(f"[BrowserCaptcha] 刷新常驻标签页以获取最新 cookies...")
+            await tab.reload()
+            
+            # 等待页面加载完成
+            for i in range(30):
+                await asyncio.sleep(1)
+                try:
+                    ready_state = await tab.evaluate("document.readyState")
+                    if ready_state == "complete":
+                        break
+                except Exception:
+                    pass
+            
+            # 额外等待确保 cookies 已设置
+            await asyncio.sleep(2)
+            
+            # 从 cookies 中提取 __Secure-next-auth.session-token
+            # nodriver 可以通过 browser 获取 cookies
+            session_token = None
+            
+            try:
+                # 使用 nodriver 的 cookies API 获取所有 cookies
+                cookies = await self.browser.cookies.get_all()
+                
+                for cookie in cookies:
+                    if cookie.name == "__Secure-next-auth.session-token":
+                        session_token = cookie.value
+                        break
+                        
+            except Exception as e:
+                debug_logger.log_warning(f"[BrowserCaptcha] 通过 cookies API 获取失败: {e}，尝试从 document.cookie 获取...")
+                
+                # 备选方案：通过 JavaScript 获取 (注意：HttpOnly cookies 可能无法通过此方式获取)
+                try:
+                    all_cookies = await tab.evaluate("document.cookie")
+                    if all_cookies:
+                        for part in all_cookies.split(";"):
+                            part = part.strip()
+                            if part.startswith("__Secure-next-auth.session-token="):
+                                session_token = part.split("=", 1)[1]
+                                break
+                except Exception as e2:
+                    debug_logger.log_error(f"[BrowserCaptcha] document.cookie 获取失败: {e2}")
+            
+            duration_ms = (time.time() - start_time) * 1000
+            
+            if session_token:
+                debug_logger.log_info(f"[BrowserCaptcha] ✅ Session Token 获取成功（耗时 {duration_ms:.0f}ms）")
+                return session_token
+            else:
+                debug_logger.log_error(f"[BrowserCaptcha] ❌ 未找到 __Secure-next-auth.session-token cookie")
+                return None
+                
+        except Exception as e:
+            debug_logger.log_error(f"[BrowserCaptcha] 刷新 Session Token 异常: {str(e)}")
+            
+            # 常驻标签页可能已失效，尝试重建
+            async with self._resident_lock:
+                await self._close_resident_tab(project_id)
+                resident_info = await self._create_resident_tab(project_id)
+                if resident_info:
+                    self._resident_tabs[project_id] = resident_info
+                    # 重建后再次尝试获取
+                    try:
+                        cookies = await self.browser.cookies.get_all()
+                        for cookie in cookies:
+                            if cookie.name == "__Secure-next-auth.session-token":
+                                debug_logger.log_info(f"[BrowserCaptcha] ✅ 重建后 Session Token 获取成功")
+                                return cookie.value
+                    except Exception:
+                        pass
+            
+            return None
+
+    # ========== 状态查询 ==========
+
+    def is_resident_mode_active(self) -> bool:
+        """检查是否有任何常驻标签页激活"""
+        return len(self._resident_tabs) > 0 or self._running
+
+    def get_resident_count(self) -> int:
+        """获取当前常驻标签页数量"""
+        return len(self._resident_tabs)
+
+    def get_resident_project_ids(self) -> list[str]:
+        """获取所有当前常驻的 project_id 列表"""
+        return list(self._resident_tabs.keys())
+
+    def get_resident_project_id(self) -> Optional[str]:
+        """获取当前常驻的 project_id（向后兼容，返回第一个）"""
+        if self._resident_tabs:
+            return next(iter(self._resident_tabs.keys()))
+        return self.resident_project_id

src/services/flow_client.py

@@ -12,11 +12,86 @@ from ..core.config import config
 class FlowClient:
     """VideoFX API客户端"""
 
-    def __init__(self, proxy_manager):
+    def __init__(self, proxy_manager, db=None):
         self.proxy_manager = proxy_manager
+        self.db = db  # Database instance for captcha config
         self.labs_base_url = config.flow_labs_base_url  # https://labs.google/fx/api
         self.api_base_url = config.flow_api_base_url    # https://aisandbox-pa.googleapis.com/v1
         self.timeout = config.flow_timeout
+        # 缓存每个账号的 User-Agent
+        self._user_agent_cache = {}
+
+    def _generate_user_agent(self, account_id: str = None) -> str:
+        """基于账号ID生成固定的 User-Agent
+        
+        Args:
+            account_id: 账号标识（如 email 或 token_id），相同账号返回相同 UA
+            
+        Returns:
+            User-Agent 字符串
+        """
+        # 如果没有提供账号ID，生成随机UA
+        if not account_id:
+            account_id = f"random_{random.randint(1, 999999)}"
+        
+        # 如果已缓存，直接返回
+        if account_id in self._user_agent_cache:
+            return self._user_agent_cache[account_id]
+        
+        # 使用账号ID作为随机种子，确保同一账号生成相同的UA
+        import hashlib
+        seed = int(hashlib.md5(account_id.encode()).hexdigest()[:8], 16)
+        rng = random.Random(seed)
+        
+        # Chrome 版本池
+        chrome_versions = ["130.0.0.0", "131.0.0.0", "132.0.0.0", "129.0.0.0"]
+        # Firefox 版本池
+        firefox_versions = ["133.0", "132.0", "131.0", "134.0"]
+        # Safari 版本池
+        safari_versions = ["18.2", "18.1", "18.0", "17.6"]
+        # Edge 版本池
+        edge_versions = ["130.0.0.0", "131.0.0.0", "132.0.0.0"]
+
+        # 操作系统配置
+        os_configs = [
+            # Windows
+            {
+                "platform": "Windows NT 10.0; Win64; x64",
+                "browsers": [
+                    lambda r: f"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/{r.choice(chrome_versions)} Safari/537.36",
+                    lambda r: f"Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:{r.choice(firefox_versions).split('.')[0]}.0) Gecko/20100101 Firefox/{r.choice(firefox_versions)}",
+                    lambda r: f"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/{r.choice(chrome_versions)} Safari/537.36 Edg/{r.choice(edge_versions)}",
+                ]
+            },
+            # macOS
+            {
+                "platform": "Macintosh; Intel Mac OS X 10_15_7",
+                "browsers": [
+                    lambda r: f"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/{r.choice(chrome_versions)} Safari/537.36",
+                    lambda r: f"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/{r.choice(safari_versions)} Safari/605.1.15",
+                    lambda r: f"Mozilla/5.0 (Macintosh; Intel Mac OS X 14.{r.randint(0, 7)}; rv:{r.choice(firefox_versions).split('.')[0]}.0) Gecko/20100101 Firefox/{r.choice(firefox_versions)}",
+                ]
+            },
+            # Linux
+            {
+                "platform": "X11; Linux x86_64",
+                "browsers": [
+                    lambda r: f"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/{r.choice(chrome_versions)} Safari/537.36",
+                    lambda r: f"Mozilla/5.0 (X11; Linux x86_64; rv:{r.choice(firefox_versions).split('.')[0]}.0) Gecko/20100101 Firefox/{r.choice(firefox_versions)}",
+                    lambda r: f"Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:{r.choice(firefox_versions).split('.')[0]}.0) Gecko/20100101 Firefox/{r.choice(firefox_versions)}",
+                ]
+            }
+        ]
+
+        # 使用固定种子随机选择操作系统和浏览器
+        os_config = rng.choice(os_configs)
+        browser_generator = rng.choice(os_config["browsers"])
+        user_agent = browser_generator(rng)
+        
+        # 缓存结果
+        self._user_agent_cache[account_id] = user_agent
+        
+        return user_agent
 
     async def _make_request(
         self,
@@ -52,12 +127,19 @@ class FlowClient:
 
         # AT认证 - 使用Bearer
         if use_at and at_token:
-            headers["Authorization"] = f"Bearer {at_token}"
+            headers["authorization"] = f"Bearer {at_token}"
+
+        # 确定账号标识（优先使用 token 的前16个字符作为标识）
+        account_id = None
+        if st_token:
+            account_id = st_token[:16]  # 使用 ST 的前16个字符
+        elif at_token:
+            account_id = at_token[:16]  # 使用 AT 的前16个字符
 
-        # 通用请求头
+        # 通用请求头 - 基于账号生成固定的 User-Agent
         headers.update({
             "Content-Type": "application/json",
-            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36"
+            "User-Agent": self._generate_user_agent(account_id)
         })
 
         # Log request
@@ -571,7 +653,7 @@ class FlowClient:
         Returns:
             同 generate_video_text
         """
-        url = f"{self.api_base_url}/video:batchAsyncGenerateVideoStartAndEndImage"
+        url = f"{self.api_base_url}/video:batchAsyncGenerateVideoStartImage"
 
         # 获取 reCAPTCHA token
         recaptcha_token = await self._get_recaptcha_token(project_id) or ""
@@ -684,14 +766,14 @@ class FlowClient:
         return str(uuid.uuid4())
 
     async def _get_recaptcha_token(self, project_id: str) -> Optional[str]:
-        """获取reCAPTCHA token - 支持两种方式"""
+        """获取reCAPTCHA token - 支持多种打码方式"""
         captcha_method = config.captcha_method
 
         # 恒定浏览器打码
         if captcha_method == "personal":
             try:
                 from .browser_captcha_personal import BrowserCaptchaService
-                service = await BrowserCaptchaService.get_instance(self.proxy_manager)
+                service = await BrowserCaptchaService.get_instance(self.db)
                 return await service.get_token(project_id)
             except Exception as e:
                 debug_logger.log_error(f"[reCAPTCHA Browser] error: {str(e)}")
@@ -700,67 +782,98 @@ class FlowClient:
         elif captcha_method == "browser":
             try:
                 from .browser_captcha import BrowserCaptchaService
-                service = await BrowserCaptchaService.get_instance(self.proxy_manager)
+                service = await BrowserCaptchaService.get_instance(self.db)
                 return await service.get_token(project_id)
             except Exception as e:
                 debug_logger.log_error(f"[reCAPTCHA Browser] error: {str(e)}")
                 return None
+        # API打码服务
+        elif captcha_method in ["yescaptcha", "capmonster", "ezcaptcha", "capsolver"]:
+            return await self._get_api_captcha_token(captcha_method, project_id)
         else:
-            # YesCaptcha打码
-            client_key = config.yescaptcha_api_key
-            if not client_key:
-                debug_logger.log_info("[reCAPTCHA] API key not configured, skipping")
-                return None
+            debug_logger.log_error(f"[reCAPTCHA] Unknown captcha method: {captcha_method}")
+            return None
 
-            website_key = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV"
-            website_url = f"https://labs.google/fx/tools/flow/project/{project_id}"
+    async def _get_api_captcha_token(self, method: str, project_id: str) -> Optional[str]:
+        """通用API打码服务"""
+        # 获取配置
+        if method == "yescaptcha":
+            client_key = config.yescaptcha_api_key
             base_url = config.yescaptcha_base_url
-            page_action = "FLOW_GENERATION"
+            task_type = "RecaptchaV3TaskProxylessM1"
+        elif method == "capmonster":
+            client_key = config.capmonster_api_key
+            base_url = config.capmonster_base_url
+            task_type = "RecaptchaV3EnterpriseTask"
+        elif method == "ezcaptcha":
+            client_key = config.ezcaptcha_api_key
+            base_url = config.ezcaptcha_base_url
+            task_type = "ReCaptchaV3EnterpriseTaskProxyless"
+        elif method == "capsolver":
+            client_key = config.capsolver_api_key
+            base_url = config.capsolver_base_url
+            task_type = "ReCaptchaV3EnterpriseTaskProxyLess"
+        else:
+            debug_logger.log_error(f"[reCAPTCHA] Unknown API method: {method}")
+            return None
 
-            try:
-                async with AsyncSession() as session:
-                    create_url = f"{base_url}/createTask"
-                    create_data = {
-                        "clientKey": client_key,
-                        "softID": "42780",
-                        "task": {
-                            "websiteURL": website_url,
-                            "websiteKey": website_key,
-                            "type": "RecaptchaV3TaskProxylessM1",
-                            "pageAction": page_action
-                        }
+        if not client_key:
+            debug_logger.log_info(f"[reCAPTCHA] {method} API key not configured, skipping")
+            return None
+
+        website_key = "6LdsFiUsAAAAAIjVDZcuLhaHiDn5nnHVXVRQGeMV"
+        website_url = f"https://labs.google/fx/tools/flow/project/{project_id}"
+        page_action = "FLOW_GENERATION"
+
+        try:
+            async with AsyncSession() as session:
+                create_url = f"{base_url}/createTask"
+                create_data = {
+                    "clientKey": client_key,
+                    "softID": "42780",
+                    "task": {
+                        "websiteURL": website_url,
+                        "websiteKey": website_key,
+                        "type": task_type,
+                        "pageAction": page_action
                     }
+                }
 
-                    result = await session.post(create_url, json=create_data, impersonate="chrome110")
-                    result_json = result.json()
-                    task_id = result_json.get('taskId')
+                result = await session.post(create_url, json=create_data, impersonate="chrome110")
+                result_json = result.json()
+                task_id = result_json.get('taskId')
 
-                    debug_logger.log_info(f"[reCAPTCHA] created task_id: {task_id}")
+                debug_logger.log_info(f"[reCAPTCHA {method}] created task_id: {task_id}")
 
-                    if not task_id:
-                        return None
+                if not task_id:
+                    error_desc = result_json.get('errorDescription', 'Unknown error')
+                    debug_logger.log_error(f"[reCAPTCHA {method}] Failed to create task: {error_desc}")
+                    return None
 
-                    get_url = f"{base_url}/getTaskResult"
-                    for i in range(40):
-                        get_data = {
-                            "clientKey": client_key,
-                            "taskId": task_id
-                        }
-                        result = await session.post(get_url, json=get_data, impersonate="chrome110")
-                        result_json = result.json()
+                get_url = f"{base_url}/getTaskResult"
+                for i in range(40):
+                    get_data = {
+                        "clientKey": client_key,
+                        "taskId": task_id
+                    }
+                    result = await session.post(get_url, json=get_data, impersonate="chrome110")
+                    result_json = result.json()
 
-                        debug_logger.log_info(f"[reCAPTCHA] polling #{i+1}: {result_json}")
+                    debug_logger.log_info(f"[reCAPTCHA {method}] polling #{i+1}: {result_json}")
 
+                    status = result_json.get('status')
+                    if status == 'ready':
                         solution = result_json.get('solution', {})
                         response = solution.get('gRecaptchaResponse')
-
                         if response:
+                            debug_logger.log_info(f"[reCAPTCHA {method}] Token获取成功")
                             return response
 
-                        time.sleep(3)
+                    time.sleep(3)
 
-                    return None
-
-            except Exception as e:
-                debug_logger.log_error(f"[reCAPTCHA] error: {str(e)}")
+                debug_logger.log_error(f"[reCAPTCHA {method}] Timeout waiting for token")
                 return None
+
+        except Exception as e:
+            debug_logger.log_error(f"[reCAPTCHA {method}] error: {str(e)}")
+            return None

src/services/generation_handler.py

@@ -136,7 +136,7 @@ MODEL_CONFIG = {
     "veo_3_1_i2v_s_fast_fl_portrait": {
         "type": "video",
         "video_type": "i2v",
-        "model_key": "veo_3_1_i2v_s_fast_fl",
+        "model_key": "veo_3_1_i2v_s_fast_portrait_fl_ultra_relaxed",
         "aspect_ratio": "VIDEO_ASPECT_RATIO_PORTRAIT",
         "supports_images": True,
         "min_images": 1,
@@ -145,7 +145,7 @@ MODEL_CONFIG = {
     "veo_3_1_i2v_s_fast_fl_landscape": {
         "type": "video",
         "video_type": "i2v",
-        "model_key": "veo_3_1_i2v_s_fast_fl",
+        "model_key": "veo_3_1_i2v_s_fast_fl_ultra_relaxed",
         "aspect_ratio": "VIDEO_ASPECT_RATIO_LANDSCAPE",
         "supports_images": True,
         "min_images": 1,
@@ -259,7 +259,7 @@ MODEL_CONFIG = {
     "veo_3_0_r2v_fast_portrait": {
         "type": "video",
         "video_type": "r2v",
-        "model_key": "veo_3_0_r2v_fast",
+        "model_key": "veo_3_0_r2v_fast_portrait_ultra_relaxed",
         "aspect_ratio": "VIDEO_ASPECT_RATIO_PORTRAIT",
         "supports_images": True,
         "min_images": 0,
@@ -268,7 +268,7 @@ MODEL_CONFIG = {
     "veo_3_0_r2v_fast_landscape": {
         "type": "video",
         "video_type": "r2v",
-        "model_key": "veo_3_0_r2v_fast",
+        "model_key": "veo_3_0_r2v_fast_ultra_relaxed",
         "aspect_ratio": "VIDEO_ASPECT_RATIO_LANDSCAPE",
         "supports_images": True,
         "min_images": 0,
@@ -644,6 +644,44 @@ class GenerationHandler:
             min_images = model_config.get("min_images", 0)
             max_images = model_config.get("max_images", 0)
 
+            # 根据账号tier自动调整模型 key
+            model_key = model_config["model_key"]
+            user_tier = token.user_paygate_tier or "PAYGATE_TIER_ONE"
+
+            # TIER_TWO 账号需要使用 ultra 版本的模型
+            if user_tier == "PAYGATE_TIER_TWO":
+                # 如果模型 key 不包含 ultra，自动添加
+                if "ultra" not in model_key:
+                    # veo_3_1_i2v_s_fast_fl -> veo_3_1_i2v_s_fast_ultra_fl
+                    # veo_3_1_t2v_fast -> veo_3_1_t2v_fast_ultra
+                    # veo_3_0_r2v_fast -> veo_3_0_r2v_fast_ultra
+                    if "_fl" in model_key:
+                        model_key = model_key.replace("_fl", "_ultra_fl")
+                    elif model_key.endswith("_fast"):
+                        model_key = model_key + "_ultra"
+                    elif "_fast_" in model_key:
+                        model_key = model_key.replace("_fast_", "_fast_ultra_")
+                    
+                    if stream:
+                        yield self._create_stream_chunk(f"TIER_TWO 账号自动切换到 ultra 模型: {model_key}\n")
+                    debug_logger.log_info(f"[VIDEO] TIER_TWO 账号，模型自动调整: {model_config['model_key']} -> {model_key}")
+
+            # TIER_ONE 账号需要使用非 ultra 版本
+            elif user_tier == "PAYGATE_TIER_ONE":
+                # 如果模型 key 包含 ultra，需要移除（避免用户误用）
+                if "ultra" in model_key:
+                    # veo_3_1_i2v_s_fast_ultra_fl -> veo_3_1_i2v_s_fast_fl
+                    # veo_3_1_t2v_fast_ultra -> veo_3_1_t2v_fast
+                    model_key = model_key.replace("_ultra_fl", "_fl").replace("_ultra", "")
+                    
+                    if stream:
+                        yield self._create_stream_chunk(f"TIER_ONE 账号自动切换到标准模型: {model_key}\n")
+                    debug_logger.log_info(f"[VIDEO] TIER_ONE 账号，模型自动调整: {model_config['model_key']} -> {model_key}")
+
+            # 更新 model_config 中的 model_key
+            model_config = dict(model_config)  # 创建副本避免修改原配置
+            model_config["model_key"] = model_key
+
             # 图片数量
             image_count = len(images) if images else 0
 
@@ -734,12 +772,16 @@ class GenerationHandler:
                         user_paygate_tier=token.user_paygate_tier or "PAYGATE_TIER_ONE"
                     )
                 else:
-                    # 只有首帧
+                    # 只有首帧 - 需要将 model_key 中的 _fl_ 替换为 _
+                    # 例如: veo_3_1_i2v_s_fast_fl_ultra_relaxed -> veo_3_1_i2v_s_fast_ultra_relaxed
+                    #       veo_3_1_i2v_s_fast_portrait_fl_ultra_relaxed -> veo_3_1_i2v_s_fast_portrait_ultra_relaxed
+                    actual_model_key = model_config["model_key"].replace("_fl_", "_")
+                    debug_logger.log_info(f"[I2V] 单帧模式，model_key: {model_config['model_key']} -> {actual_model_key}")
                     result = await self.flow_client.generate_video_start_image(
                         at=token.at,
                         project_id=project_id,
                         prompt=prompt,
-                        model_key=model_config["model_key"],
+                        model_key=actual_model_key,
                         aspect_ratio=model_config["aspect_ratio"],
                         start_media_id=start_media_id,
                         user_paygate_tier=token.user_paygate_tier or "PAYGATE_TIER_ONE"
@@ -888,8 +930,30 @@ class GenerationHandler:
                         )
                     return
 
+                elif status == "MEDIA_GENERATION_STATUS_FAILED":
+                    # 生成失败 - 提取错误信息
+                    error_info = operation.get("operation", {}).get("error", {})
+                    error_code = error_info.get("code", "unknown")
+                    error_message = error_info.get("message", "未知错误")
+                    
+                    # 更新数据库任务状态
+                    task_id = operation["operation"]["name"]
+                    await self.db.update_task(
+                        task_id,
+                        status="failed",
+                        error_message=f"{error_message} (code: {error_code})",
+                        completed_at=time.time()
+                    )
+                    
+                    # 返回友好的错误消息，提示用户重试
+                    friendly_error = f"视频生成失败: {error_message}，请重试"
+                    if stream:
+                        yield self._create_stream_chunk(f"❌ {friendly_error}\n")
+                    yield self._create_error_response(friendly_error)
+                    return
+
                 elif status.startswith("MEDIA_GENERATION_STATUS_ERROR"):
-                    # 失败
+                    # 其他错误状态
                     yield self._create_error_response(f"视频生成失败: {status}")
                     return
 

src/services/token_manager.py

@@ -268,9 +268,13 @@ class TokenManager:
         # AT有效
         return True
 
+
     async def _refresh_at(self, token_id: int) -> bool:
         """内部方法: 刷新AT
 
+        如果 AT 刷新失败（ST 可能过期），会尝试通过浏览器自动刷新 ST，
+        然后重试 AT 刷新。
+
         Returns:
             True if refresh successful, False otherwise
         """
@@ -279,49 +283,132 @@ class TokenManager:
             if not token:
                 return False
 
-            try:
-                debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: 开始刷新AT...")
-
-                # 使用ST转AT
-                result = await self.flow_client.st_to_at(token.st)
-                new_at = result["access_token"]
-                expires = result.get("expires")
-
-                # 解析过期时间
-                new_at_expires = None
-                if expires:
-                    try:
-                        new_at_expires = datetime.fromisoformat(expires.replace('Z', '+00:00'))
-                    except:
-                        pass
-
-                # 更新数据库
-                await self.db.update_token(
-                    token_id,
-                    at=new_at,
-                    at_expires=new_at_expires
-                )
+            # 第一次尝试刷新 AT
+            result = await self._do_refresh_at(token_id, token.st)
+            if result:
+                return True
 
-                debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: AT刷新成功")
-                debug_logger.log_info(f"  - 新过期时间: {new_at_expires}")
+            # AT 刷新失败，尝试自动更新 ST
+            debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: 第一次 AT 刷新失败，尝试自动更新 ST...")
+            
+            new_st = await self._try_refresh_st(token_id, token)
+            if new_st:
+                # ST 更新成功，重试 AT 刷新
+                debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: ST 已更新，重试 AT 刷新...")
+                result = await self._do_refresh_at(token_id, new_st)
+                if result:
+                    return True
+
+            # 所有刷新尝试都失败，禁用 Token
+            debug_logger.log_error(f"[AT_REFRESH] Token {token_id}: 所有刷新尝试失败，禁用 Token")
+            await self.disable_token(token_id)
+            return False
+
+    async def _do_refresh_at(self, token_id: int, st: str) -> bool:
+        """执行 AT 刷新的核心逻辑
+
+        Args:
+            token_id: Token ID
+            st: Session Token
 
-                # 同时刷新credits
+        Returns:
+            True if refresh successful AND AT is valid, False otherwise
+        """
+        try:
+            debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: 开始刷新AT...")
+
+            # 使用ST转AT
+            result = await self.flow_client.st_to_at(st)
+            new_at = result["access_token"]
+            expires = result.get("expires")
+
+            # 解析过期时间
+            new_at_expires = None
+            if expires:
                 try:
-                    credits_result = await self.flow_client.get_credits(new_at)
-                    await self.db.update_token(
-                        token_id,
-                        credits=credits_result.get("credits", 0)
-                    )
+                    new_at_expires = datetime.fromisoformat(expires.replace('Z', '+00:00'))
                 except:
                     pass
 
+            # 更新数据库
+            await self.db.update_token(
+                token_id,
+                at=new_at,
+                at_expires=new_at_expires
+            )
+
+            debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: AT刷新成功")
+            debug_logger.log_info(f"  - 新过期时间: {new_at_expires}")
+
+            # 验证 AT 有效性：通过 get_credits 测试
+            try:
+                credits_result = await self.flow_client.get_credits(new_at)
+                await self.db.update_token(
+                    token_id,
+                    credits=credits_result.get("credits", 0)
+                )
+                debug_logger.log_info(f"[AT_REFRESH] Token {token_id}: AT 验证成功（余额: {credits_result.get('credits', 0)}）")
                 return True
+            except Exception as verify_err:
+                # AT 验证失败（可能返回 401），说明 ST 已过期
+                error_msg = str(verify_err)
+                if "401" in error_msg or "UNAUTHENTICATED" in error_msg:
+                    debug_logger.log_warning(f"[AT_REFRESH] Token {token_id}: AT 验证失败 (401)，ST 可能已过期")
+                    return False
+                else:
+                    # 其他错误（如网络问题），仍视为成功
+                    debug_logger.log_warning(f"[AT_REFRESH] Token {token_id}: AT 验证时发生非认证错误: {error_msg}")
+                    return True
 
-            except Exception as e:
-                debug_logger.log_error(f"[AT_REFRESH] Token {token_id}: AT刷新失败 - {str(e)}")
-                # 刷新失败,禁用Token
-                await self.disable_token(token_id)
-                return False
+        except Exception as e:
+            debug_logger.log_error(f"[AT_REFRESH] Token {token_id}: AT刷新失败 - {str(e)}")
+            return False
+
+    async def _try_refresh_st(self, token_id: int, token) -> Optional[str]:
+        """尝试通过浏览器刷新 Session Token
+
+        使用常驻 tab 获取新的 __Secure-next-auth.session-token
+
+        Args:
+            token_id: Token ID
+            token: Token 对象
+
+        Returns:
+            新的 ST 字符串，如果失败返回 None
+        """
+        try:
+            from ..core.config import config
+
+            # 仅在 personal 模式下支持 ST 自动刷新
+            if config.captcha_method != "personal":
+                debug_logger.log_info(f"[ST_REFRESH] 非 personal 模式，跳过 ST 自动刷新")
+                return None
+
+            if not token.current_project_id:
+                debug_logger.log_warning(f"[ST_REFRESH] Token {token_id} 没有 project_id，无法刷新 ST")
+                return None
+
+            debug_logger.log_info(f"[ST_REFRESH] Token {token_id}: 尝试通过浏览器刷新 ST...")
+
+            from .browser_captcha_personal import BrowserCaptchaService
+            service = await BrowserCaptchaService.get_instance(self.db)
+
+            new_st = await service.refresh_session_token(token.current_project_id)
+            if new_st and new_st != token.st:
+                # 更新数据库中的 ST
+                await self.db.update_token(token_id, st=new_st)
+                debug_logger.log_info(f"[ST_REFRESH] Token {token_id}: ST 已自动更新")
+                return new_st
+            elif new_st == token.st:
+                debug_logger.log_warning(f"[ST_REFRESH] Token {token_id}: 获取到的 ST 与原 ST 相同，可能登录已失效")
+                return None
+            else:
+                debug_logger.log_warning(f"[ST_REFRESH] Token {token_id}: 无法获取新 ST")
+                return None
+
+        except Exception as e:
+            debug_logger.log_error(f"[ST_REFRESH] Token {token_id}: 刷新 ST 失败 - {str(e)}")
+            return None
 
     async def ensure_project_exists(self, token_id: int) -> str:
         """确保Token有可用的Project

static/manage.html

@@ -269,6 +269,9 @@
                             <label class="text-sm font-medium mb-2 block">打码方式</label>
                             <select id="cfgCaptchaMethod" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" onchange="toggleCaptchaOptions()">
                                 <option value="yescaptcha">YesCaptcha打码</option>
+                                <option value="capmonster">CapMonster打码</option>
+                                <option value="ezcaptcha">EzCaptcha打码</option>
+                                <option value="capsolver">CapSolver打码</option>
                                 <option value="browser">无头浏览器打码</option>
                                 <option value="personal">内置浏览器打码</option>
                             </select>
@@ -289,6 +292,48 @@
                             </div>
                         </div>
 
+                        <!-- CapMonster配置选项 -->
+                        <div id="capmonsterOptions" class="hidden space-y-4">
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">CapMonster API密钥</label>
+                                <input id="cfgCapmonsterApiKey" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="请输入CapMonster API密钥">
+                                <p class="text-xs text-muted-foreground mt-1">用于自动获取reCAPTCHA验证码</p>
+                            </div>
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">CapMonster API地址</label>
+                                <input id="cfgCapmonsterBaseUrl" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="https://api.capmonster.cloud">
+                                <p class="text-xs text-muted-foreground mt-1">CapMonster服务地址，默认：https://api.capmonster.cloud</p>
+                            </div>
+                        </div>
+
+                        <!-- EzCaptcha配置选项 -->
+                        <div id="ezcaptchaOptions" class="hidden space-y-4">
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">EzCaptcha API密钥</label>
+                                <input id="cfgEzcaptchaApiKey" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="请输入EzCaptcha API密钥">
+                                <p class="text-xs text-muted-foreground mt-1">用于自动获取reCAPTCHA验证码</p>
+                            </div>
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">EzCaptcha API地址</label>
+                                <input id="cfgEzcaptchaBaseUrl" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="https://api.ez-captcha.com">
+                                <p class="text-xs text-muted-foreground mt-1">EzCaptcha服务地址，默认：https://api.ez-captcha.com</p>
+                            </div>
+                        </div>
+
+                        <!-- CapSolver配置选项 -->
+                        <div id="capsolverOptions" class="hidden space-y-4">
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">CapSolver API密钥</label>
+                                <input id="cfgCapsolverApiKey" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="请输入CapSolver API密钥">
+                                <p class="text-xs text-muted-foreground mt-1">用于自动获取reCAPTCHA验证码</p>
+                            </div>
+                            <div>
+                                <label class="text-sm font-medium mb-2 block">CapSolver API地址</label>
+                                <input id="cfgCapsolverBaseUrl" type="text" class="flex h-9 w-full rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="https://api.capsolver.com">
+                                <p class="text-xs text-muted-foreground mt-1">CapSolver服务地址，默认：https://api.capsolver.com</p>
+                            </div>
+                        </div>
+
                         <!-- 浏览器打码配置选项 -->
                         <div id="browserCaptchaOptions" class="hidden space-y-4">
                             <div class="rounded-md bg-blue-50 dark:bg-blue-900/20 p-3 border border-blue-200 dark:border-blue-800">
@@ -335,6 +380,7 @@
                             <label class="text-sm font-semibold mb-2 block">连接Token</label>
                             <div class="flex gap-2">
                                 <input id="cfgPluginConnectionToken" type="text" class="flex h-9 flex-1 rounded-md border border-input bg-background px-3 py-2 text-sm" placeholder="留空自动生成">
+                                <button onclick="generateRandomToken()" class="inline-flex items-center justify-center rounded-md bg-primary text-primary-foreground hover:bg-primary/90 h-9 px-4">随机</button>
                                 <button onclick="copyConnectionToken()" class="inline-flex items-center justify-center rounded-md bg-secondary text-secondary-foreground hover:bg-secondary/80 h-9 px-4">复制</button>
                             </div>
                             <p class="text-xs text-muted-foreground mt-1">用于验证Chrome扩展插件的身份，留空将自动生成随机token</p>
@@ -698,14 +744,15 @@
         loadGenerationTimeout=async()=>{try{console.log('开始加载生成超时配置...');const r=await apiRequest('/api/generation/timeout');if(!r){console.error('API请求失败');return}const d=await r.json();console.log('生成超时配置数据:',d);if(d.success&&d.config){const imageTimeout=d.config.image_timeout||300;const videoTimeout=d.config.video_timeout||1500;console.log('设置图片超时:',imageTimeout);console.log('设置视频超时:',videoTimeout);$('cfgImageTimeout').value=imageTimeout;$('cfgVideoTimeout').value=videoTimeout;console.log('生成超时配置加载成功')}else{console.error('生成超时配置数据格式错误:',d)}}catch(e){console.error('加载生成超时配置失败:',e);showToast('加载生成超时配置失败: '+e.message,'error')}},
         saveCacheConfig=async()=>{const enabled=$('cfgCacheEnabled').checked,timeout=parseInt($('cfgCacheTimeout').value)||7200,baseUrl=$('cfgCacheBaseUrl').value.trim();console.log('保存缓存配置:',{enabled,timeout,baseUrl});if(timeout<60||timeout>86400)return showToast('缓存超时时间必须在 60-86400 秒之间','error');if(baseUrl&&!baseUrl.startsWith('http://')&&!baseUrl.startsWith('https://'))return showToast('域名必须以 http:// 或 https:// 开头','error');try{console.log('保存缓存启用状态...');const r0=await apiRequest('/api/cache/enabled',{method:'POST',body:JSON.stringify({enabled:enabled})});if(!r0){console.error('保存缓存启用状态请求失败');return}const d0=await r0.json();console.log('缓存启用状态保存结果:',d0);if(!d0.success){console.error('保存缓存启用状态失败:',d0);return showToast('保存缓存启用状态失败','error')}console.log('保存超时时间...');const r1=await apiRequest('/api/cache/config',{method:'POST',body:JSON.stringify({timeout:timeout})});if(!r1){console.error('保存超时时间请求失败');return}const d1=await r1.json();console.log('超时时间保存结果:',d1);if(!d1.success){console.error('保存超时时间失败:',d1);return showToast('保存超时时间失败','error')}console.log('保存域名...');const r2=await apiRequest('/api/cache/base-url',{method:'POST',body:JSON.stringify({base_url:baseUrl})});if(!r2){console.error('保存域名请求失败');return}const d2=await r2.json();console.log('域名保存结果:',d2);if(d2.success){showToast('缓存配置保存成功','success');console.log('等待配置文件写入完成...');await new Promise(r=>setTimeout(r,200));console.log('重新加载配置...');await loadCacheConfig()}else{console.error('保存域名失败:',d2);showToast('保存域名失败','error')}}catch(e){console.error('保存失败:',e);showToast('保存失败: '+e.message,'error')}},
         saveGenerationTimeout=async()=>{const imageTimeout=parseInt($('cfgImageTimeout').value)||300,videoTimeout=parseInt($('cfgVideoTimeout').value)||1500;console.log('保存生成超时配置:',{imageTimeout,videoTimeout});if(imageTimeout<60||imageTimeout>3600)return showToast('图片超时时间必须在 60-3600 秒之间','error');if(videoTimeout<60||videoTimeout>7200)return showToast('视频超时时间必须在 60-7200 秒之间','error');try{const r=await apiRequest('/api/generation/timeout',{method:'POST',body:JSON.stringify({image_timeout:imageTimeout,video_timeout:videoTimeout})});if(!r){console.error('保存请求失败');return}const d=await r.json();console.log('保存结果:',d);if(d.success){showToast('生成超时配置保存成功','success');await new Promise(r=>setTimeout(r,200));await loadGenerationTimeout()}else{console.error('保存失败:',d);showToast('保存失败','error')}}catch(e){console.error('保存失败:',e);showToast('保存失败: '+e.message,'error')}},
-        toggleCaptchaOptions=()=>{const method=$('cfgCaptchaMethod').value;$('yescaptchaOptions').style.display=method==='yescaptcha'?'block':'none';$('browserCaptchaOptions').classList.toggle('hidden',method!=='browser')},
+        toggleCaptchaOptions=()=>{const method=$('cfgCaptchaMethod').value;$('yescaptchaOptions').style.display=method==='yescaptcha'?'block':'none';$('capmonsterOptions').classList.toggle('hidden',method!=='capmonster');$('ezcaptchaOptions').classList.toggle('hidden',method!=='ezcaptcha');$('capsolverOptions').classList.toggle('hidden',method!=='capsolver');$('browserCaptchaOptions').classList.toggle('hidden',method!=='browser')},
         toggleBrowserProxyInput=()=>{const enabled=$('cfgBrowserProxyEnabled').checked;$('browserProxyUrlInput').classList.toggle('hidden',!enabled)},
-        loadCaptchaConfig=async()=>{try{console.log('开始加载验证码配置...');const r=await apiRequest('/api/captcha/config');if(!r){console.error('API请求失败');return}const d=await r.json();console.log('验证码配置数据:',d);$('cfgCaptchaMethod').value=d.captcha_method||'yescaptcha';$('cfgYescaptchaApiKey').value=d.yescaptcha_api_key||'';$('cfgYescaptchaBaseUrl').value=d.yescaptcha_base_url||'https://api.yescaptcha.com';$('cfgBrowserProxyEnabled').checked=d.browser_proxy_enabled||false;$('cfgBrowserProxyUrl').value=d.browser_proxy_url||'';toggleCaptchaOptions();toggleBrowserProxyInput();console.log('验证码配置加载成功')}catch(e){console.error('加载验证码配置失败:',e);showToast('加载验证码配置失败: '+e.message,'error')}},
-        saveCaptchaConfig=async()=>{const method=$('cfgCaptchaMethod').value,apiKey=$('cfgYescaptchaApiKey').value.trim(),baseUrl=$('cfgYescaptchaBaseUrl').value.trim(),browserProxyEnabled=$('cfgBrowserProxyEnabled').checked,browserProxyUrl=$('cfgBrowserProxyUrl').value.trim();console.log('保存验证码配置:',{method,apiKey,baseUrl,browserProxyEnabled,browserProxyUrl});try{const r=await apiRequest('/api/captcha/config',{method:'POST',body:JSON.stringify({captcha_method:method,yescaptcha_api_key:apiKey,yescaptcha_base_url:baseUrl,browser_proxy_enabled:browserProxyEnabled,browser_proxy_url:browserProxyUrl})});if(!r){console.error('保存请求失败');return}const d=await r.json();console.log('保存结果:',d);if(d.success){showToast('验证码配置保存成功','success');await new Promise(r=>setTimeout(r,200));await loadCaptchaConfig()}else{console.error('保存失败:',d);showToast(d.message||'保存失败','error')}}catch(e){console.error('保存失败:',e);showToast('保存失败: '+e.message,'error')}},
+        loadCaptchaConfig=async()=>{try{console.log('开始加载验证码配置...');const r=await apiRequest('/api/captcha/config');if(!r){console.error('API请求失败');return}const d=await r.json();console.log('验证码配置数据:',d);$('cfgCaptchaMethod').value=d.captcha_method||'yescaptcha';$('cfgYescaptchaApiKey').value=d.yescaptcha_api_key||'';$('cfgYescaptchaBaseUrl').value=d.yescaptcha_base_url||'https://api.yescaptcha.com';$('cfgCapmonsterApiKey').value=d.capmonster_api_key||'';$('cfgCapmonsterBaseUrl').value=d.capmonster_base_url||'https://api.capmonster.cloud';$('cfgEzcaptchaApiKey').value=d.ezcaptcha_api_key||'';$('cfgEzcaptchaBaseUrl').value=d.ezcaptcha_base_url||'https://api.ez-captcha.com';$('cfgCapsolverApiKey').value=d.capsolver_api_key||'';$('cfgCapsolverBaseUrl').value=d.capsolver_base_url||'https://api.capsolver.com';$('cfgBrowserProxyEnabled').checked=d.browser_proxy_enabled||false;$('cfgBrowserProxyUrl').value=d.browser_proxy_url||'';toggleCaptchaOptions();toggleBrowserProxyInput();console.log('验证码配置加载成功')}catch(e){console.error('加载验证码配置失败:',e);showToast('加载验证码配置失败: '+e.message,'error')}},
+        saveCaptchaConfig=async()=>{const method=$('cfgCaptchaMethod').value,yesApiKey=$('cfgYescaptchaApiKey').value.trim(),yesBaseUrl=$('cfgYescaptchaBaseUrl').value.trim(),capApiKey=$('cfgCapmonsterApiKey').value.trim(),capBaseUrl=$('cfgCapmonsterBaseUrl').value.trim(),ezApiKey=$('cfgEzcaptchaApiKey').value.trim(),ezBaseUrl=$('cfgEzcaptchaBaseUrl').value.trim(),solverApiKey=$('cfgCapsolverApiKey').value.trim(),solverBaseUrl=$('cfgCapsolverBaseUrl').value.trim(),browserProxyEnabled=$('cfgBrowserProxyEnabled').checked,browserProxyUrl=$('cfgBrowserProxyUrl').value.trim();console.log('保存验证码配置:',{method,yesApiKey,yesBaseUrl,capApiKey,capBaseUrl,ezApiKey,ezBaseUrl,solverApiKey,solverBaseUrl,browserProxyEnabled,browserProxyUrl});try{const r=await apiRequest('/api/captcha/config',{method:'POST',body:JSON.stringify({captcha_method:method,yescaptcha_api_key:yesApiKey,yescaptcha_base_url:yesBaseUrl,capmonster_api_key:capApiKey,capmonster_base_url:capBaseUrl,ezcaptcha_api_key:ezApiKey,ezcaptcha_base_url:ezBaseUrl,capsolver_api_key:solverApiKey,capsolver_base_url:solverBaseUrl,browser_proxy_enabled:browserProxyEnabled,browser_proxy_url:browserProxyUrl})});if(!r){console.error('保存请求失败');return}const d=await r.json();console.log('保存结果:',d);if(d.success){showToast('验证码配置保存成功','success');await new Promise(r=>setTimeout(r,200));await loadCaptchaConfig()}else{console.error('保存失败:',d);showToast(d.message||'保存失败','error')}}catch(e){console.error('保存失败:',e);showToast('保存失败: '+e.message,'error')}},
         loadPluginConfig=async()=>{try{const r=await apiRequest('/api/plugin/config');if(!r)return;const d=await r.json();if(d.success&&d.config){$('cfgPluginConnectionUrl').value=d.config.connection_url||'';$('cfgPluginConnectionToken').value=d.config.connection_token||'';$('cfgAutoEnableOnUpdate').checked=d.config.auto_enable_on_update||false}}catch(e){console.error('加���插件配置失败:',e);showToast('加载插件配置失败: '+e.message,'error')}},
         savePluginConfig=async()=>{const token=$('cfgPluginConnectionToken').value.trim();const autoEnable=$('cfgAutoEnableOnUpdate').checked;try{const r=await apiRequest('/api/plugin/config',{method:'POST',body:JSON.stringify({connection_token:token,auto_enable_on_update:autoEnable})});if(!r)return;const d=await r.json();if(d.success){showToast('插件配置保存成功','success');await loadPluginConfig()}else{showToast(d.message||'保存失败','error')}}catch(e){showToast('保存失败: '+e.message,'error')}},
         copyConnectionUrl=()=>{const url=$('cfgPluginConnectionUrl').value;if(!url){showToast('连接接口为空','error');return}navigator.clipboard.writeText(url).then(()=>showToast('连接接口已复制','success')).catch(()=>showToast('复制失败','error'))},
         copyConnectionToken=()=>{const token=$('cfgPluginConnectionToken').value;if(!token){showToast('连接Token为空','error');return}navigator.clipboard.writeText(token).then(()=>showToast('连接Token已复制','success')).catch(()=>showToast('复制失败','error'))},
+        generateRandomToken=()=>{const chars='ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';let token='';for(let i=0;i<32;i++){token+=chars.charAt(Math.floor(Math.random()*chars.length))}$('cfgPluginConnectionToken').value=token;showToast('随机Token已生成','success')},
         toggleATAutoRefresh=async()=>{try{const enabled=$('atAutoRefreshToggle').checked;const r=await apiRequest('/api/token-refresh/enabled',{method:'POST',body:JSON.stringify({enabled:enabled})});if(!r){$('atAutoRefreshToggle').checked=!enabled;return}const d=await r.json();if(d.success){showToast(enabled?'AT自动刷新已启用':'AT自动刷新已禁用','success')}else{showToast('操作失败: '+(d.detail||'未知错误'),'error');$('atAutoRefreshToggle').checked=!enabled}}catch(e){showToast('操作失败: '+e.message,'error');$('atAutoRefreshToggle').checked=!enabled}},
         loadATAutoRefreshConfig=async()=>{try{const r=await apiRequest('/api/token-refresh/config');if(!r)return;const d=await r.json();if(d.success&&d.config){$('atAutoRefreshToggle').checked=d.config.at_auto_refresh_enabled||false}else{console.error('AT自动刷新配置数据格式错误:',d)}}catch(e){console.error('加载AT自动刷新配置失败:',e)}},
         loadLogs=async()=>{try{const r=await apiRequest('/api/logs?limit=100');if(!r)return;const logs=await r.json();window.allLogs=logs;const tb=$('logsTableBody');tb.innerHTML=logs.map(l=>`<tr><td class="py-2.5 px-3">${l.operation}</td><td class="py-2.5 px-3"><span class="text-xs ${l.token_email?'text-blue-600':'text-muted-foreground'}">${l.token_email||'未知'}</span></td><td class="py-2.5 px-3"><span class="inline-flex items-center rounded px-2 py-0.5 text-xs ${l.status_code===200?'bg-green-50 text-green-700':'bg-red-50 text-red-700'}">${l.status_code}</span></td><td class="py-2.5 px-3">${l.duration.toFixed(2)}</td><td class="py-2.5 px-3 text-xs text-muted-foreground">${l.created_at?new Date(l.created_at).toLocaleString('zh-CN'):'-'}</td><td class="py-2.5 px-3"><button onclick="showLogDetail(${l.id})" class="inline-flex items-center justify-center rounded-md hover:bg-blue-50 hover:text-blue-700 h-7 px-2 text-xs">查看</button></td></tr>`).join('')}catch(e){console.error('加载日志失败:',e)}},