feat(viral-video): 角色三视图持久化到OSS（替代临时URL） (#2286)

Co-authored-by: xiaoxia <dev@xiaoxiajianji.com>
Co-committed-by: xiaoxia <dev@xiaoxiajianji.com>

alembic/versions/109_add_viral_video_param_guides.py

@@ -0,0 +1,42 @@
+# -*- coding: utf-8 -*-
+"""viral_video_param_guides 表：运营可配置的人设/结构/营销目的/目标客群/语言指导文案（PR3 P2-h）。
+
+Revision ID: 109_add_viral_video_param_guides
+Revises: 108_storyboard_v4_multivoice
+Create Date: 2026-10-12
+
+表用途：
+- 替代 worker 中 ~130 行硬编码 if/elif mapping；
+- 5 类 guide_type: persona / structure / marketing_purpose / target_customer / language；
+- 启动时由 seed_viral_video_param_guides.py 灌入代码默认值，运营可在后台改，30s TTL 缓存自动热加载。
+"""
+
+from alembic import op
+
+revision = "109_add_viral_video_param_guides"
+down_revision = "108_storyboard_v4_multivoice"
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    op.execute("""
+        CREATE TABLE IF NOT EXISTS viral_video_param_guides (
+            id SERIAL PRIMARY KEY,
+            guide_type VARCHAR(32) NOT NULL,
+            guide_key VARCHAR(64) NOT NULL,
+            guide_text TEXT NOT NULL,
+            created_at TIMESTAMP NOT NULL DEFAULT NOW(),
+            updated_at TIMESTAMP NOT NULL DEFAULT NOW(),
+            UNIQUE (guide_type, guide_key)
+        )
+    """)
+    op.execute("""
+        CREATE INDEX IF NOT EXISTS ix_viral_video_param_guides_type_key
+            ON viral_video_param_guides (guide_type, guide_key)
+    """)
+
+
+def downgrade() -> None:
+    op.execute("DROP INDEX IF EXISTS ix_viral_video_param_guides_type_key")
+    op.execute("DROP TABLE IF EXISTS viral_video_param_guides")

apps/api/app/api/routes/viral_video.py

@@ -2,12 +2,10 @@
 
 v1.6 三步分步流水线端点（单次 Seedance 出片版）：
   POST   /api/v1/viral-video/analyze-images          阶段1：创建任务 + 仅做图片/视频分析，暂停在 image_analyzed
-  POST   /api/v1/viral-video/{job_id}/generate-copy  阶段2：用户填完参数后跑意图+文案+分镜+审核，暂停在 copy_generated
-  POST   /api/v1/viral-video/{job_id}/confirm-copy   阶段3：用户确认/编辑文案后跑渲染，直到完成
+  POST   /api/v1/viral-video/{job_id}/generate-copy  阶段2：用户填完参数后文案+分镜一步生成+审核，暂停在 copy_generated
+  POST   /api/v1/viral-video/{job_id}/confirm-copy   阶段3：用户确认/编辑文案后跑渲染（TTS+Seedance+上传），直到完成
 
-旧端点（兼容保留，旧前端/一键生成模式）：
-  POST   /api/v1/viral-video/generate                一键入队，前半段跑到 wait_user_confirm
-  POST   /api/v1/viral-video/{job_id}/confirm-intent 旧的意图确认后继续渲染
+意图分析已并入脚本生成一步完成，不再有独立的 intent_parsing 阶段或 wait_user_confirm 状态。
 
 通用：
   GET    /api/v1/viral-video/{job_id}                查询任务状态（含 image_analysis/copy_result 编导脚本）
@@ -30,8 +28,6 @@ from app.schemas.viral_video import (
     AnalyzeStyleRequest,
     AnalyzeStyleResponse,
     ConfirmCopyRequest,
-    ConfirmIntentRequest,
-    CreateViralVideoRequest,
     CreditsFormulaBreakdown,
     EstimateCreditsRequest,
     EstimateCreditsResponse,
@@ -75,7 +71,7 @@ def _build_copy_result(job) -> dict | None:
     """v1.6: 返回编导分镜脚本 CopyResult 结构（给前端/Seedance 使用）。
 
     - 若 job.copy_result 已持久化（v1.6 worker 生成），直接返回（补 final_copy 兜底）。
-    - 否则从老字段（generated_copy_text=口播, storyboard=分镜列表, intent_result）拼装兼容结构。
+    - 否则从老字段（generated_copy_text=口播, storyboard=分镜列表）拼装兼容结构。
     """
     cr = getattr(job, "copy_result", None)
     if isinstance(cr, dict) and cr:
@@ -89,12 +85,9 @@ def _build_copy_result(job) -> dict | None:
     # 兼容 v1.5 老数据：storyboard 是老格式 [{order,type,description,text,duration,...}]
     copy_text = getattr(job, "generated_copy_text", "") or ""
     sb = getattr(job, "storyboard", None) or []
-    intent = getattr(job, "intent_result", None) or {}
     if not copy_text and not sb:
         return None
     title = ""
-    if isinstance(intent, dict):
-        title = intent.get("suggested_title") or intent.get("intent", "") or ""
     shots = []
     for seg in sb:
         if isinstance(seg, dict):
@@ -155,7 +148,6 @@ def _to_response(job) -> ViralVideoJobResponse:
         language=getattr(job, "language", "zh-CN") or "zh-CN",
         video_ratio=getattr(job, "video_ratio", "9:16") or "9:16",
         video_model=getattr(job, "video_model", "") or "",
-        intent_result=job.intent_result,
         result_video_url=job.result_video_url,
         pre_trusted_images=getattr(job, "pre_trusted_images", None) or None,
         video_resolution=getattr(job, "video_resolution", "720p") or "720p",
@@ -331,57 +323,6 @@ def _settle_viral_video_credits(
 # ── Endpoints ────────────────────────────────────────────────────────────
 
 
-@router.post("/generate", response_model=ViralVideoJobResponse)
-def create_viral_video(
-    request: CreateViralVideoRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    session: Session = Depends(get_db_session),
-) -> ViralVideoJobResponse:
-    """创建爆款视频任务，入队 Celery 编排器。"""
-    from packages.domain.viral_video import ViralVideoJob
-
-    repo = _get_job_repo(session)
-
-    # 创建领域实体
-    job = ViralVideoJob(
-        user_id=authenticated_user.user.id,
-        images=list(request.images),
-        industry=request.industry,
-        target_customer=request.target_customer,
-        persona_id=request.persona_id,
-        viral_structure=request.viral_structure,
-        marketing_purpose=request.marketing_purpose,
-        bgm_preference=request.bgm_preference,
-        duration=request.duration or 15,
-        user_copy_text=request.user_copy_text,
-        fusion_level=request.fusion_level,
-        reference_audio_path=request.reference_audio_path,
-        reference_video_url=request.reference_video_url,
-        style_strength=request.style_strength,
-        style_template_id=request.style_template_id,
-        voice_id=getattr(request, "voice_id", "") or "",
-        voice_source=getattr(request, "voice_source", "") or "",
-        video_ratio=getattr(request, "video_ratio", "9:16") or "9:16",
-        video_model=getattr(request, "video_model", "") or "",
-        video_resolution=getattr(request, "video_resolution", "720p") or "720p",
-        copy_result=None,
-    )
-
-    # 持久化
-    repo.save(job)
-
-    # 入队 Celery 任务
-    try:
-        celery_app.send_task("worker.run_viral_video_pipeline", args=[job.id])
-        logger.info("[爆款视频] 任务已入队: job_id=%s user_id=%s", job.id, job.user_id)
-    except Exception as e:
-        logger.error("[爆款视频] 入队失败: %s", e, exc_info=True)
-        job.mark_failed(f"任务入队失败: {e}")
-        repo.update(job)
-
-    return _to_response(job)
-
-
 @router.post("/analyze-images", response_model=ViralVideoJobResponse)
 def analyze_images(
     request: AnalyzeImagesRequest,
@@ -766,7 +707,6 @@ def retry_viral_video_job(
     job.phase_message = ""
     job.heartbeat_at = None
     # 重试时清空上次产物（参考 resume_from_image_analyzed 逻辑）
-    job.intent_result = None
     job.copy_result = None
     job.storyboard = None
     job.generated_copy_text = ""
@@ -794,43 +734,6 @@ def retry_viral_video_job(
     return _to_response(job)
 
 
-@router.post("/{job_id}/confirm-intent", response_model=ViralVideoJobResponse)
-def confirm_intent(
-    job_id: str,
-    request: ConfirmIntentRequest,
-    authenticated_user: AuthenticatedUser = Depends(get_current_user),
-    session: Session = Depends(get_db_session),
-) -> ViralVideoJobResponse:
-    """用户确认/修改 AI 生成的意图文案，恢复流水线。"""
-    repo = _get_job_repo(session)
-    job = repo.get(job_id)
-    if job is None:
-        raise HTTPException(status_code=404, detail="任务不存在")
-    if job.user_id != authenticated_user.user.id:
-        raise HTTPException(status_code=403, detail="无权操作此任务")
-    if job.status != ViralVideoStatus.WAIT_USER_CONFIRM:
-        raise HTTPException(status_code=409, detail="任务当前不在等待确认状态")
-
-    # 更新文案
-    if request.confirmed_copy:
-        job.user_copy_text = request.confirmed_copy
-
-    # 恢复流水线
-    job.resume_from_confirm()
-    repo.update(job)
-
-    # 从断点恢复 Celery 任务
-    try:
-        celery_app.send_task("worker.resume_viral_video_pipeline", args=[job.id])
-        logger.info("[爆款视频] 意图确认，恢复流水线: job_id=%s", job.id)
-    except Exception as e:
-        logger.error("[爆款视频] 恢复流水线失败: %s", e, exc_info=True)
-        job.mark_failed(f"恢复流水线失败: {e}")
-        repo.update(job)
-
-    return _to_response(job)
-
-
 @router.post("/{job_id}/analyze-style", response_model=AnalyzeStyleResponse)
 def analyze_style(
     job_id: str,
@@ -1097,7 +1000,6 @@ _STATUS_STAGE = {
     "running": "",
     "image_analyzed": "image_analysis",
     "copy_generated": "review",
-    "wait_user_confirm": "intent_parsing",
     "completed": "uploading",
     "failed": "",
     "cancelled": "",
@@ -1108,7 +1010,6 @@ _STATUS_PROGRESS = {
     "running": 5.0,
     "image_analyzed": 15.0,
     "copy_generated": 70.0,
-    "wait_user_confirm": 35.0,
     "completed": 100.0,
     "failed": 0.0,
     "cancelled": 0.0,
@@ -1119,7 +1020,6 @@ _STATUS_MESSAGE = {
     "running": "任务执行中",
     "image_analyzed": "图片分析完成，等待填写营销参数",
     "copy_generated": "文案与分镜已生成，等待确认文案",
-    "wait_user_confirm": "等待用户确认意图文案",
     "completed": "视频生成完成",
     "failed": "任务失败",
     "cancelled": "任务已取消",

apps/api/app/schemas/viral_video.py

@@ -13,7 +13,6 @@ VALID_STYLE_STRENGTHS = ("light", "medium", "strict")
 VALID_STAGES = (
     "image_analysis",
     "video_analysis",
-    "intent_parsing",
     "script_generation",
     "review",
     "tts",
@@ -68,47 +67,6 @@ class CopyResult(BaseModel):
 # -- Request Schemas --
 
 
-class CreateViralVideoRequest(BaseModel):
-    """旧接口：一键创建（保留兼容）。"""
-
-    images: list[str] = Field(..., min_length=1, max_length=20)
-    industry: str = ""
-    target_customer: str = ""
-    persona_id: str = ""
-    viral_structure: str = ""
-    marketing_purpose: str = ""
-    bgm_preference: str = ""
-    duration: int = Field(default=15, ge=5, le=30, description="视频时长（秒），5-30")
-    user_copy_text: str = ""
-    fusion_level: str = "ai_polish"
-    reference_audio_path: str = ""
-    reference_video_url: str = ""
-    style_strength: str = "medium"
-    style_template_id: str = ""
-    voice_id: str = ""
-    voice_source: str = ""
-    language: str = "zh-CN"
-    video_ratio: str = "9:16"
-    video_model: str = ""
-    video_resolution: str = "720p"
-
-    @field_validator("fusion_level")
-    @classmethod
-    def _v_fl(cls, v: str) -> str:
-        if v == "full_ai":
-            return "ai_full"
-        if v not in VALID_FUSION_LEVELS:
-            raise ValueError(f"fusion_level must be one of {VALID_FUSION_LEVELS}")
-        return v
-
-    @field_validator("style_strength")
-    @classmethod
-    def _v_ss(cls, v: str) -> str:
-        if v not in VALID_STYLE_STRENGTHS:
-            raise ValueError(f"style_strength must be one of {VALID_STYLE_STRENGTHS}")
-        return v
-
-
 class AnalyzeImagesRequest(BaseModel):
     """v1.5+ 阶段1：创建任务 + 图片/视频分析。"""
 
@@ -179,13 +137,6 @@ class ConfirmCopyRequest(BaseModel):
     language: str | None = Field(default=None, description="用户选定的语言（confirm时可选）")
 
 
-class ConfirmIntentRequest(BaseModel):
-    """旧 confirm-intent（兼容）。"""
-
-    confirmed_copy: str = ""
-    adjustments: str = ""
-
-
 class AnalyzeStyleRequest(BaseModel):
     reference_video_url: str = Field(..., description="参考视频 URL")
     style_template_id: str = ""
@@ -231,7 +182,6 @@ class ViralVideoJobResponse(BaseModel):
     language: str = "zh-CN"
     video_ratio: str = "9:16"
     video_model: str = ""
-    intent_result: dict | None = None
     result_video_url: str = ""
     pre_trusted_images: list[str] | None = None
     video_resolution: str = "720p"

apps/web/src/api/viral-video/index.ts

@@ -1,6 +1,5 @@
 import apiClient from "@/api/client"
 import type {
-  GenerateViralVideoRequest,
   HistoryResponse,
   StyleTemplate,
   ViralVideoJob,
@@ -13,26 +12,11 @@ import type {
   ViralVideoModelsResponse,
 } from "./types"
 
-/** 创建爆款视频任务 */
-export function generateViralVideo(payload: GenerateViralVideoRequest) {
-  return apiClient.post<ViralVideoJob>("/viral-video/generate", payload).then((r) => r.data)
-}
-
 /** 查询单个任务 */
 export function getViralVideoJob(id: string) {
   return apiClient.get<ViralVideoJob>(`/viral-video/${id}`).then((r) => r.data)
 }
 
-/** 用户确认/修改 AI 理解的意图后继续 */
-export function confirmViralVideoIntent(
-  id: string,
-  payload: { confirmed_copy?: string; edits?: Record<string, unknown> },
-) {
-  return apiClient
-    .post<ViralVideoJob>(`/viral-video/${id}/confirm-intent`, payload)
-    .then((r) => r.data)
-}
-
 /** 重试失败任务 */
 export function retryViralVideo(id: string) {
   return apiClient.post<ViralVideoJob>(`/viral-video/${id}/retry`).then((r) => r.data)

apps/web/src/api/viral-video/types.ts

@@ -21,23 +21,15 @@ export const VALID_RATIOS = ["9:16", "16:9", "1:1"] as const
 export type VideoRatio = (typeof VALID_RATIOS)[number]
 
 export type ViralVideoStatus =
-  | "pending"
-  | "running"
-  | "wait_user_confirm"
-  | "image_analyzed"
-  | "copy_generated"
-  | "completed"
-  | "failed"
-  | "cancelled"
+  "pending" | "running" | "image_analyzed" | "copy_generated" | "completed" | "failed" | "cancelled"
 
 /**
  * v1.6 后端流水线阶段。单次 Seedance 出片版：
- * image_analysis → video_analysis(可选) → intent_parsing → script_generation → review → tts → rendering → uploading
+ * image_analysis → video_analysis(可选) → script_generation(含意图理解) → review → tts → rendering → uploading
  */
 export type ViralVideoStage =
   | "image_analysis"
   | "video_analysis"
-  | "intent_parsing"
   | "script_generation"
   | "review"
   | "tts"
@@ -47,7 +39,7 @@ export type ViralVideoStage =
 /** 图片+视频分析阶段：属于「分析图片」按钮的范围 */
 const IMAGE_ANALYSIS_STAGES = new Set<ViralVideoStage>(["image_analysis", "video_analysis"])
 /** 编导脚本阶段：属于「生成文案」按钮的范围 */
-const COPY_STAGES = new Set<ViralVideoStage>(["intent_parsing", "script_generation", "review"])
+const COPY_STAGES = new Set<ViralVideoStage>(["script_generation", "review"])
 /** 视频生成阶段：属于「开始生成视频」按钮的范围（v1.6: TTS+单次Seedance+上传） */
 const VIDEO_STAGES = new Set<ViralVideoStage>(["tts", "rendering", "uploading"])
 
@@ -161,22 +153,6 @@ export interface StyleTemplate {
   tags?: string[]
 }
 
-export interface IntentResult {
-  intent?: string
-  key_messages?: string[]
-  tone?: string
-  target_emotion?: string
-  call_to_action?: string
-  suggested_title?: string
-  /** v1.5 旧字段兼容 */
-  product?: string
-  selling_points?: string[]
-  target_audience?: string
-  structure?: string
-  duration?: number
-  suggested_copy?: string
-}
-
 export interface ViralVideoJob {
   id: string
   status: ViralVideoStatus
@@ -194,8 +170,6 @@ export interface ViralVideoJob {
   voice_mode?: "global" | "per_video"
   voice_source?: "preset" | "library" | "clone" | "upload" | "my_voice"
   bgm_preference?: string
-  intent_result?: IntentResult
-  intent_text?: string
   /** v1.6 编导分镜脚本（核心产物） */
   copy_result?: CopyResult
   /** 向后兼容：= copy_result.shots */
@@ -225,31 +199,6 @@ export interface ViralVideoJob {
   updated_at?: string
 }
 
-export interface GenerateViralVideoRequest {
-  images: string[]
-  reference_video_url?: string
-  douyin_url?: string
-  style_strength?: StyleStrength
-  style_template_id?: string
-  user_copy_text?: string
-  fusion_level?: FusionLevel
-  voice_id?: string
-  voice_source?: "preset" | "library" | "clone" | "upload" | "my_voice"
-  bgm_preference?: string
-  industry?: string
-  target_customer?: string
-  language?: string
-  persona_id?: string
-  viral_structure?: string
-  marketing_purpose?: string
-  /** 视频时长（5-30秒，默认15） */
-  duration?: number
-  video_model?: string
-  video_ratio?: string
-  /** 三步拆分：step 控制后端执行到哪一步暂停 */
-  step?: "analyze" | "generate_copy" | "generate_video"
-}
-
 export interface HistoryResponse {
   items: ViralVideoJob[]
   total: number

apps/web/src/pages/viral-video/ViralVideoPage.css

@@ -138,27 +138,6 @@
   border-radius: 12px;
   overflow: hidden;
 }
-.vv-section-head {
-  display: flex;
-  align-items: center;
-  justify-content: space-between;
-  padding: 14px 16px;
-  cursor: pointer;
-  user-select: none;
-  border-bottom: 1px solid #f0f0f5;
-  gap: 8px;
-}
-.vv-section.collapsed .vv-section-head {
-  border-bottom: none;
-}
-.vv-section-title {
-  display: flex;
-  align-items: center;
-  gap: 8px;
-  font-size: 15px;
-  font-weight: 600;
-  color: #1f2937;
-}
 .vv-step-badge {
   width: 22px;
   height: 22px;
@@ -310,11 +289,6 @@
 
 /* antd Select dropdown light */
 .vv-page .ant-select-dropdown,
-.vv-select-dropdown {
-  background: #fff !important;
-  border-radius: 8px !important;
-  padding: 4px !important;
-}
 .vv-page .ant-select-item {
   color: #1f2937 !important;
   border-radius: 6px !important;
@@ -655,10 +629,6 @@
   margin-left: auto;
 }
 
-.vv-douyin-input {
-  margin-bottom: 8px;
-}
-
 .vv-ref-video-box {
   margin-top: 8px;
 }
@@ -669,44 +639,6 @@
   max-height: 200px;
 }
 
-.vv-audio-grid {
-  display: grid;
-  grid-template-columns: 1fr 1fr;
-  gap: 8px;
-}
-.vv-audio-cell {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  gap: 6px;
-  padding: 14px 8px;
-  background: #fff;
-  border: 1px solid #e0e0e8;
-  border-radius: 8px;
-  color: #6b7280;
-  font-size: 12px;
-  cursor: pointer;
-  transition: all 0.15s;
-}
-.vv-audio-cell:hover:not(:disabled) {
-  border-color: #7c3aed;
-  color: #7c3aed;
-}
-.vv-audio-cell.selected,
-.vv-audio-cell.active {
-  background: #f5f0ff;
-  border-color: #7c3aed;
-  color: #7c3aed;
-}
-.vv-audio-cell:disabled {
-  opacity: 0.5;
-  cursor: not-allowed;
-}
-.vv-audio-ic {
-  font-size: 20px;
-}
-
 .vv-selected-audio {
   display: flex;
   align-items: center;
@@ -857,12 +789,6 @@
   color: #6b7280;
   flex-shrink: 0;
 }
-.vv-recog-v {
-  color: #1f2937;
-}
-.vv-recog-meta {
-  color: #9ca3af;
-}
 
 /* progress mini */
 .vv-progress-mini-inline {
@@ -1002,11 +928,6 @@
 .vv-form-row {
   margin-bottom: 10px;
 }
-.vv-form-hint {
-  font-size: 12px;
-  color: #9ca3af;
-  line-height: 1.4;
-}
 @media (max-width: 500px) {
   .vv-form-grid {
     grid-template-columns: 1fr;
@@ -1026,29 +947,6 @@
   min-height: 260px;
   overflow: hidden;
 }
-.vv-copy-head {
-  display: flex;
-  align-items: center;
-  gap: 8px;
-  margin-bottom: 12px;
-}
-.vv-copy-title {
-  font-size: 14px;
-  font-weight: 600;
-  color: #1f2937;
-}
-.vv-copy-tag {
-  font-size: 11px;
-  padding: 2px 8px;
-  border-radius: 10px;
-  font-weight: 400;
-}
-.vv-copy-tag-preview {
-  background: #fef3c7;
-  color: #b45309;
-  border: 1px solid #fcd34d;
-  margin-left: auto;
-}
 
 .vv-copy-loading {
   display: flex;
@@ -1080,15 +978,6 @@
   color: #6b7280;
 }
 
-.vv-copy-locked {
-  background: #fafafe;
-  border-color: #d8cafc;
-}
-.vv-copy-sub {
-  font-size: 12px;
-  color: #6b7280;
-}
-
 /* ── Storyboard (linear doc style) ── */
 .vv-storyboard {
   display: flex;
@@ -1789,84 +1678,10 @@
 }
 
 /* intent (keyword chips) - if used */
-.vv-intent {
-  margin-top: 10px;
-}
-.vv-intent-title {
-  font-size: 12px;
-  color: #6b7280;
-  margin-bottom: 6px;
-}
-.vv-intent-row {
-  display: flex;
-  flex-wrap: wrap;
-  gap: 6px;
-}
-.vv-chip {
-  padding: 4px 10px;
-  background: #fff;
-  border: 1px solid #e0e0e8;
-  border-radius: 14px;
-  font-size: 12px;
-  color: #374151;
-  cursor: pointer;
-}
-.vv-chip.picked {
-  background: #f5f0ff;
-  color: #7c3aed;
-  border-color: #7c3aed;
-}
 
 /* misc helpers */
-.vv-k {
-  color: #6b7280;
-}
-.vv-v {
-  color: #1f2937;
-}
-.vv-hint-yellow {
-  background: #fef3c7;
-  border: 1px solid #fcd34d;
-  color: #b45309;
-  font-size: 12px;
-  padding: 8px;
-  border-radius: 6px;
-  line-height: 1.6;
-  margin-top: 8px;
-}
-.vv-hint-gray {
-  color: #9ca3af;
-  font-size: 12px;
-}
 
 /* Segmented tabs (legacy) */
-.vv-seg-tabs {
-  display: inline-flex;
-  background: #f5f6fa;
-  border: 1px solid #e5e7eb;
-  border-radius: 8px;
-  padding: 3px;
-  gap: 2px;
-}
-.vv-seg-tab {
-  padding: 6px 14px;
-  border-radius: 6px;
-  background: #fff;
-  border: none;
-  color: #6b7280;
-  font-size: 12px;
-  cursor: pointer;
-  transition: all 0.15s;
-}
-.vv-seg-tab:hover {
-  color: #374151;
-  background: #fff;
-}
-.vv-seg-tab.active {
-  background: #f3f0ff;
-  color: #7c3aed;
-  font-weight: 500;
-}
 
 /* ── v1.6 我的音色（默认主路径） ── */
 .vv-voice-section {
@@ -2272,3 +2087,94 @@
 .vv-file-list {
   max-height: none;
 }
+
+/* ── P2 新增 utility / 组件类 ── */
+/* 短剧模式提示条（放在 Step2 区域就地显示） */
+.vv-shortdrama-hint {
+  padding: 8px 12px;
+  margin-bottom: 8px;
+  background-color: #fff7e6;
+  border: 1px solid #ffd591;
+  border-radius: 4px;
+  font-size: 13px;
+  color: #d46b08;
+}
+
+/* speaker 标签（主角 / 配角） */
+.vv-sb-speaker-tag {
+  display: inline-block;
+  padding: 2px 8px;
+  margin: 0 8px;
+  border-radius: 4px;
+  font-size: 12px;
+  font-weight: 500;
+  vertical-align: middle;
+}
+.vv-sb-speaker-tag-main {
+  background-color: #e6f7ff;
+  color: #1890ff;
+}
+.vv-sb-speaker-tag-guest {
+  background-color: #fff7e6;
+  color: #fa8c16;
+}
+.vv-sb-speaker-main {
+  color: #1890ff;
+}
+.vv-sb-speaker-guest {
+  color: #fa8c16;
+}
+
+/* 间距 / 排版 helpers */
+.vv-mt-4 {
+  margin-top: 4px;
+}
+.vv-mt-6 {
+  margin-top: 6px;
+}
+.vv-mt-8 {
+  margin-top: 8px;
+}
+.vv-mb-6 {
+  margin-bottom: 6px;
+}
+.vv-mr-6 {
+  margin-right: 6px;
+}
+.vv-fs-12 {
+  font-size: 12px;
+}
+.vv-fs-13 {
+  font-size: 13px;
+}
+.vv-fs-22 {
+  font-size: 22px;
+}
+.vv-p-12 {
+  padding: 12px;
+}
+.vv-text-center {
+  text-align: center;
+}
+.vv-flex-1 {
+  flex: 1;
+}
+.vv-w-170 {
+  width: 170px;
+  flex: 0 0 auto;
+}
+
+.vv-inline-spinner {
+  margin-right: 6px;
+  display: inline-block;
+  vertical-align: middle;
+}
+
+.vv-progress-bar-sm {
+  margin: 6px 0 4px;
+}
+
+.vv-loading-ic {
+  font-size: 36px;
+  color: #7c3aed;
+}

apps/web/src/pages/viral-video/ViralVideoPage.tsx

@@ -38,7 +38,6 @@ function emptyTask(id: string, title: string): TabTask {
     title,
     images: [],
     refVideo: null,
-    douyinInput: "",
     voicePanel: null,
     refAudio: null,
     fusionLevel: "ai_full",
@@ -176,7 +175,6 @@ const ViralVideoPage: React.FC = () => {
     moveImg,
     clearImages,
     handleLocalRefVideo,
-    handleDouyinUrl,
     removeRefVideo,
     handleVoiceFile,
     onCloneSuccess,
@@ -208,8 +206,8 @@ const ViralVideoPage: React.FC = () => {
       try {
         const job = await getViralVideoJob(ev.job_id)
         onPollUpdate(job)
-      } catch (e) {
-        console.warn("[viral-video] WS终态主动拉取失败，等待HTTP轮询兜底", e)
+      } catch {
+        // WS终态拉取失败，等待HTTP轮询兜底
       }
     },
   })
@@ -413,7 +411,6 @@ const ViralVideoPage: React.FC = () => {
           <Step1UploadPanel
             images={task.images}
             refVideo={task.refVideo}
-            douyinInput={task.douyinInput}
             voicePanel={task.voicePanel}
             refAudio={task.refAudio}
             voiceTipsOpen={task.voiceTipsOpen}
@@ -435,11 +432,6 @@ const ViralVideoPage: React.FC = () => {
             onImagesSelected={appendImagesFromFiles}
             onAnalyze={handleAnalyzeImages}
             onPickLocalVideo={() => videoInputRef.current?.click()}
-            onToggleDouyinPanel={() =>
-              setTask({ voicePanel: task.voicePanel === "douyin" ? null : "douyin" })
-            }
-            onDouyinInputChange={(v) => setTask({ douyinInput: v })}
-            onDouyinSubmit={handleDouyinUrl}
             onVideoSelected={handleLocalRefVideo}
             onRemoveRefVideo={removeRefVideo}
             onStyleStrengthChange={(v) => setTask({ styleStrength: v })}
@@ -473,6 +465,7 @@ const ViralVideoPage: React.FC = () => {
             viralStructure={task.viralStructure}
             marketingPurpose={task.marketingPurpose}
             duration={task.duration}
+            copyError={task.copyError}
             onFusionLevelChange={(v) => setTask({ fusionLevel: v })}
             onUserCopyChange={(v) => setTask({ userCopy: v })}
             onParamChange={(patch) => setTask(patch)}
@@ -529,31 +522,9 @@ const ViralVideoPage: React.FC = () => {
               onRetry={handleRetry}
             />
           )}
-
-          {/* REVIEW 合规失败就地显示 */}
-          {task.uiStep === "step2_copy_ready" && task.copyError && (
-            <ErrorRetryBar label="文案审核未通过" message={task.copyError} />
-          )}
         </div>
       </div>
 
-      {/* 短剧提示条 */}
-      {task.marketingPurpose && task.marketingPurpose.includes("短剧") && (
-        <div
-          style={{
-            padding: "8px 12px",
-            marginBottom: 8,
-            backgroundColor: "#fff7e6",
-            border: "1px solid #ffd591",
-            borderRadius: 4,
-            fontSize: 13,
-            color: "#d46b08",
-          }}
-        >
-          💡 短剧模式将自动为对手戏角色分配配角音色
-        </div>
-      )}
-
       <CloneModal
         open={cloneModalOpen}
         onClose={() => setCloneModalOpen(false)}

apps/web/src/pages/viral-video/components/AssetPickerModal.tsx

@@ -152,8 +152,7 @@ export default function AssetPickerModal({
         <div className="vv-modal-body">
           <div className="vv-asset-search">
             <select
-              className="vv-input"
-              style={{ width: 170, flex: "0 0 auto" }}
+              className="vv-input vv-w-170"
               value={libraryId}
               onChange={(e) => setLibraryId(e.target.value)}
               disabled={loadingLibs || libraries.length === 0}
@@ -201,8 +200,8 @@ export default function AssetPickerModal({
               </div>
               {kind === "voice" ? (
                 <>
-                  <div style={{ marginTop: 8, fontSize: 13 }}>暂无配音素材</div>
-                  <div style={{ marginTop: 4, fontSize: 12, color: "#9ca3af" }}>
+                  <div className="vv-mt-8 vv-fs-13">暂无配音素材</div>
+                  <div className="vv-muted vv-mt-4 vv-fs-12">
                     请先在「配音/我的音色」中上传音频文件，或在素材库管理中添加
                   </div>
                 </>

apps/web/src/pages/viral-video/components/PresetVoicePickerModal.tsx

@@ -106,10 +106,10 @@ const CATEGORY_LABELS: Record<string, string> = {
 const GENDER_LABEL = (v: PresetVoice) => {
   if (v.gender_label) return v.gender_label
   const g = v.gender
-  if (g === "female") return "女声·女声"
-  if (g === "male") return "男声·男声"
-  if (g === "child") return "童声·童声"
-  return "性别未标注·其他"
+  if (g === "female") return "女声"
+  if (g === "male") return "男声"
+  if (g === "child") return "童声"
+  return "其他"
 }
 
 const AVATAR_BG = (gender?: string) => {
@@ -303,7 +303,7 @@ const PresetVoicePickerModal: React.FC<Props> = ({
                       {v.avatar_url ? (
                         <img src={v.avatar_url} alt={v.name} />
                       ) : (
-                        <UserOutlined style={{ fontSize: 22 }} />
+                        <UserOutlined className="vv-fs-22" />
                       )}
                     </div>
                     <div className="vv-voice-card-name" title={v.name}>

apps/web/src/pages/viral-video/components/Step1UploadPanel.tsx

@@ -5,9 +5,7 @@ import {
   ArrowUpOutlined,
   ArrowDownOutlined,
   CloseOutlined,
-  LinkOutlined,
 } from "@ant-design/icons"
-import { Input } from "antd"
 import { VVSpinner } from "./VVSpinner"
 import { renderMarkdown } from "../utils/renderMarkdown"
 import { CheckCircleFilled } from "@ant-design/icons"
@@ -21,7 +19,6 @@ import type { AssetItem } from "@/api/assets"
 export interface Step1UploadPanelProps {
   images: UploadedImage[]
   refVideo: RefVideo
-  douyinInput: string
   voicePanel: VoicePanel
   refAudio: RefAudio
   voiceTipsOpen: boolean
@@ -45,9 +42,6 @@ export interface Step1UploadPanelProps {
   onAnalyze: () => void
   // callbacks - ref video
   onPickLocalVideo: () => void
-  onToggleDouyinPanel: () => void
-  onDouyinInputChange: (v: string) => void
-  onDouyinSubmit: () => void
   onVideoSelected: (file: File) => void
   onRemoveRefVideo: () => void
   onStyleStrengthChange: (v: StyleStrength) => void
@@ -94,10 +88,7 @@ function RecognitionBlock({
     return (
       <div className="vv-recog">
         <div className="vv-recog-title">
-          <VVSpinner
-            color="#7c3aed"
-            style={{ marginRight: 6, display: "inline-block", verticalAlign: "middle" }}
-          />
+          <VVSpinner color="#7c3aed" className="vv-inline-spinner" />
           识别描述汇览
         </div>
         <div className="vv-muted">AI 正在识别画面…</div>
@@ -240,9 +231,6 @@ export const Step1UploadPanel: React.FC<Step1UploadPanelProps> = (p) => {
               <button className="vv-action-btn" onClick={p.onPickLocalVideo}>
                 <UploadOutlined /> 本地上传视频
               </button>
-              <button className="vv-action-btn" onClick={p.onToggleDouyinPanel}>
-                <LinkOutlined /> 抖音链接识别
-              </button>
             </div>
             <input
               ref={p.videoInputRef}
@@ -254,24 +242,6 @@ export const Step1UploadPanel: React.FC<Step1UploadPanelProps> = (p) => {
                 e.target.value = ""
               }}
             />
-            {p.voicePanel === "douyin" && !p.refVideo && (
-              <div className="vv-douyin-input">
-                <Input
-                  placeholder="粘贴抖音分享链接，例：https://v.douyin.com/xxxxx/"
-                  value={p.douyinInput}
-                  onChange={(e) => p.onDouyinInputChange(e.target.value)}
-                  onPressEnter={p.onDouyinSubmit}
-                  suffix={
-                    <button className="vv-link-btn" onClick={p.onDouyinSubmit}>
-                      识别
-                    </button>
-                  }
-                />
-                <div className="vv-muted" style={{ marginTop: 4, fontSize: 11 }}>
-                  粘贴后自动解析下载参考视频（敬请期待）
-                </div>
-              </div>
-            )}
             {p.refVideo && (
               <div className="vv-ref-video-box">
                 <video
@@ -279,10 +249,10 @@ export const Step1UploadPanel: React.FC<Step1UploadPanelProps> = (p) => {
                   controls
                   className="vv-ref-video-el"
                 />
-                <div className="vv-file-info" style={{ marginTop: 6 }}>
+                <div className="vv-file-info vv-mt-6">
                   <div className="vv-file-name">{p.refVideo.name}</div>
                   {p.refVideo.uploading && (
-                    <div className="vv-progress-bar" style={{ margin: "6px 0 4px" }}>
+                    <div className="vv-progress-bar vv-progress-bar-sm">
                       <div className="vv-progress-fill" style={{ width: `${p.refVideo.pct}%` }} />
                     </div>
                   )}
@@ -292,9 +262,7 @@ export const Step1UploadPanel: React.FC<Step1UploadPanelProps> = (p) => {
                 </button>
                 {p.refVideo.ossUrl && (
                   <div className="vv-mt-8">
-                    <div className="vv-label" style={{ marginBottom: 6 }}>
-                      风格借鉴强度
-                    </div>
+                    <div className="vv-label vv-mb-6">风格借鉴强度</div>
                     <div className="vv-pill-row">
                       {STYLE_STRENGTHS.map((s) => (
                         <button

apps/web/src/pages/viral-video/components/Step2CopyPanel.tsx

@@ -4,6 +4,7 @@ import { Select } from "antd"
 import { FUSION_LEVELS } from "@/api/viral-video/types"
 import type { FusionLevel } from "@/api/viral-video/types"
 import { VVSpinner } from "./VVSpinner"
+import { ErrorRetryBar } from "./ErrorRetryBar"
 import { StoryboardCard } from "./StoryboardCard"
 import type { SbDoc, StoryboardEditor } from "../hooks/useStoryboardEditor"
 import type { UploadedImage, UIStep, ViralVideoJob } from "../types"
@@ -52,6 +53,7 @@ export interface Step2CopyPanelProps {
   images: UploadedImage[]
   locked: boolean
   job: ViralVideoJob | null
+  copyError?: string
 }
 
 export const Step2CopyPanel: React.FC<Step2CopyPanelProps> = (p) => {
@@ -181,6 +183,16 @@ export const Step2CopyPanel: React.FC<Step2CopyPanelProps> = (p) => {
             </div>
           </div>
 
+          {/* 短剧模式提示 */}
+          {p.marketingPurpose && p.marketingPurpose.includes("短剧") && (
+            <div className="vv-shortdrama-hint">
+              💡 短剧模式已选中，对手戏角色将自动分配配角音色
+            </div>
+          )}
+
+          {/* 文案审核错误（持久显示） */}
+          {p.copyError && <ErrorRetryBar label="文案审核未通过" message={p.copyError} />}
+
           {/* 分镜结果区 / 流式预览 */}
           <StoryboardCard
             uiStep={p.uiStep}

apps/web/src/pages/viral-video/components/Step3VideoPanel.tsx

@@ -154,7 +154,7 @@ export const Step3VideoPanel: React.FC<Step3VideoPanelProps> = (p) => {
             ) : isGenerating ? (
               <div className="vv-preview-placeholder">
                 <div className="ph-icon">
-                  <LoadingOutlined style={{ fontSize: 36, color: "#7c3aed" }} />
+                  <LoadingOutlined className="vv-loading-ic" />
                 </div>
                 <div className="ph-txt">
                   AI 正在生成视频中…
@@ -162,9 +162,7 @@ export const Step3VideoPanel: React.FC<Step3VideoPanelProps> = (p) => {
                   预计 1-3 分钟，请勿关闭页面
                 </div>
                 {getJobPhaseMessage(p.job) && (
-                  <div className="vv-muted" style={{ marginTop: 6, fontSize: 12 }}>
-                    {getJobPhaseMessage(p.job)}
-                  </div>
+                  <div className="vv-muted vv-mt-6 vv-fs-12">{getJobPhaseMessage(p.job)}</div>
                 )}
               </div>
             ) : (

apps/web/src/pages/viral-video/components/StoryboardCard.tsx

@@ -39,7 +39,7 @@ function renderVoiceoverWithSpeakers(text: string) {
     const isMain = MAIN_SPEAKERS.includes(speaker)
     elements.push(
       <span key={i}>
-        <strong style={{ color: isMain ? "#1890ff" : "#fa8c16" }}>{speaker}</strong>
+        <strong className={isMain ? "vv-sb-speaker-main" : "vv-sb-speaker-guest"}>{speaker}</strong>
         <span>{segText}</span>
       </span>,
     )
@@ -111,7 +111,7 @@ export const StoryboardCard: React.FC<StoryboardCardProps> = ({
     if (uiStep === "step2_copy_ready" || uiStep === "step3_generating" || uiStep === "step3_done") {
       return (
         <div className="vv-copy-box vv-copy-loading">
-          <span style={{ color: "#9ca3af" }}>暂无分镜数据</span>
+          <span className="vv-muted">暂无分镜数据</span>
         </div>
       )
     }

apps/web/src/pages/viral-video/components/StoryboardShotItem.tsx

@@ -51,18 +51,7 @@ export const StoryboardShotItem: React.FC<StoryboardShotItemProps> = ({
       {/* 说话人标签（有 speaker 时展示，纯展示不加编辑） */}
       {shot.speaker && (
         <span
-          className="vv-sb-speaker-tag"
-          style={{
-            display: "inline-block",
-            padding: "2px 8px",
-            marginRight: 8,
-            marginLeft: 8,
-            borderRadius: 4,
-            fontSize: 12,
-            fontWeight: 500,
-            backgroundColor: isMainSpeaker ? "#e6f7ff" : "#fff7e6",
-            color: isMainSpeaker ? "#1890ff" : "#fa8c16",
-          }}
+          className={`vv-sb-speaker-tag ${isMainSpeaker ? "vv-sb-speaker-tag-main" : "vv-sb-speaker-tag-guest"}`}
         >
           {shot.speaker}
         </span>

apps/web/src/pages/viral-video/components/VoicePickerSection.tsx

@@ -143,8 +143,8 @@ export const VoicePickerSection: React.FC<VoicePickerSectionProps> = (p) => {
       />
       {p.refAudio && (
         <div className="vv-selected-audio">
-          <span style={{ marginRight: 6 }}>🔊</span>
-          <span style={{ flex: 1 }}>
+          <span className="vv-mr-6">🔊</span>
+          <span className="vv-flex-1">
             已选：
             {p.refAudio.source === "my_voice"
               ? `我的音色 · ${p.refAudio.name}`
@@ -168,9 +168,7 @@ export const VoicePickerSection: React.FC<VoicePickerSectionProps> = (p) => {
             </button>
           </div>
           {p.voiceAssets.length === 0 ? (
-            <div className="vv-muted" style={{ padding: 12, textAlign: "center" }}>
-              暂无已上传的配音文件
-            </div>
+            <div className="vv-muted vv-text-center vv-p-12">暂无已上传的配音文件</div>
           ) : (
             <div className="vv-voice-list">
               {p.voiceAssets.map((v) => (

apps/web/src/pages/viral-video/hooks/useViralVideoHandlers.ts

@@ -58,7 +58,6 @@ function emptyTask(id: string, title: string): TabTask {
     title,
     images: [],
     refVideo: null,
-    douyinInput: "",
     voicePanel: null,
     refAudio: null,
     fusionLevel: "ai_full",

apps/web/src/pages/viral-video/hooks/useViralVideoMedia.ts

@@ -27,7 +27,6 @@ export interface MediaActions {
   removeImg: (localId: string) => void
   moveImg: (idx: number, dir: -1 | 1) => void
   handleLocalRefVideo: (file: File) => void
-  handleDouyinUrl: () => void
   removeRefVideo: () => void
   handleVoiceFile: (file: File) => void
   onCloneSuccess: (v: VoiceClone | { id?: string; name?: string; voice_id?: string | null }) => void
@@ -221,20 +220,6 @@ export function useViralVideoMedia(opts: UseViralVideoMediaOptions): MediaAction
     [setTask, uploadFile],
   )
 
-  const handleDouyinUrl = () => {
-    const url = task.douyinInput.trim()
-    if (!url) {
-      message.warning("请粘贴抖音分享链接")
-      return
-    }
-    if (!/(douyin\.com|iesdouyin\.com)/.test(url)) {
-      message.warning("请输入有效的抖音链接")
-      return
-    }
-    message.info("抖音链接识别功能即将上线，当前请使用本地上传参考视频")
-    setTask({ douyinInput: "" })
-  }
-
   const removeRefVideo = () => {
     setTask((t) => {
       if (t.refVideo?.url.startsWith("blob:")) URL.revokeObjectURL(t.refVideo.url)
@@ -350,7 +335,6 @@ export function useViralVideoMedia(opts: UseViralVideoMediaOptions): MediaAction
     removeImg,
     moveImg,
     handleLocalRefVideo,
-    handleDouyinUrl,
     removeRefVideo,
     handleVoiceFile,
     onCloneSuccess,

apps/web/src/pages/viral-video/hooks/useViralVideoPolling.ts

@@ -61,7 +61,7 @@ export function useViralVideoPolling(
         failCountRef.current += 1
         if (stoppedRef.current) return
         if (failCountRef.current >= 20) {
-          console.warn("[viral-video] 轮询连续失败 20 次，停止轮询，请刷新页面重试")
+          // 轮询连续失败 20 次，停止轮询
           stop()
           return
         }

apps/web/src/pages/viral-video/types.ts

@@ -33,14 +33,13 @@ export type UploadedImage = {
 }
 
 export type RefVideo = {
-  source: "local" | "douyin"
+  source: "local"
   url: string
   name: string
   uploading: boolean
   pct: number
   ossUrl?: string
   file?: File
-  douyinUrl?: string
 } | null
 
 export type RefAudio = {
@@ -52,7 +51,7 @@ export type RefAudio = {
   ttsVoiceId?: string
 } | null
 
-export type VoicePanel = "my_voices" | "preset" | "upload" | "library" | "record" | "douyin" | null
+export type VoicePanel = "my_voices" | "preset" | "upload" | "library" | "record" | null
 
 // ── 分镜脚本数据模型（新后端 copy_result 结构） ──
 export interface StoryboardShot {
@@ -82,7 +81,6 @@ export type TabTask = {
   // 素材
   images: UploadedImage[]
   refVideo: RefVideo
-  douyinInput: string
   voicePanel: VoicePanel
   refAudio: RefAudio
   // STEP2 参数

apps/web/src/pages/viral-video/utils/applyPollUpdate.ts

@@ -42,9 +42,6 @@ export function applyPollUpdate(t: TabTask, job: ViralVideoJob): TabTask {
       nextStep = "step2_copy_ready"
       copyError = undefined
       break
-    case "wait_user_confirm":
-      nextStep = t.uiStep === "step3_generating" ? t.uiStep : "step2_copy_ready"
-      break
     case "running":
       if (isVideoStage(stage)) nextStep = "step3_generating"
       else if (isCopyStage(stage)) nextStep = "step2_generating"

apps/web/src/test/api/viral-video.test.ts

@@ -1,8 +1,6 @@
 import { describe, expect, it, vi, beforeEach, afterEach } from "vitest"
 import {
-  generateViralVideo,
   getViralVideoJob,
-  confirmViralVideoIntent,
   retryViralVideo,
   getViralVideoHistory,
   getViralStyleTemplates,
@@ -76,10 +74,10 @@ describe("viral-video constants & stage helpers", () => {
   })
 
   it("isCopyStage", () => {
-    expect(isCopyStage("intent_parsing")).toBe(true)
     expect(isCopyStage("script_generation")).toBe(true)
     expect(isCopyStage("review")).toBe(true)
     expect(isCopyStage("tts")).toBe(false)
+    expect(isCopyStage("image_analysis")).toBe(false)
   })
 
   it("isAnalysisStage is union", () => {
@@ -101,14 +99,6 @@ describe("viral-video API wrappers", () => {
     mockPost.mockResolvedValue({ data: {} })
   })
 
-  it("generateViralVideo", async () => {
-    mockPost.mockResolvedValue({ data: { id: "j1" } })
-    const r = generateViralVideo({ images: ["img1"] } as never)
-    vi.runAllTimersAsync()
-    expect(await r).toEqual({ id: "j1" })
-    expect(mockPost).toHaveBeenCalledWith("/viral-video/generate", { images: ["img1"] })
-  })
-
   it("getViralVideoJob", async () => {
     mockGet.mockResolvedValue({ data: { id: "j2" } })
     const r = getViralVideoJob("j2")
@@ -117,16 +107,6 @@ describe("viral-video API wrappers", () => {
     expect(mockGet).toHaveBeenCalledWith("/viral-video/j2")
   })
 
-  it("confirmViralVideoIntent", async () => {
-    mockPost.mockResolvedValue({ data: { id: "j3" } })
-    const r = confirmViralVideoIntent("j3", { confirmed_copy: "hi" })
-    vi.runAllTimersAsync()
-    await r
-    expect(mockPost).toHaveBeenCalledWith("/viral-video/j3/confirm-intent", {
-      confirmed_copy: "hi",
-    })
-  })
-
   it("retryViralVideo", async () => {
     mockPost.mockResolvedValue({ data: { id: "j4" } })
     await retryViralVideo("j4")

apps/worker/worker_app/tasks/viral_video.py

@@ -5,14 +5,16 @@ V2 图片分析（10-05）：火山OCR专用API + doubao-lite强约束JSON并行
 流水线步骤：
   1. _step_image_analysis   图片分析（V2: OCR+qwen3.8-flash并行 + qwen3.7-plus兜底）
   1.5 _step_video_analysis  参考视频风格分析（可选）
-  2. _step_intent_parsing   用户文案意图解析
-  3. _step_script_generation 编导分镜脚本生成（融合原 copy_fusion+storyboard+review，输出 copy_result 结构 + voiceover_script）
-  4. _step_review           合规审核（本地规则 + LLM review，LLM 不可用降级放行，不再自动重写）
-  5. _step_tts              CosyVoice 整段配音（voiceover_script → 单个 mp3 → 上传 OSS 拿公网 URL）
-  6. _step_render           单次 Seedance 生成（prompt=完整编导脚本，reference_audios=[TTS URL]，reference_images=产品图，generate_audio=true）
-  7. _step_upload           OSS 上传单个视频文件 + 通知 + 扣点
+
+  2. _step_script_generation   文案+分镜一步生成（VLM+LLM一次出文案+分镜，已包含意图理解、storyboard+review，输出 copy_result 结构 + voiceover_script）
+  3. _step_review           合规审核（本地规则 + LLM review，LLM 不可用降级放行，不再自动重写）
+  4. _step_tts              CosyVoice 整段配音（voiceover_script → 单个 mp3 → 上传 OSS 拿公网 URL）
+  5. _step_render           单次 Seedance 生成（prompt=完整编导脚本，reference_audios=[TTS URL]，reference_images=产品图，generate_audio=true）
+  6. _step_upload           OSS 上传单个视频文件 + 通知 + 扣点
 
 删除/不再使用：
+- 意图分析独立步骤 _step_intent_parsing（已并入脚本生成，不再单独调 LLM、不再停在 WAIT_USER_CONFIRM）
+- 旧一键流水线 run_viral_video_pipeline / resume_viral_video_pipeline（前端已走三步分离接口）
 - 分镜拆分多段生成（storyboard 不再单独驱动分段生成，仅作为 copy_result.shots 存到 DB 给前端/日志参考）
 - ffmpeg concat 拼接（concat_engine 保留但 viral video 主流程不再调用）
 - placeholder 占位视频、分段重试降级
@@ -47,12 +49,19 @@ from packages.application.viral_video.constants import (
     get_duration_spec,
 )
 from packages.application.viral_video.constants import get_expected_shot_count as _const_expected_shot_count
+from packages.application.viral_video.param_guides import get_param_guide
 from packages.application.viral_video.prompts import COMPLIANCE_BLACKLIST
 from packages.domain.viral_video import (
     STAGE_LABELS,
+    ViralVideoComplianceError,
+    ViralVideoError,
     ViralVideoJob,
+    ViralVideoLLMError,
+    ViralVideoResourceError,
     ViralVideoStage,
     ViralVideoStatus,
+    ViralVideoTimeoutError,
+    ViralVideoUpstreamError,
 )
 
 logger = logging.getLogger(__name__)
@@ -516,6 +525,49 @@ def with_viral_job(
                 return func(job, repo, session, *rest_args, **kwargs)
             except Retry:
                 raise
+            except ViralVideoError as e:
+                # PR3 P2(b): 业务异常走友好 message，不打堆栈
+                logger.warning(
+                    "[viral] task %s business_error code=%s user_msg=%s detail=%s",
+                    func.__name__,
+                    e.code,
+                    e.user_message,
+                    e.detail,
+                )
+                err_user_msg = e.user_message
+                err_stage = (
+                    getattr(e, "stage", "") if isinstance(e, (ViralVideoTimeoutError, ViralVideoLLMError)) else ""
+                )
+                # refund_on_failure: 业务异常同样按阶段3退款
+                if refund_on_failure and job is None:
+                    try:
+                        if session is not None:
+                            _repo_safe = SQLAlchemyViralVideoJobRepository(session)
+                            _job_safe = _repo_safe.get(job_id)
+                            if _job_safe is not None and float(getattr(_job_safe, "credits_prepaid", 0) or 0) > 0:
+                                _try_refund_viral_video(_job_safe)
+                                _repo_safe.update(_job_safe)
+                    except Exception:
+                        logger.exception("[viral] task %s 兜底退款异常", func.__name__)
+                elif refund_on_failure and job is not None:
+                    try:
+                        if float(getattr(job, "credits_prepaid", 0) or 0) > 0:
+                            _try_refund_viral_video(job)
+                    except Exception:
+                        logger.exception("[viral] task %s 兜底退款异常", func.__name__)
+                _err_job = job
+                try:
+                    if job is None and session is not None:
+                        _repo_tmp = SQLAlchemyViralVideoJobRepository(session)
+                        _err_job = _repo_tmp.get(job_id)
+                    if _err_job is not None and getattr(_err_job, "current_stage", None) and not err_stage:
+                        err_stage = _err_job.current_stage
+                except Exception:
+                    pass
+                _mark_failed_and_notify(
+                    job_id, session, None, _err_job if _err_job is not None else None, err_user_msg, err_stage
+                )
+                return {"ok": False, "job_id": job_id, "error": err_user_msg, "code": e.code}
             except Exception as e:
                 logger.exception("[viral] task %s failed: %s", func.__name__, e)
                 # refund_on_failure: 阶段3（render）失败兜底退款
@@ -749,22 +801,16 @@ def _step_video_analysis(job: ViralVideoJob) -> dict | None:
         style_guide = analyze_video_style(video_url)
         return style_guide if isinstance(style_guide, dict) else None
     except ImportError as e:
-        logger.info("[爆款视频] video_analyzer 模块未就绪(%s)，使用占位风格分析", e)
-        return {
-            "cut_speed": "medium",
-            "transition": "cross_dissolve",
-            "energy": "medium",
-            "color_grade": "neutral",
-            "narrative": False,
-            "source": "placeholder",
-        }
+        logger.info("[爆款视频] video_analyzer 模块未就绪(%s)，跳过参考视频风格分析", e)
+        return None
     except Exception as e:
         logger.error("[爆款视频] 视频风格分析失败: %s", e)
         return {"error": str(e), "source": "failed"}
 
 
-# persona_id -> 文案风格指导（仅用于给脚本生成 LLM 的风格提示）
-_PERSONA_STYLE_GUIDE: dict[str, str] = {
+# ── PR3 P2(h): 参数指导优先查 DB（viral_video_param_guides），代码默认值兜底 ──
+# 代码默认值保证 DB 未 seed / DB 异常时不阻断流程
+_DEFAULT_PERSONA_HINTS: dict[str, str] = {
     "宝妈": "温柔贴心，多从带娃和家庭实用角度分享，语气亲切有共鸣",
     "店主": "热情实在，像当面招呼客人，突出靠谱和实在优惠",
     "专业顾问": "专业可信，讲清原理和效果，用事实打消顾虑",
@@ -779,19 +825,7 @@ _PERSONA_STYLE_GUIDE: dict[str, str] = {
     "育儿师": "科学育儿角度，温柔坚定，给具体可操作的建议",
 }
 
-
-def _persona_style_hint(persona_id: str) -> str:
-    """根据 persona_id 查文案风格指导；未命中/空值返回通用提示。"""
-    pid = (persona_id or "").strip()
-    if pid in _PERSONA_STYLE_GUIDE:
-        return f"【人设风格：{pid}】{_PERSONA_STYLE_GUIDE[pid]}"
-    if pid:
-        # 前端传了自由值，照直提示，不阻塞
-        return f"【人设风格：{pid}】按该人设的口吻、话术习惯组织口播和出镜动作"
-    return "【人设风格：未指定】亲切自然、像朋友分享好物"
-
-
-_VIRAL_STRUCTURE_GUIDE: dict[str, str] = {
+_DEFAULT_VIRAL_STRUCTURE_HINTS: dict[str, str] = {
     "反差破局+亮明观点+还原现状": "开头3秒用反差/痛点钩子抓注意力，中段亮出核心卖点或观点，结尾还原真实到店/使用场景引导行动",
     "痛点切入+方案展示+效果对比": "开头直击用户痛点场景，中间展示产品/服务解决方案，结尾用前后对比强化效果",
     "故事引入+产品种草+行动引导": "用一个真实小故事/案例引入，自然过渡到产品种草，结尾明确引导用户下一步行动",
@@ -800,81 +834,92 @@ _VIRAL_STRUCTURE_GUIDE: dict[str, str] = {
 }
 
 
+def _db_guide(guide_type: str, guide_key: str) -> str | None:
+    """读 DB 指导文本；DB 异常返回 None（不抛异常、不打刷屏日志）。"""
+    try:
+        return get_param_guide(guide_type, guide_key)
+    except Exception:  # noqa: BLE001
+        return None
+
+
+def _persona_style_hint(persona_id: str) -> str:
+    """根据 persona_id 查文案风格指导；未命中/空值返回通用提示。"""
+    pid = (persona_id or "").strip()
+    if not pid:
+        return "【人设风格：未指定】亲切自然、像朋友分享好物"
+    text = _db_guide("persona", pid) or _DEFAULT_PERSONA_HINTS.get(pid)
+    if text:
+        return f"【人设风格：{pid}】{text}"
+    return f"【人设风格：{pid}】按该人设的口吻、话术习惯组织口播和出镜动作"
+
+
 def _viral_structure_hint(structure: str) -> str:
     """根据 viral_structure 映射具体写作指导；未命中返回通用提示。"""
     s = (structure or "").strip()
-    if s in _VIRAL_STRUCTURE_GUIDE:
-        return f"【爆款结构：{s}】{_VIRAL_STRUCTURE_GUIDE[s]}"
-    if s:
-        return f"【爆款结构：{s}】按该结构编排内容节奏和叙事逻辑"
-    return "【爆款结构：未指定】自由组织，保证开头有钩子、中段有卖点、结尾有行动引导"
+    if not s:
+        return "【爆款结构：未指定】自由组织，保证开头有钩子、中段有卖点、结尾有行动引导"
+    text = _db_guide("structure", s) or _DEFAULT_VIRAL_STRUCTURE_HINTS.get(s)
+    if text:
+        return f"【爆款结构：{s}】{text}"
+    return f"【爆款结构：{s}】按该结构编排内容节奏和叙事逻辑"
 
 
 def _marketing_purpose_hint(mp: str) -> str:
-    """根据营销目的提供创作指导 hint。
-
-    覆盖前端 20 个 PURPOSES，分 4 类指导：
-    - 短剧类：多角色对话，格式"角色：台词"，禁止旁白，角色间镜头切换
-    - 口播类：第一人称对镜头说话，真人出镜感
-    - 门店类：店主或探店博主出镜讲解+场景展示
-    - 品牌类：主演出镜说话或角色对白，禁止上帝视角旁白
-    """
+    """根据营销目的提供创作指导 hint（关键词分类，DB 精确覆盖优先）。"""
     mp = (mp or "").strip()
     if not mp:
         return ""
 
+    # 精确匹配 DB 覆盖（运营可配置自定义营销目的）
+    db_text = _db_guide("marketing_purpose", mp)
+    if db_text:
+        return db_text
+
     # 短剧类（多角色对话）
     if any(k in mp for k in ["对话短剧", "反转短剧", "悬念短剧", "情绪短片"]):
         return "【短剧模式】必须双/多角色对话格式，台词用'角色：xxx'格式，镜头在角色间切换，禁止第三人称旁白解说。"
-
     # 口播类（第一人称对镜头说话）
     if any(
         k in mp
         for k in ["口播带货", "促销转化", "功能演示", "痛点解决", "获客引流", "账号涨粉", "活动通知", "场景种草"]
     ):
         return "【口播模式】第一人称对镜头说话，像真人出镜，有语气停顿和情绪，禁止第三人称旁白。"
-
     # 门店类（店主/探店博主出镜）
     if any(k in mp for k in ["门店发现", "到店实录", "招牌体验", "同城团购"]):
         return "【门店模式】店主或探店博主出镜讲解+场景展示，第一人称或角色对白，禁止上帝视角旁白。"
-
     # 品牌类（主演出镜或角色对白）
     if any(k in mp for k in ["品牌主张", "品牌故事", "生活方式", "创意概念"]):
         return "【品牌模式】主演出镜说话或角色对白，禁止上帝视角旁白，要有品牌调性和情感共鸣。"
-
     # 未匹配的营销目的：通用 hint
     return "【通用模式】避免上帝视角旁白，优先第一人称或角色对话。"
 
 
 def _target_customer_hint(tc: str) -> str:
-    """根据目标客户提供台词风格指导。"""
+    """根据目标客户提供台词风格指导（关键词分类，DB 精确覆盖优先）。"""
     tc = (tc or "").strip()
     if not tc:
         return ""
-
-    # 年轻人
+    db_text = _db_guide("target_customer", tc)
+    if db_text:
+        return db_text
     if any(k in tc for k in ["18-25", "年轻", "学生", "Z世代", "95后", "00后"]):
         return "【目标年轻客群】台词要活泼、有梗、节奏快，可用网络流行语。"
-
-    # 中年人
     if any(k in tc for k in ["30-45", "中年", "家庭", "宝妈", "职场"]):
         return "【目标中年客群】台词要实用、有共鸣，强调性价比和品质。"
-
-    # 老年人
     if any(k in tc for k in ["50+", "老年", "退休", "银发"]):
         return "【目标老年客群】台词要清晰、慢节奏，强调健康和实惠。"
-
-    # 高端
     if any(k in tc for k in ["高端", "商务", "精英", "白领"]):
         return "【目标高端客群】台词要专业、有格调，强调品质和身份。"
-
     return ""
 
 
 def _language_hint(language: str) -> str:
-    """根据 language 代码返回语言提示。"""
+    """根据 language 代码返回语言提示（DB 精确覆盖优先，代码默认兜底）。"""
     lang = (language or "zh-CN").strip().lower()
-    mapping = {
+    db_text = _db_guide("language", lang)
+    if db_text:
+        return f"【语言：{lang}】{db_text}"
+    _defaults: dict[str, str] = {
         "zh-cn": "使用标准普通话，口语化表达",
         "zh-tw": "使用台湾腔中文，语气温柔亲切",
         "zh-hk": "使用粤语风格中文表达",
@@ -883,7 +928,7 @@ def _language_hint(language: str) -> str:
         "ja-jp": "使用日语，自然口语化",
         "ko-kr": "使用韩语，亲切自然",
     }
-    hint = mapping.get(lang, "")
+    hint = _defaults.get(lang, "")
     if hint:
         return f"【语言：{lang}】{hint}"
     if lang.startswith("zh"):
@@ -988,25 +1033,15 @@ def _fallback_script(job: ViralVideoJob) -> dict:
     _brand_str = _brands[0] if _brands else ""
     _mp = (getattr(job, "marketing_purpose", "") or "").strip()
 
-    # 基于真实识别结果构建口播，不再用"这家店""一款好物"等通用表述
+    # PR3 P2(c): 兜底口播只用真实 VLM 输入，诚实简短，让前端/用户一眼看出是兜底触发重试
     if job.user_copy_text:
         voiceover = job.user_copy_text
-    elif _dominant == "store" and _name_str:
-        voiceover = (
-            f"今天带大家来{_name_str}看看，{_brand_str + '，' if _brand_str else ''}环境和服务都很赞，推荐来体验！"
-        )
-    elif _dominant == "store":
-        voiceover = "今天带大家探店，这家店的环境和服务都很不错，推荐大家来体验一下。"
-    elif _dominant == "product" and _name_str:
-        voiceover = f"给大家分享{_brand_str + '家的' if _brand_str else ''}{_name_str}，真心不错，推荐你们试试。"
-    elif _dominant == "product":
-        voiceover = "给大家分享一款我最近在用的好物，真的很不错，推荐你们也试试。"
-    elif _dominant == "person":
-        voiceover = "哈喽，今天给大家分享我的日常，简单舒适又好看，你们觉得怎么样？"
-    elif _dominant == "scene" and _name_str:
-        voiceover = f"带大家感受一下{_name_str}，氛围感拉满，真的很适合打卡体验。"
+    elif _brand_str and _name_str:
+        voiceover = f"来看看{_brand_str}家的{_name_str}"
+    elif _name_str:
+        voiceover = f"来看看{_name_str}"
     else:
-        voiceover = "带大家感受一下这个空间，氛围感拉满，真的很适合打卡体验。"
+        voiceover = "今天分享一个好东西"
     # 口播超长时截断（字数上限统一从 constants 取）
     _max_v = get_duration_spec(dur)["max_chars"]
     if len(voiceover) > _max_v:
@@ -1232,7 +1267,7 @@ def _step_review(job: ViralVideoJob, copy_result: dict) -> dict:
     """步骤 4: 合规审核（PR1 简化版：Reviewer 直接接 voiceover 字符串，不做自动重写）。
 
     返回结构与旧版兼容：{passed, score, details, issues}
-    注：rewrite 死路径（调用不存在的 copy_fusion 模板必崩）已在 PR1 删除。LLM 审核不可用
+    注：rewrite 死路径（调用不存在的 copy_fusion 模板必崩）已删除。LLM 审核不可用
     时降级放行，Reviewer 会在 issues 里塞一条 warning 告知前端。
     """
     try:
@@ -1699,11 +1734,161 @@ def _finalize_fallback_script(job: ViralVideoJob) -> dict:
     return fb
 
 
+# ── PR3 P2(e): Seedance/Wan prompt 常量与辅助函数（从 _assemble_seedance_prompt 中抽出） ──
+_SEEDANCE_OVERVIEW_HEADER = "【视频总览】"
+_SEEDANCE_REFS_HEADER = "【参考素材】"
+_SEEDANCE_SCRIPT_HEADER = "【分镜脚本】"
+_SEEDANCE_HARD_HEADER = "【硬性约束】"
+_SEEDANCE_NEG_HEADER = "【负面提示词】"
+_SEEDANCE_DEFAULT_SCENE = "专业、清晰、明亮有质感"
+_SEEDANCE_DURATION_FOOT = "（单次生成，时长严格匹配）"
+_SEEDANCE_NEG_JOINER = "，"
+_WAN_HEAD_SCENE_FALLBACK = "画面清晰有质感"
+_WAN_STYLE_LABEL = "风格说明："
+_WAN_SHOT_PREFIX = "第{n}个镜头[{label}]"
+
+
+def _build_style_section(style_guide: dict | None, scene_lighting: str) -> str:
+    """从 style_guide / scene_lighting 生成整体风格描述文本。"""
+    if not isinstance(style_guide, dict):
+        return scene_lighting or _SEEDANCE_DEFAULT_SCENE
+    parts: list[str] = []
+    if scene_lighting:
+        parts.append(scene_lighting)
+    for k in ("color_grade", "energy", "cut_speed", "transition"):
+        v = style_guide.get(k)
+        if v and v != "placeholder":
+            parts.append(f"{k}={v}")
+    if style_guide.get("narrative"):
+        parts.append("叙事感强")
+    return "，".join(parts) if parts else _SEEDANCE_DEFAULT_SCENE
+
+
+def _build_character_section(person_portraits, pre_trusted_images, trusted_urls) -> str:
+    """人物参考段落。当前版本人物参考走 reference_images 通道，
+    不在 prompt 正文重复描述；保留接口供后续扩展，当前返回空串。
+    """
+    # person_portraits / pre_trusted_images / trusted_urls 目前由 call_video_generation
+    # 通过 reference_images / pre_trusted_images 参数直接传 Seedance，不在文本 prompt
+    # 中重复声明以避免冲突。此处保留函数入口以匹配设计文档，未来可扩展肖像一致性文本提示。
+    return ""
+
+
+# ── MVP 角色三视图自动生成（真人照片→Seedream 白底插画三视图→Seedance reference_image） ──
+
+# 实验验证通过的三视图 prompt（参考 experiment/report.md）
+_CHARACTER_SHEET_BASE_PROMPT = (
+    "Full-color cinematic digital painting character turnaround sheet on pure white background, "
+    "no text or watermarks. Three equal horizontal panels show THE SAME person, full body: "
+    "LEFT=three-quarter left view facing left, CENTER=front view facing camera, "
+    "RIGHT=three-quarter right view facing right. IDENTICAL person in all three views. "
+    "Outfit (identical all panels): same clothing and accessories as in the reference photo, "
+    "same hairstyle and glasses, same body type. "
+    "Style: rich color digital painting, painterly brushwork, cinematic film lighting, "
+    "detailed fabric texture, high-end film concept art quality "
+    "(NOT line art, NOT sketch, NOT anime, NOT black-white, NOT photorealistic photo). "
+    "Three figures upright at same height, hands at sides or behind back. 3:4 vertical, pure white background only."
+)
+
+_REALISTIC_SUFFIX = "真人实拍电影质感，ARRI Alexa色调，真实皮肤纹理，自然色彩，8K，浅景深"
+
+
+def _generate_character_sheet(
+    person_image_url: str,
+    person_desc: str,
+    job_id: str,
+    tmpdir: Path,
+    *,
+    timeout: int = 90,
+) -> str | None:
+    """用 Seedream 基于真人照片生成白底插画角色三视图并上传 OSS（MVP）。
+
+    - person_image_url: 已签名的用户上传真人原图 URL（作 reference）
+    - person_desc: VLM 输出的人物外貌描述（拼入 prompt 辅助人物一致性）
+    - job_id: 任务 ID，用于生成 OSS 存储路径
+    - tmpdir: 渲染阶段临时目录，用于暂存 Seedream 返回的图片
+    - 成功返回 OSS 签名 URL（2h 有效，存盘路径 viral-video/character-sheets/{job_id}.jpg）
+    - 失败时静默降级，不抛异常，不阻断渲染流程
+    """
+    try:
+        from packages.shared.ai_router import ai_router
+
+        img_client = ai_router.get_image_gen_client()
+        if img_client is None:
+            logger.warning("[character-sheet] 图片生成客户端不可用，跳过三视图")
+            return None
+        desc_short = (person_desc or "").strip()[:300]
+        prompt = _CHARACTER_SHEET_BASE_PROMPT
+        if desc_short:
+            prompt = f"Character description: {desc_short}. " + prompt
+        _t0 = time.time()
+        result = img_client.image_generation(
+            prompt=prompt,
+            reference_images=[person_image_url],
+            size="2K",
+            timeout=timeout,
+        )
+        if not result or not result.get("url"):
+            logger.warning(
+                "[character-sheet] Seedream 返回为空: %s",
+                getattr(img_client, "last_image_error", None),
+            )
+            return None
+        sheet_url = result["url"]
+        logger.info(
+            "[character-sheet] Seedream 生成完成 耗时%.1fs，开始下载并上传OSS",
+            time.time() - _t0,
+        )
+        # 下载 Seedream 返回的图片到 tmpdir
+        import httpx
+
+        local_path = tmpdir / f"character_sheet_{job_id}.jpg"
+        try:
+            with httpx.stream("GET", sheet_url, timeout=60) as resp:
+                resp.raise_for_status()
+                with open(local_path, "wb") as f:
+                    for chunk in resp.iter_bytes(chunk_size=65536):
+                        if chunk:
+                            f.write(chunk)
+        except Exception as _de:
+            logger.warning("[character-sheet] 下载Seedream图片失败: %s，降级用临时URL", _de)
+            return sheet_url  # 下载失败时降级用Seedream临时URL，不阻断流程
+        # 上传到 OSS
+        try:
+            from video_processing.oss_helpers import get_signed_download_url, upload_to_oss
+
+            storage_key = f"viral-video/character-sheets/{job_id}.jpg"
+            upload_ok = upload_to_oss(str(local_path), storage_key)
+            if not upload_ok:
+                logger.warning("[character-sheet] OSS上传失败，降级用临时URL")
+                return sheet_url
+            signed_url = get_signed_download_url(storage_key, expires_seconds=7200)
+            if not signed_url:
+                logger.warning("[character-sheet] OSS签名URL生成失败，降级用临时URL")
+                return sheet_url
+            logger.info(
+                "[character-sheet] 三视图已存OSS key=%s 总耗时%.1fs",
+                storage_key,
+                time.time() - _t0,
+            )
+            return signed_url
+        except Exception as _ue:
+            logger.warning("[character-sheet] OSS上传异常（降级用临时URL）: %s", _ue, exc_info=True)
+            return sheet_url
+    except Exception as e:  # noqa: BLE001
+        logger.warning("[character-sheet] 三视图生成异常（降级用原图）: %s", e, exc_info=True)
+        return None
+
+
 def _assemble_seedance_prompt(copy_result: dict, job: ViralVideoJob) -> str:
     """把编导脚本拼成符合官方推荐格式的 prompt（按 provider 分发）。
 
     - doubao (Seedance): [X-Y秒] 单行时间戳 + 镜头级 @图片N 绑定
     - dashscope (Wan 3.0): 第N个镜头[X-Y秒] 单行格式
+
+    PR3 P2(e): 字符串常量已抽取到模块级 _SEEDANCE_* / _WAN_*，
+    风格段与人物段通过 _build_style_section / _build_character_section 组装，
+    输出内容与旧版完全一致。
     """
     from packages.domain.points_rules import get_viral_video_model_config
 
@@ -1719,6 +1904,7 @@ def _assemble_seedance_prompt(copy_result: dict, job: ViralVideoJob) -> str:
     hc = copy_result.get("hard_constraints") or _DEFAULT_HARD_CONSTRAINTS
     np_list = copy_result.get("negative_prompts") or _DEFAULT_NEGATIVE_PROMPTS
     images = list(job.images or [])
+    style_guide = job.style_guide if isinstance(getattr(job, "style_guide", None), dict) else None
 
     model = getattr(job, "video_model", "") or None
     provider = get_viral_video_model_config(model).get("provider", "doubao")
@@ -1730,9 +1916,15 @@ def _assemble_seedance_prompt(copy_result: dict, job: ViralVideoJob) -> str:
             return idx
         return 0 if images else None
 
+    # 整体风格描述（复用 style_guide 如果有）
+    style_text = _build_style_section(style_guide, scene_lighting)
+    # 人物段（当前为空实现，仅保留扩展点，保持输出不变）
+    # 未来可注入 person_portraits/pre_trusted 提示，目前人物参考走 reference_images 通道
+    _char_text = _build_character_section([], getattr(job, "pre_trusted_images", None) or [], [])
+
     if provider == "dashscope":
         # ========== Wan 3.0 格式 ==========
-        head = f"{theme}，{scene_lighting or '画面清晰有质感'}，总时长{total_duration}秒。"
+        head = f"{theme}，{style_text or _WAN_HEAD_SCENE_FALLBACK}，总时长{total_duration}秒。"
         body: list[str] = [head, ""]
         for i, s in enumerate(shots):
             tr = str(s.get("time_range", ""))
@@ -1740,40 +1932,37 @@ def _assemble_seedance_prompt(copy_result: dict, job: ViralVideoJob) -> str:
             label = f"{pr[0]}-{pr[1]}秒" if pr else tr
             cam = str(s.get("shot_type_angle_movement", "") or "").strip()
             voice = str(s.get("voiceover", "") or "").strip()
-            pieces = [f"第{i + 1}个镜头[{label}]"]
+            pieces = [_WAN_SHOT_PREFIX.format(n=i + 1, label=label)]
             if cam:
                 pieces.append(f"运镜：{cam}")
             pieces.append(f"画面：{_shot_visual(s)}")
             if voice:
                 pieces.append(f'配音："{voice}"')
-            # Wan 通过 input.media 数组顺序隐式引用图1/图2，不写@图片
             body.append(" ".join(pieces))
         style_parts = [str(x) for x in hc if x] + [str(x) for x in np_list if x]
         if style_parts:
             body.append("")
-            body.append("风格说明：" + "；".join(style_parts[:6]))
+            body.append(_WAN_STYLE_LABEL + "；".join(style_parts[:6]))
         return "\n".join(body)
 
     # ========== Seedance 格式 ==========
     lines: list[str] = []
-    lines.append("【视频总览】")
+    lines.append(_SEEDANCE_OVERVIEW_HEADER)
     lines.append(f"- 主题：{theme}")
-    lines.append(f"- 总时长：{total_duration}秒（单次生成，时长严格匹配）")
+    lines.append(f"- 总时长：{total_duration}秒{_SEEDANCE_DURATION_FOOT}")
     lines.append(f"- 画幅：{aspect_ratio}")
-    lines.append(f"- 整体风格：{scene_lighting or '专业、清晰、明亮有质感'}")
+    lines.append(f"- 整体风格：{style_text}")
     lines.append("")
 
-    # 【参考素材】按镜头绑定
     if images:
-        lines.append("【参考素材】")
+        lines.append(_SEEDANCE_REFS_HEADER)
         for i in range(len(shots)):
             ri = _ref(i)
             if ri is not None:
                 lines.append(f"镜头{i + 1}参考@图片{ri + 1}")
         lines.append("")
 
-    # 单行时间戳分镜
-    lines.append("【分镜脚本】")
+    lines.append(_SEEDANCE_SCRIPT_HEADER)
     for i, s in enumerate(shots):
         tr = str(s.get("time_range", ""))
         pr = _parse_shot_seconds(tr)
@@ -1795,12 +1984,12 @@ def _assemble_seedance_prompt(copy_result: dict, job: ViralVideoJob) -> str:
         lines.append(" ".join(pieces))
 
     lines.append("")
-    lines.append("【硬性约束】")
+    lines.append(_SEEDANCE_HARD_HEADER)
     for c in hc:
         lines.append(f"- {c}")
     lines.append("")
-    lines.append("【负面提示词】")
-    lines.append("，".join([str(x) for x in np_list if x]))
+    lines.append(_SEEDANCE_NEG_HEADER)
+    lines.append(_SEEDANCE_NEG_JOINER.join([str(x) for x in np_list if x]))
     return "\n".join(lines)
 
 
@@ -1896,6 +2085,66 @@ def _step_render(job: ViralVideoJob, copy_result: dict, tts_audio_url: str | Non
         except Exception as _te:
             logger.warning("[爆款视频] 现场跑信任链异常: %s，回退原图+400降级纯t2v", _te, exc_info=True)
 
+    # ── MVP: 自动生成角色三视图并替换人像位 reference ──
+    # 流程：VLM 分析完成后（image_analysis 已有 has_person/portrait 描述）→
+    #       取第一个清晰人物照，用 Seedream i2i 生成白底电影插画风格三视图 →
+    #       三视图 URL 替换所有人物位 reference（作为 pre_trusted_images 传给 Seedance）→
+    #       失败时静默回退到上面的原 trust_chain / 原图逻辑，不阻断渲染
+    _character_sheet_url: str | None = None
+    try:
+        if first_image and _mcfg.get("provider", "doubao") == "doubao":
+            _ia = normalize_image_analysis(getattr(job, "image_analysis", None))
+            _person_idx, _person_descs = _collect_person_portraits(_ia.get("images", []))
+            if _person_descs:
+                # MVP: 只取第一个清晰人物
+                _primary_idx = _person_idx[0]
+                _primary_desc = _person_descs[0]
+                # 取该位置已签名 URL（images 列表已 _refresh_oss_signed_url 过，但需对齐 all_portrait_urls 顺序）
+                # all_portrait_urls 是 images 的重签版，按 images 顺序；_primary_idx 是 images 中的索引
+                if _primary_idx < len(images):
+                    _primary_url = images[_primary_idx]
+                    logger.info(
+                        "[character-sheet] 检测到人物(idx=%d desc=%d字)，开始生成三视图",
+                        _primary_idx,
+                        len(_primary_desc),
+                    )
+                    _character_sheet_url = _generate_character_sheet(
+                        _primary_url,
+                        _primary_desc,
+                        job.id,
+                        tmpdir,
+                        timeout=120,
+                    )
+                    if _character_sheet_url:
+                        # 把三视图作为 pre_trusted：所有人物位都用三视图，非人物位保持 None（用原图）
+                        # 若之前已有预热 t2i 结果，三视图优先覆盖（实验验证插画三视图比写实 t2i 更稳、不被 50411 拦截）
+                        _sheet_sparse: list[str | None] = [None] * _n_total
+                        for _pi in _person_idx:
+                            if 0 <= _pi < _n_total:
+                                _sheet_sparse[_pi] = _character_sheet_url
+                        # 首图如果是人物位，直接替换 first_image 为三视图
+                        if _sheet_sparse[0]:
+                            first_image = _character_sheet_url
+                            # rest_images 里如果首图原本也在，替换掉（rest_images = images[1:]）
+                            if _primary_idx == 0:
+                                pass  # first_image 已替换
+                            # 其他非首图的人物位：通过 pre_trusted 传（ai_client 会优先用 pre_trusted）
+                        pre_trusted = _sheet_sparse
+                        _n_trusted = len(_person_idx)
+                        logger.info(
+                            "[character-sheet] 三视图已替换人物 reference n_person=%d total=%d",
+                            _n_trusted,
+                            _n_total,
+                        )
+                    else:
+                        logger.info("[character-sheet] 三视图生成失败，回退原 trust_chain/原图逻辑")
+    except Exception as _cse:
+        logger.warning("[character-sheet] 三视图替换异常（不阻断渲染）: %s", _cse, exc_info=True)
+
+    # MVP: 有人物出镜时统一追加写实尾句（实验验证的有效提示，提升"插画→写实"跨域还原度）
+    if _character_sheet_url:
+        prompt = f"{prompt.rstrip()}\n\n{_REALISTIC_SUFFIX}"
+
     # 第一次调用：带参考图/首帧/音频/参考视频（pre_trusted有值→走信任链；无值→原图；若400 ai_client内部自动降级纯t2v）
     result = call_video_generation(
         prompt=prompt,
@@ -1935,14 +2184,22 @@ def _step_render(job: ViralVideoJob, copy_result: dict, tts_audio_url: str | Non
             user_msg,
             (detail or "")[:500],
         )
-        raise RuntimeError(err_msg)
+        raise ViralVideoUpstreamError(
+            provider=err_provider,
+            upstream_code=str(err_code),
+            user_message=err_msg,
+            detail=(detail or "")[:1000] or None,
+            status_code=int(status_code) if isinstance(status_code, int) and status_code else None,
+        )
 
     if not result or not isinstance(result, dict):
         _check_and_reraise(result)
     video_path = result.get("video_path") or ""
     usage = result.get("usage")
     if not video_path or not Path(video_path).exists() or Path(video_path).stat().st_size == 0:
-        raise RuntimeError("视频生成失败：返回空文件或路径不存在")
+        raise ViralVideoResourceError(
+            resource_type="video_file", user_message="视频生成失败：返回空文件或路径不存在", detail=f"path={video_path}"
+        )
     # #2170: 统一走方舟 Seedance（含信任链），usage 里的 provider/model_key 用于积分结算；
     # 信任链产生的 Seedream 图成本已在利润率中覆盖，不单独结算。
     size = Path(video_path).stat().st_size
@@ -1959,7 +2216,12 @@ def _step_upload(job: ViralVideoJob, video_path: str) -> str:
     logger.info("[爆款视频] 开始上传成片: local=%s key=%s size=%d", local, storage_key, local.stat().st_size)
     video_url = upload_to_oss(local, storage_key)
     if not video_url:
-        raise RuntimeError(f"OSS 上传失败: storage_key={storage_key}")
+        raise ViralVideoUpstreamError(
+            provider="oss",
+            upstream_code="upload_failed",
+            user_message="视频上传失败，请稍后重试",
+            detail=f"storage_key={storage_key}",
+        )
     return video_url
 
 
@@ -1984,73 +2246,6 @@ def _wait_oss_ready(url: str, timeout_sec: int = 10) -> bool:
     return False
 
 
-# ── 主编排器 ────────────────────────────────────────────────────────────
-
-
-@shared_task(
-    bind=True,
-    max_retries=2,
-    name="worker.run_viral_video_pipeline",
-    soft_time_limit=900,  # 15min（完整流水线）
-    time_limit=960,
-)
-@with_viral_job(mark_running_on_entry=True)
-def run_viral_video_pipeline(self: Task, job, repo, session) -> dict:
-    """旧一键流水线（保留兼容）：图片分析→风格分析→意图解析→WAIT_USER_CONFIRM。"""
-    job_id = job.id
-    _set_stage(job, repo, session, ViralVideoStage.IMAGE_ANALYSIS, "正在分析商品特征...")
-
-    image_analysis = _step_image_analysis(job)
-    job.image_analysis = image_analysis
-    # #2174: VLM完成后立即启动信任链t2i预热（从VLM结果提取人物描述），与文案阶段并行
-    if job.images:
-        try:
-            _imgs = (image_analysis or {}).get("images", []) or []
-            _start_trust_chain_preheat(job.id, _imgs)
-        except Exception as _e:
-            logger.warning("[爆款视频][阶段1] 启动信任链t2i预热失败: %s", _e)
-    _save_job(repo, job, session)
-    _emit_progress(job_id, ViralVideoStage.IMAGE_ANALYSIS, 15.0, "图片分析完成", {"result": image_analysis})
-
-    style_guide = None
-    if job.reference_video_url or job.style_template_id:
-        _set_stage(job, repo, session, ViralVideoStage.VIDEO_ANALYSIS, "正在分析参考视频风格...")
-        style_guide = _step_video_analysis(job)
-        job.style_guide = style_guide
-        _save_job(repo, job, session)
-        _emit_progress(job_id, ViralVideoStage.VIDEO_ANALYSIS, 25.0, "风格分析完成", {"style_guide": style_guide})
-
-    # v8：意图解析已并入分镜生成，旧流水线不再单独解析
-    intent_result = {"intent": "", "key_messages": [], "tone": "", "suggested_title": ""}
-    job.mark_wait_user_confirm(intent_result)
-    job.current_stage = ViralVideoStage.INTENT_PARSING
-    job.phase_message = "意图解析完成，等待用户确认"
-    _save_job(repo, job, session)
-    _emit_progress(
-        job_id,
-        ViralVideoStage.INTENT_PARSING,
-        35.0,
-        "意图解析完成，等待用户确认",
-        {"intent_result": intent_result, "waiting_confirm": True},
-    )
-    _emit_progress(
-        job_id,
-        ViralVideoStage.INTENT_PARSING,
-        35.0,
-        "等待用户确认意图文案",
-        {"intent_result": intent_result},
-        event_type="viral_video:wait_user",
-    )
-    return {"ok": True, "job_id": job_id, "status": "wait_user_confirm", "intent_result": intent_result}
-
-
-@shared_task(bind=True, max_retries=2, name="worker.resume_viral_video_pipeline")
-@with_viral_job(require_status=[ViralVideoStatus.RUNNING], start_heartbeat=False, recover_stale=False)
-def resume_viral_video_pipeline(self: Task, job, repo, session) -> dict:
-    """旧 confirm-intent 路径兼容：从 WAIT_USER_CONFIRM 跑完整个渲染。"""
-    return _run_render_pipeline(job.id, session, repo, job)
-
-
 @shared_task(bind=True, max_retries=1, name="worker.run_video_style_analysis")
 @with_viral_job(start_heartbeat=False, recover_stale=False)
 def run_video_style_analysis(self: Task, job, repo, session) -> dict:
@@ -2176,7 +2371,7 @@ def run_viral_video_analyze(self: Task, job, repo, session) -> dict:
     bind=True,
     max_retries=1,
     name="worker.run_viral_video_generate_copy",
-    soft_time_limit=600,  # #2183: pro长脚本~120s+三级重试最坏300s+intent/review ~105s，给到10min
+    soft_time_limit=600,  # #2183: pro长脚本~120s+三级重试最坏300s+review ~60s，给到10min
     time_limit=660,  # #2183: 11min hard limit
 )
 @with_viral_job(require_status=[ViralVideoStatus.RUNNING])
@@ -2418,12 +2613,15 @@ def _run_render_pipeline(job_id: str, session, repo, job) -> dict:
     _copy_src = "db"
     if not isinstance(copy_result, dict) or not copy_result:
         logger.error(
-            "[爆款视频][阶段3] copy_result 为空或无效，无法进入渲染流程。job_id=%s status=%s intent_len=%d，请重新触发「生成文案」",
+            "[爆款视频][阶段3] copy_result 为空或无效，无法进入渲染流程。job_id=%s status=%s，请重新触发「生成文案」",
             job_id,
             job.status,
-            len((job.intent_result or {}) if isinstance(job.intent_result, dict) else {}),
         )
-        raise ValueError("文案数据缺失，请先点击「生成文案」完成文案生成后再生成视频")
+        raise ViralVideoError(
+            code="copy_missing",
+            user_message="文案数据缺失，请先点击「生成文案」完成文案生成后再生成视频",
+            http_status=400,
+        )
     logger.info(
         "[爆款视频][阶段3] 进入渲染流程 job_id=%s copy_result_shots=%d copy_result_len=%d source=%s",
         job_id,
@@ -2447,7 +2645,7 @@ def _run_render_pipeline(job_id: str, session, repo, job) -> dict:
                 )
                 review_result["passed"] = True
             else:
-                # PR1: 删除自动重写死路径（原 reviewer.rewrite() 调用不存在的 copy_fusion 模板必崩）；
+                # 自动重写死路径（reviewer.rewrite 调用不存在的 copy_fusion 模板必崩）已删除；
                 # error 级问题直接终止渲染，让用户修改文案后重试
                 logger.error(
                     "[爆款视频][阶段3] 合规审核未通过（%d个error），终止渲染 job_id=%s issues=%s",
@@ -2455,12 +2653,16 @@ def _run_render_pipeline(job_id: str, session, repo, job) -> dict:
                     job_id,
                     [i.get("text", "")[:40] for i in _error_issues[:3]],
                 )
-                raise ValueError("文案合规审核未通过，请修改文案后重试或重新生成文案")
+                raise ViralVideoComplianceError(
+                    user_message="文案合规审核未通过，请修改文案后重试或重新生成文案",
+                    issues=list(_error_issues),
+                    detail=f"{len(_error_issues)} error issues",
+                )
             job.copy_result = copy_result
             job.generated_copy_text = copy_result.get("voiceover_script", "") or ""
             _save_job(repo, job, session)
-    except ValueError:
-        # #2218: 审核未通过/文案缺失的业务异常，不继续出片，向上抛出
+    except (ValueError, ViralVideoError):
+        # #2218 / PR3: 业务异常（审核未通过/文案缺失/积分不足等）不继续出片，向上抛出
         raise
     except Exception as e:
         logger.warning("[爆款视频][阶段3] 合规审核异常，继续出片: %s", e)

packages/adapters/sqlalchemy_impl/viral_video_repository.py

@@ -56,7 +56,6 @@ def _to_domain(model: ViralVideoJobModel) -> ViralVideoJob:
         current_stage=getattr(model, "current_stage", "") or "",
         phase_message=getattr(model, "phase_message", "") or "",
         heartbeat_at=getattr(model, "heartbeat_at", None),
-        intent_result=dict(model.intent_result) if model.intent_result else None,
         image_analysis=dict(model.image_analysis) if getattr(model, "image_analysis", None) else None,
         storyboard=list(model.storyboard) if getattr(model, "storyboard", None) else None,
         generated_copy_text=getattr(model, "generated_copy_text", "") or "",
@@ -110,7 +109,6 @@ class SQLAlchemyViralVideoJobRepository:
             current_stage=job.current_stage or "",
             phase_message=job.phase_message or "",
             heartbeat_at=job.heartbeat_at,
-            intent_result=job.intent_result,
             image_analysis=job.image_analysis,
             storyboard=job.storyboard,
             generated_copy_text=job.generated_copy_text,
@@ -139,7 +137,6 @@ class SQLAlchemyViralVideoJobRepository:
         model.current_stage = job.current_stage or ""
         model.phase_message = job.phase_message or ""
         model.heartbeat_at = job.heartbeat_at
-        model.intent_result = job.intent_result
         model.image_analysis = job.image_analysis
         model.storyboard = job.storyboard
         model.generated_copy_text = job.generated_copy_text or ""
@@ -199,9 +196,7 @@ class SQLAlchemyViralVideoJobRepository:
             self.session.query(ViralVideoJobModel)
             .filter(
                 ViralVideoJobModel.user_id == user_id,
-                ViralVideoJobModel.status.in_(
-                    ["pending", "running", "wait_user_confirm", "image_analyzed", "copy_generated"]
-                ),
+                ViralVideoJobModel.status.in_(["pending", "running", "image_analyzed", "copy_generated"]),
             )
             .count()
         )

packages/application/viral_video/param_guides.py

@@ -0,0 +1,115 @@
+"""爆款视频参数指导（persona/viral_structure/marketing_purpose/target_customer/language）。
+
+PR3 P2(h): 把原来 worker 里 130 行 if/elif 硬编码 mapping 迁到 DB 表
+`viral_video_param_guides`，提供 30 秒 TTL 缓存读取。DB miss 时返回 None，
+由调用方兜底到代码默认值（保证 worker 冷启动/DB 不可用时不阻断流程）。
+"""
+
+from __future__ import annotations
+
+import threading
+import time
+from typing import Optional
+
+import sqlalchemy as sa
+
+from packages.adapters.sqlalchemy_impl import session as _session_mod
+
+CACHE_TTL_SECONDS = 30.0
+
+VALID_GUIDE_TYPES = frozenset({"persona", "structure", "marketing_purpose", "target_customer", "language"})
+
+_lock = threading.Lock()
+# key = f"{guide_type}:{guide_key}", value = (expire_monotonic_ts, text|None)
+_cache: dict[str, tuple[float, Optional[str]]] = {}
+
+_lazy_session = None
+
+
+def _get_session():
+    """优先复用 worker 的 SessionLocal；否则懒建（API 场景）。"""
+    global _lazy_session
+    if _session_mod.SessionLocal is not None:
+        return _session_mod.SessionLocal()
+    if _lazy_session is not None:
+        return _lazy_session()
+    try:
+        from packages.config import get_shared_settings
+
+        url = str(get_shared_settings().database_url)
+    except Exception:  # noqa: BLE001
+        return None
+    if not url:
+        return None
+    url = url.replace("postgresql+asyncpg://", "postgresql+psycopg://")
+    if url.startswith("postgresql://") and "psycopg" not in url:
+        url = url.replace("postgresql://", "postgresql+psycopg://", 1)
+    engine = sa.create_engine(url, pool_pre_ping=True, pool_size=2, max_overflow=2)
+    from sqlalchemy.orm import sessionmaker
+
+    _lazy_session = sessionmaker(bind=engine)
+    return _lazy_session()
+
+
+def _cache_key(guide_type: str, guide_key: str) -> str:
+    return f"{guide_type}:{guide_key}"
+
+
+def _load_from_db(guide_type: str, guide_key: str) -> Optional[str]:
+    session = None
+    try:
+        session = _get_session()
+        if session is None:
+            return None
+        sql = sa.text("""
+            SELECT guide_text
+              FROM viral_video_param_guides
+             WHERE guide_type = :gt AND guide_key = :gk
+            """)
+        row = session.execute(sql, {"gt": guide_type, "gk": guide_key}).first()
+        if row is None:
+            return None
+        return row[0] if row[0] is not None else None
+    except Exception:  # noqa: BLE001 - 表不存在/DB 不可用静默返回 None
+        return None
+    finally:
+        if session is not None:
+            try:
+                session.close()
+            except Exception:  # noqa: BLE001
+                pass
+
+
+def get_param_guide(guide_type: str, guide_key: str, *, force_refresh: bool = False) -> Optional[str]:
+    """读参数指导文本，30 秒 TTL；DB 无数据返回 None，调用方自行兜底。"""
+    if guide_type not in VALID_GUIDE_TYPES:
+        return None
+    gk = (guide_key or "").strip()
+    if not gk:
+        return None
+    key = _cache_key(guide_type, gk)
+    now = time.monotonic()
+    with _lock:
+        if not force_refresh:
+            cached = _cache.get(key)
+            if cached and now < cached[0]:
+                return cached[1]
+
+    text = _load_from_db(guide_type, gk)
+    with _lock:
+        _cache[key] = (now + CACHE_TTL_SECONDS, text)
+    return text
+
+
+def invalidate() -> None:
+    """清空缓存（测试用）。"""
+    with _lock:
+        _cache.clear()
+
+
+__all__ = [
+    "CACHE_TTL_SECONDS",
+    "VALID_GUIDE_TYPES",
+    "get_param_guide",
+    "invalidate",
+]

packages/application/viral_video/prompt_loader.py

@@ -1,10 +1,12 @@
 """Prompt 模板加载器：从 viral_video_prompt_templates 读模板，30 秒 TTL 热加载。
 
-DB 不可用或没有数据时自动回落到 prompts.DEFAULT_TEMPLATES，保证流程不阻断。
+DB 不可用或没有数据时自动回落到 prompts.DEFAULT_TEMPLATES，保证流程不阻断；
+首次回落会打 warning（PR3 P2(f)），避免静默掩盖配置问题，又不刷屏。
 """
 
 from __future__ import annotations
 
+import logging
 import threading
 import time
 from dataclasses import dataclass
@@ -15,10 +17,28 @@ import sqlalchemy as sa
 from packages.adapters.sqlalchemy_impl import session as _session_mod
 from packages.application.viral_video.prompts import DEFAULT_TEMPLATES
 
+logger = logging.getLogger(__name__)
+
 CACHE_TTL_SECONDS = 30.0
 
 _VALID_TYPES = {"image_analysis", "storyboard", "review"}
 
+# PR3 P2(f): 回落 warning 去重 — key -> 上次打 warning 的 monotonic 时间戳，
+# 同一 key 在 _WARN_COOLDOWN_SECONDS 内不再重复告警。
+_WARN_COOLDOWN_SECONDS = 300.0  # 5 分钟
+_warned: dict[str, float] = {}
+_warn_lock = threading.Lock()
+
+
+def _warn_once(key: str, template_type: str, e: BaseException | str | None = None) -> None:
+    now = time.monotonic()
+    with _warn_lock:
+        last = _warned.get(key, 0.0)
+        if now - last < _WARN_COOLDOWN_SECONDS:
+            return
+        _warned[key] = now
+    logger.warning("viral_video prompt template %s fallback to default: %s", template_type, e)
+
 
 @dataclass
 class PromptTemplate:
@@ -64,12 +84,15 @@ def _get_session():
         from packages.config import get_shared_settings
 
         url = str(get_shared_settings().database_url)
-    except Exception:  # noqa: BLE001
+    except Exception as e:  # noqa: BLE001
+        _warn_once("session_config", "db_config", e)
         return None
     if not url:
+        _warn_once("session_url", "db_url", "database_url empty")
         return None
     url = url.replace("postgresql+asyncpg://", "postgresql+psycopg://")
-    url = url.replace("postgresql://", "postgresql+psycopg://") if url.startswith("postgresql://") else url
+    if url.startswith("postgresql://") and "psycopg" not in url:
+        url = url.replace("postgresql://", "postgresql+psycopg://", 1)
     engine = sa.create_engine(url, pool_pre_ping=True, pool_size=2, max_overflow=2)
     from sqlalchemy.orm import sessionmaker
 
@@ -104,14 +127,15 @@ def _load_from_db(prompt_type: str) -> Optional[PromptTemplate]:
             example_output=row[5] or "",
             is_active=bool(row[6]),
         )
-    except Exception:  # noqa: BLE001 - 表不存在/DB 不可用时静默回落
+    except Exception as e:  # noqa: BLE001 - 表不存在/DB 不可用时静默回落
+        _warn_once(f"load_db:{prompt_type}", prompt_type, e)
         return None
     finally:
         if session is not None:
             try:
                 session.close()
-            except Exception:  # noqa: BLE001
-                pass
+            except Exception as e:  # noqa: BLE001
+                _warn_once(f"session_close:{prompt_type}", prompt_type, e)
 
 
 def get_template(prompt_type: str, *, force_refresh: bool = False) -> Optional[PromptTemplate]:
@@ -126,6 +150,8 @@ def get_template(prompt_type: str, *, force_refresh: bool = False) -> Optional[P
             return cached[1]
 
     template = _load_from_db(prompt_type) or _fallback(prompt_type)
+    if template is None:
+        _warn_once(f"no_template:{prompt_type}", prompt_type, "no template in db or code defaults")
     if template is not None:
         with _lock:
             _cache[prompt_type] = (now, template)
@@ -136,6 +162,8 @@ def invalidate() -> None:
     """清空缓存（测试用）。"""
     with _lock:
         _cache.clear()
+    with _warn_lock:
+        _warned.clear()
 
 
 class _SafeDict(dict):
@@ -146,7 +174,8 @@ class _SafeDict(dict):
 def _safe_format(text: str, kwargs: dict) -> str:
     try:
         return text.format_map(_SafeDict(kwargs))
-    except Exception:  # noqa: BLE001
+    except Exception as e:  # noqa: BLE001
+        _warn_once("safe_format", "format", e)
         return text
 
 

packages/application/viral_video/schemas.py

@@ -37,26 +37,6 @@ class ImageAnalysis(BaseModel):
     raw: str = ""
 
 
-class CoreMessage(BaseModel):
-    text: str
-    must_keep: bool = False
-    confidence: float = 0.0
-
-
-class PersonalBrand(BaseModel):
-    text: str
-    category: str = "brand"
-
-
-class IntentResult(BaseModel):
-    intent_summary: str = ""
-    core_messages: list[CoreMessage] = Field(default_factory=list)
-    personal_brands: list[PersonalBrand] = Field(default_factory=list)
-    emotion_tone: str = ""
-    missing_info: list[str] = Field(default_factory=list)
-    raw: str = ""
-
-
 class BodyPoint(BaseModel):
     text: str
     elaboration: str = ""

packages/domain/viral_video/__init__.py

@@ -0,0 +1,86 @@
+"""爆款视频领域层包（PR3 P2：从单文件转为包，保持原有对外符号不变）。"""
+
+from packages.domain.viral_video.entities import (
+    STAGE_LABELS,
+    FusionLevel,
+    PromptType,
+    StyleStrength,
+    ViralVideoJob,
+    ViralVideoStage,
+    ViralVideoStatus,
+)
+from packages.domain.viral_video.errors import (
+    ViralVideoComplianceError,
+    ViralVideoConfigError,
+    ViralVideoCreditsError,
+    ViralVideoError,
+    ViralVideoLLMError,
+    ViralVideoResourceError,
+    ViralVideoTimeoutError,
+    ViralVideoUpstreamError,
+)
+from packages.domain.viral_video.stages import (
+    PROGRESS_COPY_DONE,
+    PROGRESS_COPY_START,
+    PROGRESS_COPY_STREAMING,
+    PROGRESS_DONE,
+    PROGRESS_IMAGE_DONE,
+    PROGRESS_REVIEW,
+    PROGRESS_START,
+    PROGRESS_TRUST,
+    PROGRESS_TTS,
+    PROGRESS_UPLOAD_DONE,
+    PROGRESS_VIDEO_DONE,
+    PROGRESS_VIDEO_START,
+    STAGE_COPY_GENERATION,
+    STAGE_IMAGE_ANALYSIS,
+    STAGE_PHASE_MESSAGES,
+    STAGE_REVIEW,
+    STAGE_TRUST_CHAIN,
+    STAGE_TTS,
+    STAGE_UPLOADING,
+    STAGE_VIDEO_ANALYSIS,
+    STAGE_VIDEO_GENERATION,
+)
+
+__all__ = [
+    # entities
+    "FusionLevel",
+    "PromptType",
+    "STAGE_LABELS",
+    "StyleStrength",
+    "ViralVideoJob",
+    "ViralVideoStage",
+    "ViralVideoStatus",
+    # errors
+    "ViralVideoError",
+    "ViralVideoConfigError",
+    "ViralVideoUpstreamError",
+    "ViralVideoComplianceError",
+    "ViralVideoResourceError",
+    "ViralVideoCreditsError",
+    "ViralVideoTimeoutError",
+    "ViralVideoLLMError",
+    # stages
+    "STAGE_IMAGE_ANALYSIS",
+    "STAGE_VIDEO_ANALYSIS",
+    "STAGE_COPY_GENERATION",
+    "STAGE_REVIEW",
+    "STAGE_TRUST_CHAIN",
+    "STAGE_TTS",
+    "STAGE_VIDEO_GENERATION",
+    "STAGE_UPLOADING",
+    "STAGE_PHASE_MESSAGES",
+    "PROGRESS_START",
+    "PROGRESS_IMAGE_DONE",
+    "PROGRESS_COPY_START",
+    "PROGRESS_COPY_STREAMING",
+    "PROGRESS_COPY_DONE",
+    "PROGRESS_REVIEW",
+    "PROGRESS_TRUST",
+    "PROGRESS_TTS",
+    "PROGRESS_VIDEO_START",
+    "PROGRESS_VIDEO_DONE",
+    "PROGRESS_UPLOAD_DONE",
+    "PROGRESS_DONE",
+]

packages/domain/viral_video/entities.py

@@ -3,9 +3,10 @@
 v1.6 重大简化：Seedance 2.5 单次最长30秒，单次调用直接出片，不再分段/拼接/ffmpeg concat。
 状态机（三步分步）：
   pending -> running -> image_analyzed -> running -> copy_generated -> running -> completed
-                                 wait_user_confirm -> running -> completed (旧路径兼容)
   任意阶段 fail; 任意非终态 cancel.
   failed -> pending (retry 重置后重跑)。
+
+  意图解析(intent_parsing) 已并入脚本生成一步完成，不再单独作为阶段/状态存在。
 """
 
 from __future__ import annotations
@@ -31,7 +32,6 @@ class ViralVideoStatus(StrEnum):
     RUNNING = "running"
     IMAGE_ANALYZED = "image_analyzed"
     COPY_GENERATED = "copy_generated"
-    WAIT_USER_CONFIRM = "wait_user_confirm"
     COMPLETED = "completed"
     FAILED = "failed"
     CANCELLED = "cancelled"
@@ -40,7 +40,6 @@ class ViralVideoStatus(StrEnum):
 class ViralVideoStage(StrEnum):
     IMAGE_ANALYSIS = "image_analysis"
     VIDEO_ANALYSIS = "video_analysis"
-    INTENT_PARSING = "intent_parsing"
     SCRIPT_GENERATION = "script_generation"  # v1.6: 编导分镜脚本（融合原 copy_fusion+storyboard+review）
     REVIEW = "review"
     TTS = "tts"
@@ -62,7 +61,6 @@ class StyleStrength(StrEnum):
 
 class PromptType(StrEnum):
     IMAGE_ANALYSIS = "image_analysis"
-    INTENT_PARSING = "intent_parsing"
     SCRIPT_GENERATION = "script_generation"
     REVIEW = "review"
     VIDEO_STYLE_INTEGRATION = "video_style_integration"
@@ -72,7 +70,6 @@ class PromptType(StrEnum):
 STAGE_LABELS = {
     ViralVideoStage.IMAGE_ANALYSIS: "图片分析",
     ViralVideoStage.VIDEO_ANALYSIS: "视频风格分析",
-    ViralVideoStage.INTENT_PARSING: "意图解析",
     ViralVideoStage.SCRIPT_GENERATION: "编导脚本生成",
     ViralVideoStage.REVIEW: "合规审核",
     ViralVideoStage.TTS: "AI 配音",
@@ -112,7 +109,6 @@ class ViralVideoJob:
     video_model: str = ""
     # v1.4+ 产物
     image_analysis: dict | None = None
-    intent_result: dict | None = None
     generated_copy_text: str = ""  # v1.6: 存 voiceover_script（纯口播对白），字段名兼容
     storyboard: list | None = None  # v1.6: 存 copy_result.shots，字段名兼容
     copy_result: dict | None = None  # v1.6: 完整编导脚本结构
@@ -141,7 +137,6 @@ class ViralVideoJob:
             ViralVideoStatus.PENDING,
             ViralVideoStatus.IMAGE_ANALYZED,
             ViralVideoStatus.COPY_GENERATED,
-            ViralVideoStatus.WAIT_USER_CONFIRM,
             ViralVideoStatus.RUNNING,
         ):
             raise ValueError(f"Cannot transition from {self.status} to running")
@@ -184,17 +179,10 @@ class ViralVideoJob:
             self.storyboard = list(shots) if isinstance(shots, list) else []
         self.updated_at = datetime.now(timezone.utc)
 
-    def mark_wait_user_confirm(self, intent_result: dict) -> None:
-        if self.status != ViralVideoStatus.RUNNING:
-            raise ValueError(f"Cannot transition from {self.status} to wait_user_confirm")
-        self.status = ViralVideoStatus.WAIT_USER_CONFIRM
-        self.intent_result = intent_result
-        self.updated_at = datetime.now(timezone.utc)
-
     def resume_from_image_analyzed(self, **kwargs) -> None:
         """阶段2入口：允许从 IMAGE_ANALYZED/PENDING 首次进入，也允许从 COPY_GENERATED/COMPLETED/FAILED 重新生成文案。
 
-        重新生成时清空上一轮文案产物（copy_result/intent_result/storyboard/generated_copy_text），
+        重新生成时清空上一轮文案产物（copy_result/storyboard/generated_copy_text），
         并重置 completed_at/result_video_url/error_msg，确保前端轮询能看到新的阶段2进度。
         """
         _allowed = (
@@ -216,7 +204,6 @@ class ViralVideoJob:
                 setattr(self, k, v)
         if _is_regen:
             # 清空上一轮文案/视频产物，避免前端拿到旧数据
-            self.intent_result = None
             self.copy_result = None
             self.storyboard = None
             self.generated_copy_text = ""
@@ -252,15 +239,6 @@ class ViralVideoJob:
         self.completed_at = None
         self.credits_cost = 0.0
 
-    def resume_from_confirm(self) -> None:
-        if self.status != ViralVideoStatus.WAIT_USER_CONFIRM:
-            raise ValueError(f"Cannot resume from {self.status}")
-        _now = datetime.now(timezone.utc)
-        self.started_at = _now
-        self.heartbeat_at = _now
-        self.status = ViralVideoStatus.RUNNING
-        self.updated_at = _now
-
     def mark_completed(self, video_url: str) -> None:
         self.status = ViralVideoStatus.COMPLETED
         self.result_video_url = video_url

packages/domain/viral_video/errors.py

@@ -0,0 +1,167 @@
+"""爆款视频领域统一异常体系（PR3 P2）。
+
+所有爆款视频相关业务异常均继承 ViralVideoError，保证：
+1. 上层可统一捕获，按 code/user_message 组装前端响应；
+2. 不暴露内部栈/traceback；
+3. http_status 供 API 层映射 HTTP 状态码。
+"""
+
+from __future__ import annotations
+
+
+class ViralVideoError(Exception):
+    """爆款视频业务异常基类。"""
+
+    code: str = "viral_video_error"
+    user_message: str = "视频生成失败，请稍后重试"
+    detail: str | None = None
+    http_status: int = 500
+
+    def __init__(
+        self,
+        user_message: str | None = None,
+        detail: str | None = None,
+        code: str | None = None,
+        http_status: int | None = None,
+    ) -> None:
+        if user_message is not None:
+            self.user_message = user_message
+        self.detail = detail
+        if code is not None:
+            self.code = code
+        if http_status is not None:
+            self.http_status = http_status
+        super().__init__(self.user_message)
+
+    def __str__(self) -> str:  # pragma: no cover
+        return f"[{self.code}] {self.user_message}" + (f" :: {self.detail}" if self.detail else "")
+
+
+class ViralVideoConfigError(ViralVideoError):
+    """配置/初始化错误：缺模型、缺 API Key、依赖未就绪等。"""
+
+    code = "config_error"
+    http_status = 500
+
+    def __init__(
+        self,
+        user_message: str = "服务配置异常，请稍后重试",
+        detail: str | None = None,
+    ) -> None:
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoUpstreamError(ViralVideoError):
+    """上游模型/云服务错误（火山 Seedance、阿里 Wan、OSS 等）。"""
+
+    code = "upstream_error"
+    http_status = 502
+
+    def __init__(
+        self,
+        provider: str,
+        upstream_code: str = "unknown",
+        user_message: str = "视频生成服务暂时不可用，请稍后重试",
+        detail: str | None = None,
+        status_code: int | None = None,
+    ) -> None:
+        self.provider = provider
+        self.upstream_code = upstream_code
+        self.status_code = status_code
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoComplianceError(ViralVideoError):
+    """合规审核不通过（用户文案命中敏感/违规内容）。"""
+
+    code = "compliance_rejected"
+    http_status = 400
+
+    def __init__(
+        self,
+        user_message: str = "文案未通过合规审核，请修改后重试",
+        issues: list | None = None,
+        detail: str | None = None,
+    ) -> None:
+        self.issues: list = list(issues) if issues else []
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoResourceError(ViralVideoError):
+    """资源不存在/失效：OSS URL 过期、图片找不到、返回空文件等。"""
+
+    code = "resource_error"
+    http_status = 502
+
+    def __init__(
+        self,
+        resource_type: str = "file",
+        resource_id: str = "",
+        user_message: str = "素材失效，请重新上传后重试",
+        detail: str | None = None,
+    ) -> None:
+        self.resource_type = resource_type
+        self.resource_id = resource_id
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoCreditsError(ViralVideoError):
+    """积分不足/结算失败。"""
+
+    code = "credits_insufficient"
+    http_status = 402
+
+    def __init__(
+        self,
+        user_message: str = "积分不足，请充值后重试",
+        detail: str | None = None,
+    ) -> None:
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoTimeoutError(ViralVideoError):
+    """某阶段执行超时（LLM/渲染/上传）。"""
+
+    code = "timeout"
+    http_status = 504
+
+    def __init__(
+        self,
+        stage: str,
+        timeout_s: float = 0.0,
+        user_message: str = "处理超时，请稍后重试",
+        detail: str | None = None,
+    ) -> None:
+        self.stage = stage
+        self.timeout_s = timeout_s
+        super().__init__(user_message=user_message, detail=detail)
+
+
+class ViralVideoLLMError(ViralVideoError):
+    """LLM 调用失败/重试耗尽/解析失败。"""
+
+    code = "llm_error"
+    http_status = 502
+
+    def __init__(
+        self,
+        stage: str = "script_generation",
+        model: str = "",
+        user_message: str = "文案生成失败，请稍后重试",
+        detail: str | None = None,
+    ) -> None:
+        self.stage = stage
+        self.model = model
+        super().__init__(user_message=user_message, detail=detail)
+
+
+__all__ = [
+    "ViralVideoError",
+    "ViralVideoConfigError",
+    "ViralVideoUpstreamError",
+    "ViralVideoComplianceError",
+    "ViralVideoResourceError",
+    "ViralVideoCreditsError",
+    "ViralVideoTimeoutError",
+    "ViralVideoLLMError",
+]

packages/domain/viral_video/stages.py

@@ -0,0 +1,68 @@
+"""爆款视频阶段与进度点常量（PR3 P2）。
+
+worker/API 中硬编码的阶段字符串与进度数值集中到此文件统一维护；
+注意：Celery task name / HTTP path / WS event name 属对外契约，不在此列。
+"""
+
+from __future__ import annotations
+
+# ── 阶段标识（对齐 ViralVideoStage 但更贴合 v1.6 实际链路） ──────────────
+STAGE_IMAGE_ANALYSIS: str = "image_analysis"
+STAGE_VIDEO_ANALYSIS: str = "video_analysis"
+STAGE_COPY_GENERATION: str = "script_generation"  # v1.6 文案=编导分镜
+STAGE_REVIEW: str = "review"
+STAGE_TRUST_CHAIN: str = "trust_chain"  # #2172 信任链预热
+STAGE_TTS: str = "tts"
+STAGE_VIDEO_GENERATION: str = "rendering"
+STAGE_UPLOADING: str = "uploading"
+
+# ── 阶段中文提示 ────────────────────────────────────────────────────────
+STAGE_PHASE_MESSAGES: dict[str, str] = {
+    STAGE_IMAGE_ANALYSIS: "正在分析图片内容...",
+    STAGE_VIDEO_ANALYSIS: "正在分析参考视频风格...",
+    STAGE_COPY_GENERATION: "正在生成文案与分镜...",
+    STAGE_REVIEW: "正在进行出片前合规审核...",
+    STAGE_TRUST_CHAIN: "正在AI化人像参考...",
+    STAGE_TTS: "正在合成AI配音...",
+    STAGE_VIDEO_GENERATION: "正在生成视频（约1-3分钟）...",
+    STAGE_UPLOADING: "正在上传成片...",
+}
+
+# ── 关键进度点（0-100）────────────────────────────────────────────────
+PROGRESS_START: float = 0.0
+PROGRESS_IMAGE_DONE: float = 10.0  # 图片分析完成
+PROGRESS_COPY_START: float = 15.0  # 进入文案生成
+PROGRESS_COPY_STREAMING: float = 30.0  # 文案流式输出中
+PROGRESS_COPY_DONE: float = 45.0  # 文案生成完成
+PROGRESS_REVIEW: float = 50.0  # 合规审核
+PROGRESS_TRUST: float = 60.0  # 信任链 AI 化
+PROGRESS_TTS: float = 65.0  # TTS 合成
+PROGRESS_VIDEO_START: float = 70.0  # 开始视频生成
+PROGRESS_VIDEO_DONE: float = 95.0  # 视频生成完成
+PROGRESS_UPLOAD_DONE: float = 98.0  # 上传完成
+PROGRESS_DONE: float = 100.0  # 全流程完成
+
+
+__all__ = [
+    "STAGE_IMAGE_ANALYSIS",
+    "STAGE_VIDEO_ANALYSIS",
+    "STAGE_COPY_GENERATION",
+    "STAGE_REVIEW",
+    "STAGE_TRUST_CHAIN",
+    "STAGE_TTS",
+    "STAGE_VIDEO_GENERATION",
+    "STAGE_UPLOADING",
+    "STAGE_PHASE_MESSAGES",
+    "PROGRESS_START",
+    "PROGRESS_IMAGE_DONE",
+    "PROGRESS_COPY_START",
+    "PROGRESS_COPY_STREAMING",
+    "PROGRESS_COPY_DONE",
+    "PROGRESS_REVIEW",
+    "PROGRESS_TRUST",
+    "PROGRESS_TTS",
+    "PROGRESS_VIDEO_START",
+    "PROGRESS_VIDEO_DONE",
+    "PROGRESS_UPLOAD_DONE",
+    "PROGRESS_DONE",
+]

scripts/seed_viral_video_param_guides.py

@@ -0,0 +1,247 @@
+"""Seed viral_video_param_guides 表（PR3 P2-h）。
+
+将 worker 中硬编码的人设/结构/语言默认值灌入 DB，保证部署后查询有默认返回；
+运营可后续在后台修改，30s TTL 缓存自动生效。
+
+用法：
+    cd /root/work/xiaoxia-saas
+    PYTHONPATH=. python scripts/seed_viral_video_param_guides.py
+
+幂等：用 ON CONFLICT (guide_type, guide_key) DO UPDATE 保证重复执行安全。
+"""
+
+from __future__ import annotations
+
+import sys
+from pathlib import Path
+
+ROOT = Path(__file__).resolve().parents[1]
+sys.path.insert(0, str(ROOT))
+
+from sqlalchemy import create_engine, text  # noqa: E402
+
+SEED_DATA: list[tuple[str, str, str]] = [
+    # ── persona：人设风格 ──────────────────────────────────────────────
+    ("persona", "宝妈", "温柔贴心，多从带娃和家庭实用角度分享，语气亲切有共鸣"),
+    ("persona", "店主", "热情实在，像当面招呼客人，突出靠谱和实在优惠"),
+    ("persona", "专业顾问", "专业可信，讲清原理和效果，用事实打消顾虑"),
+    ("persona", "年轻达人", "活泼有网感，节奏轻快，金句和梗自然不尬"),
+    ("persona", "老板型IP", "以老板第一人称出镜，真诚接地气，像招呼街坊邻居一样分享，突出创业初心和靠谱"),
+    ("persona", "知识博主", "条理清晰、数据说话，干货密度高，语气专业但不枯燥"),
+    ("persona", "生活美学", "画面感强，注重氛围和质感描述，语速偏慢，文字有诗意"),
+    ("persona", "健身教练", "energetic、鼓励式口吻，强调动作要领和效果变化"),
+    ("persona", "美妆达人", "细腻讲质地和妆效，像闺蜜安利，语气亲切有感染力"),
+    ("persona", "美食博主", "色香味描述丰富，口语化带馋感，节奏轻快"),
+    ("persona", "穿搭博主", "讲搭配逻辑和场景适配，时尚但不高冷，像朋友建议"),
+    ("persona", "育儿师", "科学育儿角度，温柔坚定，给具体可操作的建议"),
+    # ── structure：爆款结构 ────────────────────────────────────────────
+    (
+        "structure",
+        "反差破局+亮明观点+还原现状",
+        "开头3秒用反差/痛点钩子抓注意力，中段亮出核心卖点或观点，结尾还原真实到店/使用场景引导行动",
+    ),
+    (
+        "structure",
+        "痛点切入+方案展示+效果对比",
+        "开头直击用户痛点场景，中间展示产品/服务解决方案，结尾用前后对比强化效果",
+    ),
+    (
+        "structure",
+        "故事引入+产品种草+行动引导",
+        "用一个真实小故事/案例引入，自然过渡到产品种草，结尾明确引导用户下一步行动",
+    ),
+    (
+        "structure",
+        "场景展示+价值输出+信任背书",
+        "开头展示使用场景让用户代入，中间输出核心价值主张，结尾用客户评价/数据等信任背书收尾",
+    ),
+    ("structure", "悬念开场+层层递进+高潮转化", "开头制造悬念引发好奇，内容层层推进保持张力，高潮处给出转化钩子"),
+    # ── language：语言提示 ─────────────────────────────────────────────
+    ("language", "zh-cn", "使用标准普通话，口语化表达"),
+    ("language", "zh-tw", "使用台湾腔中文，语气温柔亲切"),
+    ("language", "zh-hk", "使用粤语风格中文表达"),
+    ("language", "en-us", "使用美式英语，自然口语化"),
+    ("language", "en-gb", "使用英式英语"),
+    ("language", "ja-jp", "使用日语，自然口语化"),
+    ("language", "ko-kr", "使用韩语，亲切自然"),
+    # ── marketing_purpose：营销目的（前端枚举 + 常见关键词，20项）─────────
+    (
+        "marketing_purpose",
+        "获客引流",
+        "【口播获客】第一人称对镜头发声，突出到店/加粉福利和行动引导，节奏紧凑有钩子，结尾明确CTA",
+    ),
+    (
+        "marketing_purpose",
+        "账号涨粉",
+        "【涨粉内容】开头有强反差/悬念钩子抓注意力，内容有信息密度和共鸣点，结尾引导关注不生硬",
+    ),
+    (
+        "marketing_purpose",
+        "活动通知",
+        "【活动通知】开头直接说活动主题和时间，中段讲福利/优惠力度，结尾强调截止时间和参与方式，信息清晰不绕弯",
+    ),
+    (
+        "marketing_purpose",
+        "口播带货",
+        "【口播带货】第一人称对镜头说话，像真人出镜推荐好物，有真实使用体验感，突出卖点和使用效果，结尾有购买引导",
+    ),
+    (
+        "marketing_purpose",
+        "促销转化",
+        "【促销转化】强调限时/限量/专属优惠，制造紧迫感，价格/优惠信息清晰突出，有明确购买路径",
+    ),
+    (
+        "marketing_purpose",
+        "场景种草",
+        "【场景种草】在真实使用场景中展示产品/服务，自然带出卖点，让用户产生代入感和'我也想试试'的欲望",
+    ),
+    (
+        "marketing_purpose",
+        "痛点解决",
+        "【痛点解决】开头直击目标用户的具体痛点场景，中段给出解决方案和使用演示，结尾强调效果对比",
+    ),
+    (
+        "marketing_purpose",
+        "功能演示",
+        "【功能演示】以产品功能展示为主，操作步骤清晰可见，讲清楚'怎么用'和'用了有什么效果'，少废话多演示",
+    ),
+    (
+        "marketing_purpose",
+        "门店发现",
+        "【门店探店】店主或探店博主出镜，真实展示门店环境、招牌产品/服务、价格和体验感，结尾有到店引导",
+    ),
+    (
+        "marketing_purpose",
+        "到店实录",
+        "【到店实录】真实记录到店体验全过程，镜头跟着主走进店、看环境、体验服务、尝产品，节奏自然真实",
+    ),
+    (
+        "marketing_purpose",
+        "招牌体验",
+        "【招牌体验】聚焦门店/品牌的招牌产品/服务，细节展示特色卖点，突出'为什么这是招牌'，有记忆点",
+    ),
+    (
+        "marketing_purpose",
+        "同城团购",
+        "【同城团购】突出本地/同城/到店属性，讲清楚团购优惠内容、使用规则、门店位置，结尾引导下单",
+    ),
+    (
+        "marketing_purpose",
+        "品牌主张",
+        "【品牌主张】传递品牌理念和价值观，有态度有情感共鸣，画面质感高级，少硬广多故事感",
+    ),
+    (
+        "marketing_purpose",
+        "品牌故事",
+        "【品牌故事】用叙事方式讲品牌的创立初心/工艺传承/用户故事，有情感起伏，建立品牌信任",
+    ),
+    (
+        "marketing_purpose",
+        "生活方式",
+        "【生活方式】营造向往的生活场景和氛围，产品/服务自然融入生活片段，调性好看有质感，引发'想过这样的生活'的共鸣",
+    ),
+    (
+        "marketing_purpose",
+        "创意概念",
+        "【创意概念】画面有创意和视觉冲击力，概念新颖不套路，适合做品牌传播内容，让人愿意转发分享",
+    ),
+    (
+        "marketing_purpose",
+        "对话短剧",
+        "【短剧模式】必须双/多角色对话格式，台词用'角色：xxx'格式，镜头在角色间切换，有剧情冲突或反转，禁止第三人称旁白解说",
+    ),
+    (
+        "marketing_purpose",
+        "反转短剧",
+        "【反转短剧】前半段建立常规预期，后半段出人意料反转，对话推动剧情，节奏紧凑有爽感，结尾反转干脆利落",
+    ),
+    (
+        "marketing_purpose",
+        "悬念短剧",
+        "【悬念短剧】开头制造悬念或谜题，剧情层层推进吊足胃口，结尾揭晓答案，角色对话推进，不要旁白解说",
+    ),
+    (
+        "marketing_purpose",
+        "情绪短片",
+        "【情绪短片】用画面、音乐和简短台词传递情绪（治愈/感动/激励/共鸣），节奏偏慢有氛围感，文字克制留白",
+    ),
+    # ── target_customer：目标客群（前端枚举 8项）─────────────────────
+    (
+        "target_customer",
+        "小镇青年",
+        "【目标小镇青年】台词接地气有网感，贴近下沉市场生活场景，讲实在优惠和真实体验，节奏轻快不端着",
+    ),
+    (
+        "target_customer",
+        "小镇中老年",
+        "【目标小镇中老年】台词慢节奏、吐字清晰、信息直白，强调实惠耐用和健康养生，少用网络梗",
+    ),
+    (
+        "target_customer",
+        "Z世代",
+        "【目标Z世代】台词活泼有梗、节奏快，可用流行语和弹幕感表达，突出个性、有趣、社交话题性",
+    ),
+    (
+        "target_customer",
+        "精致妈妈",
+        "【目标精致妈妈】台词温柔贴心，从育儿/家庭/品质生活角度切入，强调安全、省心、性价比，有真实带娃/家居场景共鸣",
+    ),
+    (
+        "target_customer",
+        "新锐白领",
+        "【目标新锐白领】台词简洁干练，突出效率、品质、格调，讲职场/都市生活场景，少废话直接说价值",
+    ),
+    (
+        "target_customer",
+        "资深中产",
+        "【目标资深中产】台词专业有深度，强调品质、品位、身份感，调性高级克制，不浮夸不喊麦",
+    ),
+    (
+        "target_customer",
+        "都市蓝领",
+        "【目标都市蓝领】台词实在接地气，强调性价比、耐用、实惠，讲打工/租房/日常刚需场景，贴近生活",
+    ),
+    (
+        "target_customer",
+        "都市银发",
+        "【目标都市银发】台词清晰慢节奏，强调健康、实惠、方便操作，避免复杂术语和网络用语，信息直白",
+    ),
+]
+
+
+def _get_engine():
+    """获取 DB engine。优先 DATABASE_URL 环境变量；否则走应用配置（与 seed_viral_video_prompts.py 一致）。"""
+    import os
+
+    database_url = os.environ.get("DATABASE_URL")
+    if database_url:
+        url = database_url
+    else:
+        from packages.config import get_shared_settings
+
+        url = str(get_shared_settings().database_url)
+    # asyncpg → psycopg2（脚本里不能用 async driver）
+    url = url.replace("postgresql+asyncpg://", "postgresql+psycopg2://")
+    if url.startswith("postgresql://") and "psycopg" not in url:
+        url = url.replace("postgresql://", "postgresql+psycopg2://", 1)
+    return create_engine(url, pool_pre_ping=True)
+
+
+def main() -> None:
+    engine = _get_engine()
+    insert_sql = text("""
+        INSERT INTO viral_video_param_guides (guide_type, guide_key, guide_text)
+        VALUES (:gt, :gk, :gtxt)
+        ON CONFLICT (guide_type, guide_key)
+        DO UPDATE SET guide_text = EXCLUDED.guide_text, updated_at = NOW()
+        """)
+    count = 0
+    with engine.begin() as conn:
+        for gt, gk, gtxt in SEED_DATA:
+            conn.execute(insert_sql, {"gt": gt, "gk": gk, "gtxt": gtxt})
+            count += 1
+    print(f"[seed_viral_video_param_guides] upserted {count} rows")
+
+
+if __name__ == "__main__":
+    main()

tests/unit/test_domain_entities_extended.py

@@ -535,7 +535,6 @@ class TestViralVideoResumeForRegenerate:
         # 模拟已经生成过文案和视频
         job.status = ViralVideoStatus.COPY_GENERATED
         job.copy_result = {"shots": [{"x": 1}], "voiceover_script": "旧文案"}
-        job.intent_result = {"intent": "旧意图"}
         job.storyboard = [{"x": 1}]
         job.generated_copy_text = "旧文案"
         job.result_video_url = "http://old.mp4"
@@ -549,7 +548,6 @@ class TestViralVideoResumeForRegenerate:
 
         assert job.status == ViralVideoStatus.RUNNING
         assert job.copy_result is None
-        assert job.intent_result is None
         assert job.storyboard is None
         assert job.generated_copy_text == ""
         assert job.result_video_url == ""
@@ -564,14 +562,12 @@ class TestViralVideoResumeForRegenerate:
         job = ViralVideoJob(user_id="u1", images=["img1"])
         job.status = ViralVideoStatus.COMPLETED
         job.copy_result = {"shots": [], "voiceover_script": "xx"}
-        job.intent_result = {"intent": "x"}
         job.result_video_url = "http://v.mp4"
 
         job.resume_from_image_analyzed()
 
         assert job.status == ViralVideoStatus.RUNNING
         assert job.copy_result is None
-        assert job.intent_result is None
         assert job.result_video_url == ""
 
     def test_first_call_from_image_analyzed_keeps_fields(self):
@@ -588,14 +584,3 @@ class TestViralVideoResumeForRegenerate:
         assert job.status == ViralVideoStatus.RUNNING
         assert job.image_analysis == {"products": []}
         assert job.industry == "美妆"
-
-    def test_wait_user_confirm_rejected(self):
-        """wait_user_confirm 中间状态应被拒绝（前端正在编辑/确认文案）。"""
-        import pytest
-
-        from packages.domain.viral_video import ViralVideoJob, ViralVideoStatus
-
-        job = ViralVideoJob(user_id="u1", images=["img1"])
-        job.status = ViralVideoStatus.WAIT_USER_CONFIRM
-        with pytest.raises(ValueError, match="Cannot resume"):
-            job.resume_from_image_analyzed()

tests/unit/test_viral_video.py

@@ -34,7 +34,6 @@ class TestViralVideoStatus:
     def test_status_values(self):
         assert ViralVideoStatus.PENDING == "pending"
         assert ViralVideoStatus.RUNNING == "running"
-        assert ViralVideoStatus.WAIT_USER_CONFIRM == "wait_user_confirm"
         assert ViralVideoStatus.COMPLETED == "completed"
         assert ViralVideoStatus.FAILED == "failed"
         assert ViralVideoStatus.CANCELLED == "cancelled"
@@ -66,28 +65,6 @@ class TestViralVideoJobStateTransitions:
         with pytest.raises(ValueError, match="Cannot transition"):
             job.mark_running()
 
-    def test_mark_wait_user_confirm(self):
-        job = ViralVideoJob(user_id="u1", status=ViralVideoStatus.RUNNING)
-        intent = {"intent": "推广", "key_messages": ["卖点1"]}
-        job.mark_wait_user_confirm(intent)
-        assert job.status == ViralVideoStatus.WAIT_USER_CONFIRM
-        assert job.intent_result == intent
-
-    def test_mark_wait_user_confirm_from_non_running_raises(self):
-        job = ViralVideoJob(user_id="u1", status=ViralVideoStatus.PENDING)
-        with pytest.raises(ValueError, match="Cannot transition"):
-            job.mark_wait_user_confirm({})
-
-    def test_resume_from_confirm(self):
-        job = ViralVideoJob(user_id="u1", status=ViralVideoStatus.WAIT_USER_CONFIRM)
-        job.resume_from_confirm()
-        assert job.status == ViralVideoStatus.RUNNING
-
-    def test_resume_from_non_confirm_raises(self):
-        job = ViralVideoJob(user_id="u1", status=ViralVideoStatus.RUNNING)
-        with pytest.raises(ValueError, match="Cannot resume"):
-            job.resume_from_confirm()
-
     def test_mark_completed(self):
         job = ViralVideoJob(user_id="u1", status=ViralVideoStatus.RUNNING)
         job.mark_completed("https://oss.example.com/video.mp4")
@@ -140,7 +117,6 @@ class TestViralVideoStage:
         expected_order = [
             "image_analysis",
             "video_analysis",
-            "intent_parsing",
             "script_generation",
             "review",
             "tts",
@@ -157,46 +133,6 @@ class TestViralVideoStage:
 class TestViralVideoSchemas:
     """Pydantic Schema 校验测试。"""
 
-    def test_create_request_valid(self):
-        from app.schemas.viral_video import CreateViralVideoRequest
-
-        req = CreateViralVideoRequest(images=["https://example.com/img.jpg"])
-        assert req.images == ["https://example.com/img.jpg"]
-        assert req.fusion_level == "ai_polish"
-        assert req.style_strength == "medium"
-        assert req.duration == 15
-
-    def test_create_request_empty_images_raises(self):
-        from app.schemas.viral_video import CreateViralVideoRequest
-
-        with pytest.raises(ValidationError):
-            CreateViralVideoRequest(images=[])
-
-    def test_create_request_invalid_fusion_level(self):
-        from app.schemas.viral_video import CreateViralVideoRequest
-
-        with pytest.raises(ValidationError):
-            CreateViralVideoRequest(
-                images=["https://example.com/img.jpg"],
-                fusion_level="invalid_level",
-            )
-
-    def test_create_request_invalid_style_strength(self):
-        from app.schemas.viral_video import CreateViralVideoRequest
-
-        with pytest.raises(ValidationError):
-            CreateViralVideoRequest(
-                images=["https://example.com/img.jpg"],
-                style_strength="ultra",
-            )
-
-    def test_confirm_intent_request_defaults(self):
-        from app.schemas.viral_video import ConfirmIntentRequest
-
-        req = ConfirmIntentRequest()
-        assert req.confirmed_copy == ""
-        assert req.adjustments == ""
-
     def test_analyze_style_request(self):
         from app.schemas.viral_video import AnalyzeStyleRequest
 
@@ -549,7 +485,7 @@ class TestPipelineIntegration:
     ):
         """v1.6: TTS整段合成 → 上传TTS到OSS → 单次 Seedance → 上传成片。"""
         from apps.worker.worker_app.tasks.viral_video import (
-            resume_viral_video_pipeline,
+            run_viral_video_render,
         )
 
         job = ViralVideoJob(
@@ -557,7 +493,6 @@ class TestPipelineIntegration:
             images=["https://img.com/1.jpg"],
             industry="美妆",
             status=ViralVideoStatus.RUNNING,
-            intent_result={"intent": "推广"},
             duration=15,
             video_ratio="9:16",
         )
@@ -583,7 +518,7 @@ class TestPipelineIntegration:
         mock_render.return_value = ("/tmp/video.mp4", {"completion_tokens": 1000000})
         mock_upload.return_value = "https://oss.example.com/final.mp4"
 
-        result = resume_viral_video_pipeline.run("job-001")
+        result = run_viral_video_render.run("job-001")
 
         assert result["ok"] is True
         assert result["video_url"] == "https://oss.example.com/final.mp4"

tests/unit/test_viral_video_p0.py

@@ -289,19 +289,19 @@ class TestDoubaoClientVideoGen:
 # ── P0-3: resume 从 job 读 image_analysis ────────────────────────
 
 
-class TestResumeReadsImageAnalysis:
-    def test_resume_uses_persisted_image_analysis(self):
-        """resume/render pipeline 应从 job.image_analysis 读（v1.5 _run_render_pipeline 共享渲染逻辑）。"""
+class TestRenderReadsImageAnalysis:
+    def test_render_uses_persisted_image_analysis(self):
+        """render pipeline 应从 job.copy_result 读（_run_render_pipeline 共享渲染逻辑）。"""
         import inspect
 
         from apps.worker.worker_app.tasks import viral_video as vv
 
-        # v1.5 改造后 resume 委托给 _run_render_pipeline，那里读取 job.image_analysis
+        # render task 委托给 _run_render_pipeline，那里读取 job.copy_result
         src = inspect.getsource(vv._run_render_pipeline)
         assert "job.copy_result" in src
-        # resume 本身应该调用 _run_render_pipeline
-        resume_src = inspect.getsource(vv.resume_viral_video_pipeline)
-        assert "_run_render_pipeline" in resume_src
+        # run_viral_video_render 本身应该调用 _run_render_pipeline
+        render_src = inspect.getsource(vv.run_viral_video_render)
+        assert "_run_render_pipeline" in render_src
 
 
 # ============ PR1: _replace_henjin_everywhere 已删除（错别字改为 prompt NEGATIVE_RULES 禁止） ============

tests/unit/test_viral_video_p2_errors.py

@@ -0,0 +1,213 @@
+"""PR3 P2 爆款视频后端：errors/stages/param_guides 基础单测。"""
+
+from __future__ import annotations
+
+
+def test_errors_hierarchy():
+    from packages.domain.viral_video import (
+        ViralVideoComplianceError,
+        ViralVideoConfigError,
+        ViralVideoCreditsError,
+        ViralVideoError,
+        ViralVideoLLMError,
+        ViralVideoResourceError,
+        ViralVideoTimeoutError,
+        ViralVideoUpstreamError,
+    )
+
+    # 基类
+    e = ViralVideoError()
+    assert e.code == "viral_video_error"
+    assert e.http_status == 500
+    assert str(e)
+
+    # 上游错误
+    ue = ViralVideoUpstreamError("doubao", upstream_code="50411", user_message="模型不可用", status_code=400)
+    assert isinstance(ue, ViralVideoError)
+    assert ue.provider == "doubao"
+    assert ue.upstream_code == "50411"
+    assert ue.http_status == 502
+    assert ue.status_code == 400
+
+    # 合规错误带 issues
+    ce = ViralVideoComplianceError(user_message="审核未通过", issues=[{"text": "违规", "severity": "error"}])
+    assert ce.code == "compliance_rejected"
+    assert ce.http_status == 400
+    assert len(ce.issues) == 1
+
+    # 资源/积分/超时/LLM/配置
+    assert ViralVideoResourceError("video_file", "x").http_status == 502
+    assert ViralVideoCreditsError().http_status == 402
+    te = ViralVideoTimeoutError("rendering", timeout_s=180)
+    assert te.stage == "rendering"
+    assert te.http_status == 504
+    le = ViralVideoLLMError(stage="script", model="seed-2.1-lite", detail="max retries")
+    assert le.http_status == 502
+    assert le.model == "seed-2.1-lite"
+    assert ViralVideoConfigError().http_status == 500
+
+
+def test_stages_constants():
+    from packages.domain.viral_video import (
+        PROGRESS_COPY_DONE,
+        PROGRESS_COPY_START,
+        PROGRESS_COPY_STREAMING,
+        PROGRESS_DONE,
+        PROGRESS_IMAGE_DONE,
+        PROGRESS_REVIEW,
+        PROGRESS_TRUST,
+        PROGRESS_TTS,
+        PROGRESS_UPLOAD_DONE,
+        PROGRESS_VIDEO_DONE,
+        PROGRESS_VIDEO_START,
+        STAGE_COPY_GENERATION,
+        STAGE_IMAGE_ANALYSIS,
+        STAGE_PHASE_MESSAGES,
+        STAGE_REVIEW,
+        STAGE_TRUST_CHAIN,
+        STAGE_TTS,
+        STAGE_UPLOADING,
+        STAGE_VIDEO_GENERATION,
+    )
+
+    assert STAGE_IMAGE_ANALYSIS == "image_analysis"
+    assert STAGE_COPY_GENERATION == "script_generation"
+    assert STAGE_REVIEW == "review"
+    assert STAGE_TRUST_CHAIN == "trust_chain"
+    assert STAGE_VIDEO_GENERATION == "rendering"
+    assert STAGE_UPLOADING == "uploading"
+    # 进度单调递增
+    assert PROGRESS_IMAGE_DONE < PROGRESS_COPY_START < PROGRESS_COPY_STREAMING < PROGRESS_COPY_DONE
+    assert PROGRESS_COPY_DONE < PROGRESS_REVIEW < PROGRESS_TRUST < PROGRESS_TTS < PROGRESS_VIDEO_START
+    assert PROGRESS_VIDEO_START < PROGRESS_VIDEO_DONE < PROGRESS_UPLOAD_DONE <= PROGRESS_DONE
+    # 阶段中文提示
+    assert "分析" in STAGE_PHASE_MESSAGES[STAGE_IMAGE_ANALYSIS]
+    assert "审核" in STAGE_PHASE_MESSAGES[STAGE_REVIEW]
+
+
+def test_param_guides_invalid_type_returns_none():
+    from packages.application.viral_video.param_guides import get_param_guide
+
+    assert get_param_guide("bogus", "x") is None
+    assert get_param_guide("persona", "") is None
+    assert get_param_guide("persona", "   ") is None
+
+
+def test_fallback_script_honest_short(monkeypatch):
+    """兜底文案必须短、诚实、基于真实 VLM 输入。"""
+    import sys
+    from unittest.mock import MagicMock
+
+    # mock celery/db 依赖
+    for mod in ["worker_app.celery_app", "worker_app.db"]:
+        monkeypatch.setitem(sys.modules, mod, MagicMock())
+    import celery
+
+    monkeypatch.setattr(celery, "shared_task", lambda **kw: (lambda f: f))
+
+    from worker_app.tasks import viral_video as wv
+
+    from packages.domain.viral_video import ViralVideoJob
+
+    # 有 name+brand
+    j = ViralVideoJob(user_id="u", duration=15, video_ratio="9:16")
+    j.image_analysis = {"images": [{"name": "口红", "brand": "XX牌", "type": "product"}]}
+    fb = wv._fallback_script(j)
+    assert "XX牌" in fb["voiceover_script"]
+    assert "口红" in fb["voiceover_script"]
+    assert len(fb["voiceover_script"]) < 20  # 非常短，不再是营销套话
+    assert fb["shots"] and len(fb["shots"]) == 1  # 只有一个镜头
+    assert fb["shots"][0]["time_range"] == "0-15秒"
+
+    # 只有 name
+    j2 = ViralVideoJob(user_id="u", duration=10)
+    j2.image_analysis = {"images": [{"name": "面馆", "type": "store"}]}
+    fb2 = wv._fallback_script(j2)
+    assert "来看看面馆" in fb2["voiceover_script"]
+    assert "都很赞" not in fb2["voiceover_script"]  # 不再有营销套话
+
+    # 都没有
+    j3 = ViralVideoJob(user_id="u", duration=15)
+    j3.image_analysis = {"images": []}
+    fb3 = wv._fallback_script(j3)
+    assert "好东西" in fb3["voiceover_script"]
+
+    # user_copy_text 优先
+    j4 = ViralVideoJob(user_id="u", duration=15, user_copy_text="自定义文案")
+    j4.image_analysis = {"images": [{"name": "X", "brand": "Y"}]}
+    fb4 = wv._fallback_script(j4)
+    assert fb4["voiceover_script"] == "自定义文案"
+
+
+def test_video_analysis_returns_none_on_import_error(monkeypatch):
+    """ImportError 时返回 None，下游 isinstance(dict) 会跳过。"""
+    import sys
+    from unittest.mock import MagicMock
+
+    for mod in ["worker_app.celery_app", "worker_app.db"]:
+        monkeypatch.setitem(sys.modules, mod, MagicMock())
+    import celery
+
+    monkeypatch.setattr(celery, "shared_task", lambda **kw: (lambda f: f))
+
+    # 让 import viral_video.video_analyzer 抛 ImportError
+    import builtins
+
+    from worker_app.tasks import viral_video as wv
+
+    from packages.domain.viral_video import ViralVideoJob
+
+    real_import = builtins.__import__
+
+    def fake_import(name, *a, **kw):
+        if "video_analyzer" in name:
+            raise ImportError("no module")
+        return real_import(name, *a, **kw)
+
+    monkeypatch.setattr(builtins, "__import__", fake_import)
+    j = ViralVideoJob(user_id="u", reference_video_url="https://x/y.mp4")
+    res = wv._step_video_analysis(j)
+    assert res is None
+
+
+def test_seedance_prompt_uses_helpers(monkeypatch):
+    """_assemble_seedance_prompt 拆分后输出包含必要段落，且长度合理。"""
+    import sys
+    from unittest.mock import MagicMock, patch
+
+    for mod in ["worker_app.celery_app", "worker_app.db"]:
+        monkeypatch.setitem(sys.modules, mod, MagicMock())
+    import celery
+
+    monkeypatch.setattr(celery, "shared_task", lambda **kw: (lambda f: f))
+
+    from worker_app.tasks import viral_video as wv
+
+    from packages.domain.viral_video import ViralVideoJob
+
+    j = ViralVideoJob(user_id="u", duration=15, video_ratio="9:16", images=["https://x/1.jpg"])
+    copy_result = {
+        "overview": {"theme": "口红试色", "total_duration": 15, "aspect_ratio": "9:16"},
+        "scene_and_lighting": "暖光，室内美妆场景",
+        "shots": [
+            {
+                "time_range": "0-15秒",
+                "shot_type_angle_movement": "中景",
+                "voiceover": "这支口红颜色超正",
+                "reference_image_index": 0,
+                "transition": "结束",
+            }
+        ],
+        "hard_constraints": ["无水印"],
+        "negative_prompts": ["字幕"],
+    }
+    with patch("packages.domain.points_rules.get_viral_video_model_config", return_value={"provider": "doubao"}):
+        with patch.object(wv, "_shot_visual", return_value="女生涂口红特写"):
+            with patch.object(wv, "_parse_shot_seconds", return_value=(0, 15)):
+                p = wv._assemble_seedance_prompt(copy_result, j)
+    assert "【视频总览】" in p
+    assert "【分镜脚本】" in p
+    assert "【硬性约束】" in p
+    assert "【负面提示词】" in p
+    assert "@图片1" in p
+    assert "口红试色" in p

tests/unit/test_viral_video_routes.py

@@ -1,11 +1,12 @@
 """viral_video.py HTTP 端点单元测试（celery send_task 分支覆盖）。
 
 直接调用路由函数（不启动 TestClient），通过 patch 注入 repo/session/user，
-覆盖 4 个 celery_app.send_task(...) 调用点：
+覆盖三步流程 celery_app.send_task(...) 调用点：
 
-- create_viral_video (generate)    -> worker.run_viral_video_pipeline
-- retry_viral_video_job (retry)    -> worker.run_viral_video_pipeline
-- confirm_intent                   -> worker.resume_viral_video_pipeline
+- analyze_images (analyze-images)  -> worker.run_viral_video_analyze
+- generate_copy (generate-copy)    -> worker.run_viral_video_generate_copy
+- confirm_copy (confirm-copy)      -> worker.run_viral_video_render
+- retry_viral_video_job (retry)    -> worker.run_viral_video_analyze
 - analyze_style                    -> worker.run_video_style_analysis
 """
 
@@ -61,7 +62,6 @@ def _make_job(job_id: str = "job-1", user_id: str = "u1", status: str = "pending
         "completed_at": None,
         "stage": "",
         "progress": 0.0,
-        "intent_result": None,
         "image_analysis": None,
         "storyboard": None,
         "generated_copy_text": "",
@@ -86,42 +86,7 @@ def _make_job(job_id: str = "job-1", user_id: str = "u1", status: str = "pending
     return job
 
 
-# ── generate ────────────────────────────────────────────────────────────
-
-
-class TestCreateViralVideo:
-    def _req(self, **kw):
-        from app.schemas.viral_video import CreateViralVideoRequest
-
-        d = {"images": ["https://x.com/a.jpg"], "industry": "电商", "target_customer": "年轻人"}
-        d.update(kw)
-        return CreateViralVideoRequest(**d)
-
-    def test_generate_dispatches_celery_task(self):
-        from app.api.routes import viral_video as vv_mod
-
-        req = self._req()
-        user = _auth_user("u1")
-        session = MagicMock()
-        saved_job = _make_job(job_id="job-new", user_id="u1", status="pending")
-        repo = MagicMock()
-
-        def fake_save(job):
-            job.id = saved_job.id
-
-        repo.save.side_effect = fake_save
-
-        with (
-            patch.object(vv_mod, "_get_job_repo", return_value=repo),
-            patch.object(vv_mod.celery_app, "send_task") as mock_send,
-        ):
-            resp = vv_mod.create_viral_video(req, authenticated_user=user, session=session)
-
-        mock_send.assert_called_once_with("worker.run_viral_video_pipeline", args=[saved_job.id])
-        assert resp.id == saved_job.id
-
-
-# ── retry ───────────────────────────────────────────────────────────────
+# ── retry ──────────────────────────────────────────────────────────────
 
 
 class TestRetryViralVideo:
@@ -339,37 +304,6 @@ class TestRetryViralVideo:
         assert call_args.kwargs["amount"] == 7.0
 
 
-# ── confirm-intent ──────────────────────────────────────────────────────
-
-
-class TestConfirmIntent:
-    def test_confirm_intent_dispatches_resume_task(self):
-        from app.api.routes import viral_video as vv_mod
-        from app.schemas.viral_video import ConfirmIntentRequest
-
-        from packages.domain.viral_video import ViralVideoStatus
-
-        user = _auth_user("u1")
-        session = MagicMock()
-        job = _make_job(job_id="job-cfm", user_id="u1", status=ViralVideoStatus.WAIT_USER_CONFIRM)
-        repo = MagicMock()
-        repo.get.return_value = job
-        req = ConfirmIntentRequest(confirmed_copy="确认后的文案")
-
-        with (
-            patch.object(vv_mod, "_get_job_repo", return_value=repo),
-            patch.object(vv_mod.celery_app, "send_task") as mock_send,
-        ):
-            resp = vv_mod.confirm_intent("job-cfm", req, authenticated_user=user, session=session)
-
-        assert job.user_copy_text == "确认后的文案"
-        job.resume_from_confirm.assert_called_once()
-        mock_send.assert_called_once_with("worker.resume_viral_video_pipeline", args=["job-cfm"])
-        assert resp.id == "job-cfm"
-
-
-# ── analyze-style ───────────────────────────────────────────────────────
-
 
 class TestAnalyzeStyle:
     def test_analyze_style_dispatches_analysis_task(self):
@@ -474,7 +408,7 @@ class TestGenerateCopy:
         assert resp.id == "job-gc"
 
     def test_generate_copy_rejects_wrong_status(self):
-        """wait_user_confirm 等中间状态不允许调用 generate-copy（状态保护）。"""
+        """cancelled 等非预期状态不允许调用 generate-copy（状态保护）。"""
         import pytest
         from app.api.routes import viral_video as vv_mod
         from app.schemas.viral_video import GenerateCopyRequest
@@ -484,8 +418,8 @@ class TestGenerateCopy:
 
         user = _auth_user("u1")
         session = MagicMock()
-        # wait_user_confirm 属于前端在编辑/确认文案的中间状态，应拒绝重新触发生成
-        job = _make_job(job_id="job-gc2", user_id="u1", status=ViralVideoStatus.WAIT_USER_CONFIRM)
+        # cancelled 状态下不应触发生成文案
+        job = _make_job(job_id="job-gc2", user_id="u1", status=ViralVideoStatus.CANCELLED)
         repo = MagicMock()
         repo.get.return_value = job
 

tests/unit/test_viral_video_v8_bugs.py

@@ -51,7 +51,6 @@ def _make_job(job_id: str = "job-1", user_id: str = "u1", status: str = "pending
         "completed_at": None,
         "stage": "",
         "progress": 0.0,
-        "intent_result": None,
         "image_analysis": None,
         "storyboard": None,
         "copy_result": {"voiceover_script": "测试口播", "shots": [{"clip_id": 1}]},
@@ -966,7 +965,7 @@ class TestIssue2249UserParamsFix:
 
     def test_bug2_persona_style_guide_covers_boss_ip(self):
         """Bug2: _PERSONA_STYLE_GUIDE 必须覆盖'老板型IP'"""
-        from apps.worker.worker_app.tasks.viral_video import _PERSONA_STYLE_GUIDE
+        from apps.worker.worker_app.tasks.viral_video import _DEFAULT_PERSONA_HINTS as _PERSONA_STYLE_GUIDE
 
         assert "老板型IP" in _PERSONA_STYLE_GUIDE
         assert "老板" in _PERSONA_STYLE_GUIDE["老板型IP"] or "第一人称" in _PERSONA_STYLE_GUIDE["老板型IP"]
@@ -1050,13 +1049,6 @@ class TestIssue2249UserParamsFix:
         assert hasattr(job, "language")
         assert job.language == "zh-CN"
 
-    def test_bug5_language_in_create_request(self):
-        """Bug5: CreateViralVideoRequest 接受 language"""
-        from apps.api.app.schemas.viral_video import CreateViralVideoRequest
-
-        req = CreateViralVideoRequest(images=["http://a.jpg"], language="en-US")
-        assert req.language == "en-US"
-
     def test_bug5_language_in_generate_copy_request(self):
         """Bug5: GenerateCopyRequest 接受 language"""
         from apps.api.app.schemas.viral_video import GenerateCopyRequest

tests/unit/test_viral_video_wiring.py

@@ -209,7 +209,6 @@ class TestReviewWiring:
             "voiceover_script": "这款口红显白又持久",
             "shots": [{"scene_and_dialogue": "展示口红"}],
         }
-        job.intent_result = {"key_messages": ["显白", "持久"], "intent": "推广"}
 
         pass_result = ReviewResult(passed=True, score=90, issues=[], rewrite_suggestions=[])
         with patch.object(Reviewer, "review", return_value=pass_result):
@@ -228,7 +227,6 @@ class TestReviewWiring:
             "voiceover_script": "这款口红100%有效",
             "shots": [{"scene_and_dialogue": "展示"}],
         }
-        job.intent_result = {"key_messages": ["显白"], "intent": "推广"}
 
         fail_result = ReviewResult(
             passed=False,

tests/unit/test_viral_video_ws.py

@@ -106,31 +106,11 @@ class TestWorkerEmitProgress:
         assert parsed["type"] == "viral_video:failed"
         assert parsed["data"]["error"] == "oom"
 
-    def test_emit_progress_wait_user_event(self):
-        fake_r = MagicMock()
-        with patch("redis.from_url", return_value=fake_r):
-            worker_vv._emit_progress(
-                "job-4",
-                "intent_parsing",
-                35,
-                message="waiting for you",
-                event_type="viral_video:wait_user",
-            )
-        _, payload = fake_r.publish.call_args.args
-        parsed = json.loads(payload)
-        assert parsed["type"] == "viral_video:wait_user"
-
-
-# ---------------------------------------------------------------------------
-# Pure helpers on the route module
-# ---------------------------------------------------------------------------
-
 
 class TestWSHelpers:
     def test_estimate_progress_maps_status(self):
         assert vv_module._estimate_progress(_make_job(status="pending")) == 0.0
         assert vv_module._estimate_progress(_make_job(status="running")) == 5.0
-        assert vv_module._estimate_progress(_make_job(status="wait_user_confirm")) == 35.0
         assert vv_module._estimate_progress(_make_job(status="completed")) == 100.0
         assert vv_module._estimate_progress(_make_job(status="failed")) == 0.0
 
@@ -140,8 +120,6 @@ class TestWSHelpers:
         assert isinstance(msg, str) and msg
         job_failed = _make_job(status="failed", error_msg="boom")
         assert "boom" in vv_module._initial_message(job_failed)
-        job_wait = _make_job(status="wait_user_confirm")
-        assert "等待" in vv_module._initial_message(job_wait)
 
     def test_stage_from_status_falls_back(self):
         assert isinstance(vv_module._stage_from_status(_make_job(status="pending")), str)
@@ -325,16 +303,16 @@ class TestWSInitialSnapshot:
         # Session was used for both ownership check and initial snapshot.
         assert sess.close.call_count >= 2
 
-    def test_running_job_with_enum_status(self):
+    def test_image_analyzed_job_sends_snapshot(self):
         job = _make_job(
-            status=SimpleNamespace(value="wait_user_confirm"),
+            status=SimpleNamespace(value="image_analyzed"),
             user_id="user-a",
             is_terminal=False,
         )
         received, _, _ = _run_ws_handshake(job=job)
-        assert received[0]["data"]["status"] == "wait_user_confirm"
-        assert received[0]["progress"] == 35.0
-        assert "等待" in received[0]["message"]
+        assert received[0]["data"]["status"] == "image_analyzed"
+        assert received[0]["progress"] == 15.0
+        assert "图片分析" in received[0]["message"]
 
     def test_already_completed_job_sends_completion_event_and_closes(self):
         job = _make_job(