"""
sys_strategy_workbench_snapshot 表 Model。

命名约定：表中列 ``version`` 为工作台快照整型版本号（一条快照一行）；
``version_id`` / ``v{n}`` 仅作展示用字符串。与磁盘模拟产物 ``output_version`` 无关。

JSON 聚合列在 schema 中为 ``reports``；读出行上同时提供 ``result_report`` 键（与 ``reports`` 同一 dict），便于调用方沿用原有命名。
"""

import json
import threading
from datetime import datetime
from typing import Any, Dict, List, Optional

from core.infra.db import DbBaseModel
from core.tables.ui_bff.strategy_workbench_snapshot.schema import schema as _schema

COL_SETTINGS_FP = "settings_finger_print_id"
COL_ENV_FP = "env_fingerprint_id"
COL_REPORTS = "reports"


class SysStrategyWorkbenchSnapshotModel(DbBaseModel):
    """策略工作台快照版本表 Model（表名 sys_strategy_workbench_snapshot）。"""
    _table_ready = False
    _table_ready_lock = threading.Lock()

    def __init__(self, db=None):
        super().__init__(_schema["name"], db)

    @staticmethod
    def _coerce_json_dict(raw: Any) -> Dict[str, Any]:
        if isinstance(raw, dict):
            return dict(raw)
        if isinstance(raw, str):
            try:
                parsed = json.loads(raw)
            except Exception:
                return {}
            return dict(parsed) if isinstance(parsed, dict) else {}
        return {}

    def _ensure_table_ready(self) -> None:
        if self.__class__._table_ready:
            return
        with self.__class__._table_ready_lock:
            if self.__class__._table_ready:
                return
            exists = False
            try:
                exists = self.db.is_table_exists(self.table_name)
            except Exception:
                exists = False
            if not exists:
                self.db.schema_manager.create_table_with_indexes(self.schema, self.db.get_connection)
            self.__class__._table_ready = True

    def load_by_strategy_version(
        self, strategy_name: str, version: int
    ) -> Optional[Dict[str, Any]]:
        self._ensure_table_ready()
        row = self.load_one("strategy_name = %s AND version = %s", (strategy_name, int(version)))
        return self._normalize_row(row) if row else None

    def touch_version_updated_at(self, strategy_name: str, version: int) -> int:
        """仅刷新 ``updated_at``（V2-09 apply-settings 落盘后与会话对齐）。"""
        self._ensure_table_ready()
        return self.execute_raw_update(
            (
                f"UPDATE {self.table_name} SET updated_at = %s "
                "WHERE strategy_name = %s AND version = %s"
            ),
            (datetime.now(), str(strategy_name), int(version)),
        )

    def list_by_strategy(self, strategy_name: str, limit: int = 100) -> List[Dict[str, Any]]:
        self._ensure_table_ready()
        safe_limit = max(1, min(int(limit or 100), 500))
        rows = self.load(
            "strategy_name = %s",
            (strategy_name,),
            order_by="version DESC",
            limit=safe_limit,
        )
        return [self._normalize_row(row) for row in rows]

    def _normalize_row(self, row: Dict[str, Any]) -> Dict[str, Any]:
        out = dict(row or {})
        out["settings_snapshot"] = self._coerce_json_dict(out.get("settings_snapshot"))
        blob = self._coerce_json_dict(out.get(COL_REPORTS))
        out[COL_REPORTS] = blob
        out["result_report"] = blob
        if "version" in out:
            out["version"] = int(out.get("version") or 0)
        return out

    def get_next_version(self, strategy_name: str) -> int:
        self._ensure_table_ready()
        latest = self.load(
            "strategy_name = %s",
            (strategy_name,),
            order_by="version DESC",
            limit=1,
        )
        if not latest:
            return 1
        current = latest[0].get("version", 0) or 0
        return int(current) + 1

    def create_snapshot(
        self,
        strategy_name: str,
        settings_snapshot: Dict[str, Any],
        result_report: Optional[Dict[str, Any]] = None,
        settings_finger_print_id: str = "",
        env_fingerprint_id: str = "",
    ) -> Dict[str, Any]:
        self._ensure_table_ready()
        version = self.get_next_version(strategy_name)
        now = datetime.now()
        payload = {
            "strategy_name": strategy_name,
            "version": version,
            "settings_snapshot": settings_snapshot or {},
            COL_REPORTS: result_report or {},
            COL_SETTINGS_FP: str(settings_finger_print_id or ""),
            COL_ENV_FP: str(env_fingerprint_id or ""),
            "created_at": now,
            "updated_at": now,
        }
        self.upsert_one(payload, unique_keys=["strategy_name", "version"])
        return {"strategy_name": strategy_name, "version": version}

    def update_result_report(
        self,
        strategy_name: str,
        version: int,
        result_report: Dict[str, Any],
        settings_finger_print_id: str = "",
        env_fingerprint_id: str = "",
    ) -> int:
        """更新聚合 JSON（物理列 ``reports``）。"""
        self._ensure_table_ready()
        current = self.load_by_strategy_version(strategy_name, version)
        if not current:
            return 0
        target_settings_fp = (
            str(settings_finger_print_id)
            if settings_finger_print_id is not None and str(settings_finger_print_id) != ""
            else str(current.get(COL_SETTINGS_FP) or "")
        )
        target_env_fp = (
            str(env_fingerprint_id)
            if env_fingerprint_id is not None and str(env_fingerprint_id) != ""
            else str(current.get(COL_ENV_FP) or "")
        )
        return self.execute_raw_update(
            (
                f"UPDATE sys_strategy_workbench_snapshot "
                f"SET {COL_REPORTS} = %s, {COL_SETTINGS_FP} = %s, {COL_ENV_FP} = %s, updated_at = %s "
                "WHERE strategy_name = %s AND version = %s"
            ),
            (
                json.dumps(result_report or {}, ensure_ascii=False),
                target_settings_fp,
                target_env_fp,
                datetime.now(),
                strategy_name,
                int(version),
            ),
        )

    def list_by_strategy_fingerprints(
        self,
        strategy_name: str,
        *,
        settings_finger_print_id: str = "",
        env_fingerprint_id: str = "",
        limit: int = 100,
    ) -> List[Dict[str, Any]]:
        """
        按指纹列匹配。

        - 若 **同时** 传入 settings_fp 与 env_fp：**两条必须同时相等（AND）**，才是 DbCache 语义下的命中。
        - 若仅传其一：按单列相等筛选（调试或迁移脚本用途）。
        """
        self._ensure_table_ready()
        safe_limit = max(1, min(int(limit or 100), 500))
        settings_fp = str(settings_finger_print_id or "").strip()
        env_fp = str(env_fingerprint_id or "").strip()
        if settings_fp and env_fp:
            where = (
                f"strategy_name = %s AND {COL_SETTINGS_FP} = %s AND {COL_ENV_FP} = %s"
            )
            params = (strategy_name, settings_fp, env_fp)
        elif settings_fp:
            where = f"strategy_name = %s AND {COL_SETTINGS_FP} = %s"
            params = (strategy_name, settings_fp)
        elif env_fp:
            where = f"strategy_name = %s AND {COL_ENV_FP} = %s"
            params = (strategy_name, env_fp)
        else:
            return []
        rows = self.load(where, params, order_by="version DESC", limit=safe_limit)
        return [self._normalize_row(row) for row in rows]

    def delete_version_row(self, strategy_name: str, version: int) -> int:
        """删除指定策略版本行（``strategy_name`` + ``version``）。"""
        self._ensure_table_ready()
        return self.delete_one("strategy_name = %s AND version = %s", (strategy_name, int(version)))

    def list_versions_asc(self, strategy_name: str, *, limit: int = 500) -> List[Dict[str, Any]]:
        """同一策略下按 ``version`` 升序（用于淘汰最早版本）。"""
        self._ensure_table_ready()
        safe_limit = max(1, min(int(limit or 500), 1000))
        rows = self.load(
            "strategy_name = %s",
            (strategy_name,),
            order_by="version ASC",
            limit=safe_limit,
        )
        return [self._normalize_row(row) for row in rows]
