feat: 缓存批量下载 + 媒体文件在线预览 + 视频超分 + 多项增强

- 缓存管理：新增 ZIP 批量下载端点 + 单文件下载按钮 + 底部工具栏下载操作
- 媒体预览：FileResponse 设置 Content-Disposition: inline，浏览器直接播放视频/显示图片
- 视频超分：新增 upscale 工具模块
- 聊天处理器：重构流式响应逻辑，增强多模态处理
- NSFW 服务：扩展过滤和检测能力
- Token 管理：优化路由和并发控制
- 安全：.gitignore 排除 data/config.toml 防止敏感信息泄露

Author: WangXingFan

.gitignore

@@ -45,6 +45,7 @@ logs/
 *.log
 
 # Data
+data/config.toml
 data/*.json
 data/tmp/*
 data/.locks/*

README.md

@@ -70,6 +70,14 @@
 
 - 新增 **「刷新全部」** 按钮：一键刷新所有 Token 状态，无需手动全选
 
+---
+
+### 缓存管理增强
+
+- 新增 **批量下载**：勾选多个本地图片/视频文件后，点击底部工具栏「下载」按钮，服务端自动打包为 ZIP（`ZIP_STORED` 不压缩）一次性下载；仅选 1 个文件时直接下载，不打包
+- 新增 **单文件下载**：每行文件操作列新增下载图标，一键下载单个文件
+- 新增 **视频/图片在线预览**：浏览器打开文件链接可直接播放视频或显示图片，不再触发下载
+
 <br>
 
 ## 部署方式
@@ -140,7 +148,7 @@ docker compose up -d
 - **状态筛选**：按状态（正常/限流/失效）或 NSFW 状态筛选
 - **批量操作**：批量刷新、导出、删除、开启 NSFW
 - **配置管理**：在线修改系统配置
-- **缓存管理**：查看和清理媒体缓存
+- **缓存管理**：查看、清理和下载媒体缓存（支持批量下载图片/视频）
 - **Imagine 图片生成/编辑**：WebSocket/SSE 实时图片生成 + 图片编辑模式（二开增强）
 - **Video 视频生成**：可视化视频生成，支持图生视频（二开新增）
 - **Voice Live 陪聊**：LiveKit 语音会话

app/api/v1/admin.py

@@ -1689,6 +1689,72 @@ async def delete_local_cache_item_api(data: dict):
         raise HTTPException(status_code=500, detail=str(e))
 
 
+@router.post("/api/v1/admin/cache/download", dependencies=[Depends(verify_api_key)])
+async def download_cache_files_api(data: dict):
+    """Batch download local cache files as a ZIP archive (ZIP_STORED, no compression)."""
+    import zipfile
+    import tempfile
+    from datetime import datetime
+    from fastapi.responses import FileResponse
+    from starlette.background import BackgroundTask
+    from app.services.grok.services.assets import DownloadService
+
+    cache_type = data.get("type", "image")
+    names = data.get("names", [])
+
+    if not names or not isinstance(names, list):
+        raise HTTPException(status_code=400, detail="No files specified")
+
+    dl_service = DownloadService()
+    base_dir = dl_service.image_dir if cache_type == "image" else dl_service.video_dir
+
+    tmp = tempfile.NamedTemporaryFile(delete=False, suffix=".zip")
+    try:
+        packed = 0
+        with zipfile.ZipFile(tmp, "w", zipfile.ZIP_STORED) as zf:
+            for name in names:
+                if not name or ".." in name or "/" in name or "\\" in name or ":" in name:
+                    continue
+                file_path = base_dir / name
+                try:
+                    if file_path.resolve().parent != base_dir.resolve():
+                        continue
+                except (ValueError, OSError):
+                    continue
+                if file_path.exists() and file_path.is_file():
+                    zf.write(file_path, name)
+                    packed += 1
+        tmp.close()
+
+        if packed == 0:
+            os.unlink(tmp.name)
+            raise HTTPException(status_code=404, detail="No valid files found")
+
+        timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
+        zip_name = f"{cache_type}_{timestamp}.zip"
+
+        async def cleanup():
+            try:
+                os.unlink(tmp.name)
+            except Exception:
+                pass
+
+        return FileResponse(
+            tmp.name,
+            media_type="application/zip",
+            filename=zip_name,
+            background=BackgroundTask(cleanup),
+        )
+    except HTTPException:
+        raise
+    except Exception:
+        try:
+            os.unlink(tmp.name)
+        except Exception:
+            pass
+        raise HTTPException(status_code=500, detail="Failed to create ZIP archive")
+
+
 @router.post("/api/v1/admin/cache/online/clear", dependencies=[Depends(verify_api_key)])
 async def clear_online_cache_api(data: dict):
     """清理在线缓存"""

app/api/v1/chat.py

@@ -110,7 +110,11 @@ class ChatCompletionRequest(BaseModel):
     model: str = Field(..., description="模型名称")
     messages: List[MessageItem] = Field(..., description="消息数组")
     stream: Optional[bool] = Field(None, description="是否流式输出")
-    thinking: Optional[str] = Field(None, description="思考模式: enabled/disabled/None")
+    reasoning_effort: Optional[str] = Field(
+        None, description="推理强度: none/minimal/low/medium/high/xhigh"
+    )
+    temperature: Optional[float] = Field(0.8, description="采样温度: 0-2")
+    top_p: Optional[float] = Field(0.95, description="nucleus 采样: 0-1")
 
     # 视频生成配置
     video_config: Optional[VideoConfig] = Field(None, description="视频生成参数")
@@ -272,7 +276,7 @@ async def chat_completions(request: ChatCompletionRequest):
             model=request.model,
             messages=[msg.model_dump() for msg in request.messages],
             stream=resolved_stream,
-            thinking=request.thinking,
+            thinking=request.reasoning_effort,
             aspect_ratio=v_conf.aspect_ratio,
             video_length=v_conf.video_length,
             resolution=v_conf.resolution_name,
@@ -283,7 +287,9 @@ async def chat_completions(request: ChatCompletionRequest):
             model=request.model,
             messages=[msg.model_dump() for msg in request.messages],
             stream=resolved_stream,
-            thinking=request.thinking,
+            reasoning_effort=request.reasoning_effort,
+            temperature=request.temperature,
+            top_p=request.top_p,
         )
 
     if isinstance(result, dict):

app/api/v1/files.py

@@ -17,6 +17,12 @@
 IMAGE_DIR = BASE_DIR / "image"
 VIDEO_DIR = BASE_DIR / "video"
 
+# 浏览器直接预览，不触发下载
+_INLINE_HEADERS = {
+    "Content-Disposition": "inline",
+    "Cache-Control": "public, max-age=31536000, immutable",
+}
+
 
 def _resolve_media_path(base_dir: Path, filename: str) -> Path:
     """Resolve a safe media path under the target directory."""
@@ -55,11 +61,10 @@ async def get_image(filename: str):
             elif file_path.suffix.lower() == ".webp":
                 content_type = "image/webp"
 
-            # 增加缓存头，支持高并发场景下的浏览器/CDN缓存
             return FileResponse(
                 file_path,
                 media_type=content_type,
-                headers={"Cache-Control": "public, max-age=31536000, immutable"},
+                headers=_INLINE_HEADERS,
             )
 
     logger.warning(f"Image not found: {filename}")
@@ -78,7 +83,7 @@ async def get_video(filename: str):
             return FileResponse(
                 file_path,
                 media_type="video/mp4",
-                headers={"Cache-Control": "public, max-age=31536000, immutable"},
+                headers=_INLINE_HEADERS,
             )
 
     logger.warning(f"Video not found: {filename}")

app/services/grok/models/model.py

@@ -119,6 +119,13 @@ class ModelService:
             cost=Cost.HIGH,
             display_name="GROK-4.1-THINKING",
         ),
+        ModelInfo(
+            model_id="grok-4.20-beta",
+            grok_model="grok-420",
+            model_mode="MODEL_MODE_GROK_420",
+            cost=Cost.LOW,
+            display_name="GROK-4.20-BETA",
+        ),
         ModelInfo(
             model_id="grok-imagine-1.0",
             grok_model="grok-3",