using EasyModbus;
using HH.WCS.ZhongCeJinTan.util;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
using static HH.WCS.ZhongCeJinTan.device.TcpServer;

namespace HH.WCS.ZhongCeJinTan.device
{
    internal class ModbusHelper
    {
        private static Dictionary<string, ModbusClient> clients = new Dictionary<string, ModbusClient>();

        /// <summary>
        /// 读线圈
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        internal bool[] ReadCoils(int address, int qty, string ip, int port = 502) {
            bool[] res = new bool[0];
            LogHelper.Info($"ReadCoils:SendMsg:Addr:{address},Qty:{qty},Ip:{ip},Port:{port}", "ModBus");
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                client.ConnectionTimeout = 3500;
                try
                {
                    res = client.ReadCoils(address, qty);
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            LogHelper.Info($"ReadCoils:ReqMsg:{JsonConvert.SerializeObject(res)},Addr:{address},Ip:{ip},Port:{port}", "ModBus");
            return res;
        }
        /// <summary>
        /// 读离散输入
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        internal bool[] ReadDiscreteInputs(int address, int qty, string ip, int port = 502) {
            bool[] res = new bool[0];
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                try {
                    res = client.ReadDiscreteInputs(address, qty);
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;

        }

        static object ReadHoldingRegistersLock = new object();
        /// <summary>
        /// 读保持寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        internal static int[] ReadHoldingRegisters(int address, int qty) {
            int[] res = new int[0];
            lock (ReadHoldingRegistersLock)
            {
                LogHelper.Info($"ReadHoldingRegisters:SendMsg:Addr:{address},Qty:{qty},Ip:{TmIp},Port:{TmPort}", "ModBus");

                var client = GetClient(TmIp, TmPort);
                if (client != null && client.Connected)
                {
                    client.ConnectionTimeout = 5000;
                    try
                    {
                        res = client.ReadHoldingRegisters(address, qty);
                        client.Disconnect();
                    }
                    catch (Exception ex)
                    {
                        //LogHelper.Error(ex.Message, ex);
                        LogHelper.Info($"ReadHoldingRegisters：Error:{ex.Message}");
                    }
                }
                LogHelper.Info($"ReadHoldingRegisters:ReqMsg:{JsonConvert.SerializeObject(res)},Addr:{address},Ip:{TmIp},Port:{TmPort}", "ModBus");
            }
            return res;
        }
        /// <summary>
        /// 读输入寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        internal int[] ReadInputRegisters(int address, int qty, string ip, int port = 502) {
            int[] res = new int[0];
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                try {
                    res = client.ReadInputRegisters(address, qty);
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;

        }
        /// <summary>
        /// 写单个线圈
        /// </summary>
        /// <param name="address"></param>
        /// <param name="value"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        internal bool WriteSingleCoil(int address, bool value, string ip, int port = 502) {
            var res = false;
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                try {
                    client.WriteSingleCoil(address, value);
                    res = true;
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;

        }
        /// <summary>
        /// 写多个线圈
        /// </summary>
        /// <param name="address"></param>
        /// <param name="values"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        internal bool WriteMultipleCoils(int address, bool[] values, string ip, int port = 502) {
            var res = false;
            LogHelper.Info($"WriteMultipleCoils:SendMsg:Addr:{address},Values:{values},Ip:{ip},Port:{port}","ModBus");
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                client.ConnectionTimeout = 3500;
                try {
                    client.WriteMultipleCoils(address, values);
                    res = true;
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            LogHelper.Info($"WriteMultipleCoils:ReqMsg:{JsonConvert.SerializeObject(res)},Addr:{address},Values:{values},Ip:{ip},Port:{port}", "ModBus");
            return res;
        }


        static string TmIp = Settings.TmDeviceIp;
        static int TmPort = Settings.TmDevicePort;


        /// <summary>
        /// 写单个寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="value"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        internal static bool WriteSingleRegister(int address, int value) {
            var res = false;
            var client = GetClient(TmIp, TmPort);
            if (client != null && client.Connected) {
                try {
                    client.WriteSingleRegister(address, value);
                    res = true;
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;
        }
        /// <summary>
        /// 写多个寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="values"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        internal bool WriteMultipleRegisters(int address, int[] values, string ip, int port = 503) {
            var res = false;
            var client = GetClient(ip, port);
            if (client != null && client.Connected) {
                try {
                    client.WriteMultipleRegisters(address, values);
                    res = true;
                }
                catch (Exception ex) {
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;
        }

        static ModbusClient GetClient(string ip, int port) {
            ModbusClient client = null;
            LogHelper.Info($"GetClient:ip:{ip},port:{port}","ModBus");
            if (!clients.ContainsKey(ip)) {
                LogHelper.Info($"GetClient:ip:{ip},port:{port}.链接不存在，开始链接", "ModBus");
                client = new ModbusClient(ip, port);
                try {
                    client.Connect();
                    //clients[ip] = client;
                    LogHelper.Info($"GetClient:ip:{ip},port:{port}.链接成功", "ModBus");
                }
                catch (Exception ex) {
                    LogHelper.Info($"GetClient:ip:{ip},port:{port}.链接异常：{ex.Message}", "ModBus");
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return client;
        }
    }

    
}