using EasyModbus;
using HH.WCS.Mobox3.DoubleCoin;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HH.WCS.JunzhouNongfu.device
{
    /// <summary>
    /// modbus tcp 用第三方的包
    /// </summary>
    public class ModbusHelper
    {
        public static Dictionary<string, ModbusClient> ipPort_ModbusClient = new Dictionary<string, ModbusClient>();//内存，连接上的mocbus通讯对象

        public ModbusHelper(string ip, int port)
        {
            Init(new ModbusConfigModel() { Ip = ip, Port = port });
        }

        /// <summary>
        /// modbus启动初始化
        /// </summary>
        public static void Init(ModbusConfigModel modbusConfigModel)
        {
            //配置文件读取所有的mocbus进行初始化
            try
            {
                if (modbusConfigModel == null)
                {
                    //读取配置信息失败
                    return;
                }

                var modbusClient = new ModbusClient(modbusConfigModel.Ip, modbusConfigModel.Port);
                ipPort_ModbusClient.Add($"{modbusConfigModel.Ip}:{modbusConfigModel.Port}", modbusClient);
                Link(modbusClient);
            }
            catch (Exception ex)
            {

            }
        }

        /// <summary>
        /// 连接modbus下位机
        /// </summary>
        /// <param name="modbusClient"></param>
        private static void Link(ModbusClient modbusClient)
        {
            try
            {
                modbusClient.Disconnect();
                modbusClient.Connect();
                if (modbusClient.Connected)
                {
                    //连接上
                }
                else
                {
                    //没连上
                }
            }
            catch (Exception ex)
            {

            }
        }

        /// <summary>
        /// 重连
        /// </summary>
        internal static void RestLink()
        {
            if (ipPort_ModbusClient.Count > 0)
            {
                foreach (var item in ipPort_ModbusClient)
                {
                    if (!item.Value.Connected)
                    {
                        Link(item.Value);
                    }
                }
            }
        }

        /// <summary>
        /// 读一个或多个线圈，返回一个bit真假数组
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public static bool[] ReadCoils(int address, int qty, string ip, int port = 502)
        {
            bool[] res = new bool[0];
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    res = client.ReadCoils(address, qty);
                    if (res.Length != 0)
                    {
                        //读取成功
                    }
                    else
                    {
                        //读取失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;
        }

        /// <summary>
        /// 写入单个线圈
        /// </summary>
        /// <param name="address"></param>
        /// <param name="value"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        public static bool WriteSingleCoil(int address, bool value, string ip, int port = 502)
        {
            var res = false;
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    client.WriteSingleCoil(address, value);
                    res = value == client.ReadCoils(address, 1)[0];
                    if (res)
                    {
                        //写入成功
                    }
                    else
                    {
                        //写入失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;
        }
        /// <summary>
        /// 写入多个线圈
        /// </summary>
        /// <param name="address"></param>
        /// <param name="values"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        public static bool WriteMultipleCoils(int address, bool[] values, string ip, int port = 502)
        {
            var res = false;
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    client.WriteMultipleCoils(address, values);
                    var dataRead = client.ReadCoils(address, values.Length);
                    res = values.SequenceEqual(dataRead);
                    if (res)
                    {
                        //写入成功
                    }
                    else
                    {
                        //写入失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;

        }

        /// <summary>
        /// 批量读取或单独读取保持寄存器，返回的是32位int数组
        /// </summary>
        /// <param name="address">读取起始位</param>
        /// <param name="qty">读取的数量</param>
        /// <param name="ip">IP地址</param>
        /// <param name="port">端口号</param>
        /// <returns></returns>
        public static int[] ReadHoldingRegisters(int address, int qty, string ip, int port = 502)
        {
            int[] res = new int[0];
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    //一个寄存器是16位，返回2个int类型
                    res = client.ReadHoldingRegisters(address, qty);
                    if (res.Length != 0)
                    {
                        //读取成功
                    }
                    else
                    {
                        //读取失败
                    }
                }
                catch (Exception ex)
                {
                    //如果请求数量超出保持寄存器的最大数据行数，会报错
                    LogHelper.Info($"发生了异常:{ex.Message},IP:{ip},Port:{port}", "Error");
                }
            }
            else
            {
                LogHelper.Info($"未找到Modbus设备实例对象:IP:{ip},Port:{port}");
            }
            return res;
        }

        /// <summary>
        /// 写入单个寄存器数据
        /// </summary>
        /// <param name="address"></param>
        /// <param name="value"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        public static bool WriteSingleRegister(int address, int value, string ip, int port = 502)
        {
            var res = false;
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    client.WriteSingleRegister(address, value);
                    res = value == client.ReadHoldingRegisters(address, 1)[0];
                    if (res)
                    {
                        //写入成功
                    }
                    else
                    {
                        //写入失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;
        }

        /// <summary>
        /// 写入多个寄存器数据
        /// </summary>
        /// <param name="address"></param>
        /// <param name="values"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        public static bool WriteMultipleRegisters(int address, int[] values, string ip, int port = 502)
        {
            var res = false;
            var client = GetModbusClient(ip, port);
            var log = string.Join(",", values.Select(x => x.ToString()));
            if (client != null && client.Connected)
            {
                try
                {
                    client.WriteMultipleRegisters(address, values);
                    var dataRead = client.ReadHoldingRegisters(address, values.Length);
                    res = values.SequenceEqual(dataRead);
                    if (res)
                    {
                        LogHelper.Info($"写入成功,IP:{ip},Port:{port},{log}");
                    }
                    else
                    {
                        LogHelper.Info($"写入失败,IP:{ip},Port:{port},{log}");
                    }
                }
                catch (Exception ex)
                {
                    LogHelper.Info($"发生了异常:{ex.Message},IP:{ip},Port:{port},{log}","Error");
                }
            }
            else
            {
                LogHelper.Info($"未配置的设备信息,IP:{ip},Port:{port},{log}");
            }
            return res;
        }

        /// <summary>
        /// 读一个或多个离散输入，返回一个bit真假数组
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public static bool[] ReadDiscreteInputs(int address, int qty, string ip, int port = 502)
        {
            bool[] res = new bool[0];
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    res = client.ReadDiscreteInputs(address, qty);
                    if (res.Length != 0)
                    {
                        //读取成功
                    }
                    else
                    {
                        //读取失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;

        }

        /// <summary>
        /// 读一个或多个输入寄存器，返回一个int32位数组
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public static int[] ReadInputRegisters(int address, int qty, string ip, int port = 502)
        {
            int[] res = new int[0];
            var client = GetModbusClient(ip, port);
            if (client != null && client.Connected)
            {
                try
                {
                    res = client.ReadInputRegisters(address, qty);
                    if (res.Length != 0)
                    {
                        //读取成功
                    }
                    else
                    {
                        //读取失败
                    }
                }
                catch (Exception ex)
                {

                }
            }
            else
            {

            }
            return res;
        }

        /// <summary>
        /// 获取modbus通讯对象
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        private static ModbusClient GetModbusClient(string ip, int port)
        {
            if (ipPort_ModbusClient.ContainsKey($"{ip}:{port}"))
            {
                return ipPort_ModbusClient[$"{ip}:{port}"];
            }
            else
            {
                return null;
            }
        }

        /// <summary>
        /// 通过Modbus协议连接下位机时需要的model，应该放在model层，这里我懒了
        /// </summary>
        public class ModbusConfigModel
        {
            public string Ip { set; get; }//IP地址
            public int Port { set; get; }//端口号
        }
    }
}