fix: 修复 _storage_key 无法写入 EditPlanClip（slots=True）

EditPlanClip 使用 @dataclass(slots=True)，不允许 setattr 动态添加属性。
将 _storage_key 改为存储在 clip.config 字典中，所有读取处同步修改。

- render_adapter.py: c._storage_key = sk → c.config['_storage_key'] = sk
- unified_render_service.py: getattr → config.get('_storage_key')
- gpu_direct_pipeline.py: getattr → config.get('_storage_key')

apps/worker/video_processing/gpu_direct_pipeline.py

@@ -22,7 +22,7 @@ from typing import Any, Optional
 logger = logging.getLogger(__name__)
 
 # drawtext 默认字体名（fontconfig 解析）；P4000 装好中文字体后可在 config 指定
-DEFAULT_DRAWTEXT_FONT = "sans"
+DEFAULT_DRAWTEXT_FONT = "Noto Sans CJK SC"
 
 
 def escape_drawtext_text(text: str) -> str:
@@ -156,9 +156,9 @@ def build_direct_render(
 
     # 1. 视频输入（原始素材签名 URL）
     for i, clip in enumerate(resolved_clips):
-        sk = getattr(clip, "_storage_key", None)
+        sk = (getattr(clip, "config", None) or {}).get("_storage_key")
         if not sk:
-            raise ValueError(f"clip {getattr(clip,'clip_id',i)} missing _storage_key")
+            raise ValueError(f"clip {getattr(clip, 'clip_id', i)} missing _storage_key")
         fname = f"v{i}.mp4"
         inputs[fname] = sign_asset_url(sk)
         input_args.extend(["-i", fname])
@@ -192,7 +192,7 @@ def build_direct_render(
         pre_labels.append(label)
 
     # 3. concat（全硬切；原生音频丢弃，v=1:a=0）
-    concat_in = "".join(f"[{l}]" for l in pre_labels)
+    concat_in = "".join(f"[{l}]" for _lbl in pre_labels)
     fc.append(f"{concat_in}concat=n={n}:v=1:a=0[vcat]")
     cur = "vcat"
 
@@ -277,15 +277,11 @@ def build_direct_render(
         for k, (idx, vol) in enumerate(audio_items):
             alabel = f"au{k}"
             fc.append(
-                f"[{idx}:a]aresample=44100,volume={vol:.2f},"
-                f"aformat=sample_fmts=fltp:channel_layouts=stereo[{alabel}]"
+                f"[{idx}:a]aresample=44100,volume={vol:.2f},aformat=sample_fmts=fltp:channel_layouts=stereo[{alabel}]"
             )
             mix_labels.append(alabel)
-        mix_in = "".join(f"[{l}]" for l in mix_labels)
-        fc.append(
-            f"{mix_in}amix=inputs={len(mix_labels)}:duration=first:dropout_transition=2,"
-            f"aresample=44100[afinal]"
-        )
+        mix_in = "".join(f"[{l}]" for _lbl in mix_labels)
+        fc.append(f"{mix_in}amix=inputs={len(mix_labels)}:duration=first:dropout_transition=2,aresample=44100[afinal]")
         maps.extend(["-map", "[afinal]", "-c:a", "aac", "-b:a", "128k"])
 
     # 7. 组装 ffmpeg_args + NVENC 编码

apps/worker/video_processing/render_adapter.py

@@ -599,7 +599,10 @@ class RenderAdapter:
         for c in clips:
             sk = _storage_map.get(getattr(c, "asset_id", ""))
             if sk:
-                setattr(c, "_storage_key", sk)
+                # EditPlanClip 使用 __slots__，不能 setattr，改存 config 字典
+                if not isinstance(c.config, dict):
+                    c.config = dict(c.config) if c.config else {}
+                c.config["_storage_key"] = sk
         result = render_svc.render()
 
         # 4.5 渲染后校验输出完整性

apps/worker/video_processing/unified_render_service.py

@@ -233,7 +233,7 @@ class UnifiedRenderService:
             return
         if abs(mt.brightness) > 1e-4 or abs(mt.contrast - 1.0) > 1e-4 or abs(mt.saturation - 1.0) > 1e-4:
             filters.append(
-                f"eq=brightness={mt.brightness:+.4f}:" f"contrast={mt.contrast:.4f}:saturation={mt.saturation:.4f}"
+                f"eq=brightness={mt.brightness:+.4f}:contrast={mt.contrast:.4f}:saturation={mt.saturation:.4f}"
             )
 
     @staticmethod
@@ -2217,7 +2217,7 @@ class UnifiedRenderService:
             if not bool(cfg.get("gpu_direct_enabled", True)):
                 return False
 
-            video_layers = [l for l in layers if l.role not in ("audio",)]
+            video_layers = [_lyr for _lyr in layers if l.role not in ("audio",)]
             # 只允许一个视频层，且角色为主层
             if len(video_layers) != 1:
                 return False
@@ -2247,7 +2247,7 @@ class UnifiedRenderService:
                 cg = ColorGradeConfig.from_dict(cc.get("color_grade"))
                 if cg.enabled and cg.has_effect():
                     return False
-                if not getattr(c, "_storage_key", None):
+                if not (c.config or {}).get("_storage_key"):
                     return False
             return True
         except Exception:  # noqa: BLE001
@@ -2272,16 +2272,14 @@ class UnifiedRenderService:
             from video_processing import gpu_direct_pipeline as gdp
 
             cfg = self.plan.config or {}
-            video_layer = next(l for l in layers if l.role not in ("audio",))
+            video_layer = next(_lyr for _lyr in layers if l.role not in ("audio",))
             video_clips = [c for c in video_layer.clips if c.clip_type != "audio"]
 
             # TTS：把 audio 层的 TTS 片段合并成一个文件给 P4000
             tts_merged: Path | None = None
-            audio_layer = next((l for l in layers if l.role == "audio"), None)
+            audio_layer = next((_lyr for _lyr in layers if l.role == "audio"), None)
             if audio_layer:
-                tts_clips = [
-                    c for c in audio_layer.clips if (c.config or {}).get("tts") and c.local_path.exists()
-                ]
+                tts_clips = [c for c in audio_layer.clips if (c.config or {}).get("tts") and c.local_path.exists()]
                 if tts_clips:
                     tts_merged = self._concat_audio_clips(tts_clips, tag="tts_direct")
 
@@ -2787,7 +2785,7 @@ class UnifiedRenderService:
                 b = pixel_pert.get("color_b", 0)
                 if r != 0 or g != 0 or b != 0:
                     # color_balance 参数范围 -1.0 ~ 1.0，这里用 /100 转换
-                    filters.append(f"colorbalance=rs={r/100:.3f}:gs={g/100:.3f}:bs={b/100:.3f}")
+                    filters.append(f"colorbalance=rs={r / 100:.3f}:gs={g / 100:.3f}:bs={b / 100:.3f}")
 
     @staticmethod
     def _clip_volume(clip: ResolvedClip) -> float:

tests/unit/test_render_adapter.py

@@ -666,7 +666,7 @@ class TestDownloadAssets:
             _make_clip("c2", order=1, asset_id="asset_002"),
         ]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 2
         assert "asset_001" in asset_path_map
@@ -693,7 +693,7 @@ class TestDownloadAssets:
             _make_clip("c2", order=1, asset_id="asset_002"),
         ]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 1
         assert "asset_002" in asset_path_map
@@ -714,7 +714,7 @@ class TestDownloadAssets:
             _make_clip("c1", order=0, asset_id="asset_001"),
         ]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 0
         assert len(rendered_ids) == 0
@@ -750,7 +750,7 @@ class TestDownloadAssets:
             _make_clip("c3", order=2, asset_id="asset_003"),
         ]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 2
         assert "c1" in rendered_ids
@@ -771,7 +771,7 @@ class TestDownloadAssets:
             _make_clip("c2", order=1, asset_id="asset_shared"),
         ]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 1
         assert mock_download.call_count == 1
@@ -795,7 +795,7 @@ class TestDownloadAssets:
         adapter = RenderAdapter(mock_db)
         clips = [_make_clip("c1", order=0, asset_id="asset_fallback")]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 1
         assert "c1" in rendered_ids
@@ -820,7 +820,7 @@ class TestDownloadAssets:
         adapter = RenderAdapter(mock_db)
         clips = [_make_clip("c1", order=0, asset_id="asset_no_key")]
 
-        asset_path_map, rendered_ids, failed_ids = adapter._download_assets(clips, tmp_path)
+        asset_path_map, rendered_ids, failed_ids, _storage_map = adapter._download_assets(clips, tmp_path)
 
         assert len(asset_path_map) == 0
         assert "c1" in failed_ids