feat: 素材选取路径接入 smart_match 评分，让用过降权真正生效 (#1615)

2026-09-01 20:37:25 +08:00
parent 4aeb1d5b66
commit 9d5ae7a5bc
6 changed files with 370 additions and 2 deletions
@@ -48,6 +48,7 @@ from packages.adapters.sqlalchemy_impl.template_repository import (
    SQLAlchemyTemplateRepository,
 )
 from packages.domain.plan_generator_utils import _calc_random_start_time
+from packages.domain.smart_match import score_asset
 from packages.shared.mediakit_client import get_mediakit_client

 from .dependencies import get_draft_plan_id, get_editor_services
@@ -671,10 +672,14 @@ def create_clips_from_assets_editor(
    # 2. 获取素材实际时长（去重查询）
    unique_asset_ids = list(dict.fromkeys(asset_ids))
    asset_durations: dict[str, float] = {}
+    asset_smart_scores: dict[str, float] = {}
    for asset_id in unique_asset_ids:
        asset = asset_repo.get(asset_id)
        if asset and hasattr(asset, "duration"):
            asset_durations[asset_id] = float(asset.duration or 0.0)
+            # 计算 smart_match 综合评分，用于候选排序
+            smart_score, _ = score_asset(asset)
+            asset_smart_scores[asset_id] = smart_score

    # 3. 在内存中计算所有片段数据（使用随机起始时间，不调用MediaKit）
    # 读取素材 metadata 中持久化的历史已用区间（跨任务/跨调用去重），
@@ -740,7 +745,11 @@ def create_clips_from_assets_editor(
        }
        sorted_candidates = sorted(
            asset_ids,
-            key=lambda aid: (asset_use_counts.get(aid, 0), random.random()),
+            key=lambda aid: (
+                -asset_smart_scores.get(aid, 0.0),
+                asset_use_counts.get(aid, 0),
+                random.random(),
+            ),
        )
        for candidate in sorted_candidates:
            candidate_total = asset_durations.get(candidate, 0.0)