ci: trigger verification

TS6133: 'Tag' is declared but its value is never read.
Phase 3 Mock 替换后遗留的未使用 import。

.env.production.example

@@ -5,7 +5,6 @@ APP_ENV=production
 ENVIRONMENT=production
 DEBUG=false
 USE_IN_MEMORY_DB=false
-LOG_LEVEL=WARNING
 
 # ==================== 数据库（必须修改）====================
 DATABASE_URL=postgresql://prod_user:CHANGE_THIS_PASSWORD@db-prod:5432/xiaoxia_prod

.gitea/workflows/ci-cd.yml

@@ -19,6 +19,10 @@ on:
 permissions:
   contents: read
 
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
 jobs:
   validate:
     name: Validate Code Quality And Tests
@@ -88,9 +92,9 @@ jobs:
         shell: sh
         run: |
           set -eu
-          python3 -m pip install -q -r requirements-base.txt
-          python3 -m pip install -q -r requirements.txt
-          python3 -m pip install -q -r requirements-dev.txt
+          python3 -m pip install --break-system-packages -q -r requirements-base.txt
+          python3 -m pip install --break-system-packages -q -r requirements.txt
+          python3 -m pip install --break-system-packages -q -r requirements-dev.txt
           python3 -m black --version
           python3 -m isort --version-number
           python3 -m flake8 --version
@@ -217,9 +221,9 @@ jobs:
         shell: sh
         run: |
           set -eu
-          python3 -m pip install -q -r requirements-base.txt
-          python3 -m pip install -q -r requirements.txt
-          python3 -m pip install -q -r requirements-dev.txt
+          python3 -m pip install --break-system-packages -q -r requirements-base.txt
+          python3 -m pip install --break-system-packages -q -r requirements.txt
+          python3 -m pip install --break-system-packages -q -r requirements-dev.txt
           pytest --version
 
       - name: Run unit tests with coverage
@@ -316,9 +320,9 @@ jobs:
         shell: sh
         run: |
           set -eu
-          python3 -m pip install -q -r requirements-base.txt
-          python3 -m pip install -q -r requirements.txt
-          python3 -m pip install -q -r requirements-dev.txt
+          python3 -m pip install --break-system-packages -q -r requirements-base.txt
+          python3 -m pip install --break-system-packages -q -r requirements.txt
+          python3 -m pip install --break-system-packages -q -r requirements-dev.txt
           pytest --version
 
       - name: Start Redis
@@ -390,7 +394,7 @@ jobs:
         shell: sh
         run: |
           set -eu
-          pip install -q pytest-rerunfailures
+          pip install --break-system-packages -q pytest-rerunfailures
           PYTHONPATH="$PWD/apps/api:$PWD" python3 -m coverage run --append \
             --source=apps/api/app,packages \
             --omit="*/migrations/*,*/tests/*,*/test_*.py,*/site-packages/*" \

README.md

@@ -263,3 +263,5 @@ pytest --cov=packages --cov-report=html
 ---
 
 **License**: MIT
+
+<!-- ci-trigger-1783939777 -->

apps/api/app/api/router.py

@@ -4,19 +4,14 @@ from app.api.routes.assets import router as assets_router
 from app.api.routes.auth import router as auth_router
 from app.api.routes.chunked_upload import router as chunked_upload_router
 from app.api.routes.classification_jobs import router as classification_jobs_router
-from app.api.routes.dashboard import router as dashboard_router
 from app.api.routes.duplication import router as duplication_router
 from app.api.routes.edit_plans import router as edit_plans_router
-from app.api.routes.edit_templates import router as edit_templates_router
 from app.api.routes.feature_flags import router as feature_flags_router
-from app.api.routes.generated_videos import router as generated_videos_router
 from app.api.routes.generation_tasks import router as generation_tasks_router
 from app.api.routes.health import router as health_check_router
 from app.api.routes.ingest_jobs import router as ingest_jobs_router
 from app.api.routes.internal_render import router as internal_render_router
-from app.api.routes.jobs import router as jobs_router
 from app.api.routes.projects import router as projects_router
-from app.api.routes.recipes import router as recipes_router
 from app.api.routes.subscription import router as subscription_router
 from app.api.routes.tags import router as tags_router
 from app.api.routes.task_center import router as task_center_router
@@ -89,15 +84,6 @@ api_router.include_router(
     prefix="/generation",
     tags=["Generation"],
 )
-api_router.include_router(
-    jobs_router,
-    tags=["Job"],
-)
-api_router.include_router(
-    generated_videos_router,
-    prefix="/generated-videos",
-    tags=["GeneratedVideo"],
-)
 api_router.include_router(
     titles_router,
     prefix="/titles",
@@ -123,26 +109,11 @@ api_router.include_router(
     prefix="/subscription",
     tags=["Subscription"],
 )
-api_router.include_router(
-    recipes_router,
-    prefix="/recipes",
-    tags=["Recipe"],
-)
 api_router.include_router(
     templates_router,
     prefix="/templates",
     tags=["Template"],
 )
-api_router.include_router(
-    dashboard_router,
-    prefix="/dashboard",
-    tags=["Dashboard"],
-)
-api_router.include_router(
-    edit_templates_router,
-    prefix="/edit-templates",
-    tags=["EditTemplate"],
-)
 api_router.include_router(
     edit_plans_router,
     prefix="/edit-plans",

apps/api/app/api/routes/dashboard.py

@@ -1,92 +0,0 @@
-from typing import Any
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.dependencies import (
-    get_asset_repository,
-    get_generation_task_repository,
-    get_project_repository,
-    get_title_library_repository,
-    get_voice_library_repository,
-)
-from app.schemas.dashboard import DashboardOverviewResponse, RecentTaskItem, SubscriptionInfo
-from fastapi import APIRouter, Depends
-
-router = APIRouter()
-
-
-def _status_value(status) -> str:
-    return status.value if hasattr(status, "value") else str(status)
-
-
-def _generation_step(status: str) -> str:
-    if status == "pending":
-        return "等待 Worker 执行"
-    if status == "running":
-        return "正在生成成片"
-    if status == "completed":
-        return "生成完成"
-    if status == "failed":
-        return "生成失败"
-    return status
-
-
-@router.get("/overview", response_model=DashboardOverviewResponse)
-def get_dashboard_overview(
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    project_repository: Any = Depends(get_project_repository),
-    asset_repository: Any = Depends(get_asset_repository),
-    generation_task_repository: Any = Depends(get_generation_task_repository),
-    title_library_repository: Any = Depends(get_title_library_repository),
-    voice_library_repository: Any = Depends(get_voice_library_repository),
-) -> DashboardOverviewResponse:
-    """Dashboard 概览：用户级汇总数据。"""
-    user_id = authenticated_user.user.id
-
-    # 获取用户可访问的所有 project
-    projects = project_repository.find_accessible_projects(user_id)
-    project_ids = [p.id for p in projects]
-
-    # 素材统计
-    total_assets = asset_repository.count_by_project_ids(project_ids)
-    used_storage_bytes = asset_repository.sum_storage_by_project_ids(project_ids)
-
-    # 标题库 / 配音库统计
-    total_titles = title_library_repository.count_by_user(user_id)
-    total_voices = voice_library_repository.count_by_user(user_id)
-
-    # 生成任务统计
-    total_tasks = generation_task_repository.count_by_user(user_id)
-
-    # 最近任务（SQL 层 LIMIT 5）
-    recent = generation_task_repository.list_recent_by_user(user_id, limit=5)
-    recent_tasks = []
-    for task in recent:
-        s = _status_value(task.status)
-        recent_tasks.append(
-            RecentTaskItem(
-                id=task.id,
-                task_type="generation",
-                status=s,
-                current_step=_generation_step(s),
-                error_message=task.error_message or "",
-                updated_at=task.completed_at or task.started_at or task.created_at,
-            )
-        )
-
-    # 订阅信息
-    user = authenticated_user.user
-    subscription = SubscriptionInfo(
-        plan=getattr(user, "subscription_plan", "free") or "free",
-        is_active=getattr(user, "subscription_status", "") == "active",
-    )
-
-    return DashboardOverviewResponse(
-        total_assets=total_assets,
-        used_storage_bytes=used_storage_bytes,
-        total_titles=total_titles,
-        total_voices=total_voices,
-        total_tasks=total_tasks,
-        total_products=len(projects),
-        subscription=subscription,
-        recent_tasks=recent_tasks,
-    )

apps/api/app/api/routes/edit_templates.py

@@ -1,289 +0,0 @@
-"""模板管理 API — Phase 8 模板编排引擎.
-
-RESTful CRUD for EditTemplate:
-- GET  /api/v1/edit-templates      列表（分页 + 类型筛选）
-- GET  /api/v1/edit-templates/{id} 详情
-- POST /api/v1/edit-templates      创建（管理员）
-- PUT  /api/v1/edit-templates/{id} 更新
-- DELETE /api/v1/edit-templates/{id} 删除（软删除 → inactive）
-
-业务逻辑委托给 EditTemplateService 服务层。
-"""
-
-from __future__ import annotations
-
-import logging
-from datetime import datetime
-from typing import Any, List, Optional
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.dependencies import get_db_session
-from app.services import EditTemplateService
-from fastapi import APIRouter, Depends, HTTPException, Query, status
-from fastapi.responses import Response
-from pydantic import BaseModel, Field
-from sqlalchemy.orm import Session
-
-from packages.domain.config_schemas import normalize_template_config
-from packages.domain.edit_template import EditTemplate, EditTemplateStatus
-
-logger = logging.getLogger(__name__)
-
-router = APIRouter()
-
-
-# ── Pydantic Schemas ─────────────────────────────────────────────────────────
-
-
-class EditTemplateCreateRequest(BaseModel):
-    """创建模板请求体"""
-
-    name: str = Field(..., min_length=1, max_length=200, description="模板名称")
-    description: str = Field(default="", max_length=2000, description="模板描述")
-    template_type: str = Field(default="default", max_length=50, description="模板类型")
-    editing_mode: str = Field(
-        default="one_take", max_length=20, description="剪辑模式: one_take/pip/voice_over/voice_pip"
-    )
-    config: dict[str, Any] = Field(default_factory=dict, description="模板配置 (JSON)")
-    preview_url: str = Field(default="", max_length=500, description="预览地址")
-    sort_weight: int = Field(default=0, ge=0, le=9999, description="排序权重")
-
-
-class EditTemplateUpdateRequest(BaseModel):
-    """更新模板请求体"""
-
-    name: Optional[str] = Field(default=None, min_length=1, max_length=200, description="模板名称")
-    description: Optional[str] = Field(default=None, max_length=2000, description="模板描述")
-    template_type: Optional[str] = Field(default=None, max_length=50, description="模板类型")
-    editing_mode: Optional[str] = Field(
-        default=None, max_length=20, description="剪辑模式: one_take/pip/voice_over/voice_pip"
-    )
-    config: Optional[dict[str, Any]] = Field(default=None, description="模板配置 (JSON)")
-    preview_url: Optional[str] = Field(default=None, max_length=500, description="预览地址")
-    sort_weight: Optional[int] = Field(default=None, ge=0, le=9999, description="排序权重")
-    status: Optional[str] = Field(default=None, description="状态: active / inactive")
-
-
-class EditTemplateResponse(BaseModel):
-    """模板响应体"""
-
-    id: str
-    name: str
-    description: str
-    template_type: str
-    editing_mode: str
-    config: dict[str, Any]
-    preview_url: str
-    sort_weight: int
-    status: str
-    created_at: datetime
-    updated_at: datetime
-
-    model_config = {"from_attributes": True}
-
-
-class EditTemplateListResponse(BaseModel):
-    """模板列表响应体"""
-
-    items: List[EditTemplateResponse]
-    total: int
-    page: int
-    page_size: int
-
-
-# ── Helpers ───────────────────────────────────────────────────────────────────
-
-
-def _require_admin(current_user: AuthenticatedUser) -> None:
-    """校验当前用户是否为管理员，非管理员返回 403"""
-    if not getattr(current_user.user, "is_admin", False):
-        raise HTTPException(
-            status_code=status.HTTP_403_FORBIDDEN,
-            detail="仅管理员可执行此操作",
-        )
-
-
-def _to_response(t: EditTemplate) -> EditTemplateResponse:
-    return EditTemplateResponse(
-        id=t.id,
-        name=t.name,
-        description=t.description,
-        template_type=t.template_type,
-        editing_mode=t.editing_mode,
-        config=t.config,
-        preview_url=t.preview_url,
-        sort_weight=t.sort_weight,
-        status=t.status.value if hasattr(t.status, "value") else t.status,
-        created_at=t.created_at,
-        updated_at=t.updated_at,
-    )
-
-
-# ── Routes ────────────────────────────────────────────────────────────────────
-
-
-@router.get("", response_model=EditTemplateListResponse)
-def list_templates(
-    page: int = Query(default=1, ge=1, description="页码"),
-    page_size: int = Query(default=20, ge=1, le=100, description="每页数量"),
-    template_type: Optional[str] = Query(default=None, description="按类型筛选"),
-    status_filter: Optional[str] = Query(
-        default=None,
-        alias="status",
-        description="按状态筛选: active / inactive",
-    ),
-    db: Session = Depends(get_db_session),
-    current_user: AuthenticatedUser = Depends(get_current_user),
-) -> EditTemplateListResponse:
-    """获取模板列表（支持分页、按类型/状态筛选）"""
-    svc = EditTemplateService(db)
-
-    # 解析状态筛选
-    status_enum: Optional[EditTemplateStatus] = None
-    if status_filter:
-        try:
-            status_enum = EditTemplateStatus(status_filter)
-        except ValueError:
-            raise HTTPException(
-                status_code=status.HTTP_400_BAD_REQUEST,
-                detail=f"无效的状态值: {status_filter}，可选值: active, inactive",
-            )
-
-    skip = (page - 1) * page_size
-    templates = svc.list_templates(
-        template_type=template_type,
-        status=status_enum,
-        skip=skip,
-        limit=page_size,
-    )
-    total = svc.count_templates(
-        template_type=template_type,
-        status=status_enum,
-    )
-
-    return EditTemplateListResponse(
-        items=[_to_response(t) for t in templates],
-        total=total,
-        page=page,
-        page_size=page_size,
-    )
-
-
-@router.get("/{template_id}", response_model=EditTemplateResponse)
-def get_template(
-    template_id: str,
-    db: Session = Depends(get_db_session),
-    current_user: AuthenticatedUser = Depends(get_current_user),
-) -> EditTemplateResponse:
-    """获取单个模板详情"""
-    svc = EditTemplateService(db)
-    try:
-        template = svc.get_template_or_raise(template_id)
-    except ValueError as exc:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=str(exc),
-        )
-    return _to_response(template)
-
-
-@router.post("", response_model=EditTemplateResponse, status_code=status.HTTP_201_CREATED)
-def create_template(
-    body: EditTemplateCreateRequest,
-    db: Session = Depends(get_db_session),
-    current_user: AuthenticatedUser = Depends(get_current_user),
-) -> EditTemplateResponse:
-    """创建模板（管理员）"""
-    _require_admin(current_user)
-    svc = EditTemplateService(db)
-    # 标准化 config，填充 cover/title/subtitle/bgm 默认值
-    normalized_config = normalize_template_config(body.config)
-    try:
-        created = svc.create_template(
-            name=body.name,
-            description=body.description,
-            template_type=body.template_type,
-            editing_mode=body.editing_mode,
-            config=normalized_config,
-            preview_url=body.preview_url,
-            sort_weight=body.sort_weight,
-        )
-    except ValueError as exc:
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST,
-            detail=str(exc),
-        )
-    logger.info("创建模板: id=%s name=%s by user=%s", created.id, created.name, current_user.user.id)
-    return _to_response(created)
-
-
-@router.put("/{template_id}", response_model=EditTemplateResponse)
-def update_template(
-    template_id: str,
-    body: EditTemplateUpdateRequest,
-    db: Session = Depends(get_db_session),
-    current_user: AuthenticatedUser = Depends(get_current_user),
-) -> EditTemplateResponse:
-    """更新模板"""
-    _require_admin(current_user)
-    svc = EditTemplateService(db)
-
-    # 解析状态
-    status_enum: Optional[EditTemplateStatus] = None
-    if body.status is not None:
-        try:
-            status_enum = EditTemplateStatus(body.status)
-        except ValueError:
-            raise HTTPException(
-                status_code=status.HTTP_400_BAD_REQUEST,
-                detail=f"无效的状态值: {body.status}，可选值: active, inactive",
-            )
-
-    # 标准化 config（如果提供了）
-    config_to_update = normalize_template_config(body.config) if body.config is not None else None
-
-    try:
-        result = svc.update_template(
-            template_id,
-            name=body.name,
-            description=body.description,
-            template_type=body.template_type,
-            editing_mode=body.editing_mode,
-            config=config_to_update,
-            preview_url=body.preview_url,
-            sort_weight=body.sort_weight,
-            status=status_enum,
-        )
-    except ValueError as exc:
-        err_msg = str(exc)
-        if "不存在" in err_msg:
-            raise HTTPException(
-                status_code=status.HTTP_404_NOT_FOUND,
-                detail=err_msg,
-            )
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST,
-            detail=err_msg,
-        )
-    logger.info("更新模板: id=%s by user=%s", template_id, current_user.user.id)
-    return _to_response(result)
-
-
-@router.delete("/{template_id}", status_code=status.HTTP_204_NO_CONTENT, response_model=None)
-def delete_template(
-    template_id: str,
-    db: Session = Depends(get_db_session),
-    current_user: AuthenticatedUser = Depends(get_current_user),
-) -> Response:
-    """删除模板（软删除 → 设为 inactive）"""
-    _require_admin(current_user)
-    svc = EditTemplateService(db)
-    try:
-        svc.deactivate_template(template_id)
-    except ValueError as exc:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=str(exc),
-        )
-    logger.info("删除模板(软删除): id=%s by user=%s", template_id, current_user.user.id)
-    return Response(status_code=204)

apps/api/app/api/routes/feature_flags.py

@@ -23,7 +23,6 @@ from fastapi import APIRouter, Depends, HTTPException, Query, status
 from pydantic import BaseModel, Field
 
 from packages.adapters.redis.feature_flag_store import (
-    FEATURE_FLAG_REDIS_PREFIX,
     FeatureFlagConfig,
     RedisFeatureFlagStore,
 )

apps/api/app/api/routes/generated_videos.py

@@ -1,123 +0,0 @@
-from typing import Any
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.core.storage import OSSStorageService, get_storage_service
-from app.dependencies import get_generated_video_repository, get_project_repository
-from app.schemas.generated_video import (
-    GeneratedVideoDownloadUrlResponse,
-    GeneratedVideoResponse,
-    ListGeneratedVideosResponse,
-    UpdateGeneratedVideoReviewRequest,
-)
-from fastapi import APIRouter, Depends, HTTPException, Query
-
-from packages.application import (
-    GetGeneratedVideoDownloadUrlUseCase,
-    GetGeneratedVideoUseCase,
-    ListGeneratedVideosUseCase,
-)
-
-router = APIRouter()
-
-
-def _to_generated_video_response(item, download_url: str | None = None) -> GeneratedVideoResponse:
-    return GeneratedVideoResponse(
-        id=item.id,
-        project_id=item.project_id,
-        generation_task_id=item.generation_task_id,
-        name=item.name,
-        file_url=item.file_url,
-        file_size=item.file_size,
-        duration=item.duration,
-        thumbnail_url=item.thumbnail_url,
-        width=item.width,
-        height=item.height,
-        fps=item.fps,
-        status=item.status,
-        review_status=item.review_status,
-        generation_params=item.generation_params,
-        download_url=download_url,
-    )
-
-
-@router.get("", response_model=ListGeneratedVideosResponse)
-def list_generated_videos(
-    project_id: str | None = Query(None),
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    generated_video_repository: Any = Depends(get_generated_video_repository),
-    project_repository: Any = Depends(get_project_repository),
-    storage_service: OSSStorageService = Depends(get_storage_service),
-) -> ListGeneratedVideosResponse:
-    user_id = authenticated_user.user.id
-    use_case = ListGeneratedVideosUseCase(generated_video_repository)
-
-    if project_id:
-        # If project_id provided, check access and filter by project
-        project = project_repository.find_by_id(project_id)
-        if project is None:
-            raise HTTPException(status_code=404, detail=f"Project {project_id} not found")
-        items = use_case.execute(project_id)
-    else:
-        # If no project_id, list all videos from accessible projects
-        accessible_projects = project_repository.find_accessible_projects(user_id)
-        all_items = []
-        for proj in accessible_projects:
-            all_items.extend(use_case.execute(proj.id))
-        items = all_items
-
-    # Generate download URLs for each video
-    responses = []
-    for item in items:
-        download_url = storage_service.get_download_url(item.file_url)
-        responses.append(_to_generated_video_response(item, download_url=download_url))
-    return ListGeneratedVideosResponse(items=responses)
-
-
-@router.get("/{video_id}", response_model=GeneratedVideoResponse)
-def get_generated_video(
-    video_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    generated_video_repository: Any = Depends(get_generated_video_repository),
-    storage_service: OSSStorageService = Depends(get_storage_service),
-) -> GeneratedVideoResponse:
-    use_case = GetGeneratedVideoUseCase(generated_video_repository)
-    item = use_case.execute(video_id)
-    if item is None:
-        raise HTTPException(status_code=404, detail=f"GeneratedVideo {video_id} not found")
-    download_url = storage_service.get_download_url(item.file_url)
-    return _to_generated_video_response(item, download_url=download_url)
-
-
-@router.patch("/{video_id}/review", response_model=GeneratedVideoResponse)
-def update_generated_video_review_status(
-    video_id: str,
-    request: UpdateGeneratedVideoReviewRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    generated_video_repository: Any = Depends(get_generated_video_repository),
-    storage_service: OSSStorageService = Depends(get_storage_service),
-) -> GeneratedVideoResponse:
-    video = generated_video_repository.get(video_id)
-    if video is None:
-        raise HTTPException(status_code=404, detail=f"GeneratedVideo {video_id} not found")
-    video.review_status = request.review_status
-    updated = generated_video_repository.update(video)
-    download_url = storage_service.get_download_url(updated.file_url)
-    return _to_generated_video_response(updated, download_url=download_url)
-
-
-@router.get("/{video_id}/download-url", response_model=GeneratedVideoDownloadUrlResponse)
-def get_generated_video_download_url(
-    video_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    generated_video_repository: Any = Depends(get_generated_video_repository),
-    storage_service: OSSStorageService = Depends(get_storage_service),
-) -> GeneratedVideoDownloadUrlResponse:
-    video = generated_video_repository.get(video_id)
-    if video is None:
-        raise HTTPException(status_code=404, detail=f"GeneratedVideo {video_id} not found")
-    use_case = GetGeneratedVideoDownloadUrlUseCase(generated_video_repository)
-    file_url = use_case.execute(video_id)
-    if file_url is None:
-        raise HTTPException(status_code=404, detail=f"GeneratedVideo {video_id} not found")
-    download_url = storage_service.get_download_url(file_url)
-    return GeneratedVideoDownloadUrlResponse(video_id=video_id, download_url=download_url)

apps/api/app/api/routes/generation_tasks.py

@@ -10,7 +10,6 @@ from app.core.task_enqueue import (
     USER_PENDING_LIMIT,
     GlobalQueueFull,
     UserPendingLimitExceeded,
-    check_queue_limits,
     safe_enqueue_generation_task,
 )
 from app.dependencies import (

apps/api/app/api/routes/jobs.py

@@ -1,325 +0,0 @@
-"""Job API 路由 — Phase 8 任务 2.10.
-
-提供统一异步任务管理 RESTful 接口：
-- POST   /api/v1/jobs                        创建任务
-- GET    /api/v1/jobs/{job_id}                任务详情
-- GET    /api/v1/projects/{project_id}/jobs   项目任务列表
-- GET    /api/v1/projects/{project_id}/jobs/stats  任务统计
-- PUT    /api/v1/jobs/{job_id}/progress       更新进度
-- POST   /api/v1/jobs/{job_id}/complete       标记完成
-- POST   /api/v1/jobs/{job_id}/fail           标记失败
-- POST   /api/v1/jobs/{job_id}/retry          重试任务
-- POST   /api/v1/jobs/{job_id}/cancel         取消任务
-- POST   /api/v1/jobs/{job_id}/submit         提交执行
-"""
-
-from __future__ import annotations
-
-import logging
-from typing import Any
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.core.celery_app import celery_app
-from app.dependencies import get_job_repository, get_project_repository
-from app.schemas.job import (
-    CompleteJobRequest,
-    CreateJobRequest,
-    FailJobRequest,
-    JobResponse,
-    JobStatisticsResponse,
-    ListJobsResponse,
-    UpdateProgressRequest,
-    job_to_response,
-)
-from fastapi import APIRouter, Depends, HTTPException, Query, status
-
-from packages.application.jobs import (
-    CancelJobUseCase,
-    CompleteJobCommand,
-    CompleteJobUseCase,
-    CreateJobCommand,
-    CreateJobUseCase,
-    FailJobCommand,
-    FailJobUseCase,
-    GetJobStatisticsUseCase,
-    GetJobUseCase,
-    ListJobsUseCase,
-    RetryJobUseCase,
-    SubmitJobUseCase,
-    UpdateJobProgressCommand,
-    UpdateJobProgressUseCase,
-)
-from packages.domain.job import JobType
-
-from app.api.routes._helpers import check_project_access
-
-logger = logging.getLogger(__name__)
-
-router = APIRouter()
-
-# 任务类型 → Celery task name 映射
-_JOB_TYPE_TO_CELERY_TASK: dict[str, str] = {
-    JobType.VIDEO_COMPOSE: "worker.compose_video",
-    JobType.RENDER_EDIT_PLAN: "worker.render_edit_plan",
-    JobType.ASSET_INGEST: "worker.ingest_asset",
-    JobType.CLASSIFICATION: "worker.classify_asset",
-    JobType.VOICE_EXTRACTION: "worker.extract_voice",
-    JobType.GENERATION: "worker.generate_video",
-}
-
-
-# ── 创建任务 ──────────────────────────────────────────────────────────────────
-
-
-@router.post("/jobs", response_model=JobResponse, status_code=status.HTTP_201_CREATED)
-def create_job(
-    request: CreateJobRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-    project_repository: Any = Depends(get_project_repository),
-) -> JobResponse:
-    """创建异步任务。
-
-    创建后任务处于 pending 状态，需要调用 /submit 提交执行。
-    """
-    check_project_access(request.project_id, authenticated_user.user.id, project_repository)
-
-    # 校验 job_type
-    try:
-        JobType(request.job_type)
-    except ValueError:
-        raise HTTPException(
-            status_code=400,
-            detail=f"不支持的任务类型: {request.job_type}，" f"可选值: {[t.value for t in JobType]}",
-        )
-
-    use_case = CreateJobUseCase(job_repo)
-    job = use_case.execute(
-        CreateJobCommand(
-            project_id=request.project_id,
-            job_type=request.job_type,
-            payload=request.payload,
-            source_id=request.source_id,
-            created_by_user_id=authenticated_user.user.id,
-            max_retries=request.max_retries,
-        )
-    )
-
-    return job_to_response(job)
-
-
-# ── 提交执行 ──────────────────────────────────────────────────────────────────
-
-
-@router.post("/jobs/{job_id}/submit", response_model=JobResponse)
-def submit_job(
-    job_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """提交任务执行。
-
-    将任务状态从 pending 切换为 running，并 dispatch Celery 异步任务。
-    """
-    # 权限检查：先获取任务并验证权限，再执行状态变更
-    job = job_repo.get(job_id)
-    if job is None:
-        raise HTTPException(status_code=404, detail=f"Job {job_id} not found")
-    if job.created_by_user_id and job.created_by_user_id != authenticated_user.user.id:
-        raise HTTPException(status_code=403, detail="Access denied to this job")
-
-    use_case = SubmitJobUseCase(job_repo)
-
-    try:
-        job = use_case.execute(job_id)
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    # Dispatch Celery 任务
-    celery_task_name = _JOB_TYPE_TO_CELERY_TASK.get(job.job_type.value)
-    if celery_task_name:
-        result = celery_app.send_task(celery_task_name, args=[job.id], kwargs=job.payload)
-        job.celery_task_id = result.id
-        job_repo.update(job)
-        logger.info("已提交 Celery 任务: job_id=%s celery_task_id=%s", job.id, result.id)
-
-    return job_to_response(job)
-
-
-# ── 查询接口 ──────────────────────────────────────────────────────────────────
-
-
-@router.get("/jobs/{job_id}", response_model=JobResponse)
-def get_job(
-    job_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """获取任务详情。"""
-    use_case = GetJobUseCase(job_repo)
-    job = use_case.execute(job_id)
-    if job is None:
-        raise HTTPException(status_code=404, detail=f"Job {job_id} not found")
-    return job_to_response(job)
-
-
-@router.get("/projects/{project_id}/jobs", response_model=ListJobsResponse)
-def list_project_jobs(
-    project_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-    project_repository: Any = Depends(get_project_repository),
-    job_type: str | None = Query(default=None, description="按任务类型过滤"),
-    status_filter: str | None = Query(default=None, alias="status", description="按状态过滤"),
-    limit: int = Query(default=50, ge=1, le=200),
-    offset: int = Query(default=0, ge=0),
-) -> ListJobsResponse:
-    """获取项目下的任务列表。"""
-    check_project_access(project_id, authenticated_user.user.id, project_repository)
-
-    use_case = ListJobsUseCase(job_repo)
-    jobs = use_case.execute(
-        project_id=project_id,
-        job_type=job_type,
-        status=status_filter,
-        limit=limit,
-        offset=offset,
-    )
-    items = [job_to_response(j) for j in jobs]
-    return ListJobsResponse(items=items, total=len(items))
-
-
-@router.get("/projects/{project_id}/jobs/stats", response_model=JobStatisticsResponse)
-def get_job_statistics(
-    project_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-    project_repository: Any = Depends(get_project_repository),
-) -> JobStatisticsResponse:
-    """获取项目任务统计摘要。"""
-    check_project_access(project_id, authenticated_user.user.id, project_repository)
-
-    use_case = GetJobStatisticsUseCase(job_repo)
-    stats = use_case.execute(project_id)
-    return JobStatisticsResponse(**stats)
-
-
-# ── 进度更新 ──────────────────────────────────────────────────────────────────
-
-
-@router.put("/jobs/{job_id}/progress", response_model=JobResponse)
-def update_job_progress(
-    job_id: str,
-    request: UpdateProgressRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """更新任务进度。"""
-    use_case = UpdateJobProgressUseCase(job_repo)
-
-    try:
-        job = use_case.execute(
-            UpdateJobProgressCommand(
-                job_id=job_id,
-                progress=request.progress,
-                current_stage=request.current_stage,
-            )
-        )
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    return job_to_response(job)
-
-
-# ── 完成 / 失败 ────────────────────────────────────────────────────────────────
-
-
-@router.post("/jobs/{job_id}/complete", response_model=JobResponse)
-def complete_job(
-    job_id: str,
-    request: CompleteJobRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """标记任务完成。"""
-    use_case = CompleteJobUseCase(job_repo)
-
-    try:
-        job = use_case.execute(CompleteJobCommand(job_id=job_id, result=request.result))
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    return job_to_response(job)
-
-
-@router.post("/jobs/{job_id}/fail", response_model=JobResponse)
-def fail_job(
-    job_id: str,
-    request: FailJobRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """标记任务失败。"""
-    use_case = FailJobUseCase(job_repo)
-
-    try:
-        job = use_case.execute(FailJobCommand(job_id=job_id, error_message=request.error_message))
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    return job_to_response(job)
-
-
-# ── 重试 / 取消 ────────────────────────────────────────────────────────────────
-
-
-@router.post("/jobs/{job_id}/retry", response_model=JobResponse)
-def retry_job(
-    job_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """重试失败任务。
-
-    将任务重置为 pending，retry_count + 1，但不自动 dispatch。
-    需要再次调用 /submit 提交执行。
-    """
-    # 权限检查：先获取任务并验证权限，再执行状态变更
-    job = job_repo.get(job_id)
-    if job is None:
-        raise HTTPException(status_code=404, detail=f"Job {job_id} not found")
-    if job.created_by_user_id and job.created_by_user_id != authenticated_user.user.id:
-        raise HTTPException(status_code=403, detail="Access denied to this job")
-
-    use_case = RetryJobUseCase(job_repo)
-
-    try:
-        job = use_case.execute(job_id)
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    return job_to_response(job)
-
-
-@router.post("/jobs/{job_id}/cancel", response_model=JobResponse)
-def cancel_job(
-    job_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    job_repo: Any = Depends(get_job_repository),
-) -> JobResponse:
-    """取消任务。"""
-    # 权限检查：先获取任务并验证权限，再执行状态变更
-    job = job_repo.get(job_id)
-    if job is None:
-        raise HTTPException(status_code=404, detail=f"Job {job_id} not found")
-    if job.created_by_user_id and job.created_by_user_id != authenticated_user.user.id:
-        raise HTTPException(status_code=403, detail="Access denied to this job")
-
-    use_case = CancelJobUseCase(job_repo)
-
-    try:
-        job = use_case.execute(job_id)
-    except ValueError as e:
-        raise HTTPException(status_code=400, detail=str(e))
-
-    return job_to_response(job)

apps/api/app/api/routes/recipes.py

@@ -1,207 +0,0 @@
-"""Recipe CRUD + use routes."""
-
-from __future__ import annotations
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.dependencies import get_db_session, get_user_repository
-from app.schemas.recipe import (
-    CreateRecipeRequest,
-    ListRecipesResponse,
-    RecipeItemResponse,
-    RecipeResponse,
-    UpdateRecipeRequest,
-    UseRecipeResponse,
-)
-from fastapi import APIRouter, Depends, HTTPException, Query, Response, status
-from sqlalchemy.orm import Session
-
-from packages.adapters.sqlalchemy_impl.recipe_repository import SQLAlchemyRecipeRepository
-from packages.application.recipe.commands import (
-    CreateRecipeCommand,
-    RecipeItemCommand,
-    UpdateRecipeCommand,
-)
-from packages.application.recipe.use_cases import (
-    CreateRecipeUseCase,
-    DeleteRecipeUseCase,
-    FeatureDisabledError,
-    GetRecipeUseCase,
-    ListRecipesUseCase,
-    NotFoundError,
-    UpdateRecipeUseCase,
-    UseRecipeUseCase,
-)
-from packages.ports.user_repository import UserRepository
-
-from app.api.routes._helpers import get_user_plan
-
-router = APIRouter()
-
-
-def _get_recipe_repository(session: Session = Depends(get_db_session)) -> SQLAlchemyRecipeRepository:
-    return SQLAlchemyRecipeRepository(session)
-
-
-def _item_to_response(item) -> RecipeItemResponse:
-    return RecipeItemResponse(
-        id=item.id,
-        recipe_id=item.recipe_id,
-        item_type=item.item_type,
-        item_id=item.item_id,
-        position=item.position,
-        metadata=item.metadata_,
-    )
-
-
-def _to_response(recipe) -> RecipeResponse:
-    return RecipeResponse(
-        id=recipe.id,
-        user_id=recipe.user_id,
-        name=recipe.name,
-        description=recipe.description,
-        template_id=recipe.template_id,
-        generation_params=recipe.generation_params,
-        items=[_item_to_response(i) for i in getattr(recipe, "items", [])],
-        is_active=recipe.is_active,
-        metadata=recipe.metadata_,
-        created_at=recipe.created_at,
-        updated_at=recipe.updated_at,
-    )
-
-
-@router.get("", response_model=ListRecipesResponse)
-def list_recipes(
-    skip: int = Query(0, ge=0),
-    limit: int = Query(50, ge=1, le=200),
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-) -> ListRecipesResponse:
-    user_id = authenticated_user.user.id
-    use_case = ListRecipesUseCase(recipe_repository)
-    recipes = use_case.execute(user_id, skip=skip, limit=limit)
-    total = recipe_repository.count_by_user(user_id)
-    return ListRecipesResponse(
-        items=[_to_response(r) for r in recipes],
-        total=total,
-    )
-
-
-@router.get("/{recipe_id}", response_model=RecipeResponse)
-def get_recipe(
-    recipe_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-) -> RecipeResponse:
-    user_id = authenticated_user.user.id
-    use_case = GetRecipeUseCase(recipe_repository)
-    recipe = use_case.execute(recipe_id, user_id)
-    if recipe is None:
-        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Recipe not found")
-    return _to_response(recipe)
-
-
-@router.post("", response_model=RecipeResponse, status_code=status.HTTP_201_CREATED)
-def create_recipe(
-    request: CreateRecipeRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-) -> RecipeResponse:
-    user_id = authenticated_user.user.id
-    command = CreateRecipeCommand(
-        user_id=user_id,
-        name=request.name,
-        description=request.description,
-        template_id=request.template_id,
-        generation_params=request.generation_params,
-        items=[
-            RecipeItemCommand(
-                item_type=ic.item_type,
-                item_id=ic.item_id,
-                position=ic.position,
-                metadata_=ic.metadata_,
-            )
-            for ic in request.items
-        ],
-        metadata_=request.metadata_,
-    )
-    use_case = CreateRecipeUseCase(recipe_repository)
-    recipe = use_case.execute(command)
-    return _to_response(recipe)
-
-
-@router.patch("/{recipe_id}", response_model=RecipeResponse)
-def update_recipe(
-    recipe_id: str,
-    request: UpdateRecipeRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-) -> RecipeResponse:
-    user_id = authenticated_user.user.id
-    command = UpdateRecipeCommand(
-        recipe_id=recipe_id,
-        user_id=user_id,
-        name=request.name,
-        description=request.description,
-        template_id=request.template_id,
-        generation_params=request.generation_params,
-        items=(
-            [
-                RecipeItemCommand(
-                    item_type=ic.item_type,
-                    item_id=ic.item_id,
-                    position=ic.position,
-                    metadata_=ic.metadata_,
-                )
-                for ic in request.items
-            ]
-            if request.items is not None
-            else None
-        ),
-        metadata_=request.metadata_,
-    )
-    use_case = UpdateRecipeUseCase(recipe_repository)
-    try:
-        recipe = use_case.execute(command)
-    except NotFoundError:
-        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Recipe not found")
-    return _to_response(recipe)
-
-
-@router.delete("/{recipe_id}", status_code=status.HTTP_204_NO_CONTENT, response_model=None)
-def delete_recipe(
-    recipe_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-) -> Response:
-    user_id = authenticated_user.user.id
-    use_case = DeleteRecipeUseCase(recipe_repository)
-    deleted = use_case.execute(recipe_id, user_id)
-    if not deleted:
-        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Recipe not found")
-    return Response(status_code=204)
-
-
-@router.post("/{recipe_id}/use", response_model=UseRecipeResponse)
-def use_recipe(
-    recipe_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    recipe_repository: SQLAlchemyRecipeRepository = Depends(_get_recipe_repository),
-    user_repository: UserRepository = Depends(get_user_repository),
-) -> UseRecipeResponse:
-    user_id = authenticated_user.user.id
-    plan_name = get_user_plan(user_id, user_repository)
-    use_case = UseRecipeUseCase(recipe_repository)
-    try:
-        result = use_case.execute(recipe_id, user_id, user_plan=plan_name)
-    except FeatureDisabledError as exc:
-        raise HTTPException(
-            status_code=status.HTTP_403_FORBIDDEN,
-            detail=str(exc),
-        )
-    except NotFoundError:
-        raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Recipe not found")
-
-    return UseRecipeResponse(
-        recipe=_to_response(result.recipe),
-        warnings=[{"item_type": w.item_type, "item_id": w.item_id, "position": w.position} for w in result.warnings],
-    )

apps/api/app/config.py

@@ -19,7 +19,6 @@ class Settings(BaseSettings):
     # Container bind address; external expose is controlled by Docker/Nginx.
     API_HOST: str = "0.0.0.0"  # nosec: B104
     API_PORT: int = 8000
-    API_PREFIX: str = "/api/v1"
 
     DATABASE_URL: str = "postgresql+psycopg://postgres:postgres@localhost:5432/xiaoxia_saas"
     DATABASE_POOL_SIZE: int = 20
@@ -30,16 +29,10 @@ class Settings(BaseSettings):
     AUTO_CREATE_SCHEMA: bool = False
 
     REDIS_URL: str = "redis://localhost:6379/0"
-    REDIS_MAX_CONNECTION: int = 50
     ENABLE_REDIS_SESSIONS: bool = False
 
     # JWT secret key - MUST be set via environment variable, no default allowed
     JWT_SECRET_KEY: Optional[str] = None
-    # 旧的 JWT secret key（用于密钥轮换期间验证旧 token）
-    # 在密钥轮换时，先设置新密钥，旧密钥保留在此处直到所有旧 token 过期
-    JWT_SECRET_KEY_OLD: Optional[str] = None
-    # 密钥轮换天数（到达此天数后建议更换密钥）
-    SECRET_ROTATION_DAYS: int = 90
 
     # JWT 算法与过期时间（与 .env.example 对齐）
     JWT_ALGORITHM: str = "HS256"
@@ -80,7 +73,7 @@ class Settings(BaseSettings):
     CELERY_RESULT_BACKEND: str = "redis://localhost:6379/1"
 
     # OSS 七牛云相关
-    OSS_ENDPOINT: str = "oss-cn-hangzhou.aliiyuncs.com"
+    OSS_ENDPOINT: str = "oss-cn-hangzhou.aliyuncs.com"
     OSS_ACCESS_KEY_ID: str = ""
     OSS_ACCESS_KEY_SECRET: str = ""
     OSS_BUCKET_NAME: str = "xiaoxia-autocut"
@@ -111,7 +104,6 @@ class Settings(BaseSettings):
     )
     OSS_DIRECT_UPLOAD_EXPIRE_SECONDS: int = 900
 
-    LOG_LEVEL: str = "INFO"
     CORS_ORIGINS_RAW: str = "http://localhost:3000,http://localhost:5173,http://localhost:8000"
 
     # 渲染引擎选择：legacy=旧VideoComposeService，unified=新UnifiedRenderService

apps/api/app/core/storage.py

@@ -1,283 +1,14 @@
-"""阿里云 OSS 存储服务"""
+"""Backward-compatible re-export from shared storage.
 
-import base64
-import datetime as dt
-import hashlib
-import hmac
-import json
-import logging
-import os
-from urllib.parse import urlparse
+All storage logic now lives in ``packages.shared.storage``.
+This module keeps old import paths working so existing code
+does not need to change.
+"""
 
-try:
-    import oss2
-except ImportError:  # pragma: no cover - exercised in minimal local/test environments
-    oss2 = None
-from app.config import get_settings
+from packages.shared.storage import (
+    SharedStorageService as OSSStorageService,
+    get_shared_storage_service,
+    get_storage_service,
+)
 
-logger = logging.getLogger(__name__)
-
-
-class OSSStorageService:
-    """阿里云 OSS 存储服务"""
-
-    def __init__(self):
-        settings = get_settings()
-        self.bucket_name = settings.OSS_BUCKET_NAME
-        self.public_url = f"https://{settings.OSS_BUCKET_NAME}.{settings.OSS_ENDPOINT}"
-        self.local_url_prefix = os.getenv("GENERATED_FILES_URL_PREFIX", "/generated-files")
-        self.bucket = None
-
-        has_key_id = bool(settings.OSS_ACCESS_KEY_ID)
-        has_key_secret = bool(settings.OSS_ACCESS_KEY_SECRET)
-
-        if has_key_id and has_key_secret:
-            if oss2 is not None:
-                try:
-                    # P0-2 修复：oss2.Bucket 的 endpoint 必须带 https:// 前缀，
-                    # 否则 sign_url 默认生成 HTTP URL。
-                    bucket_endpoint = settings.OSS_ENDPOINT
-                    if not bucket_endpoint.startswith(("http://", "https://")):
-                        bucket_endpoint = f"https://{bucket_endpoint}"
-                    auth = oss2.Auth(
-                        settings.OSS_ACCESS_KEY_ID,
-                        settings.OSS_ACCESS_KEY_SECRET,
-                    )
-                    self.bucket = oss2.Bucket(
-                        auth,
-                        bucket_endpoint,
-                        settings.OSS_BUCKET_NAME,
-                    )
-                    logger.info(
-                        "OSS initialized: endpoint=%s bucket=%s",
-                        settings.OSS_ENDPOINT,
-                        settings.OSS_BUCKET_NAME,
-                    )
-                except Exception as error:
-                    logger.error("Failed to initialize OSS bucket client: %s", error)
-            else:
-                logger.error("oss2 SDK is not installed — OSS operations will fail")
-        else:
-            missing = []
-            if not has_key_id:
-                missing.append("OSS_ACCESS_KEY_ID")
-            if not has_key_secret:
-                missing.append("OSS_ACCESS_KEY_SECRET")
-            logger.error("OSS credentials not configured — missing: %s", ", ".join(missing))
-
-        self.access_key_id = settings.OSS_ACCESS_KEY_ID
-        self.access_key_secret = settings.OSS_ACCESS_KEY_SECRET
-        self.endpoint = settings.OSS_ENDPOINT
-
-    def diagnose(self) -> None:
-        """启动诊断：输出 OSS 配置状态，帮助排查预签名 URL 问题。"""
-        key_id_display = (
-            f"{self.access_key_id[:4]}...{self.access_key_id[-4:]}" if len(self.access_key_id) > 8 else "(empty)"
-        )
-        logger.info(
-            "[OSS诊断] endpoint=%s bucket_name=%s access_key_id=%s",
-            self.endpoint,
-            self.bucket_name,
-            key_id_display,
-        )
-        if self.bucket is None:
-            logger.error(
-                "[OSS诊断] ❌ bucket=None — 预签名URL不可用！"
-                "原因: OSS_ACCESS_KEY_ID/OSS_ACCESS_KEY_SECRET 未配置或 oss2 未安装。"
-                "请检查服务器 .env 文件（如 /var/lib/xiaoxia-saas-staging/.env）"
-            )
-        else:
-            logger.info("[OSS诊断] ✅ bucket 已配置，预签名URL可用")
-
-    def _is_local_generated_url(self, storage_key_or_url: str) -> bool:
-        parsed = urlparse(storage_key_or_url)
-        path = parsed.path if parsed.scheme else storage_key_or_url
-        return path.startswith(f"{self.local_url_prefix}/")
-
-    def create_direct_upload_post(
-        self,
-        storage_key: str,
-        content_type: str,
-        max_size_bytes: int,
-        expires_seconds: int,
-    ) -> dict[str, object]:
-        """创建浏览器直传 OSS 的 PostObject 表单。"""
-        if not self.access_key_id or not self.access_key_secret:
-            raise RuntimeError("OSS storage is not configured")
-        normalized_key = self._normalize_storage_key(storage_key)
-        if not normalized_key.startswith("uploads/"):
-            raise ValueError("direct upload key must be under uploads/")
-
-        expiration = (dt.datetime.now(dt.timezone.utc) + dt.timedelta(seconds=expires_seconds)).strftime(
-            "%Y-%m-%dT%H:%M:%S.000Z"
-        )
-        policy = {
-            "expiration": expiration,
-            "conditions": [
-                {"bucket": self.bucket_name},
-                {"key": normalized_key},
-                ["content-length-range", 1, max_size_bytes],
-                ["starts-with", "$Content-Type", content_type.split("/", 1)[0] + "/" if "/" in content_type else ""],
-            ],
-        }
-        encoded_policy = base64.b64encode(json.dumps(policy, separators=(",", ":")).encode("utf-8")).decode("ascii")
-        signature = base64.b64encode(
-            hmac.new(self.access_key_secret.encode("utf-8"), encoded_policy.encode("utf-8"), hashlib.sha1).digest()
-        ).decode("ascii")
-
-        return {
-            "url": self.public_url,
-            "method": "POST",
-            "storage_key": normalized_key,
-            "expires_at": expiration,
-            "fields": {
-                "key": normalized_key,
-                "OSSAccessKeyId": self.access_key_id,
-                "policy": encoded_policy,
-                "Signature": signature,
-                "success_action_status": "201",
-                "Content-Type": content_type,
-            },
-        }
-
-    def upload_file(
-        self,
-        file_or_path,
-        storage_key: str,
-        content_type: str = "application/octet-stream",
-    ) -> str:
-        """
-        上传文件到 OSS
-
-        Args:
-            file_or_path: 文件对象或本地文件路径
-            storage_key: 存储键（文件路径）
-            content_type: 内容类型
-
-        Returns:
-            文件公网 URL
-        """
-        if self.bucket is None:
-            raise RuntimeError("OSS storage is not configured")
-
-        try:
-            # 如果是字符串路径，从本地文件上传
-            if isinstance(file_or_path, str):
-                self.bucket.put_object_from_file(storage_key, file_or_path, headers={"Content-Type": content_type})
-            else:
-                # 文件对象
-                file_or_path.seek(0)
-                self.bucket.put_object(storage_key, file_or_path, headers={"Content-Type": content_type})
-
-            return f"{self.public_url}/{storage_key}"
-        except Exception as e:
-            raise Exception(f"Failed to upload file to OSS: {e}")
-
-    def get_url(self, storage_key: str) -> str:
-        """获取文件公网 URL"""
-        return f"{self.public_url}/{storage_key}"
-
-    def get_download_url(self, storage_key_or_url: str, expires_seconds: int = 3600) -> str:
-        """
-        获取文件下载签名 URL（用于私有文件）
-
-        Args:
-            storage_key_or_url: 存储键或完整 URL
-            expires_seconds: 过期时间（秒）
-
-        Returns:
-            签名 URL
-        """
-        if self.bucket is None:
-            if self._is_local_generated_url(storage_key_or_url):
-                return storage_key_or_url
-            logger.warning(
-                "get_download_url: OSS bucket not configured, returning raw URL. " "storage_key_or_url=%s",
-                storage_key_or_url[:200],
-            )
-            return self.get_url(self._normalize_storage_key(storage_key_or_url))
-
-        storage_key = self._normalize_storage_key(storage_key_or_url)
-        try:
-            signed = self.bucket.sign_url("GET", storage_key, expires_seconds)
-            logger.info(
-                "get_download_url: signed URL generated. storage_key=%s url_prefix=%s",
-                storage_key[:80],
-                signed[:60],
-            )
-            return signed
-        except Exception:
-            logger.exception(
-                "get_download_url: sign_url failed, falling back to raw URL. " "storage_key=%s",
-                storage_key[:200],
-            )
-            return self.get_url(storage_key)
-
-    def _normalize_storage_key(self, storage_key_or_url: str) -> str:
-        """从 URL 中提取存储键"""
-        if storage_key_or_url.startswith("http://") or storage_key_or_url.startswith("https://"):
-            parsed = urlparse(storage_key_or_url)
-            # 移除开头的 /
-            return parsed.path.lstrip("/")
-        return storage_key_or_url.lstrip("/")
-
-    def download_file(self, storage_key: str, local_path: str):
-        """
-        从 OSS 下载文件到本地
-
-        Args:
-            storage_key: 存储键
-            local_path: 本地文件路径
-        """
-        if self.bucket is None:
-            raise RuntimeError("OSS storage is not configured")
-
-        try:
-            os.makedirs(os.path.dirname(local_path), exist_ok=True)
-            self.bucket.get_object_to_file(storage_key, local_path)
-        except Exception as e:
-            raise Exception(f"Failed to download file from OSS: {e}")
-
-    def delete_file(self, storage_key: str):
-        """
-        删除 OSS 文件
-
-        Args:
-            storage_key: 存储键
-        """
-        if self.bucket is None:
-            return
-
-        try:
-            self.bucket.delete_object(storage_key)
-        except Exception as error:
-            logger.warning(
-                "Failed to delete file from OSS",
-                extra={"storage_key": storage_key, "error": str(error)},
-            )
-
-    def file_exists(self, storage_key: str) -> bool:
-        """
-        检查文件是否存在
-
-        Args:
-            storage_key: 存储键
-
-        Returns:
-            是否存在
-        """
-        if self.bucket is None:
-            return False
-        return self.bucket.object_exists(storage_key)
-
-
-_storage_service = None
-
-
-def get_storage_service() -> OSSStorageService:
-    """获取存储服务实例（全局单例）"""
-    global _storage_service
-    if _storage_service is None:
-        _storage_service = OSSStorageService()
-        _storage_service.diagnose()
-    return _storage_service
+__all__ = ["OSSStorageService", "get_storage_service", "get_shared_storage_service"]

apps/api/app/schemas/dashboard.py

@@ -1,32 +0,0 @@
-from datetime import datetime
-
-from pydantic import BaseModel, Field
-
-
-class RecentTaskItem(BaseModel):
-    id: str
-    task_type: str = "generation"
-    status: str
-    current_step: str = ""
-    error_message: str = ""
-    updated_at: datetime | None = None
-
-
-class SubscriptionInfo(BaseModel):
-    """用户订阅信息。"""
-
-    plan: str = "free"
-    is_active: bool = False
-
-
-class DashboardOverviewResponse(BaseModel):
-    """Dashboard 概览数据。"""
-
-    total_assets: int = 0
-    used_storage_bytes: int = 0
-    total_titles: int = 0
-    total_voices: int = 0
-    total_tasks: int = 0
-    total_products: int = 0
-    subscription: SubscriptionInfo = Field(default_factory=SubscriptionInfo)
-    recent_tasks: list[RecentTaskItem] = Field(default_factory=list)

apps/api/app/schemas/job.py

@@ -1,109 +0,0 @@
-"""Job API schemas — Phase 8 任务 2.10."""
-
-from __future__ import annotations
-
-from datetime import datetime
-from typing import Any, Optional
-
-from pydantic import BaseModel, Field
-
-
-class CreateJobRequest(BaseModel):
-    """创建任务请求体。"""
-
-    project_id: str = Field(..., min_length=1, description="项目 ID")
-    job_type: str = Field(
-        ...,
-        description="任务类型: video_compose / render_edit_plan / asset_ingest / classification / voice_extraction / generation",
-    )
-    payload: dict[str, Any] = Field(default_factory=dict, description="任务输入参数")
-    source_id: str = Field(default="", description="关联的业务实体 ID（如 edit_plan_id）")
-    max_retries: int = Field(default=3, ge=0, le=10, description="最大重试次数")
-
-
-class UpdateProgressRequest(BaseModel):
-    """更新任务进度请求体。"""
-
-    progress: float = Field(..., ge=0.0, le=100.0, description="进度百分比")
-    current_stage: str = Field(default="", description="当前阶段描述")
-
-
-class CompleteJobRequest(BaseModel):
-    """完成任务请求体。"""
-
-    result: dict[str, Any] = Field(default_factory=dict, description="任务结果")
-
-
-class FailJobRequest(BaseModel):
-    """标记任务失败请求体。"""
-
-    error_message: str = Field(..., min_length=1, description="错误信息")
-
-
-class JobResponse(BaseModel):
-    """任务响应体。"""
-
-    id: str
-    project_id: str
-    job_type: str
-    status: str
-    progress: float
-    current_stage: str
-    payload: dict[str, Any]
-    result: dict[str, Any]
-    error_message: str
-    retry_count: int
-    max_retries: int
-    celery_task_id: str
-    source_id: str
-    created_by_user_id: str
-    is_retryable: bool
-    started_at: Optional[datetime] = None
-    completed_at: Optional[datetime] = None
-    created_at: datetime
-    updated_at: datetime
-
-    model_config = {"from_attributes": True}
-
-
-class ListJobsResponse(BaseModel):
-    """任务列表响应体。"""
-
-    items: list[JobResponse]
-    total: int
-
-
-class JobStatisticsResponse(BaseModel):
-    """任务统计响应体。"""
-
-    project_id: str
-    total: int
-    pending: int
-    running: int
-    success: int
-    failed: int
-
-
-def job_to_response(job) -> JobResponse:
-    """将 Job 领域对象转换为 API 响应。"""
-    return JobResponse(
-        id=job.id,
-        project_id=job.project_id,
-        job_type=job.job_type.value if hasattr(job.job_type, "value") else str(job.job_type),
-        status=job.status.value if hasattr(job.status, "value") else str(job.status),
-        progress=job.progress,
-        current_stage=job.current_stage,
-        payload=job.payload,
-        result=job.result,
-        error_message=job.error_message,
-        retry_count=job.retry_count,
-        max_retries=job.max_retries,
-        celery_task_id=job.celery_task_id,
-        source_id=job.source_id,
-        created_by_user_id=job.created_by_user_id,
-        is_retryable=job.is_retryable,
-        started_at=job.started_at,
-        completed_at=job.completed_at,
-        created_at=job.created_at,
-        updated_at=job.updated_at,
-    )

apps/api/app/schemas/recipe.py

@@ -1,86 +0,0 @@
-"""Recipe API schemas."""
-
-from __future__ import annotations
-
-from datetime import datetime
-from typing import Any, Dict, List, Optional
-
-from pydantic import BaseModel, Field
-
-# ── Response ──
-
-
-class RecipeItemResponse(BaseModel):
-    id: str
-    recipe_id: str
-    item_type: str
-    item_id: str
-    position: int
-    metadata_: Dict[str, Any] = Field(default_factory=dict, alias="metadata")
-
-    class Config:
-        populate_by_name = True
-
-
-class RecipeResponse(BaseModel):
-    id: str
-    user_id: str
-    name: str
-    description: str = ""
-    template_id: str = ""
-    generation_params: Dict[str, Any] = Field(default_factory=dict)
-    items: List[RecipeItemResponse] = Field(default_factory=list)
-    is_active: bool = True
-    metadata_: Dict[str, Any] = Field(default_factory=dict, alias="metadata")
-    created_at: datetime
-    updated_at: datetime
-
-    class Config:
-        populate_by_name = True
-
-
-class ListRecipesResponse(BaseModel):
-    items: List[RecipeResponse]
-    total: int = 0
-
-
-class UseRecipeResponse(BaseModel):
-    recipe: RecipeResponse
-    warnings: List[Dict[str, Any]] = Field(default_factory=list)
-
-
-# ── Request ──
-
-
-class RecipeItemRequest(BaseModel):
-    item_type: str
-    item_id: str
-    position: int = 0
-    metadata_: Dict[str, Any] = Field(default_factory=dict, alias="metadata")
-
-    class Config:
-        populate_by_name = True
-
-
-class CreateRecipeRequest(BaseModel):
-    name: str
-    description: str = ""
-    template_id: str = ""
-    generation_params: Dict[str, Any] = Field(default_factory=dict)
-    items: List[RecipeItemRequest] = Field(default_factory=list)
-    metadata_: Dict[str, Any] = Field(default_factory=dict, alias="metadata")
-
-    class Config:
-        populate_by_name = True
-
-
-class UpdateRecipeRequest(BaseModel):
-    name: Optional[str] = None
-    description: Optional[str] = None
-    template_id: Optional[str] = None
-    generation_params: Optional[Dict[str, Any]] = None
-    items: Optional[List[RecipeItemRequest]] = None
-    metadata_: Optional[Dict[str, Any]] = Field(default=None, alias="metadata")
-
-    class Config:
-        populate_by_name = True

apps/web/src/api/accounts.ts

@@ -1,161 +0,0 @@
-/**
- * 账号管理 Mock API
- *
- * 模拟多平台账号绑定/解绑操作
- * 支持平台：抖音、快手、小红书、微信视频号
- */
-
-/* ── 类型定义 ───────────────────────────────────────────── */
-
-/** 平台 ID */
-export type PlatformId = "douyin" | "kuaishou" | "xiaohongshu" | "wechat";
-
-/** 账号状态 */
-export type AccountStatus = "active" | "expired" | "limited";
-
-/** 已绑定的账号 */
-export interface Account {
-  id: string;
-  platform_id: PlatformId;
-  name: string;
-  avatar?: string;
-  status: AccountStatus;
-  bound_at: string;
-}
-
-/** 平台信息 */
-export interface Platform {
-  id: PlatformId;
-  name: string;
-  subName: string;
-  icon: string;
-  gradient: string;
-}
-
-/** 绑定账号请求 */
-export interface BindAccountRequest {
-  platform_id: PlatformId;
-  name: string;
-}
-
-/* ── 平台配置 ───────────────────────────────────────────── */
-
-export const PLATFORMS: Platform[] = [
-  {
-    id: "douyin",
-    name: "抖音",
-    subName: "短视频发布平台",
-    icon: "📱",
-    gradient: "linear-gradient(135deg, #fe2c55, #25f4ee)",
-  },
-  {
-    id: "kuaishou",
-    name: "快手",
-    subName: "短视频发布平台",
-    icon: "🎬",
-    gradient: "linear-gradient(135deg, #ff4906, #ffba00)",
-  },
-  {
-    id: "xiaohongshu",
-    name: "小红书",
-    subName: "种草笔记发布平台",
-    icon: "📕",
-    gradient: "linear-gradient(135deg, #ff2442, #ff6b6b)",
-  },
-  {
-    id: "wechat",
-    name: "微信视频号",
-    subName: "视频号发布平台",
-    icon: "💬",
-    gradient: "linear-gradient(135deg, #07c160, #4cd964)",
-  },
-];
-
-/* ── Mock 数据 ───────────────────────────────────────────── */
-
-let MOCK_ACCOUNTS: Account[] = [
-  {
-    id: "acc-001",
-    platform_id: "douyin",
-    name: "小虾官方号",
-    avatar: "🦐",
-    status: "active",
-    bound_at: "2025-12-01T10:00:00Z",
-  },
-  {
-    id: "acc-002",
-    platform_id: "douyin",
-    name: "小虾日常",
-    avatar: "🐟",
-    status: "active",
-    bound_at: "2025-12-15T14:30:00Z",
-  },
-  {
-    id: "acc-003",
-    platform_id: "kuaishou",
-    name: "小虾剪辑",
-    avatar: "🎬",
-    status: "active",
-    bound_at: "2026-01-05T09:00:00Z",
-  },
-  {
-    id: "acc-004",
-    platform_id: "xiaohongshu",
-    name: "小虾种草",
-    avatar: "📕",
-    status: "limited",
-    bound_at: "2026-02-20T16:00:00Z",
-  },
-];
-
-/* ── 模拟延迟 ───────────────────────────────────────────── */
-
-const delay = (ms: number) => new Promise((r) => setTimeout(r, ms));
-
-/* ── API 函数 ───────────────────────────────────────────── */
-
-/** 获取指定平台的账号列表 */
-export async function getAccountsByPlatform(
-  platformId: PlatformId,
-): Promise<Account[]> {
-  await delay(300);
-  return MOCK_ACCOUNTS.filter((a) => a.platform_id === platformId);
-}
-
-/** 获取所有平台的账号总数 */
-export async function getAllAccounts(): Promise<Account[]> {
-  await delay(200);
-  return [...MOCK_ACCOUNTS];
-}
-
-/** 绑定新账号 */
-export async function bindAccount(data: BindAccountRequest): Promise<Account> {
-  await delay(500);
-  const newAccount: Account = {
-    id: `acc-${Date.now()}`,
-    platform_id: data.platform_id,
-    name: data.name,
-    avatar: undefined,
-    status: "active",
-    bound_at: new Date().toISOString(),
-  };
-  MOCK_ACCOUNTS = [...MOCK_ACCOUNTS, newAccount];
-  return newAccount;
-}
-
-/** 解绑账号 */
-export async function unbindAccount(accountId: string): Promise<void> {
-  await delay(400);
-  MOCK_ACCOUNTS = MOCK_ACCOUNTS.filter((a) => a.id !== accountId);
-}
-
-/* ── 状态配置 ───────────────────────────────────────────── */
-
-export const ACCOUNT_STATUS_CONFIG: Record<
-  AccountStatus,
-  { label: string; className: string }
-> = {
-  active: { label: "正常", className: "acc-status--active" },
-  expired: { label: "已过期", className: "acc-status--expired" },
-  limited: { label: "受限", className: "acc-status--limited" },
-};

apps/web/src/components/modals/CloneVoiceModal.tsx

@@ -1,290 +0,0 @@
-/**
- * CloneVoiceModal — 音色克隆弹窗
- *
- * 三步骤状态：input → uploading → success
- * 支持上传音频文件或直接录制（mock，无真实录音）
- *
- * V21 Design System — 零 antd 直接导入
- */
-import React, { useState, useCallback, useRef } from "react";
-import { Modal, Button } from "@/components/ui";
-import { createVoiceClone, toVoiceClone } from "@/api/voiceClone";
-import type { VoiceClone } from "@/api/voiceClone";
-import { uploadAsset } from "@/api/assets";
-import "./clone-voice-modal.css";
-
-/* ── 类型定义 ───────────────────────────────────────────── */
-
-type ModalStep = "input" | "uploading" | "success";
-
-export interface CloneVoiceModalProps {
-  /** 弹窗是否可见 */
-  open: boolean;
-  /** 关闭弹窗回调 */
-  onClose: () => void;
-  /** 克隆成功回调（返回新创建的音色） */
-  onSuccess?: (voice: VoiceClone) => void;
-}
-
-/* ── 默认音色名称计数器 ─────────────────────────────────── */
-
-let cloneCounter = 1;
-
-const getNextDefaultName = (): string => {
-  const name = `我的声音 ${cloneCounter}`;
-  cloneCounter += 1;
-  return name;
-};
-
-/* ── 组件 ───────────────────────────────────────────────── */
-
-const CloneVoiceModal: React.FC<CloneVoiceModalProps> = ({
-  open,
-  onClose,
-  onSuccess,
-}) => {
-  const [step, setStep] = useState<ModalStep>("input");
-  const [voiceName, setVoiceName] = useState("");
-  const [isRecording, setIsRecording] = useState(false);
-  const [selectedFile, setSelectedFile] = useState<File | null>(null);
-  const [dragActive, setDragActive] = useState(false);
-  const fileInputRef = useRef<HTMLInputElement>(null);
-
-  /** 重置弹窗状态 */
-  const resetState = useCallback(() => {
-    setStep("input");
-    setVoiceName("");
-    setSelectedFile(null);
-    setIsRecording(false);
-    setDragActive(false);
-  }, []);
-
-  /** 关闭弹窗 */
-  const handleClose = useCallback(() => {
-    resetState();
-    onClose();
-  }, [resetState, onClose]);
-
-  /** 上传区域点击 */
-  const handleUploadClick = () => {
-    fileInputRef.current?.click();
-  };
-
-  /** 文件选择 */
-  const handleFileChange = (e: React.ChangeEvent<HTMLInputElement>) => {
-    const file = e.target.files?.[0];
-    if (file) {
-      setSelectedFile(file);
-      // 清除之前的录制状态
-      setIsRecording(false);
-    }
-    // 清空 input 以允许重复选择同一文件
-    e.target.value = "";
-  };
-
-  /** 拖拽事件 */
-  const handleDrag = (e: React.DragEvent) => {
-    e.preventDefault();
-    e.stopPropagation();
-    if (e.type === "dragenter" || e.type === "dragover") {
-      setDragActive(true);
-    } else if (e.type === "dragleave") {
-      setDragActive(false);
-    }
-  };
-
-  const handleDrop = (e: React.DragEvent) => {
-    e.preventDefault();
-    e.stopPropagation();
-    setDragActive(false);
-    const file = e.dataTransfer.files?.[0];
-    if (file) {
-      const ext = file.name.split(".").pop()?.toLowerCase();
-      if (ext === "mp3" || ext === "wav") {
-        setSelectedFile(file);
-        setIsRecording(false);
-      }
-    }
-  };
-
-  /** 录制按钮（mock） */
-  const handleRecord = () => {
-    setIsRecording((prev) => !prev);
-    if (!isRecording) {
-      // 开始录制 — 清除已选文件
-      setSelectedFile(null);
-    }
-  };
-
-  /** 开始克隆 */
-  const handleStartClone = async () => {
-    const name = voiceName.trim() || getNextDefaultName();
-    setStep("uploading");
-
-    try {
-      // 先上传音频文件获取真实 URL
-      let audioUrl: string;
-      if (selectedFile) {
-        const formData = new FormData();
-        formData.append("file", selectedFile);
-        formData.append("kind", "voice");
-        const uploadResult = await uploadAsset(formData);
-        audioUrl = uploadResult.url;
-      } else {
-        // 录制功能暂未实现，提示用户上传
-        setStep("input");
-        return;
-      }
-
-      // 提交克隆请求
-      const result = await createVoiceClone({
-        name,
-        audio_url: audioUrl,
-      });
-
-      setStep("success");
-
-      // 2秒后自动关闭
-      setTimeout(() => {
-        onSuccess?.(toVoiceClone(result));
-        handleClose();
-      }, 2000);
-    } catch {
-      setStep("input");
-    }
-  };
-
-  /** 弹窗打开时初始化默认名称 */
-  const handleAfterOpenChange = (visible: boolean) => {
-    if (visible) {
-      setVoiceName(getNextDefaultName());
-    }
-  };
-
-  const canStart = selectedFile || isRecording;
-
-  return (
-    <Modal
-      open={open}
-      onCancel={handleClose}
-      title="🎤 克隆新音色"
-      width={520}
-      footer={null}
-      destroyOnClose
-      afterOpenChange={handleAfterOpenChange}
-    >
-      {/* ── 输入步骤 ──────────────────────────────────── */}
-      {step === "input" && (
-        <div className="cvm-body">
-          {/* 音色名称 */}
-          <div className="cvm-field">
-            <label className="cvm-label">音色名称</label>
-            <input
-              type="text"
-              className="cvm-input"
-              value={voiceName}
-              onChange={(e) => setVoiceName(e.target.value)}
-              placeholder="输入音色名称"
-            />
-          </div>
-
-          {/* 上传区域 */}
-          <div className="cvm-field">
-            <label className="cvm-label">上传音频</label>
-            <div
-              className={`cvm-upload-zone${dragActive ? " cvm-upload-zone--active" : ""}`}
-              onClick={handleUploadClick}
-              onDragEnter={handleDrag}
-              onDragOver={handleDrag}
-              onDragLeave={handleDrag}
-              onDrop={handleDrop}
-            >
-              <div className="cvm-upload-icon">🎵</div>
-              <p className="cvm-upload-title">
-                {selectedFile ? selectedFile.name : "拖拽音频文件到此处"}
-              </p>
-              <p className="cvm-upload-hint">支持 MP3、WAV 格式</p>
-              <input
-                ref={fileInputRef}
-                type="file"
-                accept=".mp3,.wav,audio/mpeg,audio/wav"
-                style={{ display: "none" }}
-                onChange={handleFileChange}
-              />
-            </div>
-          </div>
-
-          {/* 或分隔 */}
-          <div className="cvm-divider">
-            <div className="cvm-divider-line" />
-            <span className="cvm-divider-text">或</span>
-            <div className="cvm-divider-line" />
-          </div>
-
-          {/* 录制区域 */}
-          <div className="cvm-field">
-            <label className="cvm-label">直接录制</label>
-            <div className="cvm-record-area">
-              <p className="cvm-record-hint">
-                {isRecording
-                  ? "录制中…再次点击停止"
-                  : "点击按钮开始录制你的声音"}
-              </p>
-              <button
-                type="button"
-                className={`cvm-record-btn${isRecording ? " cvm-record-btn--recording" : ""}`}
-                onClick={handleRecord}
-              >
-                🎙️
-              </button>
-            </div>
-          </div>
-
-          {/* 提示 */}
-          <div className="cvm-tip">
-            <span className="cvm-tip-icon">💡</span>
-            <span>
-              建议上传10秒~3分钟的清晰语音，环境安静、语速均匀效果最佳
-            </span>
-          </div>
-
-          {/* 底部按钮 */}
-          <div className="cvm-footer">
-            <Button buttonType="ghost" onClick={handleClose}>
-              取消
-            </Button>
-            <Button
-              buttonType="primary"
-              disabled={!canStart}
-              onClick={handleStartClone}
-            >
-              🎤 开始克隆
-            </Button>
-          </div>
-        </div>
-      )}
-
-      {/* ── 上传中步骤 ────────────────────────────────── */}
-      {step === "uploading" && (
-        <div className="cvm-uploading">
-          <div className="cvm-uploading-spinner" />
-          <p className="cvm-uploading-text">正在克隆你的音色…</p>
-          <p className="cvm-uploading-sub">AI 正在分析你的声音特征，请稍候</p>
-        </div>
-      )}
-
-      {/* ── 成功步骤 ──────────────────────────────────── */}
-      {step === "success" && (
-        <div className="cvm-success">
-          <div className="cvm-success-icon">✅</div>
-          <h3 className="cvm-success-title">克隆已提交</h3>
-          <p className="cvm-success-desc">
-            音色正在生成中，完成后将出现在列表中
-          </p>
-        </div>
-      )}
-    </Modal>
-  );
-};
-
-export default CloneVoiceModal;

apps/web/src/components/modals/clone-voice-modal.css

@@ -1,325 +0,0 @@
-/**
- * CloneVoiceModal — V21 Design System
- *
- * 音色克隆弹窗样式
- * 三步骤状态：input → uploading → success
- */
-
-/* ── 弹窗内容区 ─────────────────────────────────────────── */
-
-.cvm-body {
-  display: flex;
-  flex-direction: column;
-  gap: 20px;
-}
-
-/* ── 表单区 ─────────────────────────────────────────────── */
-
-.cvm-field {
-  display: flex;
-  flex-direction: column;
-  gap: 6px;
-}
-
-.cvm-label {
-  font-size: 13px;
-  font-weight: 600;
-  color: var(--text-secondary, #475467);
-}
-
-.cvm-input {
-  width: 100%;
-  padding: 10px 14px;
-  border: 1px solid var(--line, #e4e7ec);
-  border-radius: var(--radius-sm);
-  background: var(--bg-surface, #fff);
-  color: var(--text-primary, #101828);
-  font-size: 14px;
-  line-height: 1.5;
-  transition:
-    border-color 0.2s,
-    box-shadow 0.2s;
-  outline: none;
-}
-
-.cvm-input:focus {
-  border-color: var(--primary, #6366f1);
-  box-shadow: 0 0 0 3px
-    color-mix(in srgb, var(--primary-color) 12%, transparent);
-}
-
-.cvm-input::placeholder {
-  color: var(--muted, #98a2b3);
-}
-
-/* ── 上传区域 ───────────────────────────────────────────── */
-
-.cvm-upload-zone {
-  border: 2px dashed var(--line, #e4e7ec);
-  border-radius: var(--radius-md);
-  padding: 28px 20px;
-  text-align: center;
-  background: var(--bg-subtle, #f8fafc);
-  cursor: pointer;
-  transition:
-    border-color 0.2s,
-    background 0.2s;
-}
-
-.cvm-upload-zone:hover {
-  border-color: var(--primary, #6366f1);
-  background: color-mix(in srgb, var(--primary-color) 4%, transparent);
-}
-
-.cvm-upload-zone.cvm-upload-zone--active {
-  border-color: var(--primary, #6366f1);
-  background: color-mix(in srgb, var(--primary-color) 6%, transparent);
-}
-
-.cvm-upload-icon {
-  font-size: 36px;
-  margin-bottom: 8px;
-  line-height: 1;
-}
-
-.cvm-upload-title {
-  font-size: 14px;
-  font-weight: 600;
-  color: var(--text-primary, #101828);
-  margin: 0 0 4px;
-}
-
-.cvm-upload-hint {
-  font-size: 13px;
-  color: var(--muted, #98a2b3);
-  margin: 0;
-}
-
-/* ── 或分隔线 ───────────────────────────────────────────── */
-
-.cvm-divider {
-  display: flex;
-  align-items: center;
-  gap: 16px;
-  margin: 4px 0;
-}
-
-.cvm-divider-line {
-  flex: 1;
-  height: 1px;
-  background: var(--line, #e4e7ec);
-}
-
-.cvm-divider-text {
-  font-size: 13px;
-  color: var(--muted, #98a2b3);
-  flex-shrink: 0;
-}
-
-/* ── 录制区域 ───────────────────────────────────────────── */
-
-.cvm-record-area {
-  border: 1px solid var(--line, #e4e7ec);
-  border-radius: var(--radius-md);
-  padding: 24px;
-  text-align: center;
-}
-
-.cvm-record-hint {
-  font-size: 13px;
-  color: var(--muted, #98a2b3);
-  margin: 0 0 14px;
-}
-
-.cvm-record-btn {
-  width: 80px;
-  height: 80px;
-  border-radius: 50%;
-  border: none;
-  cursor: pointer;
-  font-size: 32px;
-  line-height: 1;
-  padding: 0;
-  background: linear-gradient(
-    135deg,
-    var(--error-color, #ef4444),
-    var(--error-dark, #dc2626)
-  );
-  color: var(--text-inverse);
-  box-shadow: 0 4px 14px
-    color-mix(in srgb, var(--error-color, #ef4444) 35%, transparent);
-  transition:
-    transform 0.15s,
-    box-shadow 0.15s;
-  display: inline-flex;
-  align-items: center;
-  justify-content: center;
-}
-
-.cvm-record-btn:hover {
-  transform: scale(1.06);
-  box-shadow: 0 6px 20px
-    color-mix(in srgb, var(--error-color, #ef4444) 45%, transparent);
-}
-
-.cvm-record-btn:active {
-  transform: scale(0.96);
-}
-
-.cvm-record-btn--recording {
-  animation: cvm-pulse 1.2s ease-in-out infinite;
-}
-
-@keyframes cvm-pulse {
-  0%,
-  100% {
-    box-shadow: 0 4px 14px
-      color-mix(in srgb, var(--error-color, #ef4444) 35%, transparent);
-  }
-  50% {
-    box-shadow: 0 4px 28px
-      color-mix(in srgb, var(--error-color, #ef4444) 60%, transparent);
-  }
-}
-
-/* ── 提示条 ─────────────────────────────────────────────── */
-
-.cvm-tip {
-  display: flex;
-  align-items: flex-start;
-  gap: 8px;
-  padding: 12px 16px;
-  background: var(--warning-soft, #fef3c7);
-  border-radius: var(--radius-sm);
-  font-size: 13px;
-  color: var(--warning-color, #92400e);
-  line-height: 1.5;
-}
-
-.cvm-tip-icon {
-  flex-shrink: 0;
-  font-size: 14px;
-  line-height: 1.5;
-}
-
-/* ── 底部按钮 ───────────────────────────────────────────── */
-
-.cvm-footer {
-  display: flex;
-  gap: 12px;
-  margin-top: 4px;
-}
-
-.cvm-footer .xx-btn {
-  flex: 1;
-}
-
-/* ── 上传中状态 ─────────────────────────────────────────── */
-
-.cvm-uploading {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  padding: 48px 20px;
-  gap: 16px;
-}
-
-.cvm-uploading-spinner {
-  width: 48px;
-  height: 48px;
-  border: 3px solid var(--line, #e4e7ec);
-  border-top-color: var(--primary, #6366f1);
-  border-radius: 50%;
-  animation: cvm-spin 0.8s linear infinite;
-}
-
-@keyframes cvm-spin {
-  to {
-    transform: rotate(360deg);
-  }
-}
-
-.cvm-uploading-text {
-  font-size: 15px;
-  font-weight: 500;
-  color: var(--text-primary, #101828);
-  margin: 0;
-}
-
-.cvm-uploading-sub {
-  font-size: 13px;
-  color: var(--muted, #98a2b3);
-  margin: 0;
-}
-
-/* ── 成功状态 ───────────────────────────────────────────── */
-
-.cvm-success {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  padding: 48px 20px;
-  gap: 12px;
-}
-
-.cvm-success-icon {
-  font-size: 56px;
-  line-height: 1;
-}
-
-.cvm-success-title {
-  font-size: 18px;
-  font-weight: 700;
-  color: var(--text-primary, #101828);
-  margin: 0;
-}
-
-.cvm-success-desc {
-  font-size: 14px;
-  color: var(--muted, #98a2b3);
-  margin: 0;
-}
-
-/* ── 响应式 ─────────────────────────────────────────────── */
-
-@media (max-width: 768px) {
-  .cvm-overlay {
-    padding: var(--space-md);
-  }
-
-  .cvm-modal {
-    width: 100%;
-    max-width: 100%;
-    padding: var(--space-lg);
-  }
-}
-
-@media (max-width: 576px) {
-  .cvm-upload-zone {
-    padding: 20px 14px;
-  }
-
-  .cvm-record-btn {
-    width: 64px;
-    height: 64px;
-    font-size: 26px;
-  }
-
-  .cvm-footer {
-    flex-direction: column;
-  }
-}
-
-@media (max-width: 480px) {
-  .cvm-record-btn {
-    width: 60px;
-    height: 60px;
-  }
-
-  .cvm-tip {
-    font-size: 12px;
-    padding: var(--space-sm);
-  }
-}

apps/web/src/components/ui/Form.tsx

@@ -1,37 +0,0 @@
-/**
- * V21 Form 表单
- * 封装 Ant Design Form，应用 V21 设计系统样式
- */
-import React from "react";
-import { Form as AntForm } from "antd";
-import type { FormProps as AntFormProps } from "antd";
-import classNames from "classnames";
-import "./ui.css";
-
-export interface FormProps extends AntFormProps {
-  /** 紧凑模式（减小表单项间距） */
-  compact?: boolean;
-}
-
-const Form = ({ className, compact, children, ...rest }: FormProps) => {
-  const v21Class = classNames(
-    "xx-form",
-    compact && "xx-form-compact",
-    className,
-  );
-  return (
-    <AntForm
-      className={v21Class}
-      {...(rest as Omit<FormProps, "className" | "compact" | "children">)}
-    >
-      {children as React.ReactNode}
-    </AntForm>
-  );
-};
-
-/** 导出 Form 的子组件（保持 antd API 一致） */
-export const FormItem = AntForm.Item;
-export const FormList = AntForm.List;
-export const FormProvider = AntForm.Provider;
-
-export default Form;

apps/web/src/components/ui/Pagination.tsx

@@ -1,25 +0,0 @@
-/**
- * V21 Pagination 分页
- * 封装 Ant Design Pagination，应用 V21 设计系统样式
- */
-import React from "react";
-import { Pagination as AntPagination } from "antd";
-import type { PaginationProps as AntPaginationProps } from "antd";
-import classNames from "classnames";
-import "./ui.css";
-
-export interface PaginationProps extends AntPaginationProps {
-  /** 使用 V21 样式 */
-  v21?: boolean;
-}
-
-const Pagination: React.FC<PaginationProps> = ({
-  className,
-  v21 = true,
-  ...rest
-}) => {
-  const v21Class = classNames(v21 && "xx-pagination", className);
-  return <AntPagination className={v21Class} {...rest} />;
-};
-
-export default Pagination;

apps/web/src/components/ui/Table.tsx

@@ -1,29 +0,0 @@
-/**
- * V21 Table 表格
- * 封装 Ant Design Table，应用 V21 设计系统样式
- */
-import React from "react";
-import { Table as AntTable } from "antd";
-import type { TableProps as AntTableProps } from "antd";
-import classNames from "classnames";
-import "./ui.css";
-
-export interface TableProps<
-  RecordType = unknown,
-> extends AntTableProps<RecordType> {
-  /** 使用 V21 样式 */
-  v21?: boolean;
-}
-
-function Table<RecordType extends object = Record<string, unknown>>({
-  className,
-  v21 = true,
-  ...rest
-}: TableProps<RecordType>) {
-  const v21Class = classNames(v21 && "xx-table", className);
-  return <AntTable<RecordType> className={v21Class} {...rest} />;
-}
-
-export default Table as <RecordType extends object = Record<string, unknown>>(
-  props: TableProps<RecordType> & React.RefAttributes<HTMLDivElement>,
-) => React.ReactElement;

apps/web/src/components/ui/index.ts

@@ -15,9 +15,6 @@ export type { SelectProps } from "./Select";
 export { default as Modal } from "./Modal";
 export type { ModalProps } from "./Modal";
 
-export { default as Table } from "./Table";
-export type { TableProps } from "./Table";
-
 export { default as Card } from "./Card";
 export type { CardProps } from "./Card";
 
@@ -26,9 +23,3 @@ export type { TagProps, TagVariant } from "./Tag";
 
 export { Tooltip, Popover } from "./Tooltip";
 export type { TooltipProps, PopoverProps } from "./Tooltip";
-
-export { default as Form, FormItem, FormList, FormProvider } from "./Form";
-export type { FormProps } from "./Form";
-
-export { default as Pagination } from "./Pagination";
-export type { PaginationProps } from "./Pagination";

apps/web/src/components/ui/ui.css

@@ -532,3 +532,23 @@
     padding: 8px 16px !important;
   }
 }
+
+
+/* ── xx-card antd 子元素覆盖样式（从 Admin.css 迁移） ── */
+/* AdminComingSoon 等页面使用 <Card className="xx-card"> 时需要 */
+/* .xx-card 基础样式和 :hover 已在 global.css 中定义（V21 设计系统） */
+
+.xx-card .ant-card-head {
+  border-bottom: 1px solid var(--border-color);
+  padding: 20px 24px;
+}
+
+.xx-card .ant-card-head-title {
+  font-weight: 800;
+  font-size: 17px;
+  color: var(--text-primary);
+}
+
+.xx-card .ant-card-body {
+  padding: 24px;
+}

apps/web/src/pages/accounts/Accounts.tsx

@@ -2,194 +2,66 @@
  * 账号管理页面 — V21 Design System
  *
  * 展示多平台账号绑定状态（抖音/快手/小红书/微信视频号）
- * 支持绑定/解绑操作
+ * 后端账号管理 API 尚未就绪，当前展示占位状态
  *
  * 零 antd 直接导入，全部使用 CSS 变量
  */
-import React, { useState, useCallback } from "react";
-import { useQueries, useMutation, useQueryClient } from "@tanstack/react-query";
+import React from "react";
 import { Button } from "@/components/ui";
 import PageHead from "@/components/layout/PageHead";
-import {
-  PLATFORMS,
-  getAccountsByPlatform,
-  unbindAccount,
-  bindAccount,
-  ACCOUNT_STATUS_CONFIG,
-  type Platform,
-  type Account,
-  type PlatformId,
-} from "@/api/accounts";
 import "./accounts.css";
 
-/* ── Toast 系统 ─────────────────────────────────────────── */
+/* ── 类型定义 ───────────────────────────────────────────── */
 
-interface Toast {
-  id: number;
-  message: string;
-  type: "success" | "error";
+export type PlatformId =
+  | "douyin"
+  | "kuaishou"
+  | "xiaohongshu"
+  | "wechat";
+
+export interface Platform {
+  id: PlatformId;
+  name: string;
+  subName: string;
+  icon: string;
+  gradient: string;
 }
 
-let toastIdCounter = 0;
-
-/* ── 平台卡片组件 ───────────────────────────────────────── */
-
-interface PlatformCardProps {
-  platform: Platform;
-  accounts: Account[];
-  isLoading: boolean;
-  onBind: (platformId: PlatformId) => void;
-  onUnbind: (accountId: string, accountName: string) => void;
-}
-
-const PlatformCard: React.FC<PlatformCardProps> = ({
-  platform,
-  accounts,
-  isLoading,
-  onBind,
-  onUnbind,
-}) => {
-  return (
-    <div className="acc-card">
-      {/* 平台头部 */}
-      <div className="acc-card-header">
-        <div
-          className="acc-card-icon"
-          style={{ background: platform.gradient }}
-        >
-          {platform.icon}
-        </div>
-        <div>
-          <h3 className="acc-card-title">{platform.name}</h3>
-          <p className="acc-card-subtitle">{platform.subName}</p>
-        </div>
-      </div>
-
-      {/* 账号列表 */}
-      <div className="acc-account-list">
-        {isLoading ? (
-          <div className="acc-empty">
-            <p className="acc-empty-text">加载中…</p>
-          </div>
-        ) : accounts.length > 0 ? (
-          accounts.map((account) => {
-            const statusCfg = ACCOUNT_STATUS_CONFIG[account.status];
-            return (
-              <div key={account.id} className="acc-account-row">
-                <div
-                  className="acc-account-avatar"
-                  style={{ background: platform.gradient }}
-                >
-                  {account.avatar || platform.icon}
-                </div>
-                <div className="acc-account-info">
-                  <div className="acc-account-name">{account.name}</div>
-                  <span className={`acc-status-pill ${statusCfg.className}`}>
-                    {statusCfg.label}
-                  </span>
-                </div>
-                <Button
-                  buttonType="ghost"
-                  buttonSize="sm"
-                  onClick={() => onUnbind(account.id, account.name)}
-                >
-                  解绑
-                </Button>
-              </div>
-            );
-          })
-        ) : (
-          <div className="acc-empty">
-            <div className="acc-empty-icon">🔓</div>
-            <p className="acc-empty-text">暂未绑定账号</p>
-          </div>
-        )}
-      </div>
-
-      {/* 绑定按钮 */}
-      <Button buttonType="ghost" onClick={() => onBind(platform.id)}>
-        + 绑定新账号
-      </Button>
-    </div>
-  );
-};
+/** 支持的平台列表 */
+const PLATFORMS: Platform[] = [
+  {
+    id: "douyin",
+    name: "抖音",
+    subName: "短视频发布",
+    icon: "🎵",
+    gradient: "linear-gradient(135deg, #000 0%, #333 100%)",
+  },
+  {
+    id: "kuaishou",
+    name: "快手",
+    subName: "短视频发布",
+    icon: "📹",
+    gradient: "linear-gradient(135deg, #ff6600 0%, #ff9933 100%)",
+  },
+  {
+    id: "xiaohongshu",
+    name: "小红书",
+    subName: "种草笔记 + 视频",
+    icon: "📕",
+    gradient: "linear-gradient(135deg, #fe2c55 0%, #ff6680 100%)",
+  },
+  {
+    id: "wechat",
+    name: "微信视频号",
+    subName: "视频号发布",
+    icon: "💬",
+    gradient: "linear-gradient(135deg, #07c160 0%, #38d97a 100%)",
+  },
+];
 
 /* ── 主页面 ─────────────────────────────────────────────── */
 
 const Accounts: React.FC = () => {
-  const queryClient = useQueryClient();
-  const [toasts, setToasts] = useState<Toast[]>([]);
-
-  /** 显示 toast */
-  const showToast = useCallback((message: string, type: Toast["type"]) => {
-    const id = ++toastIdCounter;
-    setToasts((prev) => [...prev, { id, message, type }]);
-    setTimeout(() => {
-      setToasts((prev) => prev.filter((t) => t.id !== id));
-    }, 3000);
-  }, []);
-
-  /** 查询所有平台的账号 */
-  const _queriesResults = useQueries({
-    queries: PLATFORMS.map((platform) => ({
-      queryKey: ["accounts", platform.id] as const,
-      queryFn: () => getAccountsByPlatform(platform.id),
-    })),
-  });
-  const accountQueries = PLATFORMS.map((platform, i) => ({
-    platform,
-    ..._queriesResults[i],
-  }));
-
-  /** 解绑 mutation */
-  const unbindMutation = useMutation({
-    mutationFn: unbindAccount,
-    onSuccess: () => {
-      queryClient.invalidateQueries({ queryKey: ["accounts"] });
-      showToast("已解绑账号", "success");
-    },
-    onError: () => {
-      showToast("解绑失败", "error");
-    },
-  });
-
-  /** 绑定 mutation（mock） */
-  const bindMutation = useMutation({
-    mutationFn: bindAccount,
-    onSuccess: () => {
-      queryClient.invalidateQueries({ queryKey: ["accounts"] });
-      showToast("账号绑定成功", "success");
-    },
-    onError: () => {
-      showToast("绑定失败", "error");
-    },
-  });
-
-  /** 绑定新账号（mock：直接创建） */
-  const handleBind = (platformId: PlatformId) => {
-    const platform = PLATFORMS.find((p) => p.id === platformId);
-    if (!platform) return;
-
-    const name = window.prompt(`请输入要绑定的${platform.name}账号名称：`);
-    if (name && name.trim()) {
-      bindMutation.mutate({ platform_id: platformId, name: name.trim() });
-    }
-  };
-
-  /** 解绑账号 */
-  const handleUnbind = (accountId: string, accountName: string) => {
-    if (window.confirm(`确定解绑账号「${accountName}」吗？`)) {
-      unbindMutation.mutate(accountId);
-    }
-  };
-
-  /** 统计已绑定账号数 */
-  const totalBound = accountQueries.reduce(
-    (sum, q) => sum + (q.data?.length ?? 0),
-    0,
-  );
-  const totalPlatforms = PLATFORMS.length;
-
   return (
     <div className="acc-page">
       <PageHead
@@ -197,17 +69,34 @@ const Accounts: React.FC = () => {
         description="绑定您的社交平台账号，用于视频一键发布到各平台"
       />
 
-      {/* 平台卡片网格 */}
+      {/* 平台卡片网格 — 占位状态 */}
       <div className="acc-grid">
-        {accountQueries.map(({ platform, data, isLoading }) => (
-          <PlatformCard
-            key={platform.id}
-            platform={platform}
-            accounts={data ?? []}
-            isLoading={isLoading}
-            onBind={handleBind}
-            onUnbind={handleUnbind}
-          />
+        {PLATFORMS.map((platform) => (
+          <div key={platform.id} className="acc-card">
+            <div className="acc-card-header">
+              <div
+                className="acc-card-icon"
+                style={{ background: platform.gradient }}
+              >
+                {platform.icon}
+              </div>
+              <div>
+                <h3 className="acc-card-title">{platform.name}</h3>
+                <p className="acc-card-subtitle">{platform.subName}</p>
+              </div>
+            </div>
+
+            <div className="acc-account-list">
+              <div className="acc-empty">
+                <div className="acc-empty-icon">🔒</div>
+                <p className="acc-empty-text">功能即将上线</p>
+              </div>
+            </div>
+
+            <Button buttonType="ghost" disabled>
+              即将支持绑定
+            </Button>
+          </div>
         ))}
       </div>
 
@@ -215,22 +104,10 @@ const Accounts: React.FC = () => {
       <div className="acc-stats-bar">
         <span className="acc-stats-icon">📊</span>
         <span className="acc-stats-text">
-          已绑定 <span className="acc-stats-highlight">{totalBound}</span>{" "}
-          个账号 / 支持{" "}
-          <span className="acc-stats-highlight">{totalPlatforms}</span> 个平台
+          支持 <span className="acc-stats-highlight">{PLATFORMS.length}</span>{" "}
+          个平台，功能即将上线
         </span>
       </div>
-
-      {/* Toast 提示 */}
-      {toasts.length > 0 && (
-        <div className="vc-toast-container">
-          {toasts.map((t) => (
-            <div key={t.id} className={`vc-toast vc-toast--${t.type}`}>
-              {t.type === "success" ? "✅" : "❌"} {t.message}
-            </div>
-          ))}
-        </div>
-      )}
     </div>
   );
 };

apps/web/src/pages/accounts/accounts.css

@@ -82,77 +82,6 @@
   gap: 10px;
 }
 
-/* ── 账号行 ─────────────────────────────────────────────── */
-
-.acc-account-row {
-  display: flex;
-  align-items: center;
-  gap: 10px;
-  padding: 12px;
-  background: var(--bg-secondary);
-  border-radius: var(--radius-md);
-  transition: var(--transition-fast);
-}
-
-.acc-account-row:hover {
-  background: var(--primary-soft);
-}
-
-.acc-account-avatar {
-  width: 36px;
-  height: 36px;
-  border-radius: 50%;
-  display: grid;
-  place-items: center;
-  color: var(--text-inverse);
-  font-weight: var(--font-weight-bold);
-  font-size: var(--font-size-sm);
-  flex-shrink: 0;
-}
-
-.acc-account-info {
-  flex: 1;
-  min-width: 0;
-}
-
-.acc-account-name {
-  font-size: var(--font-size-base);
-  font-weight: var(--font-weight-semibold);
-  color: var(--text-primary);
-  white-space: nowrap;
-  overflow: hidden;
-  text-overflow: ellipsis;
-}
-
-/* ── 状态标签 ───────────────────────────────────────────── */
-
-.acc-status-pill {
-  display: inline-flex;
-  align-items: center;
-  gap: 4px;
-  padding: 2px 8px;
-  border-radius: var(--radius-full);
-  font-size: var(--font-size-xs);
-  font-weight: var(--font-weight-semibold);
-  line-height: 1.6;
-  margin-top: 2px;
-}
-
-.acc-status--active {
-  background: var(--success-soft);
-  color: var(--secondary-color);
-}
-
-.acc-status--expired {
-  background: var(--error-soft);
-  color: var(--error-color);
-}
-
-.acc-status--limited {
-  background: var(--warning-soft);
-  color: var(--accent-color);
-}
-
 /* ── 空状态 ─────────────────────────────────────────────── */
 
 .acc-empty {
@@ -235,17 +164,6 @@
     font-size: var(--font-size-base);
   }
 
-  .acc-account-row {
-    padding: 10px;
-    gap: 8px;
-  }
-
-  .acc-account-avatar {
-    width: 32px;
-    height: 32px;
-    font-size: var(--font-size-xs);
-  }
-
   .acc-stats-bar {
     padding: var(--space-sm) var(--space-md);
     font-size: var(--font-size-sm);

apps/web/src/pages/admin/Admin.css

@@ -1,442 +1,20 @@
-/* V21 Admin 页面样式 */
+/* Admin 页面样式（Phase 3 精简）
+ *
+ * 原始 477 行 → 精简至仅保留实际使用的 class。
+ * 已迁移至 global.css / ui.css 的样式不再重复定义：
+ *   .xx-page-head       → global.css
+ *   .xx-primary-btn     → global.css
+ *   .xx-tag / .xx-card  → ui.css / global.css
+ *
+ * 以下 class 仅被 AdminComingSoon.tsx 使用。
+ */
 
-/* 页面容器 */
-.dashboard-page,
-.analytics-page,
-.user-management-page,
-.log-viewer-page,
-.system-monitor-page,
 .admin-coming-soon-page {
   padding: 32px;
   max-width: 1400px;
   margin: 0 auto;
 }
 
-/* 页面头部 */
-.xx-page-head {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-xl);
-  box-shadow: 0 24px 70px rgba(15, 23, 42, 0.09);
-  padding: 32px 40px;
-  margin-bottom: 32px;
-  display: flex;
-  justify-content: space-between;
-  align-items: center;
-}
-
-.xx-page-head-content {
-  display: flex;
-  flex-direction: column;
-  gap: 8px;
-}
-
-.xx-page-head h2 {
-  font-size: 28px;
-  font-weight: 900;
-  color: var(--slate, #0f172a);
-  margin: 0;
-  letter-spacing: -0.02em;
-}
-
-.xx-page-head p {
-  font-size: 15px;
-  color: var(--muted, #64748b);
-  margin: 0;
-}
-
-.xx-page-head-actions {
-  display: flex;
-  gap: 12px;
-  align-items: center;
-}
-
-/* 简化页面头部（无操作按钮） */
-.xx-page-head-simple {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-xl);
-  box-shadow: 0 24px 70px rgba(15, 23, 42, 0.09);
-  padding: 32px 40px;
-  margin-bottom: 32px;
-}
-
-.xx-page-head-simple h2 {
-  font-size: 28px;
-  font-weight: 900;
-  color: var(--slate, #0f172a);
-  margin: 0 0 8px;
-  letter-spacing: -0.02em;
-}
-
-.xx-page-head-simple p {
-  font-size: 15px;
-  color: var(--muted, #64748b);
-  margin: 0;
-}
-
-/* 统计卡片网格 - 4列 */
-.xx-grid-4 {
-  display: grid;
-  grid-template-columns: repeat(4, 1fr);
-  gap: 24px;
-  margin-bottom: 32px;
-}
-
-@media (max-width: 1200px) {
-  .xx-grid-4 {
-    grid-template-columns: repeat(2, 1fr);
-  }
-}
-
-@media (max-width: 768px) {
-  .xx-grid-4 {
-    grid-template-columns: 1fr;
-  }
-}
-
-/* 统计卡片 */
-.xx-stat-card {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-lg);
-  box-shadow: 0 10px 30px rgba(15, 23, 42, 0.06);
-  padding: 24px;
-  transition: all 0.3s;
-}
-
-.xx-stat-card:hover {
-  transform: translateY(-2px);
-  box-shadow: 0 16px 40px rgba(15, 23, 42, 0.08);
-}
-
-.xx-stat-card-header {
-  display: flex;
-  justify-content: space-between;
-  align-items: flex-start;
-  margin-bottom: 16px;
-}
-
-.xx-stat-card-icon {
-  width: 48px;
-  height: 48px;
-  border-radius: var(--radius-md);
-  display: flex;
-  align-items: center;
-  justify-content: center;
-  font-size: 22px;
-}
-
-.xx-stat-card-icon.primary {
-  background: linear-gradient(135deg, #6366f1, #4f46e5);
-  color: white;
-}
-
-.xx-stat-card-icon.success {
-  background: linear-gradient(135deg, #34d399, #10b981);
-  color: white;
-}
-
-.xx-stat-card-icon.warning {
-  background: linear-gradient(135deg, #fbbf24, #f59e0b);
-  color: white;
-}
-
-.xx-stat-card-icon.purple {
-  background: linear-gradient(135deg, #a78bfa, #8b5cf6);
-  color: white;
-}
-
-.xx-stat-card-icon.info {
-  background: linear-gradient(135deg, #60a5fa, #3b82f6);
-  color: white;
-}
-
-.xx-stat-card-icon.orange {
-  background: linear-gradient(135deg, #fb923c, #f97316);
-  color: white;
-}
-
-.xx-stat-card-label {
-  font-size: 14px;
-  color: var(--muted, #64748b);
-  font-weight: 500;
-  margin-bottom: 8px;
-}
-
-.xx-stat-card-value {
-  font-size: 32px;
-  font-weight: 900;
-  color: var(--slate, #0f172a);
-  line-height: 1.2;
-  letter-spacing: -0.02em;
-}
-
-.xx-stat-card-value.primary {
-  color: var(--indigo, #4f46e5);
-}
-
-.xx-stat-card-value.success {
-  color: var(--green, #10b981);
-}
-
-.xx-stat-card-value.warning {
-  color: var(--amber, #f59e0b);
-}
-
-.xx-stat-card-value.purple {
-  color: #8b5cf6;
-}
-
-.xx-stat-card-growth {
-  font-size: 13px;
-  color: var(--green, #10b981);
-  font-weight: 600;
-  margin-top: 8px;
-  display: flex;
-  align-items: center;
-  gap: 4px;
-}
-
-/* 数据表格 */
-.xx-table-wrapper {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-lg);
-  box-shadow: 0 10px 30px rgba(15, 23, 42, 0.06);
-  overflow: hidden;
-}
-
-.xx-table-wrapper .ant-table {
-  background: transparent;
-}
-
-.xx-table-wrapper .ant-table-thead > tr > th {
-  background: rgba(248, 250, 252, 0.8);
-  font-weight: 800;
-  font-size: 13px;
-  color: var(--slate, #0f172a);
-  text-transform: uppercase;
-  letter-spacing: 0.05em;
-  padding: 16px 20px;
-}
-
-.xx-table-wrapper .ant-table-tbody > tr > td {
-  padding: 16px 20px;
-  font-size: 14px;
-}
-
-.xx-table-wrapper .ant-table-tbody > tr:hover > td {
-  background: rgba(79, 70, 229, 0.03);
-}
-
-/* V21 按钮 */
-.xx-primary-btn {
-  background: linear-gradient(135deg, #6366f1, #4f46e5) !important;
-  color: white !important;
-  border: none !important;
-  border-radius: var(--radius-md) !important;
-  font-weight: 700 !important;
-  box-shadow: 0 8px 20px rgba(79, 70, 229, 0.25) !important;
-  transition: all 0.2s !important;
-}
-
-.xx-primary-btn:hover {
-  box-shadow: 0 12px 28px rgba(79, 70, 229, 0.3) !important;
-  transform: translateY(-1px);
-}
-
-.xx-ghost-btn {
-  background: white !important;
-  border: 1px solid rgba(226, 232, 240, 0.95) !important;
-  color: var(--slate, #0f172a) !important;
-  border-radius: var(--radius-md) !important;
-  font-weight: 600 !important;
-  transition: all 0.2s !important;
-}
-
-.xx-ghost-btn:hover {
-  border-color: var(--indigo, #4f46e5) !important;
-  color: var(--indigo, #4f46e5) !important;
-}
-
-/* V21 输入框 */
-.xx-search-input {
-  border-radius: var(--radius-md) !important;
-  border: 1px solid rgba(226, 232, 240, 0.95) !important;
-  padding: 8px 16px !important;
-}
-
-.xx-search-input:hover,
-.xx-search-input:focus {
-  border-color: var(--indigo, #4f46e5) !important;
-  box-shadow: 0 0 0 3px rgba(79, 70, 229, 0.1) !important;
-}
-
-/* V21 Tag */
-.xx-tag {
-  border-radius: var(--radius-xs) !important;
-  font-weight: 600 !important;
-  font-size: 12px !important;
-  padding: 4px 10px !important;
-}
-
-.xx-tag.info {
-  background: rgba(59, 130, 246, 0.1) !important;
-  color: #3b82f6 !important;
-  border: 1px solid rgba(59, 130, 246, 0.2) !important;
-}
-
-.xx-tag.success {
-  background: rgba(16, 185, 129, 0.1) !important;
-  color: #10b981 !important;
-  border: 1px solid rgba(16, 185, 129, 0.2) !important;
-}
-
-.xx-tag.warning {
-  background: rgba(245, 158, 11, 0.1) !important;
-  color: #f59e0b !important;
-  border: 1px solid rgba(245, 158, 11, 0.2) !important;
-}
-
-.xx-tag.error {
-  background: rgba(239, 68, 68, 0.1) !important;
-  color: #ef4444 !important;
-  border: 1px solid rgba(239, 68, 68, 0.2) !important;
-}
-
-.xx-tag.debug {
-  background: rgba(100, 116, 139, 0.1) !important;
-  color: #64748b !important;
-  border: 1px solid rgba(100, 116, 139, 0.2) !important;
-}
-
-/* V21 Progress */
-.xx-progress-primary .ant-progress-circle .ant-progress-text {
-  color: var(--indigo, #4f46e5) !important;
-  font-weight: 700 !important;
-}
-
-.xx-progress-success .ant-progress-circle .ant-progress-text {
-  color: var(--green, #10b981) !important;
-  font-weight: 700 !important;
-}
-
-.xx-progress-warning .ant-progress-circle .ant-progress-text {
-  color: var(--amber, #f59e0b) !important;
-  font-weight: 700 !important;
-}
-
-/* 图表容器 */
-.xx-chart-container {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-lg);
-  box-shadow: 0 10px 30px rgba(15, 23, 42, 0.06);
-  padding: 24px;
-}
-
-.xx-chart-container .ant-card-head {
-  border-bottom: 1px solid rgba(226, 232, 240, 0.8);
-  padding: 20px 24px;
-}
-
-.xx-chart-container .ant-card-head-title {
-  font-weight: 800;
-  font-size: 17px;
-  color: var(--slate, #0f172a);
-}
-
-/* 筛选器区域 */
-.xx-filter-bar {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-lg);
-  box-shadow: 0 10px 30px rgba(15, 23, 42, 0.06);
-  padding: 20px 24px;
-  margin-bottom: 24px;
-  display: flex;
-  flex-wrap: wrap;
-  gap: 16px;
-  align-items: center;
-}
-
-/* 资源监控卡片 */
-.xx-resource-card {
-  background: rgba(255, 255, 255, 0.94);
-  border: 1px solid rgba(226, 232, 240, 0.95);
-  border-radius: var(--radius-lg);
-  box-shadow: 0 10px 30px rgba(15, 23, 42, 0.06);
-  padding: 24px;
-  text-align: center;
-}
-
-.xx-resource-card-icon {
-  width: 64px;
-  height: 64px;
-  border-radius: var(--radius-md);
-  display: flex;
-  align-items: center;
-  justify-content: center;
-  margin: 0 auto 16px;
-  font-size: 28px;
-}
-
-.xx-resource-card-label {
-  font-size: 14px;
-  color: var(--muted, #64748b);
-  font-weight: 600;
-  margin-bottom: 16px;
-}
-
-/* 日期选择器 */
-.xx-date-picker {
-  border-radius: var(--radius-md) !important;
-}
-
-/* Drawer */
-.xx-drawer .ant-drawer-header {
-  border-bottom: 1px solid rgba(226, 232, 240, 0.8);
-  padding: 20px 24px;
-}
-
-.xx-drawer .ant-drawer-title {
-  font-weight: 800;
-  font-size: 18px;
-  color: var(--slate, #0f172a);
-}
-
-/* 日志详情 */
-.xx-log-detail {
-  padding: 4px 0;
-}
-
-.xx-log-detail-label {
-  font-size: 13px;
-  font-weight: 700;
-  color: var(--slate, #0f172a);
-  margin-bottom: 4px;
-}
-
-.xx-log-detail-value {
-  font-size: 14px;
-  color: var(--muted, #64748b);
-  background: rgba(248, 250, 252, 0.8);
-  padding: 12px;
-  border-radius: var(--radius-sm);
-  margin-bottom: 16px;
-}
-
-.xx-log-detail-code {
-  font-family: "JetBrains Mono", "Fira Code", monospace;
-  background: rgba(248, 250, 252, 0.8);
-  padding: 12px;
-  border-radius: var(--radius-sm);
-  white-space: pre-wrap;
-  word-break: break-all;
-}
-
-/* Result 页面居中 */
 .xx-result-center {
   display: flex;
   justify-content: center;
@@ -447,31 +25,3 @@
 .xx-result-center .ant-result {
   padding: 48px;
 }
-
-/* 刷新时间显示 */
-.xx-refresh-time {
-  font-size: 13px;
-  color: var(--muted, #64748b);
-  margin-right: 12px;
-}
-
-/* 图表配色覆盖 */
-.recharts-text {
-  fill: #64748b !important;
-  font-size: 12px !important;
-}
-
-.recharts-cartesian-grid-horizontal line,
-.recharts-cartesian-grid-vertical line {
-  stroke: rgba(226, 232, 240, 0.8) !important;
-}
-
-/* 图表 Legend */
-.recharts-legend-wrapper {
-  padding-top: 16px !important;
-}
-
-.recharts-legend-item-text {
-  color: #64748b !important;
-  font-size: 13px !important;
-}

apps/web/src/pages/dashboard/Dashboard.tsx

@@ -1,451 +1,85 @@
 /**
  * 控制台页面 — V21 设计系统
  * KPI 卡片网格 + 快速入口 + 最近任务卡片列表 + 使用统计图表 + 公告
- * 使用 mock 数据，CSS 变量，V21 组件
+ * CSS 变量，V21 组件
  */
 import React from "react";
 import { useNavigate } from "react-router-dom";
-import { Button, Tag } from "@/components/ui";
-import {
-  VideoCameraOutlined,
-  AppstoreOutlined,
-  ThunderboltOutlined,
-  DatabaseOutlined,
-  FileTextOutlined,
-} from "@ant-design/icons";
+import { Button } from "@/components/ui";
+import { DatabaseOutlined } from "@ant-design/icons";
 import "./dashboard.css";
 
-/* ============================================================
- * Mock 数据
- * ============================================================ */
-interface KpiItem {
-  key: string;
-  icon: string;
-  iconGradient: string;
-  value: string;
-  label: string;
-  trend: string;
-  trendDirection: "up" | "down" | "neutral";
-  accent: string;
-}
+/* ── 主组件 ─────────────────────────────────────────────── */
 
-const kpiData: KpiItem[] = [
-  {
-    key: "projects",
-    icon: "video",
-    iconGradient: "linear-gradient(135deg, #6366f1, #4f46e5)",
-    value: "12",
-    label: "项目总数",
-    trend: "↑ 2 本月新增",
-    trendDirection: "up",
-    accent: "#6366f1",
-  },
-  {
-    key: "assets",
-    icon: "appstore",
-    iconGradient: "linear-gradient(135deg, #0ea5e9, #0284c7)",
-    value: "486",
-    label: "素材总数",
-    trend: "↑ 38 本月上传",
-    trendDirection: "up",
-    accent: "#0ea5e9",
-  },
-  {
-    key: "generations",
-    icon: "thunderbolt",
-    iconGradient: "linear-gradient(135deg, #10b981, #059669)",
-    value: "156",
-    label: "本月生成数",
-    trend: "↑ 23% 较上月",
-    trendDirection: "up",
-    accent: "#10b981",
-  },
-  {
-    key: "storage",
-    icon: "database",
-    iconGradient: "linear-gradient(135deg, #f59e0b, #d97706)",
-    value: "2.4GB",
-    label: "存储空间",
-    trend: "已用 24%",
-    trendDirection: "neutral",
-    accent: "#f59e0b",
-  },
-];
-
-interface QuickEntry {
-  id: string;
-  icon: string;
-  iconGradient: string;
-  title: string;
-  description: string;
-  path: string;
-}
-
-const quickEntries: QuickEntry[] = [
-  {
-    id: "titles",
-    icon: "filetext",
-    iconGradient: "linear-gradient(135deg, #6366f1, #4f46e5)",
-    title: "标题库",
-    description: "24条标题 · 5个分类",
-    path: "/app/titles",
-  },
-  {
-    id: "assets",
-    icon: "appstore",
-    iconGradient: "linear-gradient(135deg, #0ea5e9, #0284c7)",
-    title: "素材库",
-    description: "486个素材 · 3个素材库",
-    path: "/app/assets",
-  },
-  {
-    id: "generate",
-    icon: "thunderbolt",
-    iconGradient: "linear-gradient(135deg, #10b981, #059669)",
-    title: "一键生成",
-    description: "开始创作新视频",
-    path: "/app/generate",
-  },
-  {
-    id: "products",
-    icon: "video",
-    iconGradient: "linear-gradient(135deg, #f59e0b, #d97706)",
-    title: "成片库",
-    description: "89个成片 · 3个待复核",
-    path: "/app/products",
-  },
-];
-
-type TaskStatus = "completed" | "processing" | "pending" | "failed";
-
-interface RecentTask {
-  id: string;
-  name: string;
-  type: string;
-  template: string;
-  status: TaskStatus;
-  date: string;
-  duration?: string;
-}
-
-const statusLabel: Record<TaskStatus, string> = {
-  completed: "已完成",
-  processing: "进行中",
-  pending: "排队中",
-  failed: "失败",
-};
-
-const recentTasks: RecentTask[] = [
-  {
-    id: "t-1",
-    name: "产品介绍视频_春季促销",
-    type: "视频生成",
-    template: "商品展示模板",
-    status: "completed",
-    date: "2026-07-01 09:30",
-    duration: "2分18秒",
-  },
-  {
-    id: "t-2",
-    name: "品牌宣传片_终版",
-    type: "视频生成",
-    template: "品牌宣传模板",
-    status: "processing",
-    date: "2026-07-01 10:15",
-  },
-  {
-    id: "t-3",
-    name: "用户评价合集",
-    type: "视频生成",
-    template: "评价展示模板",
-    status: "completed",
-    date: "2026-06-30 16:42",
-    duration: "1分45秒",
-  },
-  {
-    id: "t-4",
-    name: "新品发布预告",
-    type: "视频生成",
-    template: "新品预告模板",
-    status: "pending",
-    date: "2026-06-30 14:20",
-  },
-  {
-    id: "t-5",
-    name: "活动回顾_618大促",
-    type: "视频生成",
-    template: "活动回顾模板",
-    status: "failed",
-    date: "2026-06-29 11:05",
-  },
-];
-
-interface ChartItem {
-  label: string;
-  value: number;
-}
-
-const weeklyData: ChartItem[] = [
-  { label: "周一", value: 18 },
-  { label: "周二", value: 25 },
-  { label: "周三", value: 32 },
-  { label: "周四", value: 28 },
-  { label: "周五", value: 42 },
-  { label: "周六", value: 15 },
-  { label: "周日", value: 8 },
-];
-
-interface Announcement {
-  id: string;
-  tag: "update" | "notice" | "activity";
-  tagLabel: string;
-  title: string;
-  date: string;
-}
-
-const announcements: Announcement[] = [
-  {
-    id: "a-1",
-    tag: "update",
-    tagLabel: "更新",
-    title: "系统已升级至 v2.0，新增批量生成功能",
-    date: "2026-07-01",
-  },
-  {
-    id: "a-2",
-    tag: "activity",
-    tagLabel: "活动",
-    title: "7月创作挑战赛已开启，参与赢积分奖励",
-    date: "2026-06-28",
-  },
-  {
-    id: "a-3",
-    tag: "notice",
-    tagLabel: "公告",
-    title: "7月3日凌晨 2:00-4:00 系统维护通知",
-    date: "2026-06-25",
-  },
-];
-
-/* ============================================================
- * 工具函数
- * ============================================================ */
-const getGreeting = () => {
-  const hour = new Date().getHours();
-  if (hour < 6) return "夜深了";
-  if (hour < 12) return "早上好";
-  if (hour < 14) return "中午好";
-  if (hour < 18) return "下午好";
-  return "晚上好";
-};
-
-const formatDate = () => {
-  const d = new Date();
-  const weekDays = ["日", "一", "二", "三", "四", "五", "六"];
-  return `${d.getFullYear()}年${d.getMonth() + 1}月${d.getDate()}日 星期${weekDays[d.getDay()]}`;
-};
-
-/** 图标名称 → Ant Design 组件映射 */
-const iconMap: Record<string, React.ReactNode> = {
-  video: <VideoCameraOutlined />,
-  appstore: <AppstoreOutlined />,
-  thunderbolt: <ThunderboltOutlined />,
-  database: <DatabaseOutlined />,
-  filetext: <FileTextOutlined />,
-};
-
-/* ============================================================
- * 组件
- * ============================================================ */
 const Dashboard: React.FC = () => {
   const navigate = useNavigate();
 
-  const maxChart = Math.max(...weeklyData.map((d) => d.value));
-
   return (
     <div className="xx-dashboard-page">
-      {/* ── 欢迎头部 ─────────────────────────────────────────── */}
-      <div className="xx-dashboard-welcome">
-        <h2>{getGreeting()}，创作者</h2>
-        <p>{formatDate()} — 欢迎回到小小剪辑控制台</p>
-      </div>
-
-      {/* ── KPI 卡片网格 ─────────────────────────────────────── */}
+      {/* KPI 卡片网格 */}
       <div className="xx-kpi-grid">
-        {kpiData.map((item) => (
-          <div
-            key={item.key}
-            className="xx-kpi-card"
-            style={{ "--kpi-accent": item.accent } as React.CSSProperties}
-          >
-            <div
-              className="xx-kpi-icon"
-              style={{ background: item.iconGradient }}
-            >
-              {iconMap[item.icon] ?? item.icon}
-            </div>
-            <div className="xx-kpi-value">{item.value}</div>
-            <div className="xx-kpi-label">{item.label}</div>
-            <span
-              className={`xx-kpi-trend xx-kpi-trend--${item.trendDirection}`}
-            >
-              {item.trend}
-            </span>
-          </div>
-        ))}
-      </div>
-
-      {/* ── 主内容区：左侧任务+图表 / 右侧公告 ──────────────── */}
-      <div className="xx-dashboard-main">
-        {/* 左列 */}
-        <div className="xx-dashboard-left-col">
-          {/* 最近任务 */}
-          <div className="xx-dashboard-section">
-            <div className="xx-dashboard-section-header">
-              <h3>最近任务</h3>
-              <button onClick={() => navigate("/app/history")}>查看全部</button>
-            </div>
-            <div className="xx-task-list">
-              {recentTasks.map((task) => (
-                <div key={task.id} className="xx-task-item">
-                  <div className="xx-task-info">
-                    <h4>{task.name}</h4>
-                    <span>
-                      {task.type} · 模板：{task.template}
-                    </span>
-                  </div>
-                  <Tag
-                    variant={
-                      task.status === "completed"
-                        ? "success"
-                        : task.status === "processing"
-                          ? "info"
-                          : task.status === "failed"
-                            ? "error"
-                            : "warning"
-                    }
-                  >
-                    {statusLabel[task.status]}
-                  </Tag>
-                  <div className="xx-task-time">
-                    <span>{task.date}</span>
-                    {task.status === "completed"
-                      ? `耗时 ${task.duration}`
-                      : task.status === "processing"
-                        ? "生成中..."
-                        : task.status === "failed"
-                          ? "请重试"
-                          : "等待中"}
-                  </div>
-                  <div className="xx-task-action">
-                    <Button
-                      buttonType="ghost"
-                      buttonSize="sm"
-                      onClick={() => navigate("/app/history")}
-                    >
-                      查看
-                    </Button>
-                  </div>
-                </div>
-              ))}
-            </div>
-          </div>
-
-          {/* 使用统计图表 */}
-          <div className="xx-dashboard-section">
-            <div className="xx-dashboard-section-header">
-              <h3>本周生成趋势</h3>
-              <span className="xx-chart-total">
-                共 {weeklyData.reduce((s, d) => s + d.value, 0)} 次
-              </span>
-            </div>
-            <div className="xx-chart-container">
-              <div className="xx-chart-bars">
-                {weeklyData.map((d, i) => (
-                  <div key={i} className="xx-chart-bar-wrapper">
-                    <div
-                      className="xx-chart-bar"
-                      style={{
-                        height: `${(d.value / maxChart) * 100}%`,
-                      }}
-                    >
-                      <span className="xx-chart-bar-value">{d.value}</span>
-                    </div>
-                  </div>
-                ))}
-              </div>
-              <div className="xx-chart-labels">
-                {weeklyData.map((d, i) => (
-                  <div key={i} className="xx-chart-label">
-                    {d.label}
-                  </div>
-                ))}
-              </div>
-            </div>
-          </div>
-        </div>
-
-        {/* 右列 — 公告 + 存储用量 */}
-        <div className="xx-dashboard-section xx-dashboard-section--start">
-          <div className="xx-dashboard-section-header">
-            <h3>系统公告</h3>
-          </div>
-          <div className="xx-announcement-list">
-            {announcements.map((a) => (
-              <div key={a.id} className="xx-announcement-item">
-                <span
-                  className={`xx-announcement-tag xx-announcement-tag--${a.tag}`}
-                >
-                  {a.tagLabel}
-                </span>
-                <div className="xx-announcement-content">
-                  <h4>{a.title}</h4>
-                  <time>{a.date}</time>
-                </div>
-              </div>
-            ))}
-          </div>
-
-          {/* 存储用量 */}
-          <div className="xx-storage-section">
-            <div className="xx-storage-section-title">存储用量</div>
-            <div className="xx-storage-bar">
-              <div className="xx-storage-bar-track">
-                <div className="xx-storage-bar-fill" style={{ width: "24%" }} />
-              </div>
-              <div className="xx-storage-bar-label">
-                <span>2.4 GB 已用</span>
-                <span>10 GB 总量</span>
-              </div>
-            </div>
-          </div>
+        <div className="xx-dashboard-empty">
+          <p>暂无统计数据</p>
         </div>
       </div>
 
-      {/* ── 快速入口 ─────────────────────────────────────────── */}
+      {/* 快速入口 */}
       <div className="xx-quick-entry-section">
         <div className="xx-quick-entry-header">
           <h3 className="xx-quick-entry-title">快速入口</h3>
         </div>
         <div className="xx-quick-grid">
-          {quickEntries.map((entry) => (
-            <div
-              key={entry.id}
-              className="xx-quick-card"
-              onClick={() => navigate(entry.path)}
-            >
-              <div
-                className="xx-quick-card-icon"
-                style={{ background: entry.iconGradient }}
-              >
-                {iconMap[entry.icon] ?? entry.icon}
-              </div>
-              <h3>{entry.title}</h3>
-              <p>{entry.description}</p>
-            </div>
-          ))}
+          <div className="xx-dashboard-empty">
+            <p>暂无快速入口</p>
+          </div>
         </div>
       </div>
+
+      {/* 最近任务 */}
+      <section className="xx-dashboard-section">
+        <div className="xx-dashboard-section-header">
+          <h3>最近任务</h3>
+          <Button buttonType="ghost" buttonSize="sm" onClick={() => navigate("/app/history")}>
+            查看全部
+          </Button>
+        </div>
+        <div className="xx-task-list">
+          <div className="xx-dashboard-empty">
+            <p>暂无最近任务</p>
+          </div>
+        </div>
+      </section>
+
+      {/* 使用统计 */}
+      <section className="xx-dashboard-section" style={{ marginTop: "var(--space-md)" }}>
+        <div className="xx-dashboard-section-header">
+          <h3>使用统计</h3>
+        </div>
+        <div className="xx-chart-container">
+          <div className="xx-chart-bars">
+            <div className="xx-dashboard-empty" style={{ width: "100%" }}>
+              <DatabaseOutlined style={{ fontSize: 24, marginBottom: 8 }} />
+              <p>暂无统计数据</p>
+            </div>
+          </div>
+        </div>
+      </section>
+
+      {/* 公告 */}
+      <section className="xx-dashboard-section" style={{ marginTop: "var(--space-md)" }}>
+        <div className="xx-dashboard-section-header">
+          <h3>公告</h3>
+        </div>
+        <div className="xx-announcement-list">
+          <div className="xx-announcement-item">
+            <span className="xx-announcement-tag xx-announcement-tag--notice">官方</span>
+            <div className="xx-announcement-content">
+              <h4>欢迎使用小应 SaaS 平台</h4>
+              <time>当前为演示版本，部分功能正在开发中。</time>
+            </div>
+          </div>
+        </div>
+      </section>
     </div>
   );
 };

apps/web/src/pages/dashboard/dashboard.css

@@ -1,6 +1,6 @@
 /**
  * 控制台页面 - V21 设计系统样式
- * KPI 卡片网格 + 快速入口 + 最近任务卡片列表 + 使用统计图表 + 公告
+ * KPI 卡片网格 + 快速入口 + 最近任务 + 使用统计图表 + 公告
  * 统一使用 CSS 变量，支持深色/浅色主题
  */
 @import "../../styles/global.css";
@@ -13,26 +13,6 @@
   padding: var(--space-xl);
 }
 
-/* ============================================================
-   欢迎头部
-   ============================================================ */
-.xx-dashboard-welcome {
-  margin-bottom: var(--space-lg);
-}
-
-.xx-dashboard-welcome h2 {
-  margin: 0 0 var(--space-xs);
-  font-size: var(--font-size-xl);
-  font-weight: var(--font-weight-bold);
-  color: var(--text-primary);
-}
-
-.xx-dashboard-welcome p {
-  margin: 0;
-  font-size: var(--font-size-sm);
-  color: var(--text-secondary);
-}
-
 /* ============================================================
    KPI 卡片网格
    ============================================================ */
@@ -43,76 +23,6 @@
   margin-bottom: var(--space-lg);
 }
 
-.xx-kpi-card {
-  background: linear-gradient(180deg, var(--bg-primary), var(--bg-secondary));
-  border: 1px solid var(--border-color);
-  border-radius: var(--radius-lg);
-  padding: 20px;
-  transition: 0.18s ease;
-  position: relative;
-  overflow: hidden;
-}
-
-.xx-kpi-card:hover {
-  transform: translateY(-2px);
-  box-shadow: var(--shadow-sm);
-}
-
-.xx-kpi-icon {
-  width: 40px;
-  height: 40px;
-  border-radius: var(--radius-md);
-  display: flex;
-  align-items: center;
-  justify-content: center;
-  font-size: var(--font-size-lg);
-  margin-bottom: var(--space-sm);
-}
-
-.xx-kpi-value {
-  font-size: 30px;
-  font-weight: 800;
-  color: var(--text-primary);
-  line-height: 1.2;
-  margin-bottom: var(--space-xs);
-}
-
-.xx-kpi-label {
-  font-size: var(--font-size-sm);
-  color: var(--text-secondary);
-  margin-bottom: var(--space-sm);
-}
-
-.xx-kpi-trend {
-  font-size: 12px;
-  margin-top: 8px;
-  display: inline-flex;
-  align-items: center;
-  gap: 4px;
-}
-
-.xx-kpi-trend--up {
-  color: var(--success-color);
-}
-
-.xx-kpi-trend--down {
-  color: var(--error-color);
-}
-
-.xx-kpi-trend--neutral {
-  color: var(--text-tertiary);
-}
-
-/* ============================================================
-   主内容区两栏布局
-   ============================================================ */
-.xx-dashboard-main {
-  display: grid;
-  grid-template-columns: 1fr 320px;
-  gap: var(--space-md);
-  margin-bottom: var(--space-lg);
-}
-
 /* ============================================================
    区块卡片
    ============================================================ */
@@ -161,7 +71,25 @@
 }
 
 /* ============================================================
-   最近任务卡片列表
+   空状态
+   ============================================================ */
+.xx-dashboard-empty {
+  display: flex;
+  flex-direction: column;
+  align-items: center;
+  justify-content: center;
+  padding: var(--space-xl) var(--space-md);
+  text-align: center;
+  color: var(--text-tertiary);
+}
+
+.xx-dashboard-empty p {
+  margin: 0;
+  font-size: var(--font-size-sm);
+}
+
+/* ============================================================
+   最近任务列表
    ============================================================ */
 .xx-task-list {
   display: flex;
@@ -169,86 +97,6 @@
   gap: var(--space-sm);
 }
 
-.xx-task-item {
-  background: var(--bg-primary);
-  border: 1px solid var(--border-color);
-  border-radius: var(--radius-md);
-  padding: var(--space-sm) var(--space-md);
-  display: grid;
-  grid-template-columns: 1fr auto auto auto;
-  gap: var(--space-md);
-  align-items: center;
-  transition: var(--transition-all);
-}
-
-.xx-task-item:hover {
-  border-color: var(--primary-color);
-  box-shadow: var(--shadow-sm);
-}
-
-.xx-task-info h4 {
-  margin: 0 0 var(--space-xs);
-  font-size: var(--font-size-sm);
-  font-weight: 600;
-  color: var(--text-primary);
-}
-
-.xx-task-info span {
-  font-size: var(--font-size-xs);
-  color: var(--text-secondary);
-}
-
-.xx-task-status {
-  display: inline-flex;
-  align-items: center;
-  gap: var(--space-xs);
-  padding: 3px 10px;
-  border-radius: var(--radius-sm);
-  font-size: var(--font-size-xs);
-  font-weight: 500;
-  white-space: nowrap;
-}
-
-.xx-task-status--completed {
-  color: var(--success-color);
-  background: var(--success-soft);
-  border: 1px solid var(--success-border);
-}
-
-.xx-task-status--processing {
-  color: var(--info-color);
-  background: var(--primary-soft);
-  border: 1px solid var(--color-primary-200);
-}
-
-.xx-task-status--pending {
-  color: var(--text-secondary);
-  background: var(--bg-secondary);
-  border: 1px solid var(--border-color);
-}
-
-.xx-task-status--failed {
-  color: var(--error-color);
-  background: var(--error-soft);
-  border: 1px solid var(--error-border);
-}
-
-.xx-task-time {
-  text-align: right;
-  font-size: var(--font-size-xs);
-  color: var(--text-secondary);
-  min-width: 100px;
-}
-
-.xx-task-time span {
-  display: block;
-  margin-bottom: var(--space-xxs);
-}
-
-.xx-task-action {
-  font-size: var(--font-size-xs);
-}
-
 /* ============================================================
    使用统计图表（纯 CSS 柱状图）
    ============================================================ */
@@ -264,69 +112,27 @@
   padding-top: var(--space-sm);
 }
 
-.xx-chart-bar-wrapper {
-  flex: 1;
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  height: 100%;
-  justify-content: flex-end;
-}
-
-.xx-chart-bar {
-  width: 100%;
-  max-width: 36px;
-  border-radius: var(--radius-sm) var(--radius-sm) 0 0;
-  background: var(--gradient-primary);
-  transition: height 0.6s cubic-bezier(0.34, 1.56, 0.64, 1);
-  position: relative;
-  min-height: 4px;
-  cursor: pointer;
-}
-
-.xx-chart-bar:hover {
-  opacity: 0.85;
-}
-
-.xx-chart-bar:active {
-  opacity: 0.7;
-  transform: scaleY(0.97);
-  transform-origin: bottom;
-}
-
-.xx-chart-bar-value {
-  position: absolute;
-  top: -20px;
-  left: 50%;
-  transform: translateX(-50%);
-  font-size: var(--font-size-xs);
-  font-weight: 600;
-  color: var(--text-primary);
-  white-space: nowrap;
-  opacity: 0;
-  transition: var(--transition-opacity);
-}
-
-.xx-chart-bar:hover .xx-chart-bar-value {
-  opacity: 1;
-}
-
-.xx-chart-labels {
-  display: flex;
-  gap: var(--space-sm);
-  margin-top: var(--space-sm);
-}
-
-.xx-chart-label {
-  flex: 1;
-  text-align: center;
-  font-size: var(--font-size-xs);
-  color: var(--text-secondary);
-}
-
 /* ============================================================
-   快速入口卡片网格
+   快速入口
    ============================================================ */
+.xx-quick-entry-section {
+  margin-bottom: var(--space-md);
+}
+
+.xx-quick-entry-header {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  margin-bottom: var(--space-md);
+}
+
+.xx-quick-entry-title {
+  margin: 0;
+  font-size: var(--font-size-base);
+  font-weight: var(--font-weight-semibold);
+  color: var(--text-primary);
+}
+
 .xx-quick-grid {
   display: grid;
   grid-template-columns: repeat(4, 1fr);
@@ -334,53 +140,6 @@
   margin-bottom: var(--space-lg);
 }
 
-.xx-quick-card {
-  background: var(--bg-primary);
-  border: 1px solid var(--border-color);
-  border-radius: var(--radius-lg);
-  padding: var(--space-lg);
-  cursor: pointer;
-  transition: var(--transition-all);
-  text-align: center;
-}
-
-.xx-quick-card:hover {
-  border-color: var(--primary-color);
-  box-shadow: var(--shadow-md);
-  transform: translateY(-2px);
-}
-
-.xx-quick-card:active {
-  transform: translateY(0) scale(0.98);
-  box-shadow: var(--shadow-sm);
-  transition-duration: 0.1s;
-}
-
-.xx-quick-card-icon {
-  width: 52px;
-  height: 52px;
-  border-radius: var(--radius-md);
-  display: flex;
-  align-items: center;
-  justify-content: center;
-  font-size: var(--font-size-xl);
-  margin: 0 auto var(--space-md);
-  color: var(--text-inverse);
-}
-
-.xx-quick-card h3 {
-  margin: 0 0 var(--space-sm);
-  font-size: var(--font-size-md);
-  font-weight: var(--font-weight-semibold);
-  color: var(--text-primary);
-}
-
-.xx-quick-card p {
-  margin: 0;
-  color: var(--text-secondary);
-  font-size: var(--font-size-sm);
-}
-
 /* ============================================================
    公告区域
    ============================================================ */
@@ -451,90 +210,10 @@
   color: var(--text-secondary);
 }
 
-/* ============================================================
-   存储用量条
-   ============================================================ */
-.xx-storage-bar {
-  margin-top: var(--space-sm);
-}
-
-.xx-storage-bar-track {
-  height: var(--space-sm);
-  background: var(--bg-secondary);
-  border-radius: var(--space-xs);
-  overflow: hidden;
-}
-
-.xx-storage-bar-fill {
-  height: 100%;
-  border-radius: var(--space-xs);
-  background: var(--gradient-primary);
-  transition: width 0.6s ease;
-}
-
-.xx-storage-bar-label {
-  display: flex;
-  justify-content: space-between;
-  font-size: var(--font-size-xs);
-  color: var(--text-secondary);
-  margin-top: var(--space-xs);
-}
-
-/* ============================================================
-   迁移自内联样式的工具类
-   ============================================================ */
-.xx-dashboard-left-col {
-  display: flex;
-  flex-direction: column;
-  gap: var(--space-md);
-}
-
-.xx-chart-total {
-  font-size: var(--font-size-xs);
-  color: var(--text-secondary);
-}
-
-.xx-dashboard-section--start {
-  align-self: start;
-}
-
-.xx-storage-section {
-  margin-top: var(--space-md);
-}
-
-.xx-storage-section-title {
-  font-size: 13px;
-  font-weight: 500;
-  color: var(--text-primary);
-  margin-bottom: 4px;
-}
-
-.xx-quick-entry-section {
-  margin-bottom: var(--space-md);
-}
-
-.xx-quick-entry-header {
-  display: flex;
-  align-items: center;
-  justify-content: space-between;
-  margin-bottom: var(--space-md);
-}
-
-.xx-quick-entry-title {
-  margin: 0;
-  font-size: var(--font-size-base);
-  font-weight: var(--font-weight-semibold);
-  color: var(--text-primary);
-}
-
 /* ============================================================
    响应式
    ============================================================ */
 @media (max-width: 1200px) {
-  .xx-dashboard-main {
-    grid-template-columns: 1fr;
-  }
-
   .xx-kpi-grid {
     grid-template-columns: repeat(2, 1fr);
   }
@@ -557,15 +236,6 @@
     grid-template-columns: 1fr;
   }
 
-  .xx-task-item {
-    grid-template-columns: 1fr;
-    gap: var(--space-sm);
-  }
-
-  .xx-task-time {
-    text-align: left;
-  }
-
   .xx-chart-bars {
     height: 120px;
   }

apps/web/src/pages/generate/GeneratePage.tsx

@@ -69,22 +69,6 @@ const VOICE_GENDER_ICON: Record<string, string> = {
   neutral: "✨",
 };
 
-/* ── 时间线 Mock ──
- * TODO: 后端暂无时间线场景数据 API，当前使用硬编码预览数据。
- *       待后端提供 timeline/scene 接口后替换为真实 API 调用。
- */
-interface TimelineScene {
-  scene: string;
-  time: string;
-  duration: number;
-}
-
-const MOCK_TIMELINE: TimelineScene[] = [
-  { scene: "主讲口播 · 开场钩子", time: "0-8s", duration: 8 },
-  { scene: "产品特写 · B-roll", time: "8-20s", duration: 12 },
-  { scene: "用户反馈 · 结尾", time: "20-30s", duration: 10 },
-];
-
 /* ── 步骤定义 ── */
 const STEPS = [
   { key: 1, label: "选择模板" },
@@ -1758,15 +1742,19 @@ const GeneratePage: React.FC = () => {
           <div className="xx-preview-title">剪辑计划预览</div>
 
           {/* 时间线列表 */}
-          <div className="xx-preview-timeline">
-            {MOCK_TIMELINE.map((item, idx) => (
-              <div key={idx} className="xx-timeline-item">
-                <div className="num">{idx + 1}</div>
-                <span className="scene-name">{item.scene}</span>
-                <span>{item.time}</span>
+          {generated ? (
+            <div className="xx-preview-timeline">
+              <div className="xx-timeline-item">
+                <span className="scene-name">生成完成，可下载或分享视频</span>
               </div>
-            ))}
-          </div>
+            </div>
+          ) : (
+            <div className="xx-preview-timeline">
+              <div className="xx-timeline-item">
+                <span className="scene-name">确认标题后自动生成剪辑计划</span>
+              </div>
+            </div>
+          )}
 
           {/* 生成操作按钮 */}
           <div className="xx-generate-actions">

apps/web/src/pages/titles/TitleLibrary.tsx

@@ -36,40 +36,24 @@ type TitleType = "hot" | "normal" | "creative";
 type Industry = "general" | "food" | "tech" | "beauty" | "education" | "travel";
 type Frequency = "all" | "high" | "medium" | "low";
 
-interface CategoryItem {
-  id: string;
-  name: string;
-  count: number;
-}
-
 interface TitleData {
   id: string;
   content: string;
   type: TitleType;
   industry: Industry;
+  category: string;
   usageCount: number;
   isFavorited: boolean;
   createdAt: string;
 }
 
-/* ============================================================
- * Mock 数据
- * ============================================================ */
-const MOCK_CATEGORIES: CategoryItem[] = [
-  { id: "cat-all", name: "全部标题", count: 15 },
-  { id: "cat-1", name: "美食探店", count: 4 },
-  { id: "cat-2", name: "科技数码", count: 3 },
-  { id: "cat-3", name: "生活日常", count: 4 },
-  { id: "cat-4", name: "美妆穿搭", count: 2 },
-  { id: "cat-5", name: "教育学习", count: 2 },
-];
-
 /** 后端 TitleItem → 前端 TitleData 映射 */
 const toTitleData = (item: TitleItem): TitleData => ({
   id: item.id,
   content: item.content,
   type: (item.category as TitleType) || "normal",
   industry: "general",
+  category: item.category || "未分类",
   usageCount: 0,
   isFavorited: false,
   createdAt: item.created_at?.slice(0, 10) || "",
@@ -250,9 +234,8 @@ const TitleCard: React.FC<{
 const TitleLibrary: React.FC = () => {
   const queryClient = useQueryClient();
 
-  /* 分类数据 */
-  const [categories, setCategories] = useState<CategoryItem[]>(MOCK_CATEGORIES);
-  const [activeCatId, setActiveCatId] = useState<string>(MOCK_CATEGORIES[0].id);
+  /* 分类数据 — 从真实标题数据动态派生 */
+  const [activeCatId, setActiveCatId] = useState<string>("cat-all");
 
   /* 标题数据 — 真实 API */
   const { data: apiTitles = [] } = useQuery({
@@ -265,6 +248,23 @@ const TitleLibrary: React.FC = () => {
     [apiTitles],
   );
 
+  /* 从真实标题数据动态派生分类（无需后端分类 API） */
+  const categories = useMemo(() => {
+    const cats = new Map<string, number>();
+    apiTitles.forEach((t) => {
+      const cat = t.category || "未分类";
+      cats.set(cat, (cats.get(cat) || 0) + 1);
+    });
+    return [
+      { id: "cat-all", name: "全部标题", count: apiTitles.length },
+      ...Array.from(cats.entries()).map(([name, count]) => ({
+        id: `cat-${name}`,
+        name,
+        count,
+      })),
+    ];
+  }, [apiTitles]);
+
   /* CRUD mutations */
   const createMutation = useMutation({
     mutationFn: (content: string) => createTitle({ content }),
@@ -301,10 +301,6 @@ const TitleLibrary: React.FC = () => {
   const [editingId, setEditingId] = useState<string | null>(null);
   const [editText, setEditText] = useState("");
 
-  /* 新建分类 */
-  const [createCatModalOpen, setCreateCatModalOpen] = useState(false);
-  const [newCatName, setNewCatName] = useState("");
-
   /* 新建标题 */
   const [createTitleModalOpen, setCreateTitleModalOpen] = useState(false);
   const [newTitleContent, setNewTitleContent] = useState("");
@@ -322,19 +318,11 @@ const TitleLibrary: React.FC = () => {
   const filteredTitles = useMemo(() => {
     let list = titles;
 
-    /* 按分类过滤（"全部标题" 不过滤） */
+    /* 按分类过滤（"全部标题" 不过滤）— 直接匹配后端 category 字段 */
     if (activeCatId !== "cat-all") {
       const catName = activeCategory?.name || "";
-      const catToIndustry: Record<string, Industry> = {
-        美食探店: "food",
-        科技数码: "tech",
-        生活日常: "general",
-        美妆穿搭: "beauty",
-        教育学习: "education",
-      };
-      const mappedIndustry = catToIndustry[catName];
-      if (mappedIndustry) {
-        list = list.filter((t) => t.industry === mappedIndustry);
+      if (catName) {
+        list = list.filter((t) => t.category === catName);
       }
     }
 
@@ -428,32 +416,6 @@ const TitleLibrary: React.FC = () => {
     [deleteMutation],
   );
 
-  /* 新建分类 */
-  const handleCreateCategory = () => {
-    if (!newCatName.trim()) {
-      message.warning("请输入分类名称");
-      return;
-    }
-    const cat: CategoryItem = {
-      id: `cat-${Date.now()}`,
-      name: newCatName.trim(),
-      count: 0,
-    };
-    setCategories((prev) => [...prev, cat]);
-    setActiveCatId(cat.id);
-    setCreateCatModalOpen(false);
-    setNewCatName("");
-    message.success(`分类 "${cat.name}" 创建成功`);
-  };
-
-  /* 删除分类 */
-  const handleDeleteCategory = (id: string) => {
-    setCategories((prev) => prev.filter((c) => c.id !== id));
-    if (activeCatId === id) {
-      setActiveCatId("cat-all");
-    }
-    message.success("分类已删除");
-  };
 
   /* 新建标题 */
   const handleCreateTitle = () => {
@@ -541,38 +503,12 @@ const TitleLibrary: React.FC = () => {
                   </h4>
                   <span>{cat.count} 条</span>
                 </div>
-                {cat.id !== "cat-all" && (
-                  <Popconfirm
-                    title={`确定删除分类 "${cat.name}"？`}
-                    onConfirm={(e) => {
-                      e?.stopPropagation();
-                      handleDeleteCategory(cat.id);
-                    }}
-                    onCancel={(e) => e?.stopPropagation()}
-                    okText="删除"
-                    cancelText="取消"
-                  >
-                    <button
-                      className="xx-title-category-delete"
-                      onClick={(e) => e.stopPropagation()}
-                      title="删除分类"
-                    >
-                      <DeleteOutlined />
-                    </button>
-                  </Popconfirm>
-                )}
+
               </div>
             </div>
           ))}
 
-          {/* 新建分类 */}
-          <div
-            className="xx-title-category-add"
-            onClick={() => setCreateCatModalOpen(true)}
-          >
-            <PlusOutlined />
-            新建分类
-          </div>
+          {/* TODO: 新建分类功能待后端分类 API 就绪后启用 */}
         </div>
 
         {/* ─── 右侧：内容区 ─── */}
@@ -678,34 +614,7 @@ const TitleLibrary: React.FC = () => {
         </div>
       </div>
 
-      {/* ─── 新建分类弹窗 ─── */}
-      <AntModal
-        title="新建分类"
-        open={createCatModalOpen}
-        onCancel={() => setCreateCatModalOpen(false)}
-        onOk={handleCreateCategory}
-        okText="创建"
-        cancelText="取消"
-        destroyOnClose
-      >
-        <div style={{ padding: "8px 0" }}>
-          <div
-            style={{
-              marginBottom: 6,
-              fontSize: "var(--font-size-sm)",
-              color: "var(--text-secondary)",
-            }}
-          >
-            分类名称
-          </div>
-          <Input
-            placeholder="请输入分类名称"
-            value={newCatName}
-            onChange={(e) => setNewCatName(e.target.value)}
-            maxLength={30}
-          />
-        </div>
-      </AntModal>
+
 
       {/* ─── 新建标题弹窗 ─── */}
       <AntModal

apps/web/src/pages/voice-clone/VoiceClone.tsx

@@ -18,7 +18,7 @@ import {
   CloseCircleOutlined,
 } from "@ant-design/icons";
 import PageHead from "@/components/layout/PageHead";
-import CloneVoiceModal from "@/components/modals/CloneVoiceModal";
+import CloneModal from "@/components/voice/CloneModal";
 import {
   getVoiceClones,
   deleteVoiceClone,
@@ -356,7 +356,7 @@ const VoiceClone: React.FC = () => {
       )}
 
       {/* 克隆音色弹窗 */}
-      <CloneVoiceModal
+      <CloneModal
         open={cloneModalOpen}
         onClose={() => setCloneModalOpen(false)}
         onSuccess={() => {

apps/worker/video_processing/dedup.py

@@ -1,10 +1,8 @@
 """Video deduplication module - compute fingerprints and detect duplicates."""
 
 import hashlib
-import json
 import logging
 import os
-import subprocess
 import tempfile
 from dataclasses import dataclass
 from typing import Optional
@@ -327,7 +325,6 @@ def check_duplicate_task(self: Task, generated_video_id: str) -> dict:
             raise ValueError(f"Generated video {generated_video_id} not found")
 
         local_path = os.path.join(temp_dir, f"{generated_video_id}.mp4")
-        storage_key = video.file_url.split("/")[-1]
         storage_service.download_file(
             f"projects/{video.project_id}/generated/{generated_video_id}/{generated_video_id}.mp4", local_path
         )

apps/worker/video_processing/ffmpeg_utils.py

@@ -81,7 +81,7 @@ def run_ffmpeg(
             timeout=timeout,
         )
         return (result.stdout or "", result.stderr or "")
-    except subprocess.TimeoutExpired as e:
+    except subprocess.TimeoutExpired:
         logger.error(
             "FFmpeg 命令超时 (%ds): command=%s",
             timeout or -1,

apps/worker/video_processing/oss_helpers.py

@@ -11,7 +11,6 @@ import logging
 import os
 import threading
 from pathlib import Path
-from typing import Optional
 from urllib.parse import urlparse
 
 import oss2

apps/worker/video_processing/processor.py

@@ -5,7 +5,6 @@
 import os
 import tempfile
 from dataclasses import dataclass
-from pathlib import Path
 from typing import List
 
 import ffmpeg

apps/worker/video_processing/render_adapter.py

@@ -17,15 +17,15 @@ import logging
 import tempfile
 from dataclasses import dataclass
 from pathlib import Path
-from typing import Any, Callable
+from typing import Callable
 
 from sqlalchemy.orm import Session
 from video_processing.oss_helpers import download_asset, upload_to_oss
-from video_processing.unified_render_service import RenderResult, UnifiedRenderService
+from video_processing.unified_render_service import UnifiedRenderService
 
 from packages.adapters.sqlalchemy_impl.edit_plan_clip_repository import SQLAlchemyEditPlanClipRepository
 from packages.adapters.sqlalchemy_impl.edit_plan_repository import SQLAlchemyEditPlanRepository
-from packages.domain.edit_plan import EditPlan, EditPlanStatus
+from packages.domain.edit_plan import EditPlanStatus
 from packages.domain.edit_plan_clip import EditPlanClip, EditPlanClipStatus
 
 logger = logging.getLogger(__name__)

apps/worker/worker_app/tasks/asset_analyzer.py

@@ -10,12 +10,10 @@ from __future__ import annotations
 
 import json
 import logging
-import math
 import os
 import subprocess
 import tempfile
 from dataclasses import dataclass, field
-from typing import Any
 
 import numpy as np
 from PIL import Image

apps/worker/worker_app/tasks/classification.py

@@ -1,4 +1,3 @@
-from celery import Task
 from celery.utils.log import get_task_logger
 from worker_app.celery_app import celery_app
 
@@ -9,7 +8,6 @@ from packages.adapters.sqlalchemy_impl.classification_job_repository import (
     SQLAlchemyClassificationJobRepository,
 )
 from packages.domain import (
-    ClassificationJob,
     ClassificationJobStatus,
     ClassificationStatus,
 )

apps/worker/worker_app/tasks/compose_video.py

@@ -5,12 +5,9 @@
 
 from __future__ import annotations
 
-import logging
 import os
-import shutil
 import subprocess
 import tempfile
-from datetime import datetime, timezone
 from pathlib import Path
 
 from celery.utils.log import get_task_logger

apps/worker/worker_app/tasks/edit_plan_generation.py

@@ -21,7 +21,6 @@ import logging
 import tempfile
 from datetime import datetime, timezone
 from pathlib import Path
-from typing import Optional
 
 from worker_app.celery_app import celery_app
 from worker_app.db import SessionLocal

apps/worker/worker_app/tasks/generation.py

@@ -13,15 +13,13 @@
 
 from __future__ import annotations
 
-import json
 import logging
 import os
 import tempfile
 import time
 from dataclasses import dataclass, field
-from datetime import datetime, timezone
 from pathlib import Path
-from typing import Any, Optional
+from typing import Any
 
 from worker_app.celery_app import celery_app
 from worker_app.db import SessionLocal
@@ -174,7 +172,6 @@ def _build_plan_and_clips_from_task(
         path_duration[p] = probe_duration(p)
 
     clips: list[_VirtualClip] = []
-    n = len(downloaded_paths)
 
     if mode == "pip":
         # 1 main + N-1 overlay
@@ -912,7 +909,6 @@ def generate_video(self, task_id: str) -> dict:
                 render_result = render_service.render()
                 render_output_path = render_result.output_path
                 render_duration = render_result.duration
-                render_file_size = render_result.file_size
                 render_elapsed = time.monotonic() - render_start
                 logger.info(
                     "[task_id=%s] [渲染] unified 引擎完成: 耗时=%.1fs",

apps/worker/worker_app/tasks/ingest.py

@@ -1,9 +1,6 @@
 import subprocess
 from datetime import datetime, timezone
-from typing import Optional
 
-from celery import Celery
-from celery.app.task import Task
 from celery.utils.log import get_task_logger
 from worker_app.celery_app import celery_app
 from worker_app.core.asset_types import infer_mime_type_from_storage_key

apps/worker/worker_app/tasks/voice_extraction.py

@@ -1,14 +1,11 @@
 """Voice extraction tasks - extract voice tracks and background music from videos."""
 
-import json
 import logging
 import os
 import subprocess
 import tempfile
-from typing import Optional
 
 from celery import Task
-from sqlalchemy.orm import Session
 from worker_app.celery_app import celery_app
 from worker_app.db import SessionLocal
 

docs/ci-env-vars.md

@@ -112,7 +112,7 @@
 
 | 变量名 | 用途说明 | 默认值 |
 |--------|---------|--------|
-| `OSS_ENDPOINT` | OSS Endpoint | `oss-cn-hangzhou.aliiyuncs.com` |
+| `OSS_ENDPOINT` | OSS Endpoint | `oss-cn-hangzhou.aliyuncs.com` |
 | `OSS_ACCESS_KEY_ID` | OSS Access Key ID | `""`（空） |
 | `OSS_ACCESS_KEY_SECRET` | OSS Access Key Secret | `""`（空） |
 | `OSS_BUCKET_NAME` | OSS Bucket 名称 | `xiaoxia-autocut` |

packages/application/__init__.py

@@ -27,6 +27,7 @@ from .generated_videos import (
 from .generation_tasks import (
     CreateGenerationTaskCommand,
     CreateGenerationTaskUseCase,
+    GetGenerationTaskUseCase,
 )
 from .ingest_jobs import SubmitIngestJobCommand, SubmitIngestJobUseCase
 from .jobs import (
@@ -63,6 +64,7 @@ __all__ = [
     "CreateAssetUseCase",
     "CreateGenerationTaskCommand",
     "CreateGenerationTaskUseCase",
+    "GetGenerationTaskUseCase",
     "CreateJobCommand",
     "CreateJobUseCase",
     "CreateProjectCommand",

packages/shared/config.py

@@ -24,7 +24,7 @@ class SharedSettings(BaseSettings):
     celery_result_backend: str = "redis://localhost:6379/1"
 
     # OSS Aliyun
-    oss_endpoint: str = "oss-cn-hangzhou.aliiyuncs.com"
+    oss_endpoint: str = "oss-cn-hangzhou.aliyuncs.com"
     oss_access_key_id: str = ""
     oss_access_key_secret: str = ""
     oss_bucket_name: str = "xiaoxia-autocut"

packages/shared/storage.py

@@ -30,21 +30,67 @@ class SharedStorageService:
         self.local_url_prefix = os.getenv("GENERATED_FILES_URL_PREFIX", "/generated-files")
         self.bucket = None
 
-        if settings.oss_access_key_id and settings.oss_access_key_secret:
+        has_key_id = bool(settings.oss_access_key_id)
+        has_key_secret = bool(settings.oss_access_key_secret)
+
+        if has_key_id and has_key_secret:
             if oss2 is not None:
-                auth = oss2.Auth(
-                    settings.oss_access_key_id,
-                    settings.oss_access_key_secret,
-                )
-                self.bucket = oss2.Bucket(
-                    auth,
-                    settings.oss_endpoint,
-                    settings.oss_bucket_name,
-                )
+                try:
+                    # P0-2 修复：oss2.Bucket 的 endpoint 必须带 https:// 前缀，
+                    # 否则 sign_url 默认生成 HTTP URL。
+                    bucket_endpoint = settings.oss_endpoint
+                    if not bucket_endpoint.startswith(("http://", "https://")):
+                        bucket_endpoint = f"https://{bucket_endpoint}"
+                    auth = oss2.Auth(
+                        settings.oss_access_key_id,
+                        settings.oss_access_key_secret,
+                    )
+                    self.bucket = oss2.Bucket(
+                        auth,
+                        bucket_endpoint,
+                        settings.oss_bucket_name,
+                    )
+                    logger.info(
+                        "OSS initialized: endpoint=%s bucket=%s",
+                        settings.oss_endpoint,
+                        settings.oss_bucket_name,
+                    )
+                except Exception as error:
+                    logger.error("Failed to initialize OSS bucket client: %s", error)
+            else:
+                logger.error("oss2 SDK is not installed — OSS operations will fail")
+        else:
+            missing = []
+            if not has_key_id:
+                missing.append("OSS_ACCESS_KEY_ID")
+            if not has_key_secret:
+                missing.append("OSS_ACCESS_KEY_SECRET")
+            logger.error("OSS credentials not configured — missing: %s", ", ".join(missing))
+
         self.access_key_id = settings.oss_access_key_id
         self.access_key_secret = settings.oss_access_key_secret
         self.endpoint = settings.oss_endpoint
 
+    def diagnose(self) -> None:
+        """启动诊断：输出 OSS 配置状态，帮助排查预签名 URL 问题。"""
+        key_id_display = (
+            f"{self.access_key_id[:4]}...{self.access_key_id[-4:]}" if len(self.access_key_id) > 8 else "(empty)"
+        )
+        logger.info(
+            "[OSS诊断] endpoint=%s bucket_name=%s access_key_id=%s",
+            self.endpoint,
+            self.bucket_name,
+            key_id_display,
+        )
+        if self.bucket is None:
+            logger.error(
+                "[OSS诊断] ❌ bucket=None — 预签名URL不可用！"
+                "原因: OSS_ACCESS_KEY_ID/OSS_ACCESS_KEY_SECRET 未配置或 oss2 未安装。"
+                "请检查服务器 .env 文件（如 /var/lib/xiaoxia-saas-staging/.env）"
+            )
+        else:
+            logger.info("[OSS诊断] ✅ bucket 已配置，预签名URL可用")
+
     def _is_local_generated_url(self, storage_key_or_url: str) -> bool:
         parsed = urlparse(storage_key_or_url)
         path = parsed.path if parsed.scheme else storage_key_or_url
@@ -90,12 +136,26 @@ class SharedStorageService:
         if self.bucket is None:
             if self._is_local_generated_url(storage_key_or_url):
                 return storage_key_or_url
+            logger.warning(
+                "get_download_url: OSS bucket not configured, returning raw URL. storage_key_or_url=%s",
+                storage_key_or_url[:200],
+            )
             return self.get_url(self._normalize_storage_key(storage_key_or_url))
 
         storage_key = self._normalize_storage_key(storage_key_or_url)
         try:
-            return self.bucket.sign_url("GET", storage_key, expires_seconds)
+            signed = self.bucket.sign_url("GET", storage_key, expires_seconds)
+            logger.info(
+                "get_download_url: signed URL generated. storage_key=%s url_prefix=%s",
+                storage_key[:80],
+                signed[:60],
+            )
+            return signed
         except Exception:
+            logger.exception(
+                "get_download_url: sign_url failed, falling back to raw URL. storage_key=%s",
+                storage_key[:200],
+            )
             return self.get_url(storage_key)
 
     def _normalize_storage_key(self, storage_key_or_url: str) -> str:
@@ -175,6 +235,7 @@ def get_shared_storage_service() -> SharedStorageService:
     global _storage_service
     if _storage_service is None:
         _storage_service = SharedStorageService()
+        _storage_service.diagnose()
     return _storage_service
 
 

requirements-base.txt

@@ -24,9 +24,6 @@ celery==5.4.0
 
 # 对象存储
 oss2==2.18.4
-cryptography==46.0.5
-# 覆盖系统预装的旧版pyOpenSSL，与cryptography 46.0.5兼容
-pyOpenSSL==26.2.0
 
 # HTTP 客户端
 httpx==0.27.2

requirements.txt

@@ -6,9 +6,6 @@ pydantic-settings==2.6.0
 email-validator==2.2.0
 python-multipart==0.0.32
 
-# 邮件
-aiosmtplib==3.0.2
-
 # 测试
 pytest==8.3.3
 pytest-asyncio==0.24.0

scripts/init_production_env.sh

@@ -73,7 +73,6 @@ OSS_ACCESS_KEY_ID=$OSS_ACCESS_KEY_ID
 OSS_ACCESS_KEY_SECRET=$OSS_ACCESS_KEY_SECRET
 OSS_BUCKET_NAME=$OSS_BUCKET_NAME
 
-LOG_LEVEL=INFO
 CORS_ORIGINS_RAW=https://xiaoxiajianji.com,https://api.xiaoxiajianji.com
 EOF
 

tests/conftest.py

@@ -17,18 +17,13 @@ os.environ.setdefault("USE_IN_MEMORY_DB", "True")
 # CI 环境没有 Redis，所有 Celery 异步任务都 mock 掉，避免连接超时报错
 # 集成测试只测 API 层逻辑（参数校验、权限、DB 操作），异步任务由 worker 单测覆盖
 
-from unittest.mock import MagicMock, patch
+from unittest.mock import MagicMock
 
 
 def _mock_celery_task():
     """全局 mock Celery 任务的 delay/apply_async/send_task 方法。"""
     from celery import Celery, Task
 
-    # 保存原始方法
-    _orig_delay = Task.delay
-    _orig_apply_async = Task.apply_async
-    _orig_send_task = Celery.send_task
-
     def _mock_delay(self, *args, **kwargs):
         mock_result = MagicMock()
         mock_result.id = "mock-task-id"

tests/integration/conftest.py

@@ -113,7 +113,6 @@ class PerfAssert:
             raise ValueError(f"未知的阈值级别: {threshold_level}，可选: {list(PERF_THRESHOLDS.keys())}")
 
         threshold_ms = PERF_THRESHOLDS[threshold_level]
-        num_samples = samples or self.sample_count
         result = PerfResult(name=name or threshold_level, threshold_ms=threshold_ms)
 
         # 预热（第一次请求可能有冷启动开销）

tests/integration/fixtures/duplication_routes_fixed.py

@@ -1,282 +0,0 @@
-"""查重 API 路由。"""
-
-from __future__ import annotations
-
-import logging
-from typing import Any
-from uuid import uuid4
-
-from app.auth import AuthenticatedUser, get_current_user
-from app.core.storage import OSSStorageService, get_storage_service
-from app.dependencies import get_duplication_repository
-from app.schemas.duplication import (
-    DuplicateSegmentResponse,
-    DuplicationDetailResponse,
-    DuplicationRecordResponse,
-    DuplicationUploadResponse,
-)
-from fastapi import APIRouter, Depends, File, HTTPException, Response, UploadFile, status
-
-from packages.application import (
-    DeleteDuplicationRecordUseCase,
-    GetDuplicationDetailUseCase,
-    ListDuplicationRecordsUseCase,
-    RetryDuplicationUseCase,
-    UploadForDuplicationCommand,
-    UploadForDuplicationUseCase,
-)
-from packages.domain.duplication import DuplicationRecord
-
-logger = logging.getLogger(__name__)
-
-router = APIRouter()
-
-# 查重功能只接受视频文件
-ALLOWED_VIDEO_MIME_TYPES = frozenset(
-    {
-        "video/mp4",
-        "video/mpeg",
-        "video/quicktime",
-        "video/x-msvideo",
-        "video/webm",
-        "video/x-matroska",
-        "video/3gpp",
-    }
-)
-
-
-def _validate_video_mime_type(content_type: str | None) -> str:
-    """验证视频文件的 MIME 类型，如果无效则抛出异常。"""
-    if not content_type:
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST,
-            detail="Content-Type header is required",
-        )
-
-    # 处理带参数的类型，如 "video/mp4; charset=utf-8"
-    base_type = content_type.split(";")[0].strip().lower()
-
-    if base_type not in ALLOWED_VIDEO_MIME_TYPES:
-        raise HTTPException(
-            status_code=status.HTTP_415_UNSUPPORTED_MEDIA_TYPE,
-            detail="只支持视频文件。支持的类型: mp4, mpeg, mov, avi, webm, mkv, 3gp",
-        )
-
-    return base_type
-
-
-def _to_record_response(record: DuplicationRecord) -> DuplicationRecordResponse:
-    return DuplicationRecordResponse(
-        id=record.id,
-        filename=record.filename,
-        file_size=record.file_size,
-        duration_seconds=record.duration_seconds,
-        status=record.status,
-        duplicate_rate=record.duplicate_rate,
-        duplicate_count=record.duplicate_count,
-        created_at=record.created_at.isoformat(),
-        updated_at=record.updated_at.isoformat(),
-    )
-
-
-def _to_detail_response(record: DuplicationRecord) -> DuplicationDetailResponse:
-    return DuplicationDetailResponse(
-        id=record.id,
-        filename=record.filename,
-        file_size=record.file_size,
-        duration_seconds=record.duration_seconds,
-        status=record.status,
-        duplicate_rate=record.duplicate_rate,
-        duplicate_count=record.duplicate_count,
-        created_at=record.created_at.isoformat(),
-        updated_at=record.updated_at.isoformat(),
-        segments=[
-            DuplicateSegmentResponse(
-                id=seg.id,
-                source_start=seg.source_start,
-                source_end=seg.source_end,
-                matched_video_id=seg.matched_video_id,
-                matched_video_name=seg.matched_video_name,
-                matched_start=seg.matched_start,
-                matched_end=seg.matched_end,
-                similarity=seg.similarity,
-            )
-            for seg in record.segments
-        ],
-    )
-
-
-@router.post("/upload", response_model=DuplicationUploadResponse)
-async def upload_for_duplication(
-    file: UploadFile = File(..., description="要查重的视频文件"),
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    duplication_repository: Any = Depends(get_duplication_repository),
-    storage_service: OSSStorageService = Depends(get_storage_service),
-) -> DuplicationUploadResponse:
-    """上传视频进行查重。"""
-    if file.filename is None:
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST,
-            detail="文件名不能为空",
-        )
-
-    # P0-1: 验证 MIME 类型（只接受视频文件）
-    validated_content_type = _validate_video_mime_type(file.content_type)
-
-    # P0-2: 验证文件大小（参考 OSS_DIRECT_UPLOAD_MAX_MB）
-    from app.config import get_settings
-
-    settings = get_settings()
-    max_size_bytes = settings.OSS_DIRECT_UPLOAD_MAX_MB * 1024 * 1024
-
-    # 先检查 Content-Length header（如果可用）
-    if file.size is not None and file.size > max_size_bytes:
-        raise HTTPException(
-            status_code=status.HTTP_413_REQUEST_ENTITY_TOO_LARGE,
-            detail=f"文件超过上传限制 ({settings.OSS_DIRECT_UPLOAD_MAX_MB}MB)",
-        )
-
-    # 读取文件内容并上传到 OSS
-    file_id = uuid4().hex[:8]
-    safe_filename = file.filename.replace("/", "_").replace("\\", "_")
-    storage_key = f"duplication/{file_id}/{safe_filename}"
-
-    try:
-        content = await file.read()
-        file_size = len(content)
-
-        # 再次检查实际文件大小
-        if file_size > max_size_bytes:
-            raise HTTPException(
-                status_code=status.HTTP_413_REQUEST_ENTITY_TOO_LARGE,
-                detail=f"文件超过上传限制 ({settings.OSS_DIRECT_UPLOAD_MAX_MB}MB)",
-            )
-    except HTTPException:
-        raise
-    except Exception as exc:
-        logger.error("读取查重文件失败: %s", exc, exc_info=True)
-        raise HTTPException(
-            status_code=status.HTTP_400_BAD_REQUEST,
-            detail="文件读取失败，请稍后重试",
-        ) from exc
-
-    try:
-        storage_service.upload_file(
-            content,
-            storage_key,
-            content_type=validated_content_type,
-        )
-    except Exception as exc:
-        logger.error("查重文件上传 OSS 失败: %s", exc, exc_info=True)
-        raise HTTPException(
-            status_code=status.HTTP_503_SERVICE_UNAVAILABLE,
-            detail="文件上传失败，请稍后重试",
-        ) from exc
-
-    use_case = UploadForDuplicationUseCase(duplication_repository)
-    record = use_case.execute(
-        UploadForDuplicationCommand(
-            user_id=authenticated_user.user.id,
-            filename=file.filename,
-            file_size=file_size,
-            storage_key=storage_key,
-        )
-    )
-
-    logger.info(
-        "Duplication upload: record=%s file=%s user=%s",
-        record.id,
-        file.filename,
-        authenticated_user.user.id,
-    )
-
-    return DuplicationUploadResponse(
-        id=record.id,
-        status=record.status,
-        message=f'文件 "{file.filename}" 已上传，正在查重中...',
-    )
-
-
-@router.get("/records", response_model=list[DuplicationRecordResponse])
-def list_duplication_records(
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    duplication_repository: Any = Depends(get_duplication_repository),
-) -> list[DuplicationRecordResponse]:
-    """获取当前用户的查重记录列表。"""
-    use_case = ListDuplicationRecordsUseCase(duplication_repository)
-    records = use_case.execute(authenticated_user.user.id)
-    return [_to_record_response(r) for r in records]
-
-
-@router.get("/records/{record_id}", response_model=DuplicationDetailResponse)
-def get_duplication_detail(
-    record_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    duplication_repository: Any = Depends(get_duplication_repository),
-) -> DuplicationDetailResponse:
-    """获取查重记录详情（含重复片段）。"""
-    use_case = GetDuplicationDetailUseCase(duplication_repository)
-    record = use_case.execute(record_id)
-    if record is None:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=f"查重记录 {record_id} 不存在",
-        )
-    if record.user_id != authenticated_user.user.id:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=f"查重记录 {record_id} 不存在",
-        )
-    return _to_detail_response(record)
-
-
-@router.delete("/records/{record_id}", status_code=status.HTTP_204_NO_CONTENT, response_class=Response)
-def delete_duplication_record(
-    record_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    duplication_repository: Any = Depends(get_duplication_repository),
-) -> Response:
-    """删除查重记录。"""
-    # 检查记录是否存在且属于当前用户
-    detail_uc = GetDuplicationDetailUseCase(duplication_repository)
-    record = detail_uc.execute(record_id)
-    if record is None or record.user_id != authenticated_user.user.id:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=f"查重记录 {record_id} 不存在",
-        )
-
-    use_case = DeleteDuplicationRecordUseCase(duplication_repository)
-    use_case.execute(record_id)
-    return Response(status_code=204)
-
-
-@router.post("/records/{record_id}/retry", response_model=DuplicationUploadResponse)
-def retry_duplication(
-    record_id: str,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    duplication_repository: Any = Depends(get_duplication_repository),
-) -> DuplicationUploadResponse:
-    """重新提交查重。"""
-    # 检查记录存在且属于当前用户
-    detail_uc = GetDuplicationDetailUseCase(duplication_repository)
-    record = detail_uc.execute(record_id)
-    if record is None or record.user_id != authenticated_user.user.id:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=f"查重记录 {record_id} 不存在",
-        )
-
-    use_case = RetryDuplicationUseCase(duplication_repository)
-    updated = use_case.execute(record_id)
-    if updated is None:
-        raise HTTPException(
-            status_code=status.HTTP_404_NOT_FOUND,
-            detail=f"查重记录 {record_id} 不存在",
-        )
-
-    return DuplicationUploadResponse(
-        id=updated.id,
-        status=updated.status,
-        message="已重新提交查重",
-    )

tests/integration/test_api_performance.py

@@ -18,7 +18,6 @@ from __future__ import annotations
 
 import os
 import uuid
-from typing import Optional
 
 import pytest
 from fastapi.testclient import TestClient

tests/integration/test_dashboard_api.py

@@ -1,496 +0,0 @@
-"""
-仪表盘 API 集成测试。
-
-覆盖端点：
-- GET /dashboard/overview — 仪表盘概览
-
-验证返回数据结构、空数据场景、数据汇总正确性。
-"""
-
-from __future__ import annotations
-
-import os
-import sys
-from datetime import datetime, timezone
-
-# ── 环境变量 & sys.path（必须在导入 app.* 之前设置） ──────────────────────────
-os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
-os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
-
-import pytest
-from fastapi import FastAPI
-from fastapi.testclient import TestClient
-
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "api"))
-
-from app.api.routes.dashboard import router
-from app.auth import AuthenticatedUser, get_current_user
-from app.dependencies import (
-    get_asset_repository,
-    get_generation_task_repository,
-    get_project_repository,
-    get_title_library_repository,
-    get_voice_library_repository,
-)
-
-from packages.domain.entities import Project, User
-from packages.domain.generation_task import GenerationTask, GenerationTaskStatus
-
-# ---------------------------------------------------------------------------
-# 1. 内存 Repository
-# ---------------------------------------------------------------------------
-
-
-class InMemoryProjectRepository:
-    def __init__(self):
-        self._projects: dict[str, Project] = {}
-
-    def save(self, project: Project) -> None:
-        self._projects[project.id] = project
-
-    def find_by_id(self, project_id: str):
-        return self._projects.get(project_id)
-
-    def find_by_owner_user_id(self, owner_user_id: str):
-        return [p for p in self._projects.values() if p.owner_user_id == owner_user_id]
-
-    def find_accessible_projects(self, user_id: str):
-        return [p for p in self._projects.values() if p.owner_user_id == user_id]
-
-    def count_by_owner(self, owner_user_id: str) -> int:
-        return len(self.find_by_owner_user_id(owner_user_id))
-
-    def delete(self, project_id: str) -> bool:
-        if project_id in self._projects:
-            del self._projects[project_id]
-            return True
-        return False
-
-
-class InMemoryAssetRepository:
-    def __init__(self):
-        self._assets = []
-
-    def add_asset(self, project_id: str, storage_size: int = 0):
-        self._assets.append({"project_id": project_id, "storage_size": storage_size})
-
-    def count_by_project_ids(self, project_ids: list[str]) -> int:
-        return sum(1 for a in self._assets if a["project_id"] in project_ids)
-
-    def sum_storage_by_project_ids(self, project_ids: list[str]) -> int:
-        return sum(a["storage_size"] for a in self._assets if a["project_id"] in project_ids)
-
-    # 其他方法占位
-    def create(self, asset):
-        return asset
-
-    def find_by_id(self, asset_id):
-        return None
-
-    def find_by_project(self, project_id, **kwargs):
-        return []
-
-    def find_by_library(self, library_id, **kwargs):
-        return []
-
-    def update(self, asset):
-        return asset
-
-    def delete(self, asset_id):
-        return False
-
-    def batch_delete(self, asset_ids):
-        return 0
-
-    def search_candidates(self, **kwargs):
-        return []
-
-    def find_by_tag_ids(self, tag_ids):
-        return []
-
-    def count_by_project(self, project_id):
-        return 0
-
-    def find_by_library_and_file_type(self, library_id, file_type):
-        return []
-
-    def find_by_library_and_file_hash(self, library_id, file_hash):
-        return None
-
-
-class InMemoryGenerationTaskRepository:
-    def __init__(self):
-        self._tasks = {}
-
-    def add_task(self, task: GenerationTask):
-        self._tasks[task.id] = task
-
-    def count_by_user(self, user_id: str) -> int:
-        return len([t for t in self._tasks.values() if t.created_by_user_id == user_id])
-
-    def list_recent_by_user(self, user_id: str, limit: int = 5) -> list:
-        user_tasks = [t for t in self._tasks.values() if t.created_by_user_id == user_id]
-        # 按 created_at 倒序
-        user_tasks.sort(key=lambda t: t.created_at, reverse=True)
-        return user_tasks[:limit]
-
-    # 其他方法占位
-    def create(self, task):
-        return task
-
-    def get(self, task_id):
-        return None
-
-    def list_by_project(self, project_id):
-        return []
-
-    def list_by_user(self, user_id):
-        return []
-
-    def list_by_source_edit_plan(self, plan_id):
-        return []
-
-    def update(self, task):
-        return task
-
-
-class InMemoryTitleLibraryRepository:
-    def __init__(self):
-        self._items = {}
-
-    def add_item(self, user_id: str):
-        from uuid import uuid4
-
-        item_id = uuid4().hex
-        self._items[item_id] = {"id": item_id, "user_id": user_id}
-        return item_id
-
-    def count_by_user(self, user_id: str, is_active: bool = True) -> int:
-        return len([i for i in self._items.values() if i["user_id"] == user_id])
-
-    # 其他方法占位
-    def list_by_user(self, user_id, **kwargs):
-        return []
-
-    def get(self, title_id, user_id):
-        return None
-
-    def create(self, item):
-        return item
-
-    def update(self, item):
-        return item
-
-    def delete(self, title_id, user_id):
-        return False
-
-
-class InMemoryVoiceLibraryRepository:
-    def __init__(self):
-        self._items = {}
-
-    def add_item(self, user_id: str):
-        from uuid import uuid4
-
-        item_id = uuid4().hex
-        self._items[item_id] = {"id": item_id, "user_id": user_id}
-        return item_id
-
-    def count_by_user(self, user_id: str) -> int:
-        return len([i for i in self._items.values() if i["user_id"] == user_id])
-
-    # 其他方法占位
-    def list_by_user(self, user_id, **kwargs):
-        return []
-
-    def get(self, voice_id, user_id):
-        return None
-
-    def create(self, item):
-        return item
-
-    def update(self, item):
-        return item
-
-    def delete(self, voice_id, user_id):
-        return False
-
-
-# ---------------------------------------------------------------------------
-# 2. 辅助函数
-# ---------------------------------------------------------------------------
-
-
-def _make_user(**overrides) -> User:
-    defaults = dict(
-        id="user-test-001",
-        email="test@example.com",
-        display_name="Test User",
-        username="testuser",
-        subscription_plan="free",
-        subscription_status="active",
-        max_projects=3,
-        max_storage_gb=10,
-        created_at=datetime(2026, 1, 1, tzinfo=timezone.utc),
-    )
-    defaults.update(overrides)
-    return User(**defaults)
-
-
-def _make_project(project_id: str, owner_user_id: str = "user-test-001") -> Project:
-    return Project(
-        id=project_id,
-        name=f"Project {project_id}",
-        owner_user_id=owner_user_id,
-        description="",
-        created_at=datetime(2026, 1, 1, tzinfo=timezone.utc),
-    )
-
-
-def _make_generation_task(
-    task_id: str,
-    user_id: str = "user-test-001",
-    status: GenerationTaskStatus = GenerationTaskStatus.COMPLETED,
-    created_at: datetime | None = None,
-) -> GenerationTask:
-    return GenerationTask(
-        id=task_id,
-        project_id="proj-1",
-        asset_library_id="lib-1",
-        created_by_user_id=user_id,
-        status=status,
-        error_message="",
-        created_at=created_at or datetime.now(timezone.utc),
-        started_at=datetime.now(timezone.utc) if status != GenerationTaskStatus.PENDING else None,
-        completed_at=datetime.now(timezone.utc) if status == GenerationTaskStatus.COMPLETED else None,
-    )
-
-
-# ---------------------------------------------------------------------------
-# 3. Fixtures
-# ---------------------------------------------------------------------------
-
-
-@pytest.fixture
-def project_repo():
-    repo = InMemoryProjectRepository()
-    repo.save(_make_project("proj-1", "user-test-001"))
-    repo.save(_make_project("proj-2", "user-test-001"))
-    repo.save(_make_project("proj-other", "other-user"))
-    return repo
-
-
-@pytest.fixture
-def asset_repo():
-    return InMemoryAssetRepository()
-
-
-@pytest.fixture
-def generation_task_repo():
-    return InMemoryGenerationTaskRepository()
-
-
-@pytest.fixture
-def title_library_repo():
-    return InMemoryTitleLibraryRepository()
-
-
-@pytest.fixture
-def voice_library_repo():
-    return InMemoryVoiceLibraryRepository()
-
-
-@pytest.fixture
-def client(project_repo, asset_repo, generation_task_repo, title_library_repo, voice_library_repo):
-    """创建带有依赖覆盖的 TestClient。"""
-    test_app = FastAPI()
-    test_app.include_router(router, prefix="/dashboard")
-
-    def _override_current_user():
-        return AuthenticatedUser(user=_make_user())
-
-    test_app.dependency_overrides[get_current_user] = _override_current_user
-    test_app.dependency_overrides[get_project_repository] = lambda: project_repo
-    test_app.dependency_overrides[get_asset_repository] = lambda: asset_repo
-    test_app.dependency_overrides[get_generation_task_repository] = lambda: generation_task_repo
-    test_app.dependency_overrides[get_title_library_repository] = lambda: title_library_repo
-    test_app.dependency_overrides[get_voice_library_repository] = lambda: voice_library_repo
-
-    yield TestClient(test_app)
-
-    test_app.dependency_overrides.clear()
-
-
-# ---------------------------------------------------------------------------
-# 4. GET /overview — 仪表盘概览
-# ---------------------------------------------------------------------------
-
-
-class TestDashboardOverview:
-    """仪表盘概览端点测试。"""
-
-    def test_empty_data_returns_zeros(self, client):
-        """空数据时所有计数为 0。"""
-        resp = client.get("/dashboard/overview")
-        assert resp.status_code == 200
-        data = resp.json()
-
-        assert data["total_assets"] == 0
-        assert data["used_storage_bytes"] == 0
-        assert data["total_titles"] == 0
-        assert data["total_voices"] == 0
-        assert data["total_tasks"] == 0
-        assert data["total_products"] == 2  # fixture 中有 2 个项目
-        assert data["recent_tasks"] == []
-
-    def test_assets_count_and_storage(self, client, asset_repo):
-        """素材统计正确。"""
-        asset_repo.add_asset("proj-1", 1024)
-        asset_repo.add_asset("proj-1", 2048)
-        asset_repo.add_asset("proj-2", 4096)
-        # 其他用户的不计入
-        asset_repo.add_asset("proj-other", 9999)
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert data["total_assets"] == 3
-        assert data["used_storage_bytes"] == 1024 + 2048 + 4096
-
-    def test_title_library_count(self, client, title_library_repo):
-        """标题库统计正确。"""
-        title_library_repo.add_item("user-test-001")
-        title_library_repo.add_item("user-test-001")
-        title_library_repo.add_item("user-test-001")
-        title_library_repo.add_item("other-user")
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert data["total_titles"] == 3
-
-    def test_voice_library_count(self, client, voice_library_repo):
-        """配音库统计正确。"""
-        voice_library_repo.add_item("user-test-001")
-        voice_library_repo.add_item("other-user")
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert data["total_voices"] == 1
-
-    def test_generation_tasks_count(self, client, generation_task_repo):
-        """生成任务统计正确。"""
-        generation_task_repo.add_task(_make_generation_task("task-1"))
-        generation_task_repo.add_task(_make_generation_task("task-2"))
-        generation_task_repo.add_task(_make_generation_task("task-other", user_id="other-user"))
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert data["total_tasks"] == 2
-
-    def test_recent_tasks_limited_to_5(self, client, generation_task_repo):
-        """最近任务最多返回 5 个。"""
-        for i in range(10):
-            task = _make_generation_task(f"task-{i}")
-            generation_task_repo.add_task(task)
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert len(data["recent_tasks"]) <= 5
-
-    def test_recent_tasks_have_correct_fields(self, client, generation_task_repo):
-        """最近任务包含正确字段。"""
-        task = _make_generation_task("task-1", status=GenerationTaskStatus.COMPLETED)
-        generation_task_repo.add_task(task)
-
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert len(data["recent_tasks"]) == 1
-        item = data["recent_tasks"][0]
-        for field in ["id", "task_type", "status", "current_step", "error_message", "updated_at"]:
-            assert field in item, f"缺少字段: {field}"
-        assert item["task_type"] == "generation"
-
-    def test_subscription_info(self, client):
-        """订阅信息正确。"""
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-
-        assert "subscription" in data
-        sub = data["subscription"]
-        assert "plan" in sub
-        assert "is_active" in sub
-        assert sub["plan"] == "free"
-        assert sub["is_active"] is True
-
-    def test_pro_user_subscription(
-        self, project_repo, asset_repo, generation_task_repo, title_library_repo, voice_library_repo
-    ):
-        """Pro 用户订阅信息正确。"""
-        test_app = FastAPI()
-        test_app.include_router(router, prefix="/dashboard")
-
-        test_app.dependency_overrides[get_current_user] = lambda: AuthenticatedUser(
-            user=_make_user(subscription_plan="pro", subscription_status="active")
-        )
-        test_app.dependency_overrides[get_project_repository] = lambda: project_repo
-        test_app.dependency_overrides[get_asset_repository] = lambda: asset_repo
-        test_app.dependency_overrides[get_generation_task_repository] = lambda: generation_task_repo
-        test_app.dependency_overrides[get_title_library_repository] = lambda: title_library_repo
-        test_app.dependency_overrides[get_voice_library_repository] = lambda: voice_library_repo
-
-        c = TestClient(test_app)
-        resp = c.get("/dashboard/overview")
-        assert resp.status_code == 200
-        assert resp.json()["subscription"]["plan"] == "pro"
-        assert resp.json()["subscription"]["is_active"] is True
-        test_app.dependency_overrides.clear()
-
-    def test_total_products_count(self, client, project_repo):
-        """项目（产品）数量正确。"""
-        resp = client.get("/dashboard/overview")
-        data = resp.json()
-        assert data["total_products"] == 2
-
-        # 新增一个项目后
-        project_repo.save(_make_project("proj-3", "user-test-001"))
-        resp2 = client.get("/dashboard/overview")
-        assert resp2.json()["total_products"] == 3
-
-    def test_unauthorized_returns_401(
-        self, project_repo, asset_repo, generation_task_repo, title_library_repo, voice_library_repo
-    ):
-        """未授权访问返回 401/403。"""
-        test_app = FastAPI()
-        test_app.include_router(router, prefix="/dashboard")
-
-        test_app.dependency_overrides[get_project_repository] = lambda: project_repo
-        test_app.dependency_overrides[get_asset_repository] = lambda: asset_repo
-        test_app.dependency_overrides[get_generation_task_repository] = lambda: generation_task_repo
-        test_app.dependency_overrides[get_title_library_repository] = lambda: title_library_repo
-        test_app.dependency_overrides[get_voice_library_repository] = lambda: voice_library_repo
-
-        c = TestClient(test_app)
-        resp = c.get("/dashboard/overview")
-        assert resp.status_code in (401, 403)
-        test_app.dependency_overrides.clear()
-
-    def test_recent_tasks_status_mapping(self, client, generation_task_repo):
-        """不同状态的任务显示正确的当前步骤。"""
-        # 已完成任务
-        completed_task = _make_generation_task("task-completed", status=GenerationTaskStatus.COMPLETED)
-        generation_task_repo.add_task(completed_task)
-
-        resp = client.get("/dashboard/overview")
-        tasks = resp.json()["recent_tasks"]
-        completed = [t for t in tasks if t["id"] == "task-completed"][0]
-        assert completed["status"] == "completed"
-        assert "完成" in completed["current_step"] or "completed" in completed["current_step"].lower()
-
-
-if __name__ == "__main__":
-    pytest.main([__file__, "-v"])

tests/integration/test_duplication_api.py

@@ -14,7 +14,6 @@ from __future__ import annotations
 
 import os
 import sys
-from dataclasses import replace
 from datetime import datetime, timezone
 from typing import Any
 from unittest.mock import MagicMock
@@ -33,7 +32,7 @@ sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "
 from app.api.routes.duplication import router
 from app.auth import AuthenticatedUser, get_current_user
 from app.core.storage import get_storage_service
-from app.dependencies import get_db_session, get_duplication_repository
+from app.dependencies import get_duplication_repository
 
 from packages.domain.duplication import DuplicateSegment, DuplicationRecord
 

tests/integration/test_duplication_upload_error_handling.py

@@ -32,11 +32,9 @@ sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "
 
 from app.api.routes.duplication import _validate_video_mime_type, router
 from app.auth import AuthenticatedUser, get_current_user
-from app.core.storage import OSSStorageService, get_storage_service
+from app.core.storage import get_storage_service
 from app.dependencies import get_duplication_repository
 
-from packages.domain.duplication import DuplicationRecord
-
 # ── 导入真实模块（不创建 fake module） ────────────────────────────────────────
 from packages.domain.entities import User
 

tests/integration/test_error_scenarios.py

@@ -14,7 +14,6 @@
 
 from __future__ import annotations
 
-import json
 import os
 import sys
 import uuid
@@ -240,7 +239,7 @@ class TestForbidden403:
     """测试 403 禁止访问场景。"""
 
     def test_access_other_user_project(self, auth_headers, other_auth_headers):
-        """访问他人项目应返回 403/404（权限检查未实现时返回 200 为已知问题）。"""
+        """访问他人项目应返回 403。"""
         # 用户 A 创建项目
         created = client.post(
             "/api/v1/projects",
@@ -255,11 +254,10 @@ class TestForbidden403:
             f"/api/v1/projects/{project_id}",
             headers=other_auth_headers,
         )
-        # TODO: 项目权限检查未实现，当前返回 200；实现后应改为 [403, 404]
-        assert response.status_code in [200, 403, 404], f"访问他人项目状态码异常: {response.status_code}"
+        assert response.status_code == 403, f"访问他人项目应返回 403，实际: {response.status_code}"
 
     def test_delete_other_user_project(self, auth_headers, other_auth_headers):
-        """删除他人项目应返回 403/404（权限检查未实现时返回 200/204 为已知问题）。"""
+        """删除他人项目应返回 403。"""
         created = client.post(
             "/api/v1/projects",
             json={"name": "Do Not Delete"},
@@ -272,8 +270,7 @@ class TestForbidden403:
             f"/api/v1/projects/{project_id}",
             headers=other_auth_headers,
         )
-        # TODO: 项目权限检查未实现，当前可能返回 200/204；DELETE 端点未实现时返回 405；实现后应改为 [403, 404]
-        assert response.status_code in [200, 204, 403, 404, 405], f"删除他人项目状态码异常: {response.status_code}"
+        assert response.status_code == 403, f"删除他人项目应返回 403，实际: {response.status_code}"
 
 
 # ---------------------------------------------------------------------------

tests/integration/test_full_pipeline.py

@@ -9,16 +9,12 @@ import shutil
 import subprocess
 import tempfile
 from pathlib import Path
-from unittest.mock import MagicMock, patch
 
 import pytest
 from video_processing.unified_render_service import (
-    RenderResult,
     UnifiedRenderService,
 )
 from worker_app.tasks.generation import (
-    OUTPUT_HEIGHT,
-    OUTPUT_WIDTH,
     _build_plan_and_clips_from_task,
     _create_fallback_clip,
     _mux_audio_track,

tests/integration/test_generated_videos_api.py

@@ -1,554 +0,0 @@
-"""
-生成视频管理 API 集成测试。
-
-覆盖端点：
-- GET   /generated-videos — 列出生成视频
-- GET   /generated-videos/{video_id} — 获取生成视频详情
-- PATCH /generated-videos/{video_id}/review — 更新审核状态
-- GET   /generated-videos/{video_id}/download-url — 获取下载地址
-
-使用 FastAPI TestClient + dependency_overrides 模式，
-导入真实路由模块，mock 所有外部依赖。
-"""
-
-from __future__ import annotations
-
-import os
-import sys
-from dataclasses import replace
-from datetime import datetime, timezone
-from unittest.mock import MagicMock
-
-# ── 环境变量 & sys.path（必须在导入 app.* 之前设置） ──────────────────────────
-os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
-os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
-
-import pytest
-from fastapi import FastAPI
-from fastapi.testclient import TestClient
-
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "api"))
-
-from app.api.routes.generated_videos import router
-from app.auth import AuthenticatedUser, get_current_user
-from app.core.storage import get_storage_service
-from app.dependencies import get_generated_video_repository, get_project_repository
-
-from packages.domain.entities import Project, User
-from packages.domain.generated_video import GeneratedVideo
-
-# ---------------------------------------------------------------------------
-# 1. 内存 Repository + 辅助函数
-# ---------------------------------------------------------------------------
-
-
-class InMemoryGeneratedVideoRepository:
-    """内存中的生成视频 Repository。"""
-
-    def __init__(self):
-        self._items: dict[str, GeneratedVideo] = {}
-
-    def create(self, video: GeneratedVideo) -> GeneratedVideo:
-        self._items[video.id] = video
-        return video
-
-    def get(self, video_id: str) -> GeneratedVideo | None:
-        return self._items.get(video_id)
-
-    def update(self, video: GeneratedVideo) -> GeneratedVideo:
-        self._items[video.id] = video
-        return video
-
-    def list_by_project(self, project_id: str) -> list[GeneratedVideo]:
-        return [v for v in self._items.values() if v.project_id == project_id]
-
-    def list_by_generation_task(self, generation_task_id: str) -> list[GeneratedVideo]:
-        return [v for v in self._items.values() if v.generation_task_id == generation_task_id]
-
-    def list_by_batch(self, batch_id: str) -> list[GeneratedVideo]:
-        return []
-
-
-class InMemoryProjectRepository:
-    """内存中的项目 Repository。"""
-
-    def __init__(self):
-        self._projects: dict[str, Project] = {}
-
-    def save(self, project: Project) -> None:
-        self._projects[project.id] = project
-
-    def find_by_id(self, project_id: str) -> Project | None:
-        return self._projects.get(project_id)
-
-    def find_by_owner_user_id(self, owner_user_id: str) -> list[Project]:
-        return [p for p in self._projects.values() if p.owner_user_id == owner_user_id]
-
-    def find_accessible_projects(self, user_id: str) -> list[Project]:
-        return [p for p in self._projects.values() if p.owner_user_id == user_id]
-
-    def count_by_owner(self, owner_user_id: str) -> int:
-        return len(self.find_by_owner_user_id(owner_user_id))
-
-    def delete(self, project_id: str) -> bool:
-        if project_id in self._projects:
-            del self._projects[project_id]
-            return True
-        return False
-
-
-class MockStorageService:
-    """Mock OSS 存储服务。"""
-
-    def get_download_url(self, file_url: str) -> str:
-        return f"https://cdn.example.com/download/{file_url}?token=abc123"
-
-
-def _make_user(**overrides) -> User:
-    defaults = dict(
-        id="user-test-001",
-        email="test@example.com",
-        display_name="Test User",
-        username="testuser",
-        subscription_plan="free",
-        subscription_status="active",
-        max_projects=3,
-        max_storage_gb=10,
-        created_at=datetime(2026, 1, 1, tzinfo=timezone.utc),
-    )
-    defaults.update(overrides)
-    return User(**defaults)
-
-
-def _make_project(project_id: str = "proj-1", owner_user_id: str = "user-test-001") -> Project:
-    return Project(
-        id=project_id,
-        name=f"Project {project_id}",
-        owner_user_id=owner_user_id,
-        description="",
-        created_at=datetime(2026, 1, 1, tzinfo=timezone.utc),
-    )
-
-
-def _make_video(
-    project_id: str = "proj-1",
-    name: str = "output.mp4",
-    status: str = "completed",
-    review_status: str = "pending_review",
-    **kwargs,
-) -> GeneratedVideo:
-    return GeneratedVideo.create(
-        project_id=project_id,
-        generation_task_id=kwargs.pop("generation_task_id", "task-1"),
-        name=name,
-        file_url=kwargs.pop("file_url", f"generated/{name}"),
-        file_size=kwargs.pop("file_size", 1024000),
-        duration=kwargs.pop("duration", 30.5),
-        width=kwargs.pop("width", 1920),
-        height=kwargs.pop("height", 1080),
-        fps=kwargs.pop("fps", 30.0),
-        thumbnail_url=kwargs.pop("thumbnail_url", None),
-        generation_params=kwargs.pop("generation_params", {"resolution": "1080p"}),
-    )
-
-
-# ---------------------------------------------------------------------------
-# 2. Fixtures
-# ---------------------------------------------------------------------------
-
-
-@pytest.fixture
-def video_repo():
-    return InMemoryGeneratedVideoRepository()
-
-
-@pytest.fixture
-def project_repo():
-    repo = InMemoryProjectRepository()
-    # 默认创建一个项目
-    repo.save(_make_project("proj-1", "user-test-001"))
-    repo.save(_make_project("proj-2", "user-test-001"))
-    repo.save(_make_project("proj-other", "other-user"))
-    return repo
-
-
-@pytest.fixture
-def storage_service():
-    return MockStorageService()
-
-
-@pytest.fixture
-def client(video_repo, project_repo, storage_service):
-    """创建带有依赖覆盖的 TestClient。"""
-    test_app = FastAPI()
-    test_app.include_router(router, prefix="/generated-videos")
-
-    def _override_current_user():
-        return AuthenticatedUser(user=_make_user())
-
-    def _override_video_repo():
-        return video_repo
-
-    def _override_project_repo():
-        return project_repo
-
-    def _override_storage():
-        return storage_service
-
-    test_app.dependency_overrides[get_current_user] = _override_current_user
-    test_app.dependency_overrides[get_generated_video_repository] = _override_video_repo
-    test_app.dependency_overrides[get_project_repository] = _override_project_repo
-    test_app.dependency_overrides[get_storage_service] = _override_storage
-
-    yield TestClient(test_app)
-
-    test_app.dependency_overrides.clear()
-
-
-# ---------------------------------------------------------------------------
-# 3. GET / — 列出生成视频
-# ---------------------------------------------------------------------------
-
-
-class TestListGeneratedVideos:
-    """列出生成视频端点测试。"""
-
-    def test_empty_list(self, client):
-        """无视频时返回空列表。"""
-        resp = client.get("/generated-videos")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["items"] == []
-
-    def test_list_all_user_videos(self, client, video_repo, project_repo):
-        """列出当前用户所有项目的视频。"""
-        v1 = _make_video(project_id="proj-1", name="video1.mp4")
-        v2 = _make_video(project_id="proj-2", name="video2.mp4")
-        v3 = _make_video(project_id="proj-other", name="other.mp4")  # 其他用户
-        video_repo.create(v1)
-        video_repo.create(v2)
-        video_repo.create(v3)
-
-        resp = client.get("/generated-videos")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert len(data["items"]) == 2
-        names = {item["name"] for item in data["items"]}
-        assert names == {"video1.mp4", "video2.mp4"}
-
-    def test_filter_by_project_id(self, client, video_repo):
-        """按 project_id 筛选视频。"""
-        v1 = _make_video(project_id="proj-1", name="a.mp4")
-        v2 = _make_video(project_id="proj-2", name="b.mp4")
-        video_repo.create(v1)
-        video_repo.create(v2)
-
-        resp = client.get("/generated-videos?project_id=proj-1")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert len(data["items"]) == 1
-        assert data["items"][0]["name"] == "a.mp4"
-
-    def test_filter_by_nonexistent_project_returns_404(self, client):
-        """筛选不存在的项目返回 404。"""
-        resp = client.get("/generated-videos?project_id=nonexistent")
-        assert resp.status_code == 404
-
-    def test_list_includes_download_url(self, client, video_repo):
-        """列表响应应包含下载地址。"""
-        v = _make_video(file_url="generated/test.mp4")
-        video_repo.create(v)
-
-        resp = client.get("/generated-videos")
-        assert resp.status_code == 200
-        item = resp.json()["items"][0]
-        assert "download_url" in item
-        assert item["download_url"] is not None
-        assert "cdn.example.com" in item["download_url"]
-
-    def test_list_response_fields(self, client, video_repo):
-        """列表响应包含所有必需字段。"""
-        v = _make_video()
-        video_repo.create(v)
-
-        resp = client.get("/generated-videos")
-        item = resp.json()["items"][0]
-        for field in [
-            "id",
-            "project_id",
-            "generation_task_id",
-            "name",
-            "file_url",
-            "file_size",
-            "duration",
-            "width",
-            "height",
-            "fps",
-            "status",
-            "review_status",
-            "generation_params",
-            "download_url",
-        ]:
-            assert field in item, f"缺少字段: {field}"
-
-    def test_unauthorized_returns_401(self, video_repo, project_repo, storage_service):
-        """未授权访问返回 401/403。"""
-        test_app = FastAPI()
-        test_app.include_router(router, prefix="/generated-videos")
-
-        # 不覆盖 get_current_user，使用默认（会拒绝无 token 请求）
-        test_app.dependency_overrides[get_generated_video_repository] = lambda: video_repo
-        test_app.dependency_overrides[get_project_repository] = lambda: project_repo
-        test_app.dependency_overrides[get_storage_service] = lambda: storage_service
-
-        c = TestClient(test_app)
-        resp = c.get("/generated-videos")
-        # 无 token 时 fastapi HTTPBearer auto_error=False 会返回 None，
-        # get_current_user 会抛 401
-        assert resp.status_code in (401, 403)
-        test_app.dependency_overrides.clear()
-
-
-# ---------------------------------------------------------------------------
-# 4. GET /{video_id} — 获取生成视频详情
-# ---------------------------------------------------------------------------
-
-
-class TestGetGeneratedVideo:
-    """获取生成视频详情端点测试。"""
-
-    def test_get_existing_video(self, client, video_repo):
-        """获取存在的视频返回详情。"""
-        v = _make_video(name="detail.mp4", duration=45.0)
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["id"] == v.id
-        assert data["name"] == "detail.mp4"
-        assert data["duration"] == 45.0
-        assert data["status"] == "completed"
-
-    def test_get_includes_download_url(self, client, video_repo):
-        """详情响应包含下载地址。"""
-        v = _make_video(file_url="generated/detail.mp4")
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}")
-        data = resp.json()
-        assert "download_url" in data
-        assert "cdn.example.com" in data["download_url"]
-
-    def test_get_nonexistent_returns_404(self, client):
-        """获取不存在的视频返回 404。"""
-        resp = client.get("/generated-videos/nonexistent-video-id")
-        assert resp.status_code == 404
-        assert "not found" in resp.json()["detail"].lower()
-
-    def test_get_thumbnail_url(self, client, video_repo):
-        """有缩略图时返回缩略图 URL。"""
-        v = _make_video(thumbnail_url="thumbs/test.jpg")
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}")
-        data = resp.json()
-        assert data["thumbnail_url"] == "thumbs/test.jpg"
-
-    def test_get_generation_params(self, client, video_repo):
-        """返回生成参数。"""
-        params = {"resolution": "4k", "style": "cinematic"}
-        v = _make_video(generation_params=params)
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}")
-        data = resp.json()
-        assert data["generation_params"]["resolution"] == "4k"
-        assert data["generation_params"]["style"] == "cinematic"
-
-
-# ---------------------------------------------------------------------------
-# 5. PATCH /{video_id}/review — 更新审核状态
-# ---------------------------------------------------------------------------
-
-
-class TestUpdateReviewStatus:
-    """更新审核状态端点测试。"""
-
-    def test_approve_video(self, client, video_repo):
-        """审核通过。"""
-        v = _make_video(review_status="pending_review")
-        video_repo.create(v)
-
-        resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "approved"},
-        )
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["review_status"] == "approved"
-
-        # 验证 repository 已更新
-        updated = video_repo.get(v.id)
-        assert updated.review_status == "approved"
-
-    def test_reject_video(self, client, video_repo):
-        """审核拒绝。"""
-        v = _make_video(review_status="pending_review")
-        video_repo.create(v)
-
-        resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "rejected"},
-        )
-        assert resp.status_code == 200
-        assert resp.json()["review_status"] == "rejected"
-
-    def test_set_pending_review(self, client, video_repo):
-        """设置为待审核。"""
-        v = _make_video(review_status="approved")
-        video_repo.create(v)
-
-        resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "pending_review"},
-        )
-        assert resp.status_code == 200
-        assert resp.json()["review_status"] == "pending_review"
-
-    def test_nonexistent_video_returns_404(self, client):
-        """更新不存在的视频返回 404。"""
-        resp = client.patch(
-            "/nonexistent-id/review",
-            json={"review_status": "approved"},
-        )
-        assert resp.status_code == 404
-
-    def test_invalid_status_returns_422(self, client, video_repo):
-        """无效审核状态返回 422。"""
-        v = _make_video()
-        video_repo.create(v)
-
-        resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "invalid_status"},
-        )
-        assert resp.status_code == 422
-
-    def test_missing_status_returns_422(self, client, video_repo):
-        """缺少 review_status 字段返回 422。"""
-        v = _make_video()
-        video_repo.create(v)
-
-        resp = client.patch(f"/generated-videos/{v.id}/review", json={})
-        assert resp.status_code == 422
-
-    def test_update_returns_updated_fields(self, client, video_repo):
-        """更新后返回完整的视频信息。"""
-        v = _make_video(name="review_test.mp4")
-        video_repo.create(v)
-
-        resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "approved"},
-        )
-        data = resp.json()
-        assert data["name"] == "review_test.mp4"
-        assert "id" in data
-        assert "download_url" in data
-
-
-# ---------------------------------------------------------------------------
-# 6. GET /{video_id}/download-url — 获取下载地址
-# ---------------------------------------------------------------------------
-
-
-class TestGetDownloadUrl:
-    """获取下载地址端点测试。"""
-
-    def test_get_download_url_success(self, client, video_repo):
-        """获取下载地址成功。"""
-        v = _make_video(file_url="generated/video.mp4")
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}/download-url")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["video_id"] == v.id
-        assert "download_url" in data
-        assert "cdn.example.com" in data["download_url"]
-
-    def test_nonexistent_video_returns_404(self, client):
-        """获取不存在视频的下载地址返回 404。"""
-        resp = client.get("/generated-videos/nonexistent-id/download-url")
-        assert resp.status_code == 404
-
-    def test_download_url_format(self, client, video_repo):
-        """下载地址格式正确。"""
-        v = _make_video(file_url="my-video.mp4")
-        video_repo.create(v)
-
-        resp = client.get(f"/generated-videos/{v.id}/download-url")
-        url = resp.json()["download_url"]
-        assert url.startswith("https://")
-        assert "token=" in url
-
-
-# ---------------------------------------------------------------------------
-# 7. 跨端点场景
-# ---------------------------------------------------------------------------
-
-
-class TestCrossEndpointScenarios:
-    """跨端点集成场景。"""
-
-    def test_create_list_detail_review_flow(self, client, video_repo):
-        """列表 → 详情 → 审核 完整流程。"""
-        # 准备数据
-        v = _make_video(name="flow.mp4", review_status="pending_review")
-        video_repo.create(v)
-
-        # 1. 列表
-        list_resp = client.get("/generated-videos")
-        assert list_resp.status_code == 200
-        assert len(list_resp.json()["items"]) == 1
-
-        # 2. 详情
-        detail_resp = client.get(f"/generated-videos/{v.id}")
-        assert detail_resp.status_code == 200
-        assert detail_resp.json()["name"] == "flow.mp4"
-        assert detail_resp.json()["review_status"] == "pending_review"
-
-        # 3. 审核通过
-        review_resp = client.patch(
-            f"/generated-videos/{v.id}/review",
-            json={"review_status": "approved"},
-        )
-        assert review_resp.status_code == 200
-        assert review_resp.json()["review_status"] == "approved"
-
-        # 4. 再次查看详情确认
-        detail_resp2 = client.get(f"/generated-videos/{v.id}")
-        assert detail_resp2.json()["review_status"] == "approved"
-
-        # 5. 获取下载地址
-        dl_resp = client.get(f"/generated-videos/{v.id}/download-url")
-        assert dl_resp.status_code == 200
-        assert dl_resp.json()["video_id"] == v.id
-
-    def test_multiple_videos_pagination_simulation(self, client, video_repo):
-        """多个视频时列表正确返回所有视频。"""
-        for i in range(5):
-            v = _make_video(project_id="proj-1", name=f"video_{i}.mp4")
-            video_repo.create(v)
-
-        resp = client.get("/generated-videos")
-        assert resp.status_code == 200
-        items = resp.json()["items"]
-        assert len(items) == 5
-        names = {item["name"] for item in items}
-        assert len(names) == 5  # 全部不同
-
-
-if __name__ == "__main__":
-    pytest.main([__file__, "-v"])

tests/integration/test_generation_api.py

@@ -515,7 +515,6 @@ class TestRetryGenerationTask:
             task_id = resp.json()["items"][0]["id"]
 
         # 直接修改 repository 中的任务状态为 failed
-        from app.dependencies import get_generation_task_repository
 
         # 由于是 stub，我们需要通过另一种方式设置状态
         # 让我们直接通过 retry 测试来验证

tests/integration/test_ingest_pipeline.py

@@ -3,7 +3,7 @@ from packages.adapters.in_memory import (
     InMemoryIngestJobRepository,
 )
 from packages.application import SubmitIngestJobCommand, SubmitIngestJobUseCase
-from packages.domain import Asset, IngestJob, IngestJobStatus
+from packages.domain import Asset, IngestJobStatus
 
 
 def simulate_ingest_asset(

tests/integration/test_project_management.py

@@ -1,263 +0,0 @@
-"""项目管理功能集成测试"""
-
-import pytest
-
-# 项目管理功能尚未实现，相关模块不存在，跳过整个文件
-pytest.skip(
-    "项目管理功能尚未实现（project_management_repositories / "
-    "project_management_use_cases / TaskPriority / TaskStatus 均不存在）",
-    allow_module_level=True,
-)
-
-from packages.adapters.in_memory.project_management_repositories import (
-    InMemoryMilestoneRepository,
-    InMemoryTaskIssueRepository,
-    InMemoryTaskRepository,
-)
-from packages.application.project_management_use_cases import (
-    CreateMilestoneUseCase,
-    CreateTaskIssueUseCase,
-    CreateTaskUseCase,
-    ListProjectTasksUseCase,
-    ListTaskIssuesUseCase,
-    ResolveTaskIssueUseCase,
-    UpdateTaskProgressUseCase,
-    UpdateTaskStatusUseCase,
-)
-from packages.domain import TaskPriority, TaskStatus
-
-
-def test_create_task():
-    """测试创建任务"""
-    repo = InMemoryTaskRepository()
-    use_case = CreateTaskUseCase(repo)
-
-    task = use_case.execute(
-        project_id="proj_1",
-        name="开发登录功能",
-        description="实现用户登录功能",
-        priority=TaskPriority.HIGH,
-    )
-
-    assert task.id is not None
-    assert task.name == "开发登录功能"
-    assert task.status == TaskStatus.PENDING
-    assert task.priority == TaskPriority.HIGH
-    assert task.progress == 0.0
-
-
-def test_list_tasks():
-    """测试获取任务列表"""
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-
-    # 创建两个任务
-    create_use_case.execute(
-        project_id="proj_1",
-        name="任务1",
-    )
-    create_use_case.execute(
-        project_id="proj_1",
-        name="任务2",
-    )
-
-    # 查询任务列表
-    list_use_case = ListProjectTasksUseCase(repo)
-    tasks = list_use_case.execute("proj_1")
-
-    assert len(tasks) == 2
-    assert tasks[0].name == "任务1"
-    assert tasks[1].name == "任务2"
-
-
-def test_update_task_status():
-    """测试更新任务状态"""
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-    update_use_case = UpdateTaskStatusUseCase(repo)
-
-    # 创建任务
-    task = create_use_case.execute(
-        project_id="proj_1",
-        name="测试任务",
-    )
-
-    # 更新状态为进行中
-    updated_task = update_use_case.execute(task.id, TaskStatus.IN_PROGRESS)
-
-    assert updated_task.status == TaskStatus.IN_PROGRESS
-    assert updated_task.actual_start_date is not None
-
-
-def test_update_task_progress():
-    """测试更新任务进度"""
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-    progress_use_case = UpdateTaskProgressUseCase(repo)
-
-    # 创建任务
-    task = create_use_case.execute(
-        project_id="proj_1",
-        name="测试任务",
-    )
-
-    # 更新进度到 50%
-    updated_task = progress_use_case.execute(task.id, 50.0)
-
-    assert updated_task.progress == 50.0
-    assert updated_task.status == TaskStatus.IN_PROGRESS
-
-    # 更新进度到 100%
-    completed_task = progress_use_case.execute(task.id, 100.0)
-
-    assert completed_task.progress == 100.0
-    assert completed_task.status == TaskStatus.COMPLETED
-    assert completed_task.actual_end_date is not None
-
-
-def test_create_milestone():
-    """测试创建里程碑"""
-    repo = InMemoryMilestoneRepository()
-    use_case = CreateMilestoneUseCase(repo)
-
-    milestone = use_case.execute(
-        project_id="proj_1",
-        name="V1.0 发布",
-        description="第一个正式版本",
-    )
-
-    assert milestone.id is not None
-    assert milestone.name == "V1.0 发布"
-    assert milestone.completed is False
-
-
-def test_create_and_resolve_issue():
-    """测试创建和解决任务问题"""
-    repo = InMemoryTaskIssueRepository()
-    create_use_case = CreateTaskIssueUseCase(repo)
-    resolve_use_case = ResolveTaskIssueUseCase(repo)
-    list_use_case = ListTaskIssuesUseCase(repo)
-
-    # 创建问题
-    issue = create_use_case.execute(
-        task_id="task_1",
-        project_id="proj_1",
-        title="接口报错",
-        description="调用登录接口返回 500",
-    )
-
-    assert issue.id is not None
-    assert issue.title == "接口报错"
-    assert issue.resolved is False
-
-    # 解决问题
-    resolved_issue = resolve_use_case.execute(issue.id)
-
-    assert resolved_issue.resolved is True
-    assert resolved_issue.resolved_at is not None
-
-    # 查询任务问题列表
-    issues = list_use_case.execute("task_1")
-    assert len(issues) == 1
-    assert issues[0].resolved is True
-
-
-def test_task_hierarchy():
-    """测试任务层级关系"""
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-
-    # 创建父任务
-    parent_task = create_use_case.execute(
-        project_id="proj_1",
-        name="开发用户模块",
-    )
-
-    # 创建子任务
-    child_task_1 = create_use_case.execute(
-        project_id="proj_1",
-        name="登录功能",
-        parent_task_id=parent_task.id,
-    )
-
-    child_task_2 = create_use_case.execute(
-        project_id="proj_1",
-        name="注册功能",
-        parent_task_id=parent_task.id,
-    )
-
-    # 查询子任务
-    children = repo.list_by_parent(parent_task.id)
-
-    assert len(children) == 2
-    assert children[0].parent_task_id == parent_task.id
-    assert children[1].parent_task_id == parent_task.id
-
-
-def test_get_task_detail():
-    """测试获取任务详情"""
-    from packages.application.get_task_detail_use_case import GetTaskDetailUseCase
-
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-    get_use_case = GetTaskDetailUseCase(repo)
-
-    # 创建任务
-    task = create_use_case.execute(
-        project_id="proj_1",
-        name="测试任务",
-        description="这是一个测试任务",
-    )
-
-    # 获取详情
-    retrieved_task = get_use_case.execute(task.id)
-
-    assert retrieved_task.id == task.id
-    assert retrieved_task.name == "测试任务"
-    assert retrieved_task.description == "这是一个测试任务"
-
-    # 测试不存在的任务
-    try:
-        get_use_case.execute("nonexistent_id")
-        assert False, "应该抛出异常"
-    except ValueError as e:
-        assert "not found" in str(e)
-
-
-def test_update_task():
-    """测试任务基本信息更新"""
-    from packages.application.update_task_use_case import UpdateTaskUseCase
-
-    repo = InMemoryTaskRepository()
-    create_use_case = CreateTaskUseCase(repo)
-    update_use_case = UpdateTaskUseCase(repo)
-
-    # 创建任务
-    task = create_use_case.execute(
-        project_id="proj_1",
-        name="原始任务",
-        description="原始描述",
-        priority="low",
-    )
-
-    # 更新任务
-    updated_task = update_use_case.execute(
-        task_id=task.id,
-        name="更新后的任务",
-        description="更新后的描述",
-        priority="high",
-    )
-
-    assert updated_task.name == "更新后的任务"
-    assert updated_task.description == "更新后的描述"
-    assert updated_task.priority == "high"
-
-    # 部分更新
-    partial_updated = update_use_case.execute(
-        task_id=task.id,
-        name="又更新了",
-    )
-
-    assert partial_updated.name == "又更新了"
-    assert partial_updated.description == "更新后的描述"  # 保持不变
-    assert partial_updated.priority == "high"  # 保持不变

tests/integration/test_subscription_api.py

@@ -16,7 +16,6 @@ from __future__ import annotations
 import importlib.util
 import os
 import sys
-from dataclasses import dataclass, field
 from datetime import datetime, timezone
 from typing import Optional
 
@@ -30,12 +29,10 @@ from fastapi.testclient import TestClient
 
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "api"))
 
-from app.auth import AuthenticatedUser, get_current_user
-from app.dependencies import get_user_repository
+from app.auth import AuthenticatedUser
 
 # ── 导入真实模块（不创建 fake module） ────────────────────────────────────────
 from packages.domain.entities import User
-from packages.ports.user_repository import UserRepository
 
 # ── 导入被测路由模块（从 fixtures 加载简化版路由） ─────────────────────────────
 _fixture_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "fixtures", "subscription_routes.py")

tests/integration/test_task_center_api.py

@@ -629,7 +629,6 @@ class TestTaskCenterCrossEndpoint:
         # 2. 重试失败任务
         retry_resp = tc.post("/tasks/gen-fail-cross/retry")
         assert retry_resp.status_code == 200
-        new_task_id = retry_resp.json()["source_id"]
 
         # 3. 再次列出，应有2个任务（旧的failed + 新的pending）
         list_resp2 = tc.get("/tasks")

tests/integration/test_tts_api.py

@@ -18,7 +18,6 @@ from __future__ import annotations
 import os
 import sys
 from datetime import datetime, timezone
-from unittest.mock import MagicMock
 
 # ── 环境变量 & sys.path（必须在导入 app.* 之前设置） ──────────────────────────
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")

tests/integration/test_voice_clone_api.py

@@ -18,7 +18,6 @@ from __future__ import annotations
 import os
 import sys
 from datetime import datetime, timezone
-from unittest.mock import MagicMock
 
 # ── 环境变量 & sys.path（必须在导入 app.* 之前设置） ──────────────────────────
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")

tests/render_compare/audio_diff.py

@@ -181,7 +181,7 @@ def compute_audio_diff(
             timeout=120,
         )
         stderr = result.stderr or ""
-    except subprocess.CalledProcessError as e:
+    except subprocess.CalledProcessError:
         # 如果音频格式不兼容，返回失败
         return AudioDiffResult(
             audio_a=str(audio_a),

tests/render_compare/runner.py

@@ -30,7 +30,7 @@ import json
 import os
 import sys
 import time
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from datetime import datetime
 from pathlib import Path
 from typing import Any
@@ -403,9 +403,6 @@ def generate_html_report(summary: dict[str, Any], output_path: Path):
     scenarios = summary["scenarios"]
 
     # 按通过/失败分组
-    passed_list = [s for s in scenarios if s["passed"]]
-    failed_list = [s for s in scenarios if not s["passed"]]
-
     # 构建场景卡片
     scenario_cards = ""
     for s in scenarios:

tests/unit/test_asset_diagnosis.py

@@ -1,7 +1,6 @@
 import os
 import sys
 from pathlib import Path
-from uuid import uuid4
 
 # 设置必要环境变量（必须在导入 app 模块之前）
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
@@ -9,7 +8,6 @@ os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
 
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))
 
-import pytest
 from app.api.routes.asset_diagnosis import _build_diagnosis
 from fastapi import FastAPI
 from fastapi.testclient import TestClient

tests/unit/test_asset_library_delete.py

@@ -13,7 +13,6 @@ from __future__ import annotations
 import os
 import sys
 from pathlib import Path
-from unittest.mock import MagicMock
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")

tests/unit/test_asset_tagging.py

@@ -86,7 +86,7 @@ def test_find_by_tag_ids(asset_repo, tag_repo):
     a2.add_tag(tag1.id)
     asset_repo.update(a2)
 
-    a3 = _create_asset(asset_repo, name="c.mp4")
+    _create_asset(asset_repo, name="c.mp4")
     # 无标签
 
     # 按 tag1 筛选 → a1, a2

tests/unit/test_audio_url_presign.py

@@ -8,8 +8,6 @@ from __future__ import annotations
 
 from unittest.mock import MagicMock, patch
 
-import pytest
-
 
 class TestAudioUrlSigner:
     """测试音频URL签名函数的行为。"""
@@ -79,8 +77,8 @@ class TestAudioUrlSigner:
         mock_svc = MagicMock(spec=OSSStorageService)
         mock_svc.get_download_url.return_value = "https://signed/a.mp3?sig=123"
 
-        # 替换全局单例
-        with patch("app.core.storage._storage_service", mock_svc):
+        # 替换全局单例（现在位于 packages.shared.storage）
+        with patch("packages.shared.storage._storage_service", mock_svc):
             from app.dependencies import get_audio_url_signer
 
             signer = get_audio_url_signer()

tests/unit/test_auto_clip_service.py

@@ -10,10 +10,9 @@ sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))
 from dataclasses import dataclass, field
 from enum import Enum
 from typing import Any
-from unittest.mock import MagicMock
 
 import pytest
-from app.services.auto_clip_service import AutoClipService, ClipAssignDetail
+from app.services.auto_clip_service import AutoClipService
 
 # ── Stub 实体 ─────────────────────────────────────────────────────────────────
 

tests/unit/test_chunked_upload_routes.py

@@ -20,7 +20,6 @@ from unittest.mock import MagicMock
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
 
-import pytest
 
 # 确保 app 模块可导入
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))

tests/unit/test_config_oss.py

@@ -12,12 +12,9 @@ from __future__ import annotations
 
 import importlib.util
 import os
-import sys
 from pathlib import Path
 from unittest.mock import patch
 
-import pytest
-
 
 def _load_settings_class():
     """
@@ -55,7 +52,7 @@ class TestOSSConfigDefaults:
 
     def test_oss_endpoint_default(self):
         settings = _fresh_settings()
-        assert settings.OSS_ENDPOINT == "oss-cn-hangzhou.aliiyuncs.com"
+        assert settings.OSS_ENDPOINT == "oss-cn-hangzhou.aliyuncs.com"
 
     def test_oss_access_key_id_default_empty(self):
         settings = _fresh_settings()
@@ -88,8 +85,8 @@ class TestOSSConfigEnvOverride:
     """环境变量能正确覆盖 OSS 配置字段。"""
 
     def test_oss_endpoint_override(self):
-        settings = _fresh_settings(OSS_ENDPOINT="oss-cn-shanghai.aliiyuncs.com")
-        assert settings.OSS_ENDPOINT == "oss-cn-shanghai.aliiyuncs.com"
+        settings = _fresh_settings(OSS_ENDPOINT="oss-cn-shanghai.aliyuncs.com")
+        assert settings.OSS_ENDPOINT == "oss-cn-shanghai.aliyuncs.com"
 
     def test_oss_access_key_id_override(self):
         settings = _fresh_settings(OSS_ACCESS_KEY_ID="test-key-id")

tests/unit/test_config_schemas_and_ai_endpoints.py

@@ -15,9 +15,8 @@ from __future__ import annotations
 
 import os
 import sys
-from datetime import datetime, timezone
 from pathlib import Path
-from typing import Any, Optional
+from typing import Any
 from unittest.mock import MagicMock
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
@@ -41,7 +40,7 @@ class TestNormalizePlanConfig:
         assert result == DEFAULT_EDIT_PLAN_CONFIG.copy()
 
     def test_empty_dict_returns_full_defaults(self):
-        from packages.domain.config_schemas import DEFAULT_EDIT_PLAN_CONFIG, normalize_plan_config
+        from packages.domain.config_schemas import normalize_plan_config
 
         result = normalize_plan_config({})
         assert result["cover"]["type"] == "ai_frame"
@@ -363,7 +362,7 @@ def _create_ai_test_app():
 from fastapi import FastAPI
 from fastapi.testclient import TestClient
 
-from packages.domain.edit_plan import EditPlan, EditPlanStatus
+from packages.domain.edit_plan import EditPlan
 
 
 @pytest.fixture

tests/unit/test_cosyvoice_service.py

@@ -3,7 +3,7 @@
 from __future__ import annotations
 
 import json
-from unittest.mock import MagicMock, patch
+from unittest.mock import MagicMock
 
 import httpx
 import pytest

tests/unit/test_dedup_engine.py

@@ -37,13 +37,10 @@ if "worker_app.celery_app" in sys.modules and isinstance(sys.modules["worker_app
 if "worker_app.db" in sys.modules and isinstance(sys.modules["worker_app.db"], MagicMock):
     sys.modules["worker_app.db"].SessionLocal = MagicMock()
 
-# Mock celery.Task base class — 仅在 celery 不可用时注入 mock，避免污染真实包
-try:
-    import celery as _real_celery  # noqa: F401
-except ImportError:
-    _mock_if_absent("celery", MagicMock())
-    if "celery" in sys.modules and isinstance(sys.modules["celery"], MagicMock):
-        sys.modules["celery"].Task = object
+# Mock celery.Task base class
+_mock_if_absent("celery", MagicMock())
+if "celery" in sys.modules and isinstance(sys.modules["celery"], MagicMock):
+    sys.modules["celery"].Task = object
 
 # Mock packages.shared.storage
 _mock_if_absent("packages.shared")

tests/unit/test_duplication_use_cases.py

@@ -22,7 +22,7 @@ from packages.application.duplication import (
     UploadForDuplicationCommand,
     UploadForDuplicationUseCase,
 )
-from packages.domain.duplication import DuplicateSegment, DuplicationRecord
+from packages.domain.duplication import DuplicationRecord
 
 
 def _make_record(status="pending", **kwargs):

tests/unit/test_edit_plan_generation_api.py

@@ -12,7 +12,6 @@ from __future__ import annotations
 import os
 import sys
 from dataclasses import dataclass, field
-from datetime import datetime, timezone
 from typing import Any, Optional
 from unittest.mock import MagicMock, patch
 

tests/unit/test_edit_plan_worker_failure.py

@@ -13,7 +13,6 @@ from __future__ import annotations
 import os
 import sys
 from dataclasses import dataclass, field
-from datetime import datetime, timezone
 from types import ModuleType
 from typing import Any, Optional
 from unittest.mock import MagicMock, patch
@@ -176,7 +175,6 @@ class TestRenderEditPlanFailureUpdatesGenTask:
         gen_task = StubGenerationTask(id="gen-task-001", status=_StubStatus("running"))
 
         plan_repo = StubPlanRepo(plan)
-        clip_repo = StubClipRepo([])
         gen_task_repo = StubGenTaskRepo(gen_task)
 
         # 让 clip_repo 抛异常以触发 except 路径

tests/unit/test_edit_plans_api.py

@@ -13,7 +13,6 @@ from __future__ import annotations
 
 import os
 import sys
-from datetime import datetime, timezone
 from pathlib import Path
 from typing import Optional
 from unittest.mock import MagicMock

tests/unit/test_edit_template_service.py

@@ -16,8 +16,8 @@ import os
 import sys
 from datetime import datetime, timezone
 from pathlib import Path
-from typing import Any, List, Optional
-from unittest.mock import MagicMock, patch
+from typing import List, Optional
+from unittest.mock import MagicMock
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
@@ -27,7 +27,7 @@ import pytest
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))
 
 from packages.domain.edit_template import EditTemplate, EditTemplateStatus
-from packages.domain.template_clip_config import ClipType, TemplateClipConfig, TransitionEffect
+from packages.domain.template_clip_config import ClipType, TemplateClipConfig
 
 # ---------------------------------------------------------------------------
 # Stub Repositories
@@ -273,7 +273,7 @@ class TestEditTemplateServiceCRUD:
 
     def test_list_templates_active_only(self):
         svc = _make_service()
-        t1 = svc.create_template(name="活跃")
+        svc.create_template(name="活跃")
         t2 = svc.create_template(name="停用")
         svc.deactivate_template(t2.id)
         result = svc.list_templates(active_only=True)

tests/unit/test_edit_templates_api.py

@@ -1,427 +0,0 @@
-"""模板管理 API 单元测试 — Phase 8 任务 2.03.
-
-覆盖 5 个端点：
-  GET    /api/v1/edit-templates      — 列表（分页 + 筛选）
-  GET    /api/v1/edit-templates/{id} — 详情
-  POST   /api/v1/edit-templates      — 创建
-  PUT    /api/v1/edit-templates/{id} — 更新
-  DELETE /api/v1/edit-templates/{id} — 软删除
-
-使用 FastAPI TestClient + Stub Repository + dependency_overrides.
-"""
-
-from __future__ import annotations
-
-import os
-import sys
-from dataclasses import dataclass, field
-from datetime import datetime, timezone
-from typing import Any, Optional
-from unittest.mock import MagicMock
-
-os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
-os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
-
-import pytest
-from fastapi import FastAPI
-from fastapi.testclient import TestClient
-
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "api"))
-
-from packages.domain.config_schemas import normalize_template_config
-from packages.domain.edit_template import EditTemplate, EditTemplateStatus
-
-# ── Stub Repository ───────────────────────────────────────────────────────────
-
-
-class StubEditTemplateRepository:
-    """内存中模拟 EditTemplate 仓储"""
-
-    def __init__(self) -> None:
-        self._store: dict[str, EditTemplate] = {}
-
-    def list_all(
-        self,
-        *,
-        template_type: Optional[str] = None,
-        status: Optional[EditTemplateStatus] = None,
-        skip: int = 0,
-        limit: int = 50,
-    ) -> list[EditTemplate]:
-        items = list(self._store.values())
-        if template_type:
-            items = [t for t in items if t.template_type == template_type]
-        if status:
-            items = [t for t in items if t.status == status]
-        items.sort(key=lambda t: t.created_at, reverse=True)
-        return items[skip : skip + limit]
-
-    def list_active(
-        self,
-        *,
-        template_type: Optional[str] = None,
-        skip: int = 0,
-        limit: int = 50,
-    ) -> list[EditTemplate]:
-        return self.list_all(template_type=template_type, status=EditTemplateStatus.ACTIVE, skip=skip, limit=limit)
-
-    def get(self, template_id: str) -> Optional[EditTemplate]:
-        return self._store.get(template_id)
-
-    def create(self, template: EditTemplate) -> EditTemplate:
-        self._store[template.id] = template
-        return template
-
-    def update(self, template: EditTemplate) -> EditTemplate:
-        if template.id not in self._store:
-            raise ValueError(f"EditTemplate {template.id} not found")
-        self._store[template.id] = template
-        return template
-
-    def delete(self, template_id: str) -> bool:
-        if template_id in self._store:
-            del self._store[template_id]
-            return True
-        return False
-
-    def count(
-        self,
-        *,
-        template_type: Optional[str] = None,
-        status: Optional[EditTemplateStatus] = None,
-    ) -> int:
-        items = list(self._store.values())
-        if template_type:
-            items = [t for t in items if t.template_type == template_type]
-        if status:
-            items = [t for t in items if t.status == status]
-        return len(items)
-
-
-# ── Fixtures ──────────────────────────────────────────────────────────────────
-
-
-@dataclass
-class FakeUser:
-    id: str = "user-001"
-    email: str = "test@example.com"
-    is_admin: bool = True
-
-
-@dataclass
-class FakeAuthenticatedUser:
-    user: FakeUser = field(default_factory=FakeUser)
-    session_id: str | None = None
-    token_type: str | None = None
-
-
-@pytest.fixture
-def stub_repo() -> StubEditTemplateRepository:
-    return StubEditTemplateRepository()
-
-
-@pytest.fixture
-def app(stub_repo: StubEditTemplateRepository) -> FastAPI:
-    """构建测试 FastAPI 应用，注入 Stub Repository"""
-    import app.services.edit_template_service as service_module
-    from app.api.routes.edit_templates import router
-    from app.auth import get_current_user
-    from app.dependencies import get_db_session
-
-    # 替换服务模块中的 Repository 类
-    original_template_repo_cls = service_module.SQLAlchemyEditTemplateRepository
-    original_clip_config_repo_cls = service_module.SQLAlchemyTemplateClipConfigRepository
-    service_module.SQLAlchemyEditTemplateRepository = lambda session: stub_repo
-    service_module.SQLAlchemyTemplateClipConfigRepository = lambda session: stub_repo
-
-    test_app = FastAPI()
-    test_app.include_router(router, prefix="/api/v1/edit-templates")
-
-    # 覆盖依赖
-    def override_get_db_session():
-        yield MagicMock()
-
-    def override_get_current_user():
-        return FakeAuthenticatedUser()
-
-    test_app.dependency_overrides[get_db_session] = override_get_db_session
-    test_app.dependency_overrides[get_current_user] = override_get_current_user
-
-    yield test_app
-
-    # 恢复
-    service_module.SQLAlchemyEditTemplateRepository = original_template_repo_cls
-    service_module.SQLAlchemyTemplateClipConfigRepository = original_clip_config_repo_cls
-    test_app.dependency_overrides.clear()
-
-
-@pytest.fixture
-def client(app: FastAPI) -> TestClient:
-    return TestClient(app)
-
-
-def _make_template(name: str = "测试模板", **kwargs: Any) -> EditTemplate:
-    return EditTemplate.create(name=name, **kwargs)
-
-
-# ── GET /api/v1/edit-templates (列表) ─────────────────────────────────────────
-
-
-class TestListTemplates:
-    def test_empty_list(self, client: TestClient) -> None:
-        resp = client.get("/api/v1/edit-templates")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["items"] == []
-        assert data["total"] == 0
-        assert data["page"] == 1
-
-    def test_list_with_items(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        for i in range(3):
-            stub_repo.create(_make_template(f"模板{i}"))
-        resp = client.get("/api/v1/edit-templates")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["total"] == 3
-        assert len(data["items"]) == 3
-
-    def test_pagination(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        for i in range(5):
-            stub_repo.create(_make_template(f"模板{i}"))
-        resp = client.get("/api/v1/edit-templates?page=1&page_size=2")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert len(data["items"]) == 2
-        assert data["total"] == 5
-        assert data["page"] == 1
-        assert data["page_size"] == 2
-
-    def test_filter_by_type(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        stub_repo.create(_make_template("Vlog模板", template_type="vlog"))
-        stub_repo.create(_make_template("短视频模板", template_type="short"))
-        stub_repo.create(_make_template("另一个Vlog", template_type="vlog"))
-        resp = client.get("/api/v1/edit-templates?template_type=vlog")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["total"] == 2
-        assert all(item["template_type"] == "vlog" for item in data["items"])
-
-    def test_filter_by_status(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t1 = _make_template("活跃模板")
-        stub_repo.create(t1)
-        t2 = _make_template("停用模板", status=EditTemplateStatus.INACTIVE)
-        stub_repo.create(t2)
-        resp = client.get("/api/v1/edit-templates?status=active")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["total"] == 1
-        assert data["items"][0]["name"] == "活跃模板"
-
-    def test_invalid_status_filter(self, client: TestClient) -> None:
-        resp = client.get("/api/v1/edit-templates?status=invalid")
-        assert resp.status_code == 400
-
-    def test_invalid_page(self, client: TestClient) -> None:
-        resp = client.get("/api/v1/edit-templates?page=0")
-        assert resp.status_code == 422
-
-
-# ── GET /api/v1/edit-templates/{id} (详情) ────────────────────────────────────
-
-
-class TestGetTemplate:
-    def test_get_existing(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("详情模板", description="这是描述", template_type="vlog")
-        stub_repo.create(t)
-        resp = client.get(f"/api/v1/edit-templates/{t.id}")
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["id"] == t.id
-        assert data["name"] == "详情模板"
-        assert data["description"] == "这是描述"
-        assert data["template_type"] == "vlog"
-        assert data["status"] == "active"
-
-    def test_get_not_found(self, client: TestClient) -> None:
-        resp = client.get("/api/v1/edit-templates/nonexistent-id")
-        assert resp.status_code == 404
-        assert "不存在" in resp.json()["detail"]
-
-
-# ── POST /api/v1/edit-templates (创建) ────────────────────────────────────────
-
-
-class TestCreateTemplate:
-    def test_create_basic(self, client: TestClient) -> None:
-        resp = client.post("/api/v1/edit-templates", json={"name": "新模板"})
-        assert resp.status_code == 201
-        data = resp.json()
-        assert data["name"] == "新模板"
-        assert data["description"] == ""
-        assert data["template_type"] == "default"
-        assert data["status"] == "active"
-        assert data["sort_weight"] == 0
-        assert "id" in data
-
-    def test_create_with_all_fields(self, client: TestClient) -> None:
-        body = {
-            "name": "完整模板",
-            "description": "完整描述",
-            "template_type": "vlog",
-            "config": {"key": "value"},
-            "preview_url": "https://example.com/preview.mp4",
-            "sort_weight": 10,
-        }
-        resp = client.post("/api/v1/edit-templates", json=body)
-        assert resp.status_code == 201
-        data = resp.json()
-        assert data["name"] == "完整模板"
-        assert data["description"] == "完整描述"
-        assert data["template_type"] == "vlog"
-        assert data["config"] == normalize_template_config({"key": "value"})
-        assert data["preview_url"] == "https://example.com/preview.mp4"
-        assert data["sort_weight"] == 10
-
-    def test_create_empty_name(self, client: TestClient) -> None:
-        resp = client.post("/api/v1/edit-templates", json={"name": ""})
-        assert resp.status_code == 422  # Pydantic min_length=1
-
-    def test_create_whitespace_name(self, client: TestClient) -> None:
-        resp = client.post("/api/v1/edit-templates", json={"name": "   "})
-        assert resp.status_code == 400  # domain validation
-
-    def test_create_missing_name(self, client: TestClient) -> None:
-        resp = client.post("/api/v1/edit-templates", json={})
-        assert resp.status_code == 422
-
-    def test_create_negative_sort_weight(self, client: TestClient) -> None:
-        resp = client.post("/api/v1/edit-templates", json={"name": "模板", "sort_weight": -1})
-        assert resp.status_code == 422
-
-
-# ── PUT /api/v1/edit-templates/{id} (更新) ────────────────────────────────────
-
-
-class TestUpdateTemplate:
-    def test_update_name(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("旧名称")
-        stub_repo.create(t)
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json={"name": "新名称"})
-        assert resp.status_code == 200
-        assert resp.json()["name"] == "新名称"
-
-    def test_update_multiple_fields(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        body = {"name": "更新后", "description": "新描述", "sort_weight": 5}
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json=body)
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["name"] == "更新后"
-        assert data["description"] == "新描述"
-        assert data["sort_weight"] == 5
-
-    def test_update_status(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json={"status": "inactive"})
-        assert resp.status_code == 200
-        assert resp.json()["status"] == "inactive"
-
-    def test_update_invalid_status(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json={"status": "bogus"})
-        assert resp.status_code == 400
-
-    def test_update_not_found(self, client: TestClient) -> None:
-        resp = client.put("/api/v1/edit-templates/nonexistent", json={"name": "x"})
-        assert resp.status_code == 404
-
-    def test_partial_update_preserves_others(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("原名", description="原描述", template_type="vlog")
-        stub_repo.create(t)
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json={"name": "新名"})
-        assert resp.status_code == 200
-        data = resp.json()
-        assert data["name"] == "新名"
-        assert data["description"] == "原描述"
-        assert data["template_type"] == "vlog"
-
-    def test_update_empty_body(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        resp = client.put(f"/api/v1/edit-templates/{t.id}", json={})
-        assert resp.status_code == 200
-        assert resp.json()["name"] == "模板"
-
-
-# ── DELETE /api/v1/edit-templates/{id} (软删除) ───────────────────────────────
-
-
-class TestDeleteTemplate:
-    def test_soft_delete(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("待删除")
-        stub_repo.create(t)
-        resp = client.delete(f"/api/v1/edit-templates/{t.id}")
-        assert resp.status_code == 204
-        # 软删除后仍存在，但状态为 inactive
-        updated = stub_repo.get(t.id)
-        assert updated is not None
-        assert updated.status == EditTemplateStatus.INACTIVE
-
-    def test_soft_delete_not_found(self, client: TestClient) -> None:
-        resp = client.delete("/api/v1/edit-templates/nonexistent")
-        assert resp.status_code == 404
-
-    def test_soft_delete_idempotent(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        # 第一次删除
-        resp1 = client.delete(f"/api/v1/edit-templates/{t.id}")
-        assert resp1.status_code == 204
-        # 第二次删除（已经是 inactive，但仍可再次设为 inactive）
-        resp2 = client.delete(f"/api/v1/edit-templates/{t.id}")
-        assert resp2.status_code == 204
-
-    def test_deleted_not_in_active_list(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板")
-        stub_repo.create(t)
-        client.delete(f"/api/v1/edit-templates/{t.id}")
-        resp = client.get("/api/v1/edit-templates?status=active")
-        data = resp.json()
-        assert data["total"] == 0
-
-
-# ── Response Schema 验证 ──────────────────────────────────────────────────────
-
-
-class TestResponseSchema:
-    def test_response_has_all_fields(self, client: TestClient, stub_repo: StubEditTemplateRepository) -> None:
-        t = _make_template("模板", description="描述", template_type="vlog")
-        stub_repo.create(t)
-        resp = client.get(f"/api/v1/edit-templates/{t.id}")
-        data = resp.json()
-        expected_keys = {
-            "id",
-            "name",
-            "description",
-            "template_type",
-            "editing_mode",
-            "config",
-            "preview_url",
-            "sort_weight",
-            "status",
-            "created_at",
-            "updated_at",
-        }
-        assert set(data.keys()) == expected_keys
-
-    def test_list_response_structure(self, client: TestClient) -> None:
-        resp = client.get("/api/v1/edit-templates")
-        data = resp.json()
-        assert "items" in data
-        assert "total" in data
-        assert "page" in data
-        assert "page_size" in data
-        assert isinstance(data["items"], list)

tests/unit/test_email_service.py

@@ -2,7 +2,7 @@
 邮件服务测试
 """
 
-from unittest.mock import MagicMock, Mock, patch
+from unittest.mock import MagicMock, patch
 
 import pytest
 

tests/unit/test_feature_flag.py

@@ -5,10 +5,8 @@
 
 from __future__ import annotations
 
-import time
-from unittest.mock import MagicMock, patch
+from unittest.mock import MagicMock
 
-import pytest
 
 from packages.adapters.redis.feature_flag_store import (
     FeatureFlagConfig,
@@ -337,7 +335,6 @@ class TestRedisStoreDegradation:
 
     def test_get_returns_default_when_redis_unavailable(self):
         """Redis 连接失败时返回默认关闭配置，不抛异常。"""
-        import importlib
 
         from packages.adapters.redis import feature_flag_store as ff_module
 
@@ -358,7 +355,6 @@ class TestRedisStoreDegradation:
 
     def test_list_all_returns_empty_on_redis_error(self):
         """Redis 错误时 list_all 返回空字典。"""
-        import importlib
 
         from packages.adapters.redis import feature_flag_store as ff_module
 

tests/unit/test_form_upload_routes.py

@@ -21,7 +21,6 @@ from unittest.mock import MagicMock
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
 
-import pytest
 
 # 确保 app 模块可导入
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))

tests/unit/test_generation_feature_flag.py

@@ -11,18 +11,14 @@ from __future__ import annotations
 
 import os
 import sys
-from datetime import datetime, timezone
 from types import ModuleType
-from typing import Any
-from unittest.mock import MagicMock, patch
+from unittest.mock import MagicMock
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
 
 from pathlib import Path
 
-import pytest
-
 # ── Mock worker 模块以避免数据库连接 ──────────────────────────────────────────
 
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "apps", "worker"))
@@ -226,8 +222,6 @@ def test_legacy_engine_two_clips_concat_duration():
     import subprocess
     import tempfile
 
-    from video_processing.ffmpeg_utils import probe_duration
-
     from apps.worker.worker_app.tasks.generation import _render_with_legacy_engine
 
     with tempfile.TemporaryDirectory() as tmpdir:

tests/unit/test_generation_logging.py

@@ -17,7 +17,7 @@ from __future__ import annotations
 import json
 import sys
 from pathlib import Path
-from unittest.mock import MagicMock, patch
+from unittest.mock import patch
 
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "worker"))

tests/unit/test_generation_presigned_url.py

@@ -12,7 +12,7 @@ from __future__ import annotations
 import os
 import sys
 from pathlib import Path
-from unittest.mock import MagicMock, patch
+from unittest.mock import MagicMock
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")

tests/unit/test_job_service.py

@@ -429,7 +429,7 @@ class TestListJobsUseCase:
 
     def test_list_by_project_with_status_filter(self, repo):
         create_uc = CreateJobUseCase(repo)
-        j1 = create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
+        create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
         j2 = create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
         j2.mark_running()
         repo.update(j2)
@@ -460,7 +460,7 @@ class TestListJobsUseCase:
 class TestGetJobStatisticsUseCase:
     def test_statistics(self, repo):
         create_uc = CreateJobUseCase(repo)
-        j1 = create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
+        create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
         j2 = create_uc.execute(CreateJobCommand(project_id="proj-1", job_type=JobType.VIDEO_COMPOSE))
         j2.mark_running()
         repo.update(j2)

tests/unit/test_oss_upload_crash_fix.py

@@ -15,8 +15,6 @@ import time
 from pathlib import Path
 from unittest.mock import MagicMock, patch
 
-import pytest
-
 # ── oss_bucket connect_timeout 测试 ───────────────────────────────────────────
 
 

tests/unit/test_p02_oss_credential_validation.py

@@ -75,43 +75,43 @@ class TestOSSCredentialValidation:
 
 
 class TestOSSDiagnose:
-    """测试 OSSStorageService.diagnose() 方法。"""
+    """测试 SharedStorageService.diagnose() 方法。"""
 
-    @patch("apps.api.app.core.storage.oss2", None)
-    @patch("apps.api.app.core.storage.get_settings")
+    @patch("packages.shared.storage.oss2", None)
+    @patch("packages.shared.storage.get_shared_settings")
     def test_diagnose_logs_error_when_bucket_none(self, mock_settings, caplog):
         """bucket=None 时 diagnose 应输出 ERROR 日志。"""
-        from apps.api.app.core.storage import OSSStorageService
+        from packages.shared.storage import SharedStorageService
 
-        mock_settings.return_value.OSS_BUCKET_NAME = "test-bucket"
-        mock_settings.return_value.OSS_ENDPOINT = "oss-cn-test.com"
-        mock_settings.return_value.OSS_ACCESS_KEY_ID = ""
-        mock_settings.return_value.OSS_ACCESS_KEY_SECRET = ""
+        mock_settings.return_value.oss_bucket_name = "test-bucket"
+        mock_settings.return_value.oss_endpoint = "oss-cn-test.com"
+        mock_settings.return_value.oss_access_key_id = ""
+        mock_settings.return_value.oss_access_key_secret = ""
 
-        service = OSSStorageService()
+        service = SharedStorageService()
         assert service.bucket is None
 
-        with caplog.at_level(logging.ERROR, logger="apps.api.app.core.storage"):
+        with caplog.at_level(logging.ERROR, logger="packages.shared.storage"):
             service.diagnose()
 
         assert any("❌" in record.message for record in caplog.records)
 
-    @patch("apps.api.app.core.storage.oss2")
-    @patch("apps.api.app.core.storage.get_settings")
+    @patch("packages.shared.storage.oss2")
+    @patch("packages.shared.storage.get_shared_settings")
     def test_diagnose_logs_success_when_bucket_configured(self, mock_settings, mock_oss2, caplog):
         """bucket 已配置时 diagnose 应输出成功日志。"""
-        from apps.api.app.core.storage import OSSStorageService
+        from packages.shared.storage import SharedStorageService
 
-        mock_settings.return_value.OSS_BUCKET_NAME = "test-bucket"
-        mock_settings.return_value.OSS_ENDPOINT = "oss-cn-test.com"
-        mock_settings.return_value.OSS_ACCESS_KEY_ID = "test-key-id"
-        mock_settings.return_value.OSS_ACCESS_KEY_SECRET = "test-key-secret"
+        mock_settings.return_value.oss_bucket_name = "test-bucket"
+        mock_settings.return_value.oss_endpoint = "oss-cn-test.com"
+        mock_settings.return_value.oss_access_key_id = "test-key-id"
+        mock_settings.return_value.oss_access_key_secret = "test-key-secret"
         mock_oss2.Bucket.return_value = MagicMock()
 
-        service = OSSStorageService()
+        service = SharedStorageService()
         assert service.bucket is not None
 
-        with caplog.at_level(logging.INFO, logger="apps.api.app.core.storage"):
+        with caplog.at_level(logging.INFO, logger="packages.shared.storage"):
             service.diagnose()
 
         assert any("OSS诊断" in record.message for record in caplog.records)
@@ -120,38 +120,38 @@ class TestOSSDiagnose:
 class TestOSSHTTPSEndpoint:
     """测试 P0-2 真正根因：sign_url 必须返回 HTTPS URL。"""
 
-    @patch("apps.api.app.core.storage.oss2")
-    @patch("apps.api.app.core.storage.get_settings")
+    @patch("packages.shared.storage.oss2")
+    @patch("packages.shared.storage.get_shared_settings")
     def test_endpoint_without_scheme_gets_https_prefix(self, mock_settings, mock_oss2):
         """endpoint 无 scheme 时应自动加 https://，确保 sign_url 生成 HTTPS URL。"""
-        from apps.api.app.core.storage import OSSStorageService
+        from packages.shared.storage import SharedStorageService
 
-        mock_settings.return_value.OSS_BUCKET_NAME = "test-bucket"
-        mock_settings.return_value.OSS_ENDPOINT = "oss-cn-hangzhou.aliyuncs.com"
-        mock_settings.return_value.OSS_ACCESS_KEY_ID = "test-key-id"
-        mock_settings.return_value.OSS_ACCESS_KEY_SECRET = "test-key-secret"
+        mock_settings.return_value.oss_bucket_name = "test-bucket"
+        mock_settings.return_value.oss_endpoint = "oss-cn-hangzhou.aliyuncs.com"
+        mock_settings.return_value.oss_access_key_id = "test-key-id"
+        mock_settings.return_value.oss_access_key_secret = "test-key-secret"
         mock_oss2.Bucket.return_value = MagicMock()
 
-        OSSStorageService()
+        SharedStorageService()
 
         # 验证传给 oss2.Bucket 的 endpoint 带了 https://
         call_args = mock_oss2.Bucket.call_args
         endpoint_passed = call_args[0][1]  # 第二个位置参数
         assert endpoint_passed == "https://oss-cn-hangzhou.aliyuncs.com"
 
-    @patch("apps.api.app.core.storage.oss2")
-    @patch("apps.api.app.core.storage.get_settings")
+    @patch("packages.shared.storage.oss2")
+    @patch("packages.shared.storage.get_shared_settings")
     def test_endpoint_with_existing_https_not_doubled(self, mock_settings, mock_oss2):
         """endpoint 已有 https:// 时不应重复添加。"""
-        from apps.api.app.core.storage import OSSStorageService
+        from packages.shared.storage import SharedStorageService
 
-        mock_settings.return_value.OSS_BUCKET_NAME = "test-bucket"
-        mock_settings.return_value.OSS_ENDPOINT = "https://oss-cn-hangzhou.aliyuncs.com"
-        mock_settings.return_value.OSS_ACCESS_KEY_ID = "test-key-id"
-        mock_settings.return_value.OSS_ACCESS_KEY_SECRET = "test-key-secret"
+        mock_settings.return_value.oss_bucket_name = "test-bucket"
+        mock_settings.return_value.oss_endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
+        mock_settings.return_value.oss_access_key_id = "test-key-id"
+        mock_settings.return_value.oss_access_key_secret = "test-key-secret"
         mock_oss2.Bucket.return_value = MagicMock()
 
-        OSSStorageService()
+        SharedStorageService()
 
         call_args = mock_oss2.Bucket.call_args
         endpoint_passed = call_args[0][1]

tests/unit/test_p02_p03_fixes.py

@@ -9,7 +9,6 @@ from __future__ import annotations
 import logging
 from unittest.mock import MagicMock, patch
 
-import pytest
 from video_processing.ffmpeg_utils import build_xfade_filter_chain
 
 # ── P0-3: build_xfade_filter_chain 安全钳制 ──────────────────────────────────

tests/unit/test_p02_worker_oss_fix.py

@@ -11,8 +11,6 @@ from __future__ import annotations
 import os
 from unittest.mock import MagicMock, patch
 
-import pytest
-
 # ── oss_bucket endpoint scheme 修复 ──────────────────────────────────────────
 
 
@@ -34,11 +32,10 @@ class TestOSSBucketEndpointScheme:
                     "OSS_BUCKET_NAME": "test-bucket",
                 },
             ),
-            patch("video_processing.oss_helpers.oss2.Auth") as mock_auth,
+            patch("video_processing.oss_helpers.oss2.Auth"),
             patch("video_processing.oss_helpers.oss2.Bucket", return_value=mock_bucket_instance) as mock_bucket_cls,
         ):
             # 清除缓存，确保重新创建
-            import video_processing.oss_helpers as oss_mod
 
             bucket = oss_bucket()
 
@@ -67,9 +64,8 @@ class TestOSSBucketEndpointScheme:
             patch("video_processing.oss_helpers.oss2.Auth"),
             patch("video_processing.oss_helpers.oss2.Bucket", return_value=mock_bucket_instance) as mock_bucket_cls,
         ):
-            import video_processing.oss_helpers as oss_mod
 
-            bucket = oss_bucket()
+            oss_bucket()
 
             call_args = mock_bucket_cls.call_args
             endpoint_arg = call_args[0][1]
@@ -95,9 +91,8 @@ class TestOSSBucketEndpointScheme:
             patch("video_processing.oss_helpers.oss2.Auth"),
             patch("video_processing.oss_helpers.oss2.Bucket", return_value=mock_bucket_instance) as mock_bucket_cls,
         ):
-            import video_processing.oss_helpers as oss_mod
 
-            bucket = oss_bucket()
+            oss_bucket()
 
             call_args = mock_bucket_cls.call_args
             endpoint_arg = call_args[0][1]
@@ -117,7 +112,6 @@ class TestOSSBucketEndpointScheme:
             },
             clear=True,
         ):
-            import video_processing.oss_helpers as oss_mod
 
             bucket = oss_bucket()
             assert bucket is None
@@ -177,7 +171,7 @@ class TestGetSignedDownloadUrl:
             patch("video_processing.oss_helpers.oss2.Auth"),
             patch("video_processing.oss_helpers.oss2.Bucket", return_value=mock_bucket),
         ):
-            result = get_signed_download_url("https://test-bucket.oss-cn-hangzhou.aliyuncs.com/generated/test.mp4")
+            get_signed_download_url("https://test-bucket.oss-cn-hangzhou.aliyuncs.com/generated/test.mp4")
 
             mock_bucket.sign_url.assert_called_once()
             # 验证传给 sign_url 的是纯 storage key，不是完整 URL

tests/unit/test_phase8_clip_models.py

@@ -300,7 +300,7 @@ from sqlalchemy.orm import sessionmaker
 from packages.adapters.sqlalchemy_impl.edit_plan_clip_repository import (
     SQLAlchemyEditPlanClipRepository,
 )
-from packages.adapters.sqlalchemy_impl.models import Base, EditPlanClipModel, TemplateClipConfigModel
+from packages.adapters.sqlalchemy_impl.models import Base
 from packages.adapters.sqlalchemy_impl.template_clip_config_repository import (
     SQLAlchemyTemplateClipConfigRepository,
 )

tests/unit/test_phase8_edit_models.py

@@ -8,7 +8,7 @@ sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))
 import logging
 
 from sqlalchemy import create_engine
-from sqlalchemy.orm import Session, sessionmaker
+from sqlalchemy.orm import sessionmaker
 
 from packages.adapters.sqlalchemy_impl.edit_plan_repository import (
     SQLAlchemyEditPlanRepository,

tests/unit/test_plan_generator.py

@@ -16,13 +16,12 @@ import os
 import sys
 from datetime import datetime, timezone
 from pathlib import Path
-from typing import Any, List, Optional
+from typing import List, Optional
 from unittest.mock import MagicMock, patch
 
 os.environ.setdefault("JWT_SECRET_KEY", "unit-test-secret-key-for-testing")
 os.environ.setdefault("DATABASE_URL", "sqlite:///test.db")
 
-import pytest
 
 sys.path.insert(0, str(Path(__file__).resolve().parents[2] / "apps" / "api"))