fix(viral-video): 6 E2E bug fixes (fusion_level/concat/ingest/duplicated URL/TTS/Seedance ratio) (#2113)

Co-authored-by: xiaoxia <dev@xiaoxiajianji.com> Co-committed-by: xiaoxia <dev@xiaoxiajianji.com>
2026-10-01 05:12:35 +08:00
parent 5cefbc9c05
commit fc6ebbecb6
10 changed files with 106 additions and 20 deletions
@@ -502,8 +502,19 @@ class SQLAlchemyAssetRepository:
        return [self._to_domain(m) for m in models]

    def find_by_storage_key(self, storage_key: str) -> Asset | None:
-        """按 storage_key（对应 DB 中的 file_url）查找素材。"""
-        model = self.session.query(AssetModel).filter(AssetModel.file_url == storage_key).first()
+        """按 storage_key 查找素材。
+
+        Bug #2110: 历史数据 file_url 列可能是旧路径（assets/...），新代码统一写入
+        storage_key 列。双列 OR 查询，避免占位 asset 因路径错配导致 ingest 兜底新建
+        第二条 READY 记录，原占位卡 PROCESSING → 前端缩略图出现后消失。
+        """
+        if not storage_key:
+            return None
+        model = (
+            self.session.query(AssetModel)
+            .filter((AssetModel.storage_key == storage_key) | (AssetModel.file_url == storage_key))
+            .first()
+        )
        if model is None:
            return None
        return self._to_domain(model)