Method save_scenario

backend/store.py:117–186

保存（或更新）一个命名场景。 Parameters ---------- name: 场景名称（<=128 字符，全库唯一）。 engine: ``SimulationEngine`` 实例——用于提取资源配置。 stats: 运行统计快照（通常为 ``engine.get_stats()``）； 未传入时仅保存资源配置，run_stats 置空。 Returns -------

(
        self,
        name: str,
        engine: Any,
        stats: Optional[Dict[str, Any]] = None,
    )

    # ── 公共接口 ──────────────────────────────────────────────────────────────

    def save_scenario(
        self,
        name: str,
        engine: Any,
        stats: Optional[Dict[str, Any]] = None,
    ) -> Dict[str, Any]:
        """保存（或更新）一个命名场景。

        Parameters
        ----------
        name:
            场景名称（<=128 字符，全库唯一）。
        engine:
            ``SimulationEngine`` 实例——用于提取资源配置。
        stats:
            运行统计快照（通常为 ``engine.get_stats()``）；
            未传入时仅保存资源配置，run_stats 置空。

        Returns
        -------
        dict
            保存后的完整场景记录。
        """
        name = str(name)[:128].strip()
        if not name:
            raise ValueError("场景名称不可为空")

        scene = ScenarioManager.save(engine, name=name)
        run_stats: Dict[str, Any] = {}
        if stats is not None:
            # 仅保留决策指标与请求统计，避免写入大型原始数据
            run_stats = {
                "total_requests": stats.get("total_requests", 0),
                "accepted_requests": stats.get("accepted_requests", 0),
                "rejected_requests": stats.get("rejected_requests", 0),
                "completed_requests": stats.get("completed_requests", 0),
                "decision_metrics": stats.get("decision_metrics", {}),
                "rejection_distribution": stats.get("rejection_distribution", {}),
            }

        saved_at = datetime.now(tz=timezone.utc).isoformat()
        data_types_json = json.dumps(scene.get("data_types", []), ensure_ascii=False)
        run_stats_json = json.dumps(run_stats, ensure_ascii=False)

        with self._lock, self._conn:
            self._conn.execute(
                """INSERT INTO scenarios
                       (name, version, saved_at, is_baseline, gs_count, leo_count, geo_count, data_types, run_stats)
                   VALUES (?, ?, ?, 0, ?, ?, ?, ?, ?)
                   ON CONFLICT(name) DO UPDATE SET
                       version=excluded.version,
                       saved_at=excluded.saved_at,
                       gs_count=excluded.gs_count,
                       leo_count=excluded.leo_count,
                       geo_count=excluded.geo_count,
                       data_types=excluded.data_types,
                       run_stats=excluded.run_stats""",
                (