"""陕西局 JSON 适配入口；真实接口路径由同事提供，不猜测路径。"""
import asyncio

import config
from algorithms.main_fan.models import Device, MonitorPoint, OperatingSeries, SwitchRecord, FanStateRecord


def items_of(value):
    """显式支持 items 或 data.items/list；其他响应要求补充接口适配。"""
    if isinstance(value, dict) and "data" in value:
        value = value["data"]
    if isinstance(value, dict):
        value = value.get("items")
    if not isinstance(value, list):
        raise ValueError("业务接口未返回 items 数组，请按对方实际响应补充字段适配")
    return value


async def fetch(gateway, agent_code, mine_code):
    paths = {kind: config.get_str(key) for kind, key in {
        "devices": "MAIN_FAN_DEVICES_PATH", "points": "MAIN_FAN_POINTS_PATH", "files": "MAIN_FAN_REPORTS_PATH",
        "operating_series":"MAIN_FAN_SERIES_PATH", "switch_records":"MAIN_FAN_SWITCHES_PATH",
        "fan_state_records":"MAIN_FAN_OPERATION_LOG_PATH"}.items()}
    selected = [(kind, path) for kind, path in paths.items() if path]
    if not selected:
        raise ValueError("尚未配置主通风机设备、测点或报告目录接口路径")
    values = await asyncio.gather(*(gateway.proxy(agent_code, path, params={"mineCode": mine_code}) for _, path in selected))
    result = {kind: [] for kind in paths}
    for (kind, _), value in zip(selected, values):
        rows = items_of(value)
        schema = {"devices": Device, "points": MonitorPoint,"operating_series":OperatingSeries,
                  "switch_records":SwitchRecord,"fan_state_records":FanStateRecord}.get(kind)
        result[kind] = [schema.model_validate(r).model_dump(mode="json") for r in rows] if schema else rows
    return result