From 8c4c428cdcc5086c8fd23c7cfdbacbd150d25d12 Mon Sep 17 00:00:00 2001
From: xiaoxia <dev@xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 16:33:23 +0800
Subject: [PATCH 01/12] =?UTF-8?q?fix(api):=20editingPlanner=20=E5=AF=B9?=
 =?UTF-8?q?=E6=8E=A5=E5=90=8E=E7=AB=AF=20/templates=20API=EF=BC=8C?=
 =?UTF-8?q?=E5=88=A0=E9=99=A4=E9=81=97=E7=95=99=20editPlans.ts=20(#108)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Squash merge PR#108
- editingPlanner.ts: mock → 真实 /templates API（7个函数）
- editPlans.ts: 已删除
- 代码审计通过
---
 apps/web/src/api/editPlans.ts      |  98 -------------
 apps/web/src/api/editingPlanner.ts | 224 +++++++----------------------
 2 files changed, 52 insertions(+), 270 deletions(-)
 delete mode 100644 apps/web/src/api/editPlans.ts

diff --git a/apps/web/src/api/editPlans.ts b/apps/web/src/api/editPlans.ts
deleted file mode 100644
index 50f98674d..000000000
--- a/apps/web/src/api/editPlans.ts
+++ /dev/null
@@ -1,98 +0,0 @@
-/**
- * 编辑计划 API
- * Phase 1 重构：去掉 projectId，编辑计划直接归属用户
- */
-import apiClient from './client';
-
-/** 编辑模式 */
-export type EditingMode = 'one-take' | 'pip' | 'voiceover' | 'voice_pip';
-
-/** 编辑模板 */
-export interface EditTemplateItem {
-  id: string;
-  name: string;
-  description: string;
-  target_duration: number;
-  clip_count: number;
-  is_active: boolean;
-  category?: string;
-  thumbnail_url?: string;
-}
-
-/** 编辑计划片段 */
-export interface EditPlanClipItem {
-  id: string;
-  asset_id: string;
-  asset_name: string;
-  sequence: number;
-  start_time: number;
-  duration: number;
-  reason: string;
-  layer?: 'main' | 'pip' | 'broll';
-  thumbnail_url?: string;
-}
-
-/** 编辑计划 */
-export interface EditPlanItem {
-  id: string;
-  template_id: string;
-  asset_library_id: string;
-  title_id: string;
-  status: string;
-  editing_mode?: EditingMode;
-  summary: string;
-  clips: EditPlanClipItem[];
-  created_at?: string;
-  updated_at?: string;
-}
-
-// ─── 编辑计划 ──────────────────────────────────────────────
-
-/** 获取当前用户的编辑计划列表 */
-export const getEditPlans = async (): Promise<EditPlanItem[]> => {
-  const response = await apiClient.get('/edit-plans');
-  return response.data.items || [];
-};
-
-/** 获取单个编辑计划 */
-export const getEditPlan = async (planId: string): Promise<EditPlanItem> => {
-  const response = await apiClient.get(`/edit-plans/${planId}`);
-  return response.data;
-};
-
-/** 创建编辑计划 */
-export const createEditPlan = async (data: {
-  asset_library_id: string;
-  template_id?: string;
-  title_id?: string;
-}): Promise<EditPlanItem> => {
-  const response = await apiClient.post('/edit-plans', data);
-  return response.data;
-};
-
-/** 智能编排 - 自动生成编辑计划 */
-export const autoGenerateEditPlan = async (params: {
-  template_id: string;
-  asset_ids?: string[];
-  title_ids?: string[];
-  voice_ids?: string[];
-  editing_mode?: EditingMode;
-  target_duration?: number;
-}): Promise<EditPlanItem> => {
-  const response = await apiClient.post('/edit-plans/auto-generate', params);
-  return response.data;
-};
-
-/** 更新编辑计划 */
-export const updateEditPlan = async (
-  planId: string,
-  data: Partial<EditPlanItem>
-): Promise<EditPlanItem> => {
-  const response = await apiClient.patch(`/edit-plans/${planId}`, data);
-  return response.data;
-};
-
-/** 删除编辑计划 */
-export const deleteEditPlan = async (planId: string): Promise<void> => {
-  await apiClient.delete(`/edit-plans/${planId}`);
-};
diff --git a/apps/web/src/api/editingPlanner.ts b/apps/web/src/api/editingPlanner.ts
index 063acbc9f..9c032d66a 100644
--- a/apps/web/src/api/editingPlanner.ts
+++ b/apps/web/src/api/editingPlanner.ts
@@ -1,8 +1,8 @@
 /**
  * 剪辑计划编辑器 API
- * 当前使用 mock 数据，后端 API 就绪后替换
+ * 对接后端 /api/v1/templates 路由
  */
-// import apiClient from './client'; // TODO: 后端 API 就绪后启用
+import apiClient from './client';
 
 /* ──────────── 类型定义 ──────────── */
 
@@ -53,11 +53,11 @@ export interface BgmConfig {
 
 /** 模板片段 */
 export interface TemplateSegment {
-  id: string;
+  id?: string;
   segment_order: number;
   duration_min: number;
   duration_max: number;
-  material_type: string | null; // 仅 口播+混剪 模式：人物/场景
+  material_type: string | null;
 }
 
 /** 剪辑模板 */
@@ -72,6 +72,7 @@ export interface EditingTemplate {
   bgm_config: BgmConfig;
   estimated_duration: number;
   segments: TemplateSegment[];
+  is_active?: boolean;
   created_at: string;
   updated_at: string;
 }
@@ -80,6 +81,7 @@ export interface EditingTemplate {
 export interface TemplateCategory {
   id: string;
   name: string;
+  created_at?: string;
 }
 
 /** 创建/更新模板请求体 */
@@ -100,124 +102,46 @@ export interface GenerateFromTemplatePayload {
   voiceover_duration: number;
 }
 
-/** 使用模板生成响应 */
-export interface GenerateFromTemplateResponse {
-  task_id: string;
-  warning?: string;
+/** 验证/生成响应 */
+export interface ValidateWarning {
+  code: string;
+  message: string;
+  details?: Record<string, unknown>;
 }
 
-/* ──────────── Mock 数据 ──────────── */
+/** 使用模板生成响应 */
+export interface GenerateFromTemplateResponse {
+  template: EditingTemplate;
+  warnings: ValidateWarning[];
+}
 
-let _nextId = 100;
-const nextId = () => String(++_nextId);
+/** 列表响应（带分页） */
+export interface ListTemplatesResponse {
+  items: EditingTemplate[];
+  total: number;
+}
 
-const MOCK_CATEGORIES: TemplateCategory[] = [
-  { id: 'cat-1', name: '生活' },
-  { id: 'cat-2', name: '美食' },
-  { id: 'cat-3', name: '旅行' },
-  { id: 'cat-4', name: '知识' },
-];
+/** 分类列表响应 */
+export interface ListCategoriesResponse {
+  items: TemplateCategory[];
+}
 
-const MOCK_TEMPLATES: EditingTemplate[] = [
-  {
-    id: 'tpl-1',
-    name: '生活 Vlog 模板',
-    mode: 'pip',
-    category: '生活',
-    tags: ['vlog', '日常'],
-    title_config: {
-      ai_auto_select: true,
-      content: '',
-      font_preset: '思源黑体',
-      font_color: '#ffffff',
-      font_size: 32,
-      position: 'top',
-    },
-    subtitle_config: {
-      enabled: true,
-      position: 'bottom',
-      font: '思源黑体',
-      color: '#ffffff',
-      size: 24,
-      animation: 'fade',
-    },
-    bgm_config: { enabled: true, music_id: 'bgm-1' },
-    estimated_duration: 30,
-    segments: [
-      { id: 'seg-1', segment_order: 1, duration_min: 5, duration_max: 15, material_type: null },
-      { id: 'seg-2', segment_order: 2, duration_min: 10, duration_max: 20, material_type: null },
-    ],
-    created_at: '2026-06-20T10:00:00Z',
-    updated_at: '2026-06-20T10:00:00Z',
-  },
-  {
-    id: 'tpl-2',
-    name: '知识分享口播',
-    mode: 'voice_over',
-    category: '知识',
-    tags: ['口播', '分享'],
-    title_config: {
-      ai_auto_select: false,
-      content: '每日知识分享',
-      font_preset: '站酷快乐体',
-      font_color: '#ffdd00',
-      font_size: 36,
-      position: 'top',
-    },
-    subtitle_config: {
-      enabled: true,
-      position: 'bottom',
-      font: '思源黑体',
-      color: '#ffffff',
-      size: 28,
-      animation: 'typewriter',
-    },
-    bgm_config: { enabled: false, music_id: '' },
-    estimated_duration: 60,
-    segments: [
-      { id: 'seg-3', segment_order: 1, duration_min: 10, duration_max: 30, material_type: null },
-      { id: 'seg-4', segment_order: 2, duration_min: 20, duration_max: 40, material_type: null },
-      { id: 'seg-5', segment_order: 3, duration_min: 10, duration_max: 20, material_type: null },
-    ],
-    created_at: '2026-06-21T10:00:00Z',
-    updated_at: '2026-06-21T10:00:00Z',
-  },
-  {
-    id: 'tpl-3',
-    name: '一镜到底展示',
-    mode: 'one_take',
-    category: '生活',
-    tags: ['一镜到底'],
-    title_config: {
-      ai_auto_select: true,
-      content: '',
-      font_preset: '思源黑体',
-      font_color: '#ffffff',
-      font_size: 32,
-      position: 'center',
-    },
-    subtitle_config: { enabled: false, position: 'bottom', font: '思源黑体', color: '#ffffff', size: 24, animation: 'fade' },
-    bgm_config: { enabled: true, music_id: 'bgm-2' },
-    estimated_duration: 15,
-    segments: [
-      { id: 'seg-6', segment_order: 1, duration_min: 10, duration_max: 20, material_type: null },
-    ],
-    created_at: '2026-06-22T10:00:00Z',
-    updated_at: '2026-06-22T10:00:00Z',
-  },
-];
-
-/* ──────────── Mock API 函数 ──────────── */
-
-const delay = (ms = 200) => new Promise((r) => setTimeout(r, ms));
+// ============ API 函数 ============
 
 /** 获取模板列表 */
 export const getEditingTemplates = async (params?: {
   category?: string;
   tag?: string;
+  skip?: number;
+  limit?: number;
 }): Promise<EditingTemplate[]> => {
-  await delay();
-  let list = [...MOCK_TEMPLATES];
+  const response = await apiClient.get<ListTemplatesResponse>('/templates', {
+    params: {
+      skip: params?.skip ?? 0,
+      limit: params?.limit ?? 50,
+    },
+  });
+  let list = response.data.items;
   if (params?.category) list = list.filter((t) => t.category === params.category);
   if (params?.tag) list = list.filter((t) => t.tags.includes(params.tag!));
   return list;
@@ -225,38 +149,16 @@ export const getEditingTemplates = async (params?: {
 
 /** 获取模板详情 */
 export const getEditingTemplate = async (id: string): Promise<EditingTemplate> => {
-  await delay();
-  const tpl = MOCK_TEMPLATES.find((t) => t.id === id);
-  if (!tpl) throw new Error('模板不存在');
-  return { ...tpl };
+  const response = await apiClient.get<EditingTemplate>(`/templates/${id}`);
+  return response.data;
 };
 
 /** 创建模板 */
 export const createEditingTemplate = async (
   data: SaveTemplatePayload,
 ): Promise<EditingTemplate> => {
-  await delay(300);
-  const now = new Date().toISOString();
-  const tpl: EditingTemplate = {
-    id: nextId(),
-    name: data.name,
-    mode: data.mode,
-    category: data.category,
-    tags: data.tags,
-    title_config: data.title_config,
-    subtitle_config: data.subtitle_config,
-    bgm_config: data.bgm_config,
-    estimated_duration: data.estimated_duration,
-    segments: data.segments.map((s, i) => ({
-      ...s,
-      id: nextId(),
-      segment_order: i + 1,
-    })),
-    created_at: now,
-    updated_at: now,
-  };
-  MOCK_TEMPLATES.push(tpl);
-  return tpl;
+  const response = await apiClient.post<EditingTemplate>('/templates', data);
+  return response.data;
 };
 
 /** 更新模板 */
@@ -264,51 +166,29 @@ export const updateEditingTemplate = async (
   id: string,
   data: SaveTemplatePayload,
 ): Promise<EditingTemplate> => {
-  await delay(300);
-  const idx = MOCK_TEMPLATES.findIndex((t) => t.id === id);
-  if (idx === -1) throw new Error('模板不存在');
-  const updated: EditingTemplate = {
-    ...MOCK_TEMPLATES[idx],
-    name: data.name,
-    mode: data.mode,
-    category: data.category,
-    tags: data.tags,
-    title_config: data.title_config,
-    subtitle_config: data.subtitle_config,
-    bgm_config: data.bgm_config,
-    estimated_duration: data.estimated_duration,
-    segments: data.segments.map((s, i) => ({
-      ...s,
-      id: nextId(),
-      segment_order: i + 1,
-    })),
-    updated_at: new Date().toISOString(),
-  };
-  MOCK_TEMPLATES[idx] = updated;
-  return updated;
+  const response = await apiClient.patch<EditingTemplate>(`/templates/${id}`, data);
+  return response.data;
 };
 
 /** 删除模板 */
 export const deleteEditingTemplate = async (id: string): Promise<void> => {
-  await delay();
-  const idx = MOCK_TEMPLATES.findIndex((t) => t.id === id);
-  if (idx !== -1) MOCK_TEMPLATES.splice(idx, 1);
+  await apiClient.delete(`/templates/${id}`);
 };
 
 /** 获取模板分类列表 */
 export const getTemplateCategories = async (): Promise<TemplateCategory[]> => {
-  await delay();
-  return [...MOCK_CATEGORIES];
+  const response = await apiClient.get<ListCategoriesResponse>('/templates/categories/list');
+  return response.data.items;
 };
 
-/** 使用模板生成视频 */
+/** 使用模板生成视频（调用 validate 端点） */
 export const generateFromTemplate = async (
-  _templateId: string,
-  _data: GenerateFromTemplatePayload,
+  templateId: string,
+  data: GenerateFromTemplatePayload,
 ): Promise<GenerateFromTemplateResponse> => {
-  await delay(500);
-  return {
-    task_id: nextId(),
-    warning: undefined,
-  };
+  const response = await apiClient.post<GenerateFromTemplateResponse>(
+    `/templates/${templateId}/validate`,
+    data,
+  );
+  return response.data;
 };

From 8c678b9cd08591018db9eda6d18ce746c3bce6f6 Mon Sep 17 00:00:00 2001
From: CI Test <ci-test@xiaoxia.com>
Date: Mon, 29 Jun 2026 16:40:06 +0800
Subject: [PATCH 02/12] =?UTF-8?q?fix:=20TypeScript=E7=B1=BB=E5=9E=8B?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF=E4=BF=AE=E5=A4=8D=20-=20warning=E2=86=92warn?=
 =?UTF-8?q?ings,=20seg.id=E9=9D=9E=E7=A9=BA=E6=96=AD=E8=A8=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/web/src/pages/editing-planner/EditingPlanner.tsx     | 2 +-
 .../pages/editing-planner/components/TimelinePanel.tsx    | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/apps/web/src/pages/editing-planner/EditingPlanner.tsx b/apps/web/src/pages/editing-planner/EditingPlanner.tsx
index 4dd1e7b8f..e38d2df1d 100644
--- a/apps/web/src/pages/editing-planner/EditingPlanner.tsx
+++ b/apps/web/src/pages/editing-planner/EditingPlanner.tsx
@@ -168,7 +168,7 @@ const EditingPlanner: React.FC = () => {
     mutationFn: ({ templateId, duration }: { templateId: string; duration: number }) =>
       generateFromTemplate(templateId, { voiceover_duration: duration }),
     onSuccess: (data) => {
-      const msg = data.warning ? `生成任务已提交（${data.warning}）` : '生成任务已提交';
+      const msg = data.warnings && data.warnings.length > 0 ? `生成任务已提交（${data.warnings.map(w => w.message).join('; ')}）` : '生成任务已提交';
       message.success(msg);
       setGenerateModalOpen(false);
     },
diff --git a/apps/web/src/pages/editing-planner/components/TimelinePanel.tsx b/apps/web/src/pages/editing-planner/components/TimelinePanel.tsx
index 6f1d0cbb1..709be93c7 100644
--- a/apps/web/src/pages/editing-planner/components/TimelinePanel.tsx
+++ b/apps/web/src/pages/editing-planner/components/TimelinePanel.tsx
@@ -136,7 +136,7 @@ const TimelinePanel: React.FC<TimelinePanelProps> = ({
                   size="small"
                   danger
                   icon={<DeleteOutlined />}
-                  onClick={() => onRemoveSegment(seg.id)}
+                  onClick={() => onRemoveSegment(seg.id!)}
                   disabled={isOneShot}
                   style={{ marginLeft: 'auto' }}
                 />
@@ -154,7 +154,7 @@ const TimelinePanel: React.FC<TimelinePanelProps> = ({
                       min={1}
                       max={seg.duration_max}
                       value={seg.duration_min}
-                      onChange={(v) => onUpdateSegment(seg.id, { duration_min: v })}
+                      onChange={(v) => onUpdateSegment(seg.id!, { duration_min: v })}
                     />
                   </div>
                   <div>
@@ -163,7 +163,7 @@ const TimelinePanel: React.FC<TimelinePanelProps> = ({
                       min={seg.duration_min}
                       max={60}
                       value={seg.duration_max}
-                      onChange={(v) => onUpdateSegment(seg.id, { duration_max: v })}
+                      onChange={(v) => onUpdateSegment(seg.id!, { duration_max: v })}
                     />
                   </div>
                 </>
@@ -175,7 +175,7 @@ const TimelinePanel: React.FC<TimelinePanelProps> = ({
                   <Select
                     size="small"
                     value={seg.material_type || '人物'}
-                    onChange={(v) => onUpdateSegment(seg.id, { material_type: v })}
+                    onChange={(v) => onUpdateSegment(seg.id!, { material_type: v })}
                     style={{ width: '100%', marginTop: 4 }}
                     options={[
                       { value: '人物', label: '人物' },

From ea9e536740afc2027d12e835388eb4ba1e40d777 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 17:05:53 +0800
Subject: [PATCH 03/12] =?UTF-8?q?feat:=20=E6=89=A9=E5=B1=95=E7=94=9F?=
 =?UTF-8?q?=E6=88=90=E4=BB=BB=E5=8A=A1API=E6=94=AF=E6=8C=81=E6=A8=A1?=
 =?UTF-8?q?=E6=9D=BF=E6=A8=A1=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

方案A: 后端扩展3处API改动，支持前端模板中心化模型。

1. POST /api/v1/generation/tasks — project_id改为可选，新增template_id/asset_ids/title_ids/voice_ids
2. GET /api/v1/generation/tasks + GET /api/v1/tasks — 新增用户级列表（跨project）
3. POST /api/v1/tasks/{task_id}/retry + POST /api/v1/generation/tasks/{task_id}/retry — 简化重试

改动涉及：
- Domain: GenerationTask新增6个字段，放宽create()校验
- Application: CreateGenerationTaskCommand新增字段
- Ports: GenerationTaskRepository新增list_by_user()
- Adapter: SQLAlchemy模型+仓储实现新字段和list_by_user
- Schema: 双模式校验（project模式/模板模式）
- Routes: generation_tasks + task_center双路由注册
- Migration: 015_add_generation_task_extensions

向后兼容：所有旧端点和参数不变。
---
 .../015_add_generation_task_extensions.py     |  36 ++++
 apps/api/app/api/routes/generation_tasks.py   | 125 ++++++++++--
 apps/api/app/api/routes/task_center.py        | 179 +++++++++++++-----
 apps/api/app/schemas/generation_task.py       |  38 +++-
 apps/api/app/schemas/task_center.py           |  23 +++
 .../generation_task_repository.py             |  71 +++++--
 packages/adapters/sqlalchemy_impl/models.py   |  11 +-
 packages/application/generation_tasks.py      |  14 +-
 packages/domain/generation_task.py            |  23 ++-
 packages/ports/generation_task_repository.py  |   2 +
 10 files changed, 431 insertions(+), 91 deletions(-)
 create mode 100644 alembic/versions/015_add_generation_task_extensions.py

diff --git a/alembic/versions/015_add_generation_task_extensions.py b/alembic/versions/015_add_generation_task_extensions.py
new file mode 100644
index 000000000..4af932459
--- /dev/null
+++ b/alembic/versions/015_add_generation_task_extensions.py
@@ -0,0 +1,36 @@
+"""add generation task extensions
+
+Revision ID: 015
+Revises: 014
+Create Date: 2026-06-29
+"""
+
+import sqlalchemy as sa
+from sqlalchemy.dialects import mysql
+
+from alembic import op
+
+# revision identifiers
+revision = "015"
+down_revision = "014"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.add_column("generation_tasks", sa.Column("edit_plan_id", sa.String(32), nullable=False, server_default=""))
+    op.add_column("generation_tasks", sa.Column("template_id", sa.String(36), nullable=False, server_default=""))
+    op.add_column("generation_tasks", sa.Column("asset_ids", mysql.JSON(), nullable=False, server_default="[]"))
+    op.add_column("generation_tasks", sa.Column("title_ids", mysql.JSON(), nullable=False, server_default="[]"))
+    op.add_column("generation_tasks", sa.Column("voice_ids", mysql.JSON(), nullable=False, server_default="[]"))
+
+    op.create_index(op.f("ix_generation_tasks_template_id"), "generation_tasks", ["template_id"])
+
+
+def downgrade() -> None:
+    op.drop_index(op.f("ix_generation_tasks_template_id"), table_name="generation_tasks")
+    op.drop_column("generation_tasks", "voice_ids")
+    op.drop_column("generation_tasks", "title_ids")
+    op.drop_column("generation_tasks", "asset_ids")
+    op.drop_column("generation_tasks", "template_id")
+    op.drop_column("generation_tasks", "edit_plan_id")
diff --git a/apps/api/app/api/routes/generation_tasks.py b/apps/api/app/api/routes/generation_tasks.py
index c363d5595..462b92beb 100644
--- a/apps/api/app/api/routes/generation_tasks.py
+++ b/apps/api/app/api/routes/generation_tasks.py
@@ -16,6 +16,7 @@ from app.schemas.generated_video import (
 from app.schemas.generation_task import (
     CreateGenerationTaskRequest,
     GenerationTaskResponse,
+    ListGenerationTasksResponse,
 )
 from fastapi import APIRouter, Depends, HTTPException
 
@@ -45,6 +46,10 @@ def _to_generation_task_response(task) -> GenerationTaskResponse:
         asset_library_id=task.asset_library_id,
         strategy_id=task.strategy_id,
         voice_library_id=task.voice_library_id,
+        template_id=task.template_id,
+        asset_ids=task.asset_ids,
+        title_ids=task.title_ids,
+        voice_ids=task.voice_ids,
         status=task.status,
         progress=task.progress,
         result_count=task.result_count,
@@ -79,8 +84,45 @@ def _ensure_library_has_ready_video_assets(assets) -> None:
         )
 
 
+async def _resolve_project_and_library(
+    request: CreateGenerationTaskRequest,
+    project_repository: Any,
+    asset_library_repository: Any,
+    asset_repository: Any,
+    authenticated_user: AuthenticatedUser,
+) -> tuple[str, str]:
+    """解析 project_id 和 asset_library_id。
+
+    支持两种模式：
+    - 显式传入（向后兼容）
+    - 从 asset_ids 反查 asset_library（模板模式）
+    返回 (project_id, asset_library_id)。
+    """
+    project_id = request.project_id.strip()
+    asset_library_id = request.asset_library_id.strip()
+
+    # 模板模式：project_id 未提供时，从 asset_ids 反查所属 project
+    if not project_id and request.asset_ids:
+        first_asset_id = request.asset_ids[0]
+        asset = await asset_repository.find_by_id(first_asset_id)
+        if asset is not None:
+            project_id = asset.project_id
+            if not asset_library_id:
+                asset_library_id = asset.library_id
+
+    # 向后兼容校验：project_id 已提供时验证权限
+    if project_id:
+        project = project_repository.find_by_id(project_id)
+        if project is None:
+            raise HTTPException(status_code=404, detail=f"Project {project_id} not found")
+        if not project.can_access(authenticated_user.user.id):
+            raise HTTPException(status_code=403, detail="Access denied to project")
+
+    return project_id, asset_library_id
+
+
 @router.post("/tasks", response_model=GenerationTaskResponse)
-def create_generation_task(
+async def create_generation_task(
     request: CreateGenerationTaskRequest,
     authenticated_user: AuthenticatedUser = Depends(get_current_user),
     generation_task_repository: Any = Depends(get_generation_task_repository),
@@ -88,26 +130,30 @@ def create_generation_task(
     asset_library_repository: Any = Depends(get_asset_library_repository),
     asset_repository: Any = Depends(get_asset_repository),
 ) -> GenerationTaskResponse:
-    project = project_repository.find_by_id(request.project_id)
-    if project is None:
-        raise HTTPException(status_code=404, detail=f"Project {request.project_id} not found")
-    if not project.can_access(authenticated_user.user.id):
-        raise HTTPException(status_code=403, detail="Access denied to project")
-    
-    library = asset_library_repository.get(request.asset_library_id)
-    if library is None or library.project_id != request.project_id:
-        raise HTTPException(status_code=404, detail=f"AssetLibrary {request.asset_library_id} not found")
-    
-    assets = asset_repository.list_by_library(request.asset_library_id)
-    _ensure_library_has_ready_video_assets(assets)
+    project_id, asset_library_id = await _resolve_project_and_library(
+        request, project_repository, asset_library_repository, asset_repository, authenticated_user
+    )
+
+    # asset_library 存在性校验（仅在提供了 asset_library_id 时）
+    if asset_library_id:
+        library = asset_library_repository.get(asset_library_id)
+        if library is None or (project_id and library.project_id != project_id):
+            raise HTTPException(status_code=404, detail=f"AssetLibrary {asset_library_id} not found")
+
+        assets = await asset_repository.find_by_library(asset_library_id)
+        _ensure_library_has_ready_video_assets(assets)
 
     use_case = CreateGenerationTaskUseCase(generation_task_repository)
     task = use_case.execute(
         CreateGenerationTaskCommand(
-            project_id=request.project_id,
-            asset_library_id=request.asset_library_id,
+            project_id=project_id,
+            asset_library_id=asset_library_id,
             strategy_id=request.strategy_id,
             voice_library_id=request.voice_library_id,
+            template_id=request.template_id,
+            asset_ids=request.asset_ids,
+            title_ids=request.title_ids,
+            voice_ids=request.voice_ids,
             created_by_user_id=authenticated_user.user.id,
         )
     )
@@ -115,6 +161,17 @@ def create_generation_task(
     return _to_generation_task_response(task)
 
 
+@router.get("/tasks", response_model=ListGenerationTasksResponse)
+def list_generation_tasks(
+    authenticated_user: AuthenticatedUser = Depends(get_current_user),
+    generation_task_repository: Any = Depends(get_generation_task_repository),
+) -> ListGenerationTasksResponse:
+    """用户级生成任务列表（跨 project）。"""
+    tasks = generation_task_repository.list_by_user(authenticated_user.user.id)
+    items = [_to_generation_task_response(task) for task in tasks]
+    return ListGenerationTasksResponse(items=items)
+
+
 @router.get("/tasks/{task_id}", response_model=GenerationTaskResponse)
 def get_generation_task(
     task_id: str,
@@ -126,7 +183,8 @@ def get_generation_task(
     task = use_case.execute(task_id)
     if task is None:
         raise HTTPException(status_code=404, detail=f"GenerationTask {task_id} not found")
-    _check_project_access(task.project_id, authenticated_user.user.id, project_repository)
+    if task.project_id:
+        _check_project_access(task.project_id, authenticated_user.user.id, project_repository)
     return _to_generation_task_response(task)
 
 
@@ -141,7 +199,40 @@ def list_generation_results(
     task = generation_task_repository.get(task_id)
     if task is None:
         raise HTTPException(status_code=404, detail=f"GenerationTask {task_id} not found")
-    _check_project_access(task.project_id, authenticated_user.user.id, project_repository)
+    if task.project_id:
+        _check_project_access(task.project_id, authenticated_user.user.id, project_repository)
     use_case = ListGeneratedVideosByTaskUseCase(generated_video_repository)
     items = use_case.execute(task_id)
     return ListGeneratedVideosResponse(items=[_to_generated_video_response(item) for item in items])
+
+
+@router.post("/tasks/{task_id}/retry", response_model=GenerationTaskResponse)
+def retry_generation_task(
+    task_id: str,
+    authenticated_user: AuthenticatedUser = Depends(get_current_user),
+    generation_task_repository: Any = Depends(get_generation_task_repository),
+) -> GenerationTaskResponse:
+    """简化重试：通过 task_id 直接重试失败任务。"""
+    task = generation_task_repository.get(task_id)
+    if task is None:
+        raise HTTPException(status_code=404, detail="Generation task not found")
+    if task.status != "failed":
+        raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
+
+    use_case = CreateGenerationTaskUseCase(generation_task_repository)
+    retried = use_case.execute(
+        CreateGenerationTaskCommand(
+            project_id=task.project_id,
+            asset_library_id=task.asset_library_id,
+            strategy_id=task.strategy_id,
+            voice_library_id=task.voice_library_id,
+            edit_plan_id=task.edit_plan_id,
+            template_id=task.template_id,
+            asset_ids=task.asset_ids,
+            title_ids=task.title_ids,
+            voice_ids=task.voice_ids,
+            created_by_user_id=authenticated_user.user.id,
+        )
+    )
+    celery_app.send_task("worker.generate_video", args=[retried.id])
+    return _to_generation_task_response(retried)
diff --git a/apps/api/app/api/routes/task_center.py b/apps/api/app/api/routes/task_center.py
index ab72eca14..1d2e9524d 100644
--- a/apps/api/app/api/routes/task_center.py
+++ b/apps/api/app/api/routes/task_center.py
@@ -7,7 +7,12 @@ from app.dependencies import (
     get_ingest_job_repository,
     get_project_repository,
 )
-from app.schemas.task_center import ListProjectTasksResponse, ProjectTaskResponse
+from app.schemas.task_center import (
+    ListProjectTasksResponse,
+    ListTasksResponse,
+    ProjectTaskResponse,
+    UserTaskResponse,
+)
 from fastapi import APIRouter, Depends, HTTPException
 
 from packages.application import (
@@ -34,28 +39,135 @@ def _humanize_task_error(error_message: str) -> str:
     return f"任务失败：{raw}"
 
 
+def _status_value(status) -> str:
+    """安全获取状态值（兼容 StrEnum 和 plain string）。"""
+    return status.value if hasattr(status, "value") else str(status)
+
+
 def _generation_step(task) -> str:
-    if task.status.value == "pending":
+    s = _status_value(task.status)
+    if s == "pending":
         return "等待 Worker 执行"
-    if task.status.value == "running":
+    if s == "running":
         return "正在生成成片"
-    if task.status.value == "completed":
+    if s == "completed":
         return "生成完成"
-    if task.status.value == "failed":
+    if s == "failed":
         return "生成失败"
-    return task.status.value
+    return s
 
 
 def _ingest_step(job) -> str:
-    if job.status.value == "pending":
+    s = _status_value(job.status)
+    if s == "pending":
         return "等待导入"
-    if job.status.value == "processing":
+    if s == "processing":
         return "正在分析素材"
-    if job.status.value == "completed":
+    if s == "completed":
         return "导入完成"
-    if job.status.value == "failed":
+    if s == "failed":
         return "导入失败"
-    return job.status.value
+    return s
+
+
+def _generation_task_to_project_response(task) -> ProjectTaskResponse:
+    return ProjectTaskResponse(
+        id=f"generation:{task.id}",
+        task_type="generation",
+        project_id=task.project_id,
+        status=_status_value(task.status),
+        progress=task.progress,
+        current_step=_generation_step(task),
+        error_message=task.error_message,
+        user_message=_humanize_task_error(task.error_message),
+        retryable=_status_value(task.status) == "failed",
+        source_id=task.id,
+        template_id=task.template_id,
+        created_at=task.created_at,
+        updated_at=task.completed_at or task.started_at or task.created_at,
+    )
+
+
+# ── 用户级端点（放在项目级端点之前，避免路由冲突） ──
+
+
+@router.get("/tasks", response_model=ListTasksResponse)
+def list_user_tasks(
+    authenticated_user: AuthenticatedUser = Depends(get_current_user),
+    ingest_job_repository: Any = Depends(get_ingest_job_repository),
+    generation_task_repository: Any = Depends(get_generation_task_repository),
+) -> ListTasksResponse:
+    """用户级任务列表（跨 project），合并 ingest + generation 任务。"""
+    user_id = authenticated_user.user.id
+    items: list[UserTaskResponse] = []
+
+    for task in generation_task_repository.list_by_user(user_id):
+        items.append(
+            UserTaskResponse(
+                id=f"generation:{task.id}",
+                task_type="generation",
+                project_id=task.project_id,
+                template_id=task.template_id,
+                status=_status_value(task.status),
+                progress=task.progress,
+                current_step=_generation_step(task),
+                error_message=task.error_message,
+                user_message=_humanize_task_error(task.error_message),
+                retryable=_status_value(task.status) == "failed",
+                source_id=task.id,
+                created_at=task.created_at,
+                updated_at=task.completed_at or task.started_at or task.created_at,
+            )
+        )
+
+    items.sort(key=lambda item: item.updated_at or item.created_at or "", reverse=True)
+    return ListTasksResponse(items=items)
+
+
+@router.post("/tasks/{task_id}/retry", response_model=UserTaskResponse)
+def retry_task_by_id(
+    task_id: str,
+    authenticated_user: AuthenticatedUser = Depends(get_current_user),
+    generation_task_repository: Any = Depends(get_generation_task_repository),
+) -> UserTaskResponse:
+    """简化重试：通过 task_id 直接重试失败的生成任务。"""
+    task = generation_task_repository.get(task_id)
+    if task is None:
+        raise HTTPException(status_code=404, detail="Generation task not found")
+    if _status_value(task.status) != "failed":
+        raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
+
+    use_case = CreateGenerationTaskUseCase(generation_task_repository)
+    retried = use_case.execute(
+        CreateGenerationTaskCommand(
+            project_id=task.project_id,
+            asset_library_id=task.asset_library_id,
+            strategy_id=task.strategy_id,
+            voice_library_id=task.voice_library_id,
+            edit_plan_id=task.edit_plan_id,
+            template_id=task.template_id,
+            asset_ids=task.asset_ids,
+            title_ids=task.title_ids,
+            voice_ids=task.voice_ids,
+            created_by_user_id=authenticated_user.user.id,
+        )
+    )
+    celery_app.send_task("worker.generate_video", args=[retried.id])
+    return UserTaskResponse(
+        id=f"generation:{retried.id}",
+        task_type="generation",
+        project_id=retried.project_id,
+        template_id=retried.template_id,
+        status=_status_value(retried.status),
+        progress=retried.progress,
+        current_step=_generation_step(retried),
+        source_id=retried.id,
+        created_at=retried.created_at,
+        updated_at=retried.created_at,
+    )
+
+
+# ── 项目级端点 ──
 
 
 @router.get("/projects/{project_id}/tasks", response_model=ListProjectTasksResponse)
@@ -77,34 +189,19 @@ def list_project_tasks(
                 id=f"ingest:{job.id}",
                 task_type="ingest",
                 project_id=job.project_id,
-                status=job.status.value,
-                progress=100.0 if job.status.value == "completed" else 0.0,
+                status=_status_value(job.status),
+                progress=100.0 if _status_value(job.status) == "completed" else 0.0,
                 current_step=_ingest_step(job),
                 error_message=job.error_message,
                 user_message=_humanize_task_error(job.error_message),
-                retryable=job.status.value == "failed",
+                retryable=_status_value(job.status) == "failed",
                 source_id=job.id,
                 created_at=job.created_at,
                 updated_at=job.updated_at,
             )
         )
     for task in generation_task_repository.list_by_project(project_id):
-        items.append(
-            ProjectTaskResponse(
-                id=f"generation:{task.id}",
-                task_type="generation",
-                project_id=task.project_id,
-                status=task.status.value,
-                progress=task.progress,
-                current_step=_generation_step(task),
-                error_message=task.error_message,
-                user_message=_humanize_task_error(task.error_message),
-                retryable=task.status.value == "failed",
-                source_id=task.id,
-                created_at=task.created_at,
-                updated_at=task.completed_at or task.started_at or task.created_at,
-            )
-        )
+        items.append(_generation_task_to_project_response(task))
     items.sort(key=lambda item: item.updated_at or item.created_at or "", reverse=True)
     return ListProjectTasksResponse(items=items)
 
@@ -121,7 +218,7 @@ def retry_project_task(
         task = generation_task_repository.get(source_id)
         if task is None:
             raise HTTPException(status_code=404, detail="Generation task not found")
-        if task.status.value != "failed":
+        if _status_value(task.status) != "failed":
             raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
         use_case = CreateGenerationTaskUseCase(generation_task_repository)
         retried = use_case.execute(
@@ -131,26 +228,20 @@ def retry_project_task(
                 strategy_id=task.strategy_id,
                 voice_library_id=task.voice_library_id,
                 edit_plan_id=task.edit_plan_id,
+                template_id=task.template_id,
+                asset_ids=task.asset_ids,
+                title_ids=task.title_ids,
+                voice_ids=task.voice_ids,
                 created_by_user_id=authenticated_user.user.id,
             )
         )
         celery_app.send_task("worker.generate_video", args=[retried.id])
-        return ProjectTaskResponse(
-            id=f"generation:{retried.id}",
-            task_type="generation",
-            project_id=retried.project_id,
-            status=retried.status.value,
-            progress=retried.progress,
-            current_step=_generation_step(retried),
-            source_id=retried.id,
-            created_at=retried.created_at,
-            updated_at=retried.created_at,
-        )
+        return _generation_task_to_project_response(retried)
     if task_type == "ingest":
         job = ingest_job_repository.get(source_id)
         if job is None:
             raise HTTPException(status_code=404, detail="Ingest job not found")
-        if job.status.value != "failed":
+        if _status_value(job.status) != "failed":
             raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
         use_case = SubmitIngestJobUseCase(ingest_job_repository)
         retried = use_case.execute(
@@ -165,7 +256,7 @@ def retry_project_task(
             id=f"ingest:{retried.id}",
             task_type="ingest",
             project_id=retried.project_id,
-            status=retried.status.value,
+            status=_status_value(retried.status),
             progress=0,
             current_step=_ingest_step(retried),
             source_id=retried.id,
diff --git a/apps/api/app/schemas/generation_task.py b/apps/api/app/schemas/generation_task.py
index 0a6fec37b..a9e0beb91 100644
--- a/apps/api/app/schemas/generation_task.py
+++ b/apps/api/app/schemas/generation_task.py
@@ -1,12 +1,35 @@
-from pydantic import BaseModel, Field
+from pydantic import BaseModel, Field, model_validator
 
 
 class CreateGenerationTaskRequest(BaseModel):
-    project_id: str = Field(..., min_length=1)
-    asset_library_id: str = Field(..., min_length=1)
+    """创建生成任务请求。
+
+    支持两种模式（至少提供一种）：
+    - 项目模式：project_id + asset_library_id（向后兼容）
+    - 模板模式：template_id + asset_ids / title_ids / voice_ids
+    """
+    project_id: str = ""
+    asset_library_id: str = ""
     strategy_id: str = ""
     voice_library_id: str = ""
     created_by_user_id: str = ""
+    # ── 模板模式新增字段 ──
+    template_id: str = ""
+    asset_ids: list[str] = Field(default_factory=list)
+    title_ids: list[str] = Field(default_factory=list)
+    voice_ids: list[str] = Field(default_factory=list)
+
+    @model_validator(mode="after")
+    def _check_at_least_one_mode(self) -> "CreateGenerationTaskRequest":
+        has_project = bool(self.project_id.strip())
+        has_template = bool(self.template_id.strip())
+        if not has_project and not has_template:
+            raise ValueError("project_id 或 template_id 至少需要提供一个")
+        has_library = bool(self.asset_library_id.strip())
+        has_assets = bool(self.asset_ids or self.title_ids or self.voice_ids)
+        if not has_library and not has_assets:
+            raise ValueError("asset_library_id 或 asset_ids/title_ids/voice_ids 至少需要提供一个")
+        return self
 
 
 class GenerationTaskResponse(BaseModel):
@@ -15,7 +38,16 @@ class GenerationTaskResponse(BaseModel):
     asset_library_id: str
     strategy_id: str
     voice_library_id: str
+    template_id: str = ""
+    asset_ids: list[str] = Field(default_factory=list)
+    title_ids: list[str] = Field(default_factory=list)
+    voice_ids: list[str] = Field(default_factory=list)
     status: str
     progress: float
     result_count: int
     error_message: str
+
+
+class ListGenerationTasksResponse(BaseModel):
+    """用户级生成任务列表响应（跨 project）。"""
+    items: list[GenerationTaskResponse]
diff --git a/apps/api/app/schemas/task_center.py b/apps/api/app/schemas/task_center.py
index a7c5f2f9a..0aaaf7170 100644
--- a/apps/api/app/schemas/task_center.py
+++ b/apps/api/app/schemas/task_center.py
@@ -14,9 +14,32 @@ class ProjectTaskResponse(BaseModel):
     user_message: str = ""
     retryable: bool = False
     source_id: str = ""
+    template_id: str = ""
     created_at: datetime | None = None
     updated_at: datetime | None = None
 
 
 class ListProjectTasksResponse(BaseModel):
     items: list[ProjectTaskResponse] = Field(default_factory=list)
+
+
+class UserTaskResponse(BaseModel):
+    """用户级任务响应（跨 project，用于模板模式）。"""
+    id: str
+    task_type: str
+    project_id: str = ""
+    template_id: str = ""
+    status: str
+    progress: float
+    current_step: str
+    error_message: str = ""
+    user_message: str = ""
+    retryable: bool = False
+    source_id: str = ""
+    created_at: datetime | None = None
+    updated_at: datetime | None = None
+
+
+class ListTasksResponse(BaseModel):
+    """用户级任务列表响应（GET /api/v1/tasks）。"""
+    items: list[UserTaskResponse] = Field(default_factory=list)
diff --git a/packages/adapters/sqlalchemy_impl/generation_task_repository.py b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
index 430200ebf..b2c635f77 100644
--- a/packages/adapters/sqlalchemy_impl/generation_task_repository.py
+++ b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
@@ -4,6 +4,30 @@ from packages.adapters.sqlalchemy_impl.models import GenerationTaskModel
 from packages.domain import GenerationTask
 
 
+def _to_domain(model: GenerationTaskModel) -> GenerationTask:
+    """Convert ORM model to domain entity."""
+    return GenerationTask(
+        id=model.id,
+        project_id=model.project_id,
+        strategy_id=model.strategy_id,
+        asset_library_id=model.asset_library_id,
+        voice_library_id=model.voice_library_id,
+        edit_plan_id=model.edit_plan_id,
+        template_id=model.template_id,
+        asset_ids=list(model.asset_ids or []),
+        title_ids=list(model.title_ids or []),
+        voice_ids=list(model.voice_ids or []),
+        status=model.status,
+        progress=model.progress,
+        result_count=int(model.result_count or 0),
+        error_message=model.error_message,
+        started_at=model.started_at,
+        completed_at=model.completed_at,
+        created_by_user_id=model.created_by_user_id,
+        created_at=model.created_at,
+    )
+
+
 class SQLAlchemyGenerationTaskRepository:
     def __init__(self, session: Session):
         self.session = session
@@ -15,6 +39,11 @@ class SQLAlchemyGenerationTaskRepository:
             strategy_id=task.strategy_id,
             asset_library_id=task.asset_library_id,
             voice_library_id=task.voice_library_id,
+            edit_plan_id=task.edit_plan_id,
+            template_id=task.template_id,
+            asset_ids=task.asset_ids,
+            title_ids=task.title_ids,
+            voice_ids=task.voice_ids,
             status=task.status,
             progress=task.progress,
             result_count=task.result_count,
@@ -32,31 +61,39 @@ class SQLAlchemyGenerationTaskRepository:
         model = self.session.query(GenerationTaskModel).filter(GenerationTaskModel.id == task_id).first()
         if model is None:
             return None
-        return GenerationTask(
-            id=model.id,
-            project_id=model.project_id,
-            strategy_id=model.strategy_id,
-            asset_library_id=model.asset_library_id,
-            voice_library_id=model.voice_library_id,
-            status=model.status,
-            progress=model.progress,
-            result_count=int(model.result_count or 0),
-            error_message=model.error_message,
-            started_at=model.started_at,
-            completed_at=model.completed_at,
-            created_by_user_id=model.created_by_user_id,
-            created_at=model.created_at,
-        )
+        return _to_domain(model)
 
     def list_by_project(self, project_id: str) -> list[GenerationTask]:
-        models = self.session.query(GenerationTaskModel).filter(GenerationTaskModel.project_id == project_id).all()
-        return [self.get(model.id) for model in models if self.get(model.id) is not None]
+        models = (
+            self.session.query(GenerationTaskModel)
+            .filter(GenerationTaskModel.project_id == project_id)
+            .order_by(GenerationTaskModel.created_at.desc())
+            .all()
+        )
+        return [_to_domain(m) for m in models]
+
+    def list_by_user(self, user_id: str) -> list[GenerationTask]:
+        models = (
+            self.session.query(GenerationTaskModel)
+            .filter(GenerationTaskModel.created_by_user_id == user_id)
+            .order_by(GenerationTaskModel.created_at.desc())
+            .all()
+        )
+        return [_to_domain(m) for m in models]
 
     def update(self, task: GenerationTask) -> GenerationTask:
         model = self.session.query(GenerationTaskModel).filter(GenerationTaskModel.id == task.id).first()
         if model is None:
             raise ValueError(f"GenerationTask {task.id} not found")
+        model.project_id = task.project_id
+        model.asset_library_id = task.asset_library_id
+        model.strategy_id = task.strategy_id
         model.voice_library_id = task.voice_library_id
+        model.edit_plan_id = task.edit_plan_id
+        model.template_id = task.template_id
+        model.asset_ids = task.asset_ids
+        model.title_ids = task.title_ids
+        model.voice_ids = task.voice_ids
         model.status = task.status
         model.progress = task.progress
         model.result_count = task.result_count
diff --git a/packages/adapters/sqlalchemy_impl/models.py b/packages/adapters/sqlalchemy_impl/models.py
index 7bfc5fab2..280e23bc7 100755
--- a/packages/adapters/sqlalchemy_impl/models.py
+++ b/packages/adapters/sqlalchemy_impl/models.py
@@ -139,10 +139,15 @@ class GenerationTaskModel(Base):
     __tablename__ = "generation_tasks"
 
     id = Column(String(32), primary_key=True)
-    project_id = Column(String(32), nullable=False, index=True)
+    project_id = Column(String(32), nullable=False, default="", index=True)
     strategy_id = Column(String(32), nullable=False, default="")
-    asset_library_id = Column(String(32), nullable=False, index=True)
+    asset_library_id = Column(String(32), nullable=False, default="", index=True)
     voice_library_id = Column(String(32), nullable=False, default="")
+    edit_plan_id = Column(String(32), nullable=False, default="")
+    template_id = Column(String(36), nullable=False, default="", index=True)
+    asset_ids = Column(JSON, nullable=False, default=list)
+    title_ids = Column(JSON, nullable=False, default=list)
+    voice_ids = Column(JSON, nullable=False, default=list)
     editing_mode = Column(String(20), nullable=False, default="one_take", index=True)  # 剪辑模式: one_take, pip, voice_over, voice_pip
     status = Column(String(20), nullable=False, default="pending", index=True)
     progress = Column(Float, nullable=False, default=0.0)
@@ -150,7 +155,7 @@ class GenerationTaskModel(Base):
     error_message = Column(Text, nullable=False, default="")
     started_at = Column(DateTime, nullable=True)
     completed_at = Column(DateTime, nullable=True)
-    created_by_user_id = Column(String(32), nullable=False, default="")
+    created_by_user_id = Column(String(32), nullable=False, default="", index=True)
     extra_meta = Column('metadata', JSON, nullable=False, default=dict)
     created_at = Column(DateTime, nullable=False, default=lambda: datetime.now(timezone.utc))
 
diff --git a/packages/application/generation_tasks.py b/packages/application/generation_tasks.py
index 4dab04c7a..09520da0a 100644
--- a/packages/application/generation_tasks.py
+++ b/packages/application/generation_tasks.py
@@ -1,6 +1,6 @@
 from __future__ import annotations
 
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from uuid import uuid4
 
 from packages.domain import GenerationTask
@@ -9,11 +9,15 @@ from packages.ports.generation_task_repository import GenerationTaskRepository
 
 @dataclass(slots=True)
 class CreateGenerationTaskCommand:
-    project_id: str
-    asset_library_id: str
+    project_id: str = ""
+    asset_library_id: str = ""
     strategy_id: str = ""
     voice_library_id: str = ""
     edit_plan_id: str = ""
+    template_id: str = ""
+    asset_ids: list[str] = field(default_factory=list)
+    title_ids: list[str] = field(default_factory=list)
+    voice_ids: list[str] = field(default_factory=list)
     created_by_user_id: str = ""
 
 
@@ -29,6 +33,10 @@ class CreateGenerationTaskUseCase:
             strategy_id=command.strategy_id,
             voice_library_id=command.voice_library_id,
             edit_plan_id=command.edit_plan_id,
+            template_id=command.template_id,
+            asset_ids=command.asset_ids,
+            title_ids=command.title_ids,
+            voice_ids=command.voice_ids,
             status="pending",
             progress=0.0,
             result_count=0,
diff --git a/packages/domain/generation_task.py b/packages/domain/generation_task.py
index f10e8a2d4..a08c75754 100644
--- a/packages/domain/generation_task.py
+++ b/packages/domain/generation_task.py
@@ -21,6 +21,11 @@ class GenerationTask:
     asset_library_id: str
     strategy_id: str = ""
     voice_library_id: str = ""
+    edit_plan_id: str = ""
+    template_id: str = ""
+    asset_ids: list[str] = field(default_factory=list)
+    title_ids: list[str] = field(default_factory=list)
+    voice_ids: list[str] = field(default_factory=list)
     status: GenerationTaskStatus = GenerationTaskStatus.PENDING
     progress: float = 0.0
     result_count: int = 0
@@ -38,17 +43,27 @@ class GenerationTask:
         *,
         strategy_id: str = "",
         voice_library_id: str = "",
+        edit_plan_id: str = "",
+        template_id: str = "",
+        asset_ids: list[str] | None = None,
+        title_ids: list[str] | None = None,
+        voice_ids: list[str] | None = None,
         created_by_user_id: str = "",
     ) -> "GenerationTask":
-        if not project_id.strip():
-            raise ValueError("project_id 不能为空")
-        if not asset_library_id.strip():
-            raise ValueError("asset_library_id 不能为空")
+        if not project_id.strip() and not template_id.strip():
+            raise ValueError("project_id 或 template_id 至少需要提供一个")
+        if not asset_library_id.strip() and not (asset_ids or title_ids or voice_ids):
+            raise ValueError("asset_library_id 或 asset_ids/title_ids/voice_ids 至少需要提供一个")
         return cls(
             id=uuid4().hex,
             project_id=project_id.strip(),
             asset_library_id=asset_library_id.strip(),
             strategy_id=strategy_id.strip(),
             voice_library_id=voice_library_id.strip(),
+            edit_plan_id=edit_plan_id.strip(),
+            template_id=template_id.strip(),
+            asset_ids=list(asset_ids) if asset_ids else [],
+            title_ids=list(title_ids) if title_ids else [],
+            voice_ids=list(voice_ids) if voice_ids else [],
             created_by_user_id=created_by_user_id.strip(),
         )
diff --git a/packages/ports/generation_task_repository.py b/packages/ports/generation_task_repository.py
index ffeac01dd..a68f059f7 100644
--- a/packages/ports/generation_task_repository.py
+++ b/packages/ports/generation_task_repository.py
@@ -12,4 +12,6 @@ class GenerationTaskRepository(Protocol):
 
     def list_by_project(self, project_id: str) -> list[GenerationTask]: ...
 
+    def list_by_user(self, user_id: str) -> list[GenerationTask]: ...
+
     def update(self, task: GenerationTask) -> GenerationTask: ...

From d2097744e49be601f018bbf757a9cee28d2f6012 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 17:19:13 +0800
Subject: [PATCH 04/12] =?UTF-8?q?fix:=20retry=20=E7=AB=AF=E7=82=B9?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BD=92=E5=B1=9E=E6=A0=A1=E9=AA=8C=20(P1=20?=
 =?UTF-8?q?=E5=AE=89=E5=85=A8=E4=BF=AE=E5=A4=8D)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- generation_tasks.py: retry_generation_task 增加 created_by_user_id 校验
- task_center.py: retry_task_by_id 增加 created_by_user_id 校验
- 非任务创建者返回 403 Access denied
---
 apps/api/app/api/routes/generation_tasks.py | 5 ++++-
 apps/api/app/api/routes/task_center.py      | 2 ++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/apps/api/app/api/routes/generation_tasks.py b/apps/api/app/api/routes/generation_tasks.py
index 462b92beb..db2210c31 100644
--- a/apps/api/app/api/routes/generation_tasks.py
+++ b/apps/api/app/api/routes/generation_tasks.py
@@ -216,7 +216,10 @@ def retry_generation_task(
     task = generation_task_repository.get(task_id)
     if task is None:
         raise HTTPException(status_code=404, detail="Generation task not found")
-    if task.status != "failed":
+    if task.created_by_user_id and task.created_by_user_id != authenticated_user.user.id:
+        raise HTTPException(status_code=403, detail="Access denied to this task")
+    status_val = task.status.value if hasattr(task.status, "value") else str(task.status)
+    if status_val != "failed":
         raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
 
     use_case = CreateGenerationTaskUseCase(generation_task_repository)
diff --git a/apps/api/app/api/routes/task_center.py b/apps/api/app/api/routes/task_center.py
index 1d2e9524d..e899c8500 100644
--- a/apps/api/app/api/routes/task_center.py
+++ b/apps/api/app/api/routes/task_center.py
@@ -134,6 +134,8 @@ def retry_task_by_id(
     task = generation_task_repository.get(task_id)
     if task is None:
         raise HTTPException(status_code=404, detail="Generation task not found")
+    if task.created_by_user_id and task.created_by_user_id != authenticated_user.user.id:
+        raise HTTPException(status_code=403, detail="Access denied to this task")
     if _status_value(task.status) != "failed":
         raise HTTPException(status_code=409, detail="Only failed tasks can be retried")
 

From c2a522babfede2c89b2ac784725350ef22864644 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 17:20:35 +0800
Subject: [PATCH 05/12] =?UTF-8?q?fix:=20tasks.ts=20mock=20=E2=86=92=20?=
 =?UTF-8?q?=E7=9C=9F=E5=AE=9E=20API=20=E8=BF=81=E7=A7=BB=EF=BC=8C=E5=AF=B9?=
 =?UTF-8?q?=E6=8E=A5=E5=90=8E=E7=AB=AF=E6=96=B9=E6=A1=88=20A=EF=BC=88PR=20?=
 =?UTF-8?q?#109=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- createGenerationTask: 关闭 mock，调用 POST /generation/tasks
- getUserTasks: 关闭 mock，调用 GET /tasks（用户级列表）
- retryTask: 关闭 mock，调用 POST /tasks/{task_id}/retry
- 删除所有 mock 数据和 USE_MOCK 开关
---
 apps/web/src/api/tasks.ts | 46 ++++++++++++++++++---------------------
 1 file changed, 21 insertions(+), 25 deletions(-)

diff --git a/apps/web/src/api/tasks.ts b/apps/web/src/api/tasks.ts
index 536b859ba..8b3141919 100644
--- a/apps/web/src/api/tasks.ts
+++ b/apps/web/src/api/tasks.ts
@@ -1,9 +1,14 @@
 /**
  * 任务相关 API
- * Phase 1 重构：去掉 projectId，任务直接归属用户
+ * 对接后端方案 A 扩展后的端点（PR #109）
+ * - POST /api/v1/generation/tasks — 创建生成任务（template_id + asset_ids 细粒度模式）
+ * - GET  /api/v1/tasks              — 用户级任务列表（跨 project）
+ * - POST /api/v1/tasks/{task_id}/retry — 简化重试
  */
 import apiClient from './client';
 
+/* ──────────── 类型定义 ──────────── */
+
 /** 任务条目 */
 export interface TaskItem {
   id: string;
@@ -19,18 +24,6 @@ export interface TaskItem {
   updated_at?: string | null;
 }
 
-/** 获取当前用户的所有任务（生成记录） */
-export const getUserTasks = async (): Promise<TaskItem[]> => {
-  const response = await apiClient.get('/tasks');
-  return response.data.items || [];
-};
-
-/** 重试失败的任务 */
-export const retryTask = async (taskId: string): Promise<TaskItem> => {
-  const response = await apiClient.post(`/tasks/${taskId}/retry`);
-  return response.data;
-};
-
 /** 创建生成任务请求参数 */
 export interface CreateGenerationTaskRequest {
   template_id: string;
@@ -46,24 +39,27 @@ export interface CreateGenerationTaskResponse {
   message: string;
 }
 
-// TODO: 后端生成接口适配扁平化架构后切换为 false
-const USE_MOCK = true;
+/* ──────────── API 函数 ──────────── */
 
 /** 创建生成任务（一键生成） */
 export const createGenerationTask = async (
   params: CreateGenerationTaskRequest,
 ): Promise<CreateGenerationTaskResponse> => {
-  if (USE_MOCK) {
-    await new Promise((r) => setTimeout(r, 800));
-    return {
-      task_id: `task_${Date.now()}`,
-      status: 'pending',
-      message: '生成任务已创建',
-    };
-  }
-  const response = await apiClient.post<CreateGenerationTaskResponse>(
+  const { data } = await apiClient.post<CreateGenerationTaskResponse>(
     '/generation/tasks',
     params,
   );
-  return response.data;
+  return data;
+};
+
+/** 获取当前用户的所有任务（跨 project） */
+export const getUserTasks = async (): Promise<TaskItem[]> => {
+  const { data } = await apiClient.get('/tasks');
+  return data.items || [];
+};
+
+/** 重试失败的任务 */
+export const retryTask = async (taskId: string): Promise<TaskItem> => {
+  const { data } = await apiClient.post(`/tasks/${taskId}/retry`);
+  return data;
 };

From 265e49587f4c73a713e6bf5c3635b8bf918c3f2d Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 17:39:47 +0800
Subject: [PATCH 06/12] =?UTF-8?q?fix:=20tasks.ts=20=E7=B1=BB=E5=9E=8B?=
 =?UTF-8?q?=E5=AE=9A=E4=B9=89=E5=AF=B9=E9=BD=90=E5=90=8E=E7=AB=AF=20schema?=
 =?UTF-8?q?=EF=BC=88P2=20=E4=BF=AE=E5=A4=8D=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- CreateGenerationTaskResponse: task_id→id, message→error_message, 补全所有字段
- TaskItem: 补充 project_id, template_id 字段

对齐后端 GenerationTaskResponse 和 UserTaskResponse schema
---
 apps/web/src/api/tasks.ts | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

diff --git a/apps/web/src/api/tasks.ts b/apps/web/src/api/tasks.ts
index 8b3141919..de9ed2e89 100644
--- a/apps/web/src/api/tasks.ts
+++ b/apps/web/src/api/tasks.ts
@@ -9,10 +9,12 @@ import apiClient from './client';
 
 /* ──────────── 类型定义 ──────────── */
 
-/** 任务条目 */
+/** 任务条目（对应用户级 UserTaskResponse） */
 export interface TaskItem {
   id: string;
   task_type: 'ingest' | 'generation' | string;
+  project_id: string;
+  template_id: string;
   status: string;
   progress: number;
   current_step: string;
@@ -32,11 +34,21 @@ export interface CreateGenerationTaskRequest {
   voice_ids: string[];
 }
 
-/** 创建生成任务响应 */
+/** 创建生成任务响应（对齐后端 GenerationTaskResponse） */
 export interface CreateGenerationTaskResponse {
-  task_id: string;
+  id: string;
+  project_id: string;
+  asset_library_id: string;
+  strategy_id: string;
+  voice_library_id: string;
+  template_id: string;
+  asset_ids: string[];
+  title_ids: string[];
+  voice_ids: string[];
   status: string;
-  message: string;
+  progress: number;
+  result_count: number;
+  error_message: string;
 }
 
 /* ──────────── API 函数 ──────────── */

From e723025889de9a835844c0d24ae02fae137c4100 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 18:12:39 +0800
Subject: [PATCH 07/12] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=20projects=2050?=
 =?UTF-8?q?0=20+=20=E5=AE=9E=E7=8E=B0=20dashboard/overview=20=E7=AB=AF?=
 =?UTF-8?q?=E7=82=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Bug 1: GET /api/v1/projects → 500
- _to_project_response() 缺少 owner_user_id 和 shared_users 字段
- 补全 ProjectResponse schema 必填字段

Bug 2: GET /api/v1/dashboard/overview → 404
- 新建 dashboard schema + route
- 添加 count_by_user / count_by_project_ids / sum_storage_by_project_ids 仓储方法
- 注册 /api/v1/dashboard 路由
---
 apps/api/app/api/router.py                    |  6 ++
 apps/api/app/api/routes/dashboard.py          | 84 +++++++++++++++++++
 apps/api/app/api/routes/projects.py           |  2 +
 apps/api/app/schemas/dashboard.py             | 23 +++++
 .../sqlalchemy_impl/asset_repository.py       | 16 ++++
 .../generation_task_repository.py             |  7 ++
 packages/ports/asset_repository.py            |  8 ++
 packages/ports/generation_task_repository.py  |  2 +
 8 files changed, 148 insertions(+)
 create mode 100644 apps/api/app/api/routes/dashboard.py
 create mode 100644 apps/api/app/schemas/dashboard.py

diff --git a/apps/api/app/api/router.py b/apps/api/app/api/router.py
index 712580c93..aa3505b5f 100644
--- a/apps/api/app/api/router.py
+++ b/apps/api/app/api/router.py
@@ -1,3 +1,4 @@
+from app.api.routes.dashboard import router as dashboard_router
 from app.api.routes.asset_diagnosis import router as asset_diagnosis_router
 from app.api.routes.asset_libraries import router as asset_libraries_router
 from app.api.routes.assets import router as assets_router
@@ -110,3 +111,8 @@ api_router.include_router(
     prefix="/templates",
     tags=["Template"],
 )
+api_router.include_router(
+    dashboard_router,
+    prefix="/dashboard",
+    tags=["Dashboard"],
+)
diff --git a/apps/api/app/api/routes/dashboard.py b/apps/api/app/api/routes/dashboard.py
new file mode 100644
index 000000000..fedfa9f4d
--- /dev/null
+++ b/apps/api/app/api/routes/dashboard.py
@@ -0,0 +1,84 @@
+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
+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)
+
+    # 最近任务（取最新 5 条）
+    recent = generation_task_repository.list_by_user(user_id)[: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,
+            )
+        )
+
+    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),
+        recent_tasks=recent_tasks,
+    )
diff --git a/apps/api/app/api/routes/projects.py b/apps/api/app/api/routes/projects.py
index cf352a909..7e8e502b0 100644
--- a/apps/api/app/api/routes/projects.py
+++ b/apps/api/app/api/routes/projects.py
@@ -22,8 +22,10 @@ router = APIRouter()
 def _to_project_response(item) -> ProjectResponse:
     return ProjectResponse(
         id=item.id,
+        owner_user_id=item.owner_user_id,
         name=item.name,
         description=item.description,
+        shared_users=item.shared_users,
     )
 
 
diff --git a/apps/api/app/schemas/dashboard.py b/apps/api/app/schemas/dashboard.py
new file mode 100644
index 000000000..f630b5136
--- /dev/null
+++ b/apps/api/app/schemas/dashboard.py
@@ -0,0 +1,23 @@
+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 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
+    recent_tasks: list[RecentTaskItem] = Field(default_factory=list)
diff --git a/packages/adapters/sqlalchemy_impl/asset_repository.py b/packages/adapters/sqlalchemy_impl/asset_repository.py
index 063edf77e..00dcf0860 100644
--- a/packages/adapters/sqlalchemy_impl/asset_repository.py
+++ b/packages/adapters/sqlalchemy_impl/asset_repository.py
@@ -105,6 +105,22 @@ class SQLAlchemyAssetRepository:
             AssetModel.project_id == project_id
         ).count()
 
+    def count_by_project_ids(self, project_ids: list[str]) -> int:
+        if not project_ids:
+            return 0
+        return self.session.query(AssetModel).filter(
+            AssetModel.project_id.in_(project_ids)
+        ).count()
+
+    def sum_storage_by_project_ids(self, project_ids: list[str]) -> int:
+        if not project_ids:
+            return 0
+        from sqlalchemy import func
+        result = self.session.query(func.coalesce(func.sum(AssetModel.file_size), 0)).filter(
+            AssetModel.project_id.in_(project_ids)
+        ).scalar()
+        return int(result or 0)
+
     def _to_domain(self, model: AssetModel) -> Asset:
         metadata = {}
         if model.classification_result:
diff --git a/packages/adapters/sqlalchemy_impl/generation_task_repository.py b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
index b2c635f77..ae6b1d752 100644
--- a/packages/adapters/sqlalchemy_impl/generation_task_repository.py
+++ b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
@@ -81,6 +81,13 @@ class SQLAlchemyGenerationTaskRepository:
         )
         return [_to_domain(m) for m in models]
 
+    def count_by_user(self, user_id: str) -> int:
+        return (
+            self.session.query(GenerationTaskModel)
+            .filter(GenerationTaskModel.created_by_user_id == user_id)
+            .count()
+        )
+
     def update(self, task: GenerationTask) -> GenerationTask:
         model = self.session.query(GenerationTaskModel).filter(GenerationTaskModel.id == task.id).first()
         if model is None:
diff --git a/packages/ports/asset_repository.py b/packages/ports/asset_repository.py
index 14616936f..e2c0beeed 100644
--- a/packages/ports/asset_repository.py
+++ b/packages/ports/asset_repository.py
@@ -43,3 +43,11 @@ class AssetRepository(ABC):
     @abstractmethod
     async def count_by_project(self, project_id: str) -> int:
         pass
+
+    @abstractmethod
+    def count_by_project_ids(self, project_ids: list[str]) -> int:
+        pass
+
+    @abstractmethod
+    def sum_storage_by_project_ids(self, project_ids: list[str]) -> int:
+        pass
diff --git a/packages/ports/generation_task_repository.py b/packages/ports/generation_task_repository.py
index a68f059f7..b749cb2a9 100644
--- a/packages/ports/generation_task_repository.py
+++ b/packages/ports/generation_task_repository.py
@@ -14,4 +14,6 @@ class GenerationTaskRepository(Protocol):
 
     def list_by_user(self, user_id: str) -> list[GenerationTask]: ...
 
+    def count_by_user(self, user_id: str) -> int: ...
+
     def update(self, task: GenerationTask) -> GenerationTask: ...

From d2578a90930fd71516855f578eb853f4eef3d857 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 18:23:49 +0800
Subject: [PATCH 08/12] =?UTF-8?q?fix:=20PR#112=20P2=20=E5=BB=BA=E8=AE=AE?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

P2-1: list_by_user[:5] → list_recent_by_user(user_id, limit=5) SQL层LIMIT
P2-2: DashboardOverviewResponse 补充 subscription 字段（plan + is_active）

- packages/ports/generation_task_repository.py: 新增 list_recent_by_user
- packages/adapters/sqlalchemy_impl/generation_task_repository.py: 实现
- apps/api/app/schemas/dashboard.py: 新增 SubscriptionInfo + subscription 字段
- apps/api/app/api/routes/dashboard.py: 使用新接口 + 填充 subscription
---
 apps/api/app/api/routes/dashboard.py               | 14 +++++++++++---
 apps/api/app/schemas/dashboard.py                  |  7 +++++++
 .../sqlalchemy_impl/generation_task_repository.py  | 10 ++++++++++
 packages/ports/generation_task_repository.py       |  2 ++
 4 files changed, 30 insertions(+), 3 deletions(-)

diff --git a/apps/api/app/api/routes/dashboard.py b/apps/api/app/api/routes/dashboard.py
index fedfa9f4d..1cdc838cc 100644
--- a/apps/api/app/api/routes/dashboard.py
+++ b/apps/api/app/api/routes/dashboard.py
@@ -8,7 +8,7 @@ from app.dependencies import (
     get_title_library_repository,
     get_voice_library_repository,
 )
-from app.schemas.dashboard import DashboardOverviewResponse, RecentTaskItem
+from app.schemas.dashboard import DashboardOverviewResponse, RecentTaskItem, SubscriptionInfo
 from fastapi import APIRouter, Depends
 
 router = APIRouter()
@@ -57,8 +57,8 @@ def get_dashboard_overview(
     # 生成任务统计
     total_tasks = generation_task_repository.count_by_user(user_id)
 
-    # 最近任务（取最新 5 条）
-    recent = generation_task_repository.list_by_user(user_id)[:5]
+    # 最近任务（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)
@@ -73,6 +73,13 @@ def get_dashboard_overview(
             )
         )
 
+    # 订阅信息
+    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,
@@ -80,5 +87,6 @@ def get_dashboard_overview(
         total_voices=total_voices,
         total_tasks=total_tasks,
         total_products=len(projects),
+        subscription=subscription,
         recent_tasks=recent_tasks,
     )
diff --git a/apps/api/app/schemas/dashboard.py b/apps/api/app/schemas/dashboard.py
index f630b5136..d1732b0a5 100644
--- a/apps/api/app/schemas/dashboard.py
+++ b/apps/api/app/schemas/dashboard.py
@@ -12,6 +12,12 @@ class RecentTaskItem(BaseModel):
     updated_at: datetime | None = None
 
 
+class SubscriptionInfo(BaseModel):
+    """用户订阅信息。"""
+    plan: str = "free"
+    is_active: bool = False
+
+
 class DashboardOverviewResponse(BaseModel):
     """Dashboard 概览数据。"""
     total_assets: int = 0
@@ -20,4 +26,5 @@ class DashboardOverviewResponse(BaseModel):
     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)
diff --git a/packages/adapters/sqlalchemy_impl/generation_task_repository.py b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
index ae6b1d752..f7511e3a8 100644
--- a/packages/adapters/sqlalchemy_impl/generation_task_repository.py
+++ b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
@@ -88,6 +88,16 @@ class SQLAlchemyGenerationTaskRepository:
             .count()
         )
 
+    def list_recent_by_user(self, user_id: str, limit: int = 5) -> list[GenerationTask]:
+        models = (
+            self.session.query(GenerationTaskModel)
+            .filter(GenerationTaskModel.created_by_user_id == user_id)
+            .order_by(GenerationTaskModel.created_at.desc())
+            .limit(limit)
+            .all()
+        )
+        return [_to_domain(m) for m in models]
+
     def update(self, task: GenerationTask) -> GenerationTask:
         model = self.session.query(GenerationTaskModel).filter(GenerationTaskModel.id == task.id).first()
         if model is None:
diff --git a/packages/ports/generation_task_repository.py b/packages/ports/generation_task_repository.py
index b749cb2a9..329d8a39d 100644
--- a/packages/ports/generation_task_repository.py
+++ b/packages/ports/generation_task_repository.py
@@ -16,4 +16,6 @@ class GenerationTaskRepository(Protocol):
 
     def count_by_user(self, user_id: str) -> int: ...
 
+    def list_recent_by_user(self, user_id: str, limit: int = 5) -> list[GenerationTask]: ...
+
     def update(self, task: GenerationTask) -> GenerationTask: ...

From f80a311082e27c26c98b925f7bf5199c38854f47 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 19:28:59 +0800
Subject: [PATCH 09/12] =?UTF-8?q?fix:=20=E6=B8=85=E7=90=86=20entities.py?=
 =?UTF-8?q?=20=E9=87=8D=E5=A4=8D=E5=AE=9E=E4=BD=93=E5=AE=9A=E4=B9=89?=
 =?UTF-8?q?=EF=BC=8C=E7=BB=9F=E4=B8=80=E4=BD=BF=E7=94=A8=E7=8B=AC=E7=AB=8B?=
 =?UTF-8?q?=E5=9F=9F=E6=A8=A1=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

移除 entities.py 中与其他独立域文件重复的 dataclass 定义：
- ClassificationJob → 统一从 classification.py 导入
- GenerationTask → 统一从 generation_task.py 导入
- GeneratedVideo → 统一从 generated_video.py 导入
- EditTemplate → 已废弃，无引用

重复定义导致字段不一致（如 GenerationTask 缺少 template_id/asset_ids，
GeneratedVideo.file_size 类型 float vs int），可能引发运行时错误。

Fixes: #150

Co-Authored-By: 灵应 <437848575@qq.com>
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
---
 packages/domain/entities.py | 65 -------------------------------------
 1 file changed, 65 deletions(-)

diff --git a/packages/domain/entities.py b/packages/domain/entities.py
index db4dff14b..7735c0c96 100644
--- a/packages/domain/entities.py
+++ b/packages/domain/entities.py
@@ -250,71 +250,6 @@ class IngestJob:
         )
 
 
-# 继续读取其他实体定义 - 生成任务、生成视频等
-@dataclass(slots=True)
-class ClassificationJob:
-    id: str
-    project_id: str
-    asset_id: str
-    status: str = "pending"
-    classification: str = ""
-    confidence: float = 0.0
-    error_message: str = ""
-    created_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-    updated_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-
-
-@dataclass(slots=True)
-class GenerationTask:
-    id: str
-    project_id: str
-    asset_library_id: str
-    strategy_id: str = ""
-    voice_library_id: str = ""
-    edit_plan_id: str = ""
-    status: str = "pending"
-    progress: float = 0.0
-    result_count: int = 0
-    error_message: str = ""
-    started_at: datetime | None = None
-    completed_at: datetime | None = None
-    created_by_user_id: str = ""
-    created_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-
-
-@dataclass(slots=True)
-class GeneratedVideo:
-    id: str
-    project_id: str
-    generation_task_id: str
-    name: str
-    file_url: str
-    file_size: float = 0.0
-    duration: float = 0.0
-    thumbnail_url: str | None = None
-    width: int = 0
-    height: int = 0
-    fps: float = 0.0
-    status: str = "completed"
-    review_status: str = "pending_review"
-    generation_params: dict[str, Any] = field(default_factory=dict)
-    generated_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-    created_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-    updated_at: datetime | None = None
-
-
-@dataclass(slots=True)
-class EditTemplate:
-    id: str
-    project_id: str
-    name: str
-    description: str = ""
-    target_duration: float = 30.0
-    clip_count: int = 3
-    is_active: bool = True
-    created_by_user_id: str = ""
-    created_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
-    updated_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
 
 
 

From f9e8d6efdc21ced9b26dd8b6281f476131c3ad53 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 20:10:51 +0800
Subject: [PATCH 10/12] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=203=20=E4=B8=AA?=
 =?UTF-8?q?=20P0=20=E7=AB=AF=E7=82=B9=20500=20=E9=94=99=E8=AF=AF=E7=9A=84?=
 =?UTF-8?q?=E7=9C=9F=E6=AD=A3=E6=A0=B9=E5=9B=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Bug 1 — GET /api/v1/assets → 500:
  asset_repository 所有方法为 async def，但调用方为同步上下文，
  未 await 导致返回 coroutine 对象而非实际数据。
  修复：全部改为 def（同步），与 SQLAlchemy 同步 Session 一致。

Bug 2 — POST /api/v1/generation/tasks → 500:
  GenerationTaskModel 仍定义 edit_plan_id 列，但迁移 011 已从数据库
  删除该列，INSERT 时报 column does not exist。
  修复：从 model、repository、domain entity、application use case、
  所有路由中彻底移除 edit_plan_id 引用。

Bug 3 — GET /api/v1/dashboard/overview → 500:
  generation_task_repository._to_domain() 访问 model.edit_plan_id，
  该列已被迁移 011 删除，触发 AttributeError。
  修复：同上，移除 edit_plan_id 引用。

涉及文件：
  - packages/adapters/sqlalchemy_impl/asset_repository.py (async→sync)
  - packages/ports/asset_repository.py (async→sync 接口)
  - packages/adapters/sqlalchemy_impl/models.py (移除 edit_plan_id 列)
  - packages/adapters/sqlalchemy_impl/generation_task_repository.py
  - packages/domain/generation_task.py
  - packages/application/generation_tasks.py
  - apps/api/app/api/routes/generation_tasks.py
  - apps/api/app/api/routes/task_center.py
---
 apps/api/app/api/routes/generation_tasks.py      | 11 +++++------
 apps/api/app/api/routes/task_center.py           |  2 --
 .../adapters/sqlalchemy_impl/asset_repository.py | 14 +++++++-------
 .../generation_task_repository.py                |  3 ---
 packages/adapters/sqlalchemy_impl/models.py      |  1 -
 packages/application/generation_tasks.py         |  2 --
 packages/domain/generation_task.py               |  3 ---
 packages/ports/asset_repository.py               | 16 ++++++++--------
 8 files changed, 20 insertions(+), 32 deletions(-)

diff --git a/apps/api/app/api/routes/generation_tasks.py b/apps/api/app/api/routes/generation_tasks.py
index db2210c31..b01a869eb 100644
--- a/apps/api/app/api/routes/generation_tasks.py
+++ b/apps/api/app/api/routes/generation_tasks.py
@@ -84,7 +84,7 @@ def _ensure_library_has_ready_video_assets(assets) -> None:
         )
 
 
-async def _resolve_project_and_library(
+def _resolve_project_and_library(
     request: CreateGenerationTaskRequest,
     project_repository: Any,
     asset_library_repository: Any,
@@ -104,7 +104,7 @@ async def _resolve_project_and_library(
     # 模板模式：project_id 未提供时，从 asset_ids 反查所属 project
     if not project_id and request.asset_ids:
         first_asset_id = request.asset_ids[0]
-        asset = await asset_repository.find_by_id(first_asset_id)
+        asset = asset_repository.find_by_id(first_asset_id)
         if asset is not None:
             project_id = asset.project_id
             if not asset_library_id:
@@ -122,7 +122,7 @@ async def _resolve_project_and_library(
 
 
 @router.post("/tasks", response_model=GenerationTaskResponse)
-async def create_generation_task(
+def create_generation_task(
     request: CreateGenerationTaskRequest,
     authenticated_user: AuthenticatedUser = Depends(get_current_user),
     generation_task_repository: Any = Depends(get_generation_task_repository),
@@ -130,7 +130,7 @@ async def create_generation_task(
     asset_library_repository: Any = Depends(get_asset_library_repository),
     asset_repository: Any = Depends(get_asset_repository),
 ) -> GenerationTaskResponse:
-    project_id, asset_library_id = await _resolve_project_and_library(
+    project_id, asset_library_id = _resolve_project_and_library(
         request, project_repository, asset_library_repository, asset_repository, authenticated_user
     )
 
@@ -140,7 +140,7 @@ async def create_generation_task(
         if library is None or (project_id and library.project_id != project_id):
             raise HTTPException(status_code=404, detail=f"AssetLibrary {asset_library_id} not found")
 
-        assets = await asset_repository.find_by_library(asset_library_id)
+        assets = asset_repository.find_by_library(asset_library_id)
         _ensure_library_has_ready_video_assets(assets)
 
     use_case = CreateGenerationTaskUseCase(generation_task_repository)
@@ -229,7 +229,6 @@ def retry_generation_task(
             asset_library_id=task.asset_library_id,
             strategy_id=task.strategy_id,
             voice_library_id=task.voice_library_id,
-            edit_plan_id=task.edit_plan_id,
             template_id=task.template_id,
             asset_ids=task.asset_ids,
             title_ids=task.title_ids,
diff --git a/apps/api/app/api/routes/task_center.py b/apps/api/app/api/routes/task_center.py
index e899c8500..62c97c960 100644
--- a/apps/api/app/api/routes/task_center.py
+++ b/apps/api/app/api/routes/task_center.py
@@ -146,7 +146,6 @@ def retry_task_by_id(
             asset_library_id=task.asset_library_id,
             strategy_id=task.strategy_id,
             voice_library_id=task.voice_library_id,
-            edit_plan_id=task.edit_plan_id,
             template_id=task.template_id,
             asset_ids=task.asset_ids,
             title_ids=task.title_ids,
@@ -229,7 +228,6 @@ def retry_project_task(
                 asset_library_id=task.asset_library_id,
                 strategy_id=task.strategy_id,
                 voice_library_id=task.voice_library_id,
-                edit_plan_id=task.edit_plan_id,
                 template_id=task.template_id,
                 asset_ids=task.asset_ids,
                 title_ids=task.title_ids,
diff --git a/packages/adapters/sqlalchemy_impl/asset_repository.py b/packages/adapters/sqlalchemy_impl/asset_repository.py
index 00dcf0860..b53cecf3b 100644
--- a/packages/adapters/sqlalchemy_impl/asset_repository.py
+++ b/packages/adapters/sqlalchemy_impl/asset_repository.py
@@ -11,7 +11,7 @@ class SQLAlchemyAssetRepository:
     def __init__(self, session: Session):
         self.session = session
 
-    async def find_by_library(
+    def find_by_library(
         self,
         library_id: str,
         skip: int = 0,
@@ -22,7 +22,7 @@ class SQLAlchemyAssetRepository:
         ).offset(skip).limit(limit).all()
         return [self._to_domain(model) for model in models]
 
-    async def find_by_project(
+    def find_by_project(
         self,
         project_id: str,
         skip: int = 0,
@@ -33,7 +33,7 @@ class SQLAlchemyAssetRepository:
         ).offset(skip).limit(limit).all()
         return [self._to_domain(model) for model in models]
 
-    async def find_by_id(self, asset_id: str) -> Asset | None:
+    def find_by_id(self, asset_id: str) -> Asset | None:
         model = self.session.query(AssetModel).filter(AssetModel.id == asset_id).first()
         if model is None:
             return None
@@ -42,7 +42,7 @@ class SQLAlchemyAssetRepository:
     def get(self, asset_id: str) -> Asset | None:
         return self.find_by_id(asset_id)
 
-    async def create(self, asset: Asset) -> Asset:
+    def create(self, asset: Asset) -> Asset:
         now = datetime.now(timezone.utc)
         model = AssetModel(
             id=asset.id,
@@ -70,7 +70,7 @@ class SQLAlchemyAssetRepository:
         self.session.commit()
         return asset
 
-    async def update(self, asset: Asset) -> Asset:
+    def update(self, asset: Asset) -> Asset:
         model = self.session.query(AssetModel).filter(AssetModel.id == asset.id).first()
         if model is None:
             raise ValueError(f"Asset {asset.id} not found")
@@ -92,7 +92,7 @@ class SQLAlchemyAssetRepository:
         self.session.commit()
         return asset
 
-    async def delete(self, asset_id: str) -> bool:
+    def delete(self, asset_id: str) -> bool:
         model = self.session.query(AssetModel).filter(AssetModel.id == asset_id).first()
         if model:
             self.session.delete(model)
@@ -100,7 +100,7 @@ class SQLAlchemyAssetRepository:
             return True
         return False
 
-    async def count_by_project(self, project_id: str) -> int:
+    def count_by_project(self, project_id: str) -> int:
         return self.session.query(AssetModel).filter(
             AssetModel.project_id == project_id
         ).count()
diff --git a/packages/adapters/sqlalchemy_impl/generation_task_repository.py b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
index f7511e3a8..7cbdc0d61 100644
--- a/packages/adapters/sqlalchemy_impl/generation_task_repository.py
+++ b/packages/adapters/sqlalchemy_impl/generation_task_repository.py
@@ -12,7 +12,6 @@ def _to_domain(model: GenerationTaskModel) -> GenerationTask:
         strategy_id=model.strategy_id,
         asset_library_id=model.asset_library_id,
         voice_library_id=model.voice_library_id,
-        edit_plan_id=model.edit_plan_id,
         template_id=model.template_id,
         asset_ids=list(model.asset_ids or []),
         title_ids=list(model.title_ids or []),
@@ -39,7 +38,6 @@ class SQLAlchemyGenerationTaskRepository:
             strategy_id=task.strategy_id,
             asset_library_id=task.asset_library_id,
             voice_library_id=task.voice_library_id,
-            edit_plan_id=task.edit_plan_id,
             template_id=task.template_id,
             asset_ids=task.asset_ids,
             title_ids=task.title_ids,
@@ -106,7 +104,6 @@ class SQLAlchemyGenerationTaskRepository:
         model.asset_library_id = task.asset_library_id
         model.strategy_id = task.strategy_id
         model.voice_library_id = task.voice_library_id
-        model.edit_plan_id = task.edit_plan_id
         model.template_id = task.template_id
         model.asset_ids = task.asset_ids
         model.title_ids = task.title_ids
diff --git a/packages/adapters/sqlalchemy_impl/models.py b/packages/adapters/sqlalchemy_impl/models.py
index 280e23bc7..82ae038f8 100755
--- a/packages/adapters/sqlalchemy_impl/models.py
+++ b/packages/adapters/sqlalchemy_impl/models.py
@@ -143,7 +143,6 @@ class GenerationTaskModel(Base):
     strategy_id = Column(String(32), nullable=False, default="")
     asset_library_id = Column(String(32), nullable=False, default="", index=True)
     voice_library_id = Column(String(32), nullable=False, default="")
-    edit_plan_id = Column(String(32), nullable=False, default="")
     template_id = Column(String(36), nullable=False, default="", index=True)
     asset_ids = Column(JSON, nullable=False, default=list)
     title_ids = Column(JSON, nullable=False, default=list)
diff --git a/packages/application/generation_tasks.py b/packages/application/generation_tasks.py
index 09520da0a..9fb45482a 100644
--- a/packages/application/generation_tasks.py
+++ b/packages/application/generation_tasks.py
@@ -13,7 +13,6 @@ class CreateGenerationTaskCommand:
     asset_library_id: str = ""
     strategy_id: str = ""
     voice_library_id: str = ""
-    edit_plan_id: str = ""
     template_id: str = ""
     asset_ids: list[str] = field(default_factory=list)
     title_ids: list[str] = field(default_factory=list)
@@ -32,7 +31,6 @@ class CreateGenerationTaskUseCase:
             asset_library_id=command.asset_library_id,
             strategy_id=command.strategy_id,
             voice_library_id=command.voice_library_id,
-            edit_plan_id=command.edit_plan_id,
             template_id=command.template_id,
             asset_ids=command.asset_ids,
             title_ids=command.title_ids,
diff --git a/packages/domain/generation_task.py b/packages/domain/generation_task.py
index a08c75754..1809fbe79 100644
--- a/packages/domain/generation_task.py
+++ b/packages/domain/generation_task.py
@@ -21,7 +21,6 @@ class GenerationTask:
     asset_library_id: str
     strategy_id: str = ""
     voice_library_id: str = ""
-    edit_plan_id: str = ""
     template_id: str = ""
     asset_ids: list[str] = field(default_factory=list)
     title_ids: list[str] = field(default_factory=list)
@@ -43,7 +42,6 @@ class GenerationTask:
         *,
         strategy_id: str = "",
         voice_library_id: str = "",
-        edit_plan_id: str = "",
         template_id: str = "",
         asset_ids: list[str] | None = None,
         title_ids: list[str] | None = None,
@@ -60,7 +58,6 @@ class GenerationTask:
             asset_library_id=asset_library_id.strip(),
             strategy_id=strategy_id.strip(),
             voice_library_id=voice_library_id.strip(),
-            edit_plan_id=edit_plan_id.strip(),
             template_id=template_id.strip(),
             asset_ids=list(asset_ids) if asset_ids else [],
             title_ids=list(title_ids) if title_ids else [],
diff --git a/packages/ports/asset_repository.py b/packages/ports/asset_repository.py
index e2c0beeed..409dcb514 100644
--- a/packages/ports/asset_repository.py
+++ b/packages/ports/asset_repository.py
@@ -1,4 +1,4 @@
-"""兼容层：旧素材仓储接口定义，保留给遗留异步适配器使用。"""
+"""素材仓储接口定义。"""
 
 from abc import ABC, abstractmethod
 
@@ -7,15 +7,15 @@ from packages.domain import Asset
 
 class AssetRepository(ABC):
     @abstractmethod
-    async def create(self, asset: Asset) -> Asset:
+    def create(self, asset: Asset) -> Asset:
         pass
 
     @abstractmethod
-    async def find_by_id(self, asset_id: str) -> Asset | None:
+    def find_by_id(self, asset_id: str) -> Asset | None:
         pass
 
     @abstractmethod
-    async def find_by_project(
+    def find_by_project(
         self,
         project_id: str,
         skip: int = 0,
@@ -24,7 +24,7 @@ class AssetRepository(ABC):
         pass
 
     @abstractmethod
-    async def find_by_library(
+    def find_by_library(
         self,
         library_id: str,
         skip: int = 0,
@@ -33,15 +33,15 @@ class AssetRepository(ABC):
         pass
 
     @abstractmethod
-    async def update(self, asset: Asset) -> Asset:
+    def update(self, asset: Asset) -> Asset:
         pass
 
     @abstractmethod
-    async def delete(self, asset_id: str) -> bool:
+    def delete(self, asset_id: str) -> bool:
         pass
 
     @abstractmethod
-    async def count_by_project(self, project_id: str) -> int:
+    def count_by_project(self, project_id: str) -> int:
         pass
 
     @abstractmethod

From 7783f361726198d123a1929ca2dce6c2a0c4aaa1 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 20:23:23 +0800
Subject: [PATCH 11/12] =?UTF-8?q?fix:=20=E4=BB=8E=E8=BF=81=E7=A7=BB=20015?=
 =?UTF-8?q?=20=E4=B8=AD=E7=A7=BB=E9=99=A4=E6=AE=8B=E7=95=99=E7=9A=84=20edi?=
 =?UTF-8?q?t=5Fplan=5Fid=EF=BC=88=E4=BB=A3=E7=A0=81=E5=AE=A1=E8=AE=A1=20P1?=
 =?UTF-8?q?=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

迁移 011 已删除 edit_plan_id 列，迁移 015 不应再 add_column。
同时从 downgrade() 中移除对应的 drop_column。
---
 alembic/versions/015_add_generation_task_extensions.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/alembic/versions/015_add_generation_task_extensions.py b/alembic/versions/015_add_generation_task_extensions.py
index 4af932459..f36c816fa 100644
--- a/alembic/versions/015_add_generation_task_extensions.py
+++ b/alembic/versions/015_add_generation_task_extensions.py
@@ -18,7 +18,6 @@ depends_on = None
 
 
 def upgrade() -> None:
-    op.add_column("generation_tasks", sa.Column("edit_plan_id", sa.String(32), nullable=False, server_default=""))
     op.add_column("generation_tasks", sa.Column("template_id", sa.String(36), nullable=False, server_default=""))
     op.add_column("generation_tasks", sa.Column("asset_ids", mysql.JSON(), nullable=False, server_default="[]"))
     op.add_column("generation_tasks", sa.Column("title_ids", mysql.JSON(), nullable=False, server_default="[]"))
@@ -33,4 +32,3 @@ def downgrade() -> None:
     op.drop_column("generation_tasks", "title_ids")
     op.drop_column("generation_tasks", "asset_ids")
     op.drop_column("generation_tasks", "template_id")
-    op.drop_column("generation_tasks", "edit_plan_id")

From 7b08029e2e7a772544c22d970c6f026b5d1e9e73 Mon Sep 17 00:00:00 2001
From: Audit Bot <bot@xiaoxia.xiaoxiajianji.com>
Date: Mon, 29 Jun 2026 20:47:40 +0800
Subject: [PATCH 12/12] =?UTF-8?q?fix:=20=E5=88=A0=E9=99=A4=20AssetModel=20?=
 =?UTF-8?q?=E5=B9=BD=E7=81=B5=E5=88=97=20storage=5Fkey=EF=BC=88=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93=E4=B8=AD=E4=B8=8D=E5=AD=98=E5=9C=A8=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

根因：AssetModel 定义了 storage_key 列，但 assets 表从未包含此列。
SQLAlchemy 的 session.query(AssetModel) 生成 SELECT 时包含
assets.storage_key，导致 PostgreSQL 报错 column does not exist。

影响端点：
- GET /api/v1/assets?library_id=xxx → 500
- POST /api/v1/generation/tasks → 500（调用 find_by_library 验证素材）
- GET /api/v1/dashboard/overview → 500（调用 count_by_project_ids 统计）

修复：删除 models.py 中 AssetModel 的 storage_key 列定义。
域实体的 storage_key 字段通过 _to_domain() 从 model.file_url 映射，不受影响。
---
 packages/adapters/sqlalchemy_impl/models.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/packages/adapters/sqlalchemy_impl/models.py b/packages/adapters/sqlalchemy_impl/models.py
index 82ae038f8..9a6a487b8 100755
--- a/packages/adapters/sqlalchemy_impl/models.py
+++ b/packages/adapters/sqlalchemy_impl/models.py
@@ -65,8 +65,6 @@ class AssetModel(Base):
     asset_library_id = Column(String(36), nullable=False, index=True)
     name = Column(String(500), nullable=False)
     file_type = Column(String(20), nullable=False, index=True)
-    # storage_key: OSS 对象键（相对路径），用于内部存储和操作
-    storage_key = Column(String(255), nullable=False)
     # file_size: 文件大小（字节），使用 Integer 类型以确保精确性
     file_size = Column(Integer, nullable=False)
     # file_url: 完整可访问的 URL，用于客户端直接访问文件