using IoTClient;
using IoTClient.Clients.Modbus;
using IoTClient.Common.Enums;
using IoTClient.Enums;
using IoTClient.Models;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace WCS.Application;
/// <summary>
/// Modbus
/// </summary>
public class ModbusUtil
{
    public readonly long PlcId;
    public readonly string PlcIP;
    private ModbusTcpClient _client;
    private WcsPlc _modPlc;
    private readonly object OLock = new object();
    public ModbusUtil(WcsPlc modPlc)
    {
        //测试代码
        //WCS.Application.ModbusUtil modUtil = new WCS.Application.ModbusUtil(new WCS.Application.WcsPlc() { IP = "127.0.0.1", Port = 502 });
        //var result = modUtil.GetDBValue(WCS.Application.PLCDataTypeEnum.Int, "4");
        //Console.WriteLine(result.value);
        //var result2 = modUtil.SetDBValue(WCS.Application.PLCDataTypeEnum.Int, "4", "44");
        //Console.WriteLine(result2.IsSucceed);

        PlcId = modPlc.Id;
        PlcIP = modPlc.IP;
        _modPlc = modPlc;
        _client = new ModbusTcpClient(modPlc.IP, modPlc.Port);
        _client.Open();
    }

    public bool Connected
    {
        get { return _client.Connected; }
    }
    public IoTClient.Result Open()
    {
        return _client.Open();
    }
    public IoTClient.Result Close()
    {
        return _client.Close();
    }
    /// <summary>
    /// 读取PLC值
    /// </summary>
    /// <param name="PosType">字符类型</param>
    /// <param name="Pos">偏移量/地址</param>
    /// <param name="StationNumber">站号</param>
    /// <returns></returns>
    public (IoTClient.Result, dynamic value) GetDBValue(PLCDataTypeEnum PosType, string Pos, byte StationNumber = 1)
    {
        lock (OLock)
        {
            dynamic result = null;
            switch (PosType)
            {
                case PLCDataTypeEnum.Bit:
                    result = _client.ReadCoil(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Byte:
                    result = _client.ReadDiscrete(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Short:
                    result = _client.ReadInt16(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.UShort:
                    result = _client.ReadUInt16(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Int:
                    result = _client.ReadInt32(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.UInt:
                    result = _client.ReadUInt32(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Long:
                    result = _client.ReadInt64(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.ULong:
                    result = _client.ReadUInt64(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Float:
                    result = _client.ReadFloat(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.Double:
                    result = _client.ReadDouble(Pos, StationNumber);
                    break;
                case PLCDataTypeEnum.String:
                    result = _client.ReadString(Pos, StationNumber);
                    break;
                default:
                    result = new IoTClient.Result<object>();
                    break;
            }
            return (result, result.Value);
        }
    }
    /// <summary>
    /// 批量读取PLC值
    /// </summary>
    /// <returns></returns>
    public Result<List<ModbusOutput>> GetBatchDBValue(Dictionary<string, PLCDataTypeEnum> listaddress)
    {
        lock (OLock)
        {
            var list = new List<ModbusInput>();
            foreach (var address in listaddress)
            {
                switch (address.Value)
                {
                    case PLCDataTypeEnum.Bit:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Bool,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Byte:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Byte,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Short:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Int16,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.UShort:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.UInt16,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Int:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Int32,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.UInt:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.UInt32,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Long:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Int64,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.ULong:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.UInt64,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Float:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Float,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.Double:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.Double,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    case PLCDataTypeEnum.String:
                        list.Add(new ModbusInput()
                        {
                            Address = address.Key,
                            DataType = DataTypeEnum.String,
                            FunctionCode = 3,
                            StationNumber = 1
                        });
                        break;
                    default:
                        break;
                }
            }
            return _client.BatchRead(list);
        }
    }
    /// <summary>
    /// 写入PLC值
    /// </summary>
    /// <param name="PosType">字符类型</param>
    /// <param name="Pos">偏移量/地址</param>
    /// <param name="Value">写入值</param>
    /// <param name="StationNumber">站号</param>
    /// <returns></returns>
    public IoTClient.Result SetDBValue(PLCDataTypeEnum PosType, string Pos, string Value, byte StationNumber = 1)
    {
        switch (PosType)
        {
            case PLCDataTypeEnum.Bit:
                if (!bool.TryParse(Value, out bool bit))
                {
                    if (Value == "0")
                        bit = false;
                    else if (Value == "1")
                        bit = true;
                    else
                    {
                        throw new Exception("写入值错误");
                    }
                }
                return _client.Write(Pos, bit, StationNumber);
            case PLCDataTypeEnum.Byte:
                return _client.Write(Pos, byte.Parse(Value), StationNumber);
            case PLCDataTypeEnum.Short:
                return _client.Write(Pos, short.Parse(Value), StationNumber);
            case PLCDataTypeEnum.UShort:
                return _client.Write(Pos, ushort.Parse(Value), StationNumber);
            case PLCDataTypeEnum.Int:
                return _client.Write(Pos, int.Parse(Value), StationNumber);
            case PLCDataTypeEnum.UInt:
                return _client.Write(Pos, uint.Parse(Value), StationNumber);
            case PLCDataTypeEnum.Long:
                return _client.Write(Pos, long.Parse(Value), StationNumber);
            case PLCDataTypeEnum.ULong:
                return _client.Write(Pos, ulong.Parse(Value), StationNumber);
            case PLCDataTypeEnum.Float:
                return _client.Write(Pos, float.Parse(Value), StationNumber);
            case PLCDataTypeEnum.Double:
                return _client.Write(Pos, float.Parse(Value), StationNumber);
            case PLCDataTypeEnum.String:
                return _client.Write(Pos, Value, StationNumber);
            default:
                return new IoTClient.Result();
        }
    }
}