using System;
using System.Collections.Generic;
using Aging.Infrastructure.Contracts;
using log4net;

namespace Aging.Infrastructure.Drivers
{
    /// <summary>
    /// 设备驱动工厂。
    /// 根据传输协议类型和端点信息创建对应的驱动适配器实例。
    /// </summary>
    public static class DriverFactory
    {
        private static readonly ILog Log = LogManager.GetLogger(typeof(DriverFactory));

        /// <summary>
        /// 根据传输协议类型和端点创建驱动适配器
        /// </summary>
        /// <param name="deviceId">设备唯一标识符</param>
        /// <param name="transport">传输协议类型: "Tcp", "SCPI", "ModBus", "S7", "Serial"</param>
        /// <param name="endpoint">端点信息，格式: "ip:port" 或 "ip:port:extra"</param>
        /// <returns>IDeviceDriver 实例</returns>
        /// <exception cref="NotSupportedException">不支持的传输协议类型</exception>
        /// <exception cref="ArgumentException">端点格式错误</exception>
        public static IDeviceDriver CreateDriver(string deviceId, string transport, string endpoint)
        {
            return CreateDriver(deviceId, transport, endpoint, null);
        }

        /// <summary>
        /// 根据传输协议类型、端点和额外参数创建驱动适配器
        /// </summary>
        /// <param name="deviceId">设备唯一标识符</param>
        /// <param name="transport">传输协议类型: "Tcp", "SCPI", "ModBus", "S7", "Serial"</param>
        /// <param name="endpoint">端点信息，格式: "ip:port" 或 "ip:port:extra"</param>
        /// <param name="extraParams">额外参数（可选）</param>
        /// <returns>IDeviceDriver 实例</returns>
        /// <exception cref="NotSupportedException">不支持的传输协议类型</exception>
        /// <exception cref="ArgumentException">端点格式错误</exception>
        public static IDeviceDriver CreateDriver(string deviceId, string transport, string endpoint, Dictionary<string, string>? extraParams)
        {
            if (string.IsNullOrWhiteSpace(deviceId))
                throw new ArgumentNullException(nameof(deviceId));
            if (string.IsNullOrWhiteSpace(transport))
                throw new ArgumentNullException(nameof(transport));
            if (string.IsNullOrWhiteSpace(endpoint))
                throw new ArgumentNullException(nameof(endpoint));

            Log.Info($"[DriverFactory] 创建设备驱动: DeviceId={deviceId}, Transport={transport}, Endpoint={endpoint}");

            string[] parts = endpoint.Split(':');
            if (parts.Length < 2)
            {
                throw new ArgumentException($"端点格式错误，应为 'ip:port' 或 'ip:port:extra'，实际: {endpoint}");
            }

            string ip = parts[0];
            if (!int.TryParse(parts[1], out int port))
            {
                throw new ArgumentException($"端口号格式错误: {parts[1]}");
            }

            switch (transport.ToUpper())
            {
                case "TCP":
                    Log.Info($"[DriverFactory] 创建 TCP 原始通信驱动: {ip}:{port}");
                    return new TcpRawDriverAdapter(deviceId, ip, port);

                case "SCPI":
                    Log.Info($"[DriverFactory] 创建 SCPI 协议驱动: {ip}:{port}");
                    return new ScpiDriverAdapter(deviceId, ip, port);

                case "MODBUS":
                    byte slaveId = 1;
                    if (extraParams != null && extraParams.TryGetValue("slaveId", out string slaveIdStr))
                    {
                        if (!byte.TryParse(slaveIdStr, out slaveId))
                        {
                            slaveId = 1;
                        }
                    }
                    // 如果 endpoint 有第三部分，作为 slaveId
                    else if (parts.Length >= 3 && byte.TryParse(parts[2], out byte parsedSlaveId))
                    {
                        slaveId = parsedSlaveId;
                    }
                    Log.Info($"[DriverFactory] 创建 ModBus TCP 驱动: {ip}:{port} (从站: {slaveId})");
                    return new ModBusDriverAdapter(deviceId, ip, port, slaveId);

                case "S7":
                    Log.Info($"[DriverFactory] 创建 S7 PLC 驱动: {ip}:{port}");
                    return new S7DriverAdapter(deviceId, ip, port);

                case "SERIAL":
                    // TODO: 实现串口驱动适配器
                    throw new NotSupportedException("串口驱动适配器尚未实现");

                case "CAN":
                    // CAN 驱动: endpoint 格式为 "busName:nodeIndex" 如 "CAN_BUS_1:0"
                    // 统一的 CanDeviceDriver（Local 默认走 TCP NodeChannel 连模拟器）
                    Log.Info($"[DriverFactory] 创建 CAN 驱动: Endpoint={endpoint}");
                    return new CanDeviceDriver(deviceId, endpoint);

                default:
                    throw new NotSupportedException($"不支持的传输协议类型: {transport}。支持的类型: Tcp, SCPI, ModBus, S7, Serial, CAN");
            }
        }
    }
}