using HH.WCS.Hexafluo;
using HH.WCS.Hexafluo.device;
using HH.WCS.HGXCL.util;
using HH.WCS.SJML.Dto;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;

namespace HH.WCS.JunzhouNongfu.device
{
    internal class TcpClient
    {
        private static Socket client = null;
        private static string ip = "127.0.0.1";
        private static int port = 1024;

        static TcpClient()
        {
            PostTcpClient();
        }

        private static void PostTcpClient()
        {
            var trp = JsonHelper.GetValue("TcpClient");
            var Op = JsonConvert.DeserializeObject<SJTransferDto>(trp);
            client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            client.ReceiveTimeout = 2000;
            client.Connect(Op.ip, Op.port);
        }

        public static string SendHexOnce(string hex)
        {
            LogHelper.Info("发送给电梯信号:" + hex);
            var res = string.Empty;
            LogHelper.Info("发送给电梯信号 检测连接是否正常:" + client.Connected);
            if (client.Connected)
            {

                client.ReceiveTimeout = 2000;
                if (client.Connected)
                {
                    client.Send(PlcHelper.Hex2Bytes(hex));
                    byte[] buffer = new byte[1024];
                    try
                    {
                        //  client.Connected
                        var length = client.Receive(buffer, SocketFlags.None);
                        byte[] data = new byte[length];
                        Array.Copy(buffer, data, length);
                        res = BitConverter.ToString(data).Replace("-", " ");
                        LogHelper.Info("电梯回复信号:" + res);
                        //res = BitConverter.ToString(data);
                        //var tmp = res.Split(' ').ToList();
                        //var tmps = tmp.ToList();
                        //tmp.RemoveRange(0, 2);
                        //tmp.RemoveRange(tmp.Count - 2, tmp.Count - 1);
                        //List<string> Str = new List<string>();
                        //if (tmp.Count != int.Parse(tmps[2]))
                        //{
                        //    throw new Exception("数据长度和寄存器对不上");
                        //}
                        //else
                        //{
                        //    int a = 0;
                        //    int b = 1;
                        //    for (int i = 0; i < tmp.Count / 2; i++)
                        //    {
                        //        var fr = tmp[a] + tmp[b];
                        //        Str.Add(Convert.ToInt32(fr, 10).ToString());
                        //        a = a + 2;
                        //        b = b + 2;
                        //    }
                        //}
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Info("电梯报错:" + ex.Message);
                        LogHelper.Error(ex.Message, ex);
                    }
                }
            }
            else
            {
                LogHelper.Info("发送给电梯信号 连接断开 重新连接");
                try
                {
                    client.Close();
                    PostTcpClient();
                    // client.Connect(ip, port);
                }
                catch (Exception ex)
                {
                    LogHelper.Info("电梯重连报错:" + ex.Message);
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return res;
        }


        public static List<int> SendHexOnceList(string hex)
        {
            LogHelper.Info("发送给电梯信号:" + hex);
            var res = string.Empty;
            List<int> Str = new List<int>();
            LogHelper.Info("发送给电梯信号 检测连接是否正常:" + client.Connected);
            if (client.Connected)
            {

                client.ReceiveTimeout = 2000;
                if (client.Connected)
                {
                    client.Send(PlcHelper.Hex2Bytes(hex));
                    byte[] buffer = new byte[1024];
                    try
                    {
                        //  client.Connected
                        var length = client.Receive(buffer, SocketFlags.None);
                        byte[] data = new byte[length];
                        Array.Copy(buffer, data, length);
                        res = BitConverter.ToString(data).Replace("-", " ");

                        // res = BitConverter.ToString(data);
                        LogHelper.Info("电梯回复信号:" + res);
                        if (res != null)
                        {
                            res = res.Trim();
                        }
                        var tmp = res.Split(' ').ToList();
                        var tmps = tmp.ToList();
                        for (int i = 0; i < 3; i++)
                        {
                            tmp.RemoveAt(0);

                        }
                        for (int i = 0; i < 2; i++)
                        {
                            tmp.RemoveAt(tmp.Count - 1);
                        }

                        if (tmp.Count != int.Parse(tmps[2]))
                        {
                            throw new Exception("数据长度和寄存器对不上");
                        }
                        else
                        {
                            int a = 0;
                            int b = 1;
                            for (int i = 0; i < tmp.Count / 2; i++)
                            {
                                var fr = tmp[a] + tmp[b];
                                Str.Add(Convert.ToInt32(fr, 10));
                                a = a + 2;
                                b = b + 2;
                            }
                        }
                        LogHelper.Info("回复信号加工:" + JsonConvert.SerializeObject(Str));
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Info("电梯报错:" + ex.Message);
                        LogHelper.Error(ex.Message, ex);
                    }
                }
            }
            else
            {
                LogHelper.Info("发送给电梯信号 连接断开 重新连接");
                try
                {
                    client.Close();
                    PostTcpClient();
                }
                catch (Exception ex)
                {
                    LogHelper.Info("电梯重连报错:" + ex.Message);
                    LogHelper.Error(ex.Message, ex);
                }
            }
            return Str;
        }


        /// <summary>
        /// 读保持寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="qty"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        internal int[] ReadInputRegistersRtu(int address, int qty, string ip, int port = 502)
        {
            List<int> res = new List<int>();
            var hex = $"0103{address.ToString("X4")}{qty.ToString("X4")}";
            hex = hex + BitConverter.ToString(PlcHelper.CRC16LH(PlcHelper.Hex2Bytes(hex))).Replace("-", "").Replace(" ", "");
            //var data = SendHexOnce(ip, port, hex);
            var data = SendHexOnce(hex);
            if (!string.IsNullOrEmpty(data))
            {
                if (PlcHelper.CheckCRC(data))
                {
                    var lenght = Convert.ToInt16(data.Substring(4, 2), 16) / 2;
                    for (int i = 0; i < lenght; i++)
                    {
                        res[i] = Convert.ToInt16(data.Substring(6 + 4 * 1, 4), 16);
                    }
                }
            }
            return res.ToArray();
        }
        /// <summary>
        /// 写单个寄存器
        /// </summary>
        /// <param name="address"></param>
        /// <param name="value"></param>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        internal bool WriteSingleRegisterRtu(int address, int value, string ip, int port = 502)
        {
            var res = false;
            var hex = $"0106{address.ToString("X4")}{value.ToString("X4")}";
            hex = hex + BitConverter.ToString(PlcHelper.CRC16LH(PlcHelper.Hex2Bytes(hex))).Replace("-", "").Replace(" ", "");
            //var data = SendHexOnce(ip, port, hex);
            var data = SendHexOnce(hex);
            if (!string.IsNullOrEmpty(data))
            {
                res = true;
            }
            return res;
        }
    }

}