refactor: 删除generation.py中legacy渲染引擎分支，统一走unified

apps/worker/worker_app/tasks/generation.py

@@ -146,7 +146,6 @@ from video_processing.oss_helpers import (
     get_signed_download_url,
     upload_to_oss,
 )
-from video_processing.render_engine_resolver import ENGINE_LEGACY, ENGINE_UNIFIED
 from video_processing.unified_render_service import UnifiedRenderService
 
 # ── 虚拟 Plan / Clip（内存中构建，不写数据库） ────────────────────────────────
@@ -1018,161 +1017,6 @@ def _load_template_plan_config(template_id: str) -> dict:
         return {}
 
 
-# ── 渲染引擎选择 ─────────────────────────────────────────────────────────────
-
-
-def _resolve_render_engine(user_id: str) -> str:
-    """根据 Feature Flag 决定使用哪个渲染引擎。
-
-    Returns:
-        "legacy" 或 "unified"
-    """
-    try:
-        from video_processing.render_engine_resolver import get_render_engine_resolver
-
-        resolver = get_render_engine_resolver()
-        engine = resolver.get_engine(user_id=user_id)
-        # 灰度期间打印详细 flag 配置，便于排查
-        config = resolver.get_config_snapshot()
-        logger.info(
-            "[渲染引擎] flag 解析: user_id=%s engine=%s enabled=%s percentage=%s whitelist=%d default=%s",
-            user_id,
-            engine,
-            config.get("enabled"),
-            config.get("percentage"),
-            len(config.get("whitelist", [])),
-            config.get("default_engine"),
-        )
-        return engine
-    except Exception as exc:
-        # 异常时 fallback 到 legacy（保守策略，与 edit_plan_generation 一致）
-        logger.warning("获取渲染引擎配置失败，fallback 到 legacy: %s", exc, exc_info=True)
-        return ENGINE_LEGACY
-
-
-# ── 旧引擎渲染（FFmpeg filter_complex） ────────────────────────────────────────
-
-
-def _render_with_legacy_engine(
-    task_id: str,
-    virtual_clips: list[_VirtualClip],
-    asset_path_map: dict[str, Path],
-    work_dir: Path,
-    output_path: Path,
-) -> tuple[float, int]:
-    """旧引擎渲染路径：手动构建 FFmpeg filter_complex 命令。
-
-    说明：generate_video 任务使用虚拟 clips（无 EditPlan 数据库记录），
-    因此无法直接复用 VideoComposeService。这里手动构建等价的 filter_complex
-    命令，与旧引擎行为一致（scale → crop → setpts → trim → setpts，
-    无 fps 归一化，保持原帧率）。
-
-    支持模式：one_take / pip / voice_over / voice_pip
-    - 所有模式统一走 concat 滤镜（与旧引擎多片段逻辑一致）
-
-    Returns:
-        (duration_seconds, file_size_bytes)
-    """
-    import subprocess
-
-    main_clips = [
-        c
-        for c in virtual_clips
-        if c.clip_type in ("main", "b_roll", "background")
-        or (c.clip_type == "main" and c.config.get("role") == "b_roll")
-    ]
-    if not main_clips:
-        main_clips = virtual_clips[:1]
-
-    input_args: list[str] = []
-    video_filters: list[str] = []
-    audio_filters: list[str] = []
-
-    for i, clip in enumerate(main_clips):
-        local_path = asset_path_map.get(clip.asset_id)
-        if not local_path:
-            continue
-        input_args.extend(["-i", str(local_path)])
-
-        duration = clip.duration or 0.0
-
-        # 视频滤镜：scale → crop → setpts → trim → setpts（与旧引擎一致）
-        vf = (
-            f"[{i}:v]"
-            f"scale={OUTPUT_WIDTH}:{OUTPUT_HEIGHT}:force_original_aspect_ratio=increase,"
-            f"crop={OUTPUT_WIDTH}:{OUTPUT_HEIGHT},"
-            f"setpts=PTS-STARTPTS,"
-            f"trim=0:{duration:.3f},"
-            f"setpts=PTS-STARTPTS"
-            f"[v{i}]"
-        )
-        video_filters.append(vf)
-
-        # 音频滤镜：atrim → asetpts
-        af = f"[{i}:a]atrim=0:{duration:.3f},asetpts=PTS-STARTPTS[a{i}]"
-        audio_filters.append(af)
-
-    n = len(main_clips)
-
-    if n == 1:
-        video_label = "[v0]"
-        audio_label = "[a0]"
-    else:
-        # concat 视频
-        v_inputs = "".join(f"[v{i}]" for i in range(n))
-        video_filters.append(f"{v_inputs}concat=n={n}:v=1:a=0[outv]")
-        # concat 音频
-        a_inputs = "".join(f"[a{i}]" for i in range(n))
-        audio_filters.append(f"{a_inputs}concat=n={n}:v=0:a=1[outa]")
-        video_label = "[outv]"
-        audio_label = "[outa]"
-
-    # 组装 filter_complex
-    fc_parts = video_filters + audio_filters
-    filter_complex = ";".join(fc_parts)
-
-    command = [
-        FFMPEG_BIN,
-        "-y",
-        *input_args,
-        "-filter_complex",
-        filter_complex,
-        "-map",
-        video_label,
-        "-map",
-        audio_label,
-        "-c:v",
-        "libx264",
-        "-crf",
-        "23",
-        "-preset",
-        "medium",
-        "-c:a",
-        "aac",
-        "-b:a",
-        "192k",
-        "-movflags",
-        "+faststart",
-        str(output_path),
-    ]
-
-    logger.info("[task_id=%s] [渲染] legacy 引擎 FFmpeg 开始: clips=%d", task_id, n)
-    try:
-        run_ffmpeg(command)
-    except subprocess.CalledProcessError as e:
-        logger.error(
-            "[task_id=%s] [渲染] legacy 引擎 FFmpeg 失败: %s\nfilter_complex: %s",
-            task_id,
-            e,
-            filter_complex[:500],
-        )
-        raise
-
-    file_size = output_path.stat().st_size if output_path.exists() else 0
-    duration = probe_duration(output_path)
-    return duration, file_size
-
-
 # ── generate_video 阶段子函数 ─────────────────────────────────────────────────
 
 
@@ -1299,59 +1143,45 @@ def _render_video(
         total_duration,
     )
 
-    # 选择渲染引擎
-    engine = _resolve_render_engine(user_id) if user_id else ENGINE_UNIFIED
-    logger.info("[task_id=%s] [渲染] 引擎选择: %s (user_id=%s)", task_id, engine, user_id)
-
     render_start = time.monotonic()
     render_output_path = temp_path / f"rendered-{task_id}.mp4"
 
-    if engine == ENGINE_LEGACY:
-        render_duration, _ = _render_with_legacy_engine(
-            task_id=task_id,
-            virtual_clips=virtual_clips,
-            asset_path_map=asset_path_map,
-            work_dir=temp_path,
-            output_path=render_output_path,
-        )
-    else:
-        logger.info("[task_id=%s] [渲染] unified 引擎 FFmpeg 渲染开始", task_id)
+    logger.info("[task_id=%s] [渲染] unified 引擎 FFmpeg 渲染开始", task_id)
 
-        # ── 准备 BGM 音频 ──
-        bgm_path: str | None = None
-        plan_config = virtual_plan.config or {}
-        bgm_config = plan_config.get("bgm", {}) or {}
-        if bgm_config.get("enabled", False):
-            try:
-                bgm_path = _prepare_bgm_track(
-                    bgm_config=bgm_config,
-                    temp_path=temp_path,
-                    task_id=task_id,
-                )
-            except Exception as bgm_err:
-                logger.warning("[task_id=%s] [BGM] 准备失败，跳过BGM: %s", task_id, bgm_err)
-                bgm_path = None
+    # ── 准备 BGM 音频 ──
+    bgm_path: str | None = None
+    plan_config = virtual_plan.config or {}
+    bgm_config = plan_config.get("bgm", {}) or {}
+    if bgm_config.get("enabled", False):
+        try:
+            bgm_path = _prepare_bgm_track(
+                bgm_config=bgm_config,
+                temp_path=temp_path,
+                task_id=task_id,
+            )
+        except Exception as bgm_err:
+            logger.warning("[task_id=%s] [BGM] 准备失败，跳过BGM: %s", task_id, bgm_err)
+            bgm_path = None
 
-        render_service = UnifiedRenderService(
-            plan=virtual_plan,
-            clips=virtual_clips,
-            asset_path_map=asset_path_map,
-            work_dir=temp_path,
-            output_width=OUTPUT_WIDTH,
-            output_height=OUTPUT_HEIGHT,
-            output_fps=int(OUTPUT_FPS),
-            asr_service=get_asr_service(),
-            bgm_path=bgm_path,
-        )
-        render_result = render_service.render()
-        render_output_path = render_result.output_path
-        render_duration = render_result.duration
+    render_service = UnifiedRenderService(
+        plan=virtual_plan,
+        clips=virtual_clips,
+        asset_path_map=asset_path_map,
+        work_dir=temp_path,
+        output_width=OUTPUT_WIDTH,
+        output_height=OUTPUT_HEIGHT,
+        output_fps=int(OUTPUT_FPS),
+        asr_service=get_asr_service(),
+        bgm_path=bgm_path,
+    )
+    render_result = render_service.render()
+    render_output_path = render_result.output_path
+    render_duration = render_result.duration
 
     render_elapsed = time.monotonic() - render_start
     logger.info(
-        "[task_id=%s] [渲染] %s 引擎完成: 耗时=%.1fs, 时长=%.2fs",
+        "[task_id=%s] [渲染] unified 引擎完成: 耗时=%.1fs, 时长=%.2fs",
         task_id,
-        engine,
         render_elapsed,
         render_duration,
     )