using System.Data;
using Aging.Infrastructure.Contracts;
using HMI.Core.Util;
using log4net;

namespace Aging.Infrastructure.Services
{
    /// <summary>
    /// 电源端点信息，描述 Slot 映射到的具体设备通道
    /// </summary>
    public sealed class PowerEndpoint
    {
        /// <summary>
        /// 设备标识符
        /// </summary>
        public string DeviceId { get; }

        /// <summary>
        /// 通道标识
        /// </summary>
        public int ChannelId { get; }

        /// <summary>
        /// 生效版本号
        /// </summary>
        public string EffectiveVersion { get; }

        /// <summary>
        /// 初始化电源端点实例
        /// </summary>
        /// <param name="deviceId">设备标识符</param>
        /// <param name="channelId">通道标识</param>
        /// <param name="effectiveVersion">生效版本号</param>
        public PowerEndpoint(string deviceId, int channelId, string effectiveVersion)
        {
            DeviceId = deviceId ?? throw new ArgumentNullException(nameof(deviceId));
            ChannelId = channelId;
            EffectiveVersion = effectiveVersion ?? string.Empty;
        }

        /// <summary>
        /// 转换为资源键，用于资源管理器的预约和租约操作
        /// </summary>
        /// <returns>对应的资源键实例</returns>
        public ResourceKey ToResourceKey()
        {
            return new ResourceKey(DeviceId, "PowerSupply", ChannelId.ToString());
        }

        /// <inheritdoc/>
        public override string ToString() => $"{DeviceId}:CH{ChannelId}(v{EffectiveVersion})";
    }

    /// <summary>
    /// Slot-设备-通道映射解析器。
    /// 从 Plugin.DeviceConfig 的 SQLite 数据库读取 Slot-Device-Channel 映射关系，
    /// 提供根据 SlotId 和能力类型解析具体设备端点的功能。
    /// </summary>
    public sealed class SlotDeviceMappingResolver
    {
        private static readonly ILog Log = LogManager.GetLogger(typeof(SlotDeviceMappingResolver));

        /// <summary>
        /// DeviceConfig 的 SQLite 数据库文件路径
        /// </summary>
        private readonly string _deviceConfigDbPath;

        /// <summary>
        /// 初始化映射解析器实例
        /// </summary>
        /// <param name="deviceConfigDbPath">DeviceConfig 的 SQLite 数据库文件路径</param>
        public SlotDeviceMappingResolver(string deviceConfigDbPath)
        {
            _deviceConfigDbPath = deviceConfigDbPath ?? throw new ArgumentNullException(nameof(deviceConfigDbPath));
            Log.Info($"[SlotDeviceMappingResolver] 初始化完成，数据库路径: {deviceConfigDbPath}");
        }

        /// <summary>
        /// 根据 SlotId 和能力类型解析具体的电源端点。
        /// 从 slot_device_mapping 表查询匹配的最新版本映射记录。
        /// </summary>
        /// <param name="slotId">Slot 标识符</param>
        /// <param name="capability">能力类型（如 "PowerSupply"）</param>
        /// <returns>解析后的电源端点；未找到匹配映射时返回 null</returns>
        public PowerEndpoint? ResolveEndpoint(string slotId, string capability)
        {
            if (string.IsNullOrWhiteSpace(slotId))
                throw new ArgumentException("SlotId 不能为空", nameof(slotId));
            if (string.IsNullOrWhiteSpace(capability))
                throw new ArgumentException("能力类型不能为空", nameof(capability));

            SqliteHelper? sqliteHelper = null;
            try
            {
                sqliteHelper = new SqliteHelper(_deviceConfigDbPath);

                var sql = $"SELECT slot_id, capability, version, device_id, channel_id, mapping_version " +
                          $"FROM slot_device_mapping " +
                          $"WHERE slot_id = '{slotId}' AND capability = '{capability}' " +
                          $"ORDER BY mapping_version DESC LIMIT 1";

                var dataTable = sqliteHelper.GetDataTable(sql);

                if (dataTable.Rows.Count == 0)
                {
                    Log.Warn($"[SlotDeviceMappingResolver] 未找到 Slot={slotId}, Capability={capability} 的映射记录");
                    return null;
                }

                var row = dataTable.Rows[0];
                var deviceId = row["device_id"]?.ToString() ?? string.Empty;
                var channelId = Convert.ToInt32(row["channel_id"]);
                var effectiveVersion = row["mapping_version"]?.ToString() ?? string.Empty;

                var endpoint = new PowerEndpoint(deviceId, channelId, effectiveVersion);

                Log.Info($"[SlotDeviceMappingResolver] 解析映射: Slot={slotId}, Capability={capability} → {endpoint}");
                return endpoint;
            }
            catch (Exception ex)
            {
                Log.Error($"[SlotDeviceMappingResolver] 解析映射失败: Slot={slotId}, Capability={capability}, 错误: {ex.Message}", ex);
                throw;
            }
            finally
            {
                sqliteHelper?.Close();
            }
        }

        /// <summary>
        /// 获取数据库中所有的 Slot-设备-通道映射记录
        /// </summary>
        /// <returns>所有映射记录的列表</returns>
        public List<PowerEndpoint> GetAllMappings()
        {
            SqliteHelper? sqliteHelper = null;
            try
            {
                sqliteHelper = new SqliteHelper(_deviceConfigDbPath);

                var sql = "SELECT slot_id, capability, version, device_id, channel_id, mapping_version " +
                          "FROM slot_device_mapping " +
                          "ORDER BY slot_id, capability, mapping_version DESC";

                var dataTable = sqliteHelper.GetDataTable(sql);
                var results = new List<PowerEndpoint>();

                foreach (DataRow row in dataTable.Rows)
                {
                    var deviceId = row["device_id"]?.ToString() ?? string.Empty;
                    var channelId = Convert.ToInt32(row["channel_id"]);
                    var effectiveVersion = row["mapping_version"]?.ToString() ?? string.Empty;

                    results.Add(new PowerEndpoint(deviceId, channelId, effectiveVersion));
                }

                Log.Info($"[SlotDeviceMappingResolver] 获取全部映射记录，共 {results.Count} 条");
                return results;
            }
            catch (Exception ex)
            {
                Log.Error($"[SlotDeviceMappingResolver] 获取全部映射记录失败: {ex.Message}", ex);
                throw;
            }
            finally
            {
                sqliteHelper?.Close();
            }
        }

        /// <summary>
        /// 按能力类型筛选映射记录
        /// </summary>
        /// <param name="capability">能力类型（如 "PowerSupply"、"CAN" 等）</param>
        /// <returns>匹配指定能力类型的映射记录列表</returns>
        public List<PowerEndpoint> GetMappingsByCapability(string capability)
        {
            if (string.IsNullOrWhiteSpace(capability))
                throw new ArgumentException("能力类型不能为空", nameof(capability));

            SqliteHelper? sqliteHelper = null;
            try
            {
                sqliteHelper = new SqliteHelper(_deviceConfigDbPath);

                var sql = $"SELECT slot_id, capability, version, device_id, channel_id, mapping_version " +
                          $"FROM slot_device_mapping " +
                          $"WHERE capability = '{capability}' " +
                          $"ORDER BY slot_id, mapping_version DESC";

                var dataTable = sqliteHelper.GetDataTable(sql);
                var results = new List<PowerEndpoint>();

                foreach (DataRow row in dataTable.Rows)
                {
                    var deviceId = row["device_id"]?.ToString() ?? string.Empty;
                    var channelId = Convert.ToInt32(row["channel_id"]);
                    var effectiveVersion = row["mapping_version"]?.ToString() ?? string.Empty;

                    results.Add(new PowerEndpoint(deviceId, channelId, effectiveVersion));
                }

                Log.Info($"[SlotDeviceMappingResolver] 按能力类型 {capability} 筛选映射记录，共 {results.Count} 条");
                return results;
            }
            catch (Exception ex)
            {
                Log.Error($"[SlotDeviceMappingResolver] 按能力类型筛选映射记录失败: {ex.Message}", ex);
                throw;
            }
            finally
            {
                sqliteHelper?.Close();
            }
        }
    }
}