using FujianEarthquake.Common;
using FujianEarthquake.Models.ProtocolAnalyseModels;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FujianEarthquake.Models.CommModels
{
    public class ClientModel : NotifyBase
    {

        SocketInfo SI = new SocketInfo();

        //岸基站数据解析
        private ShoreBaseStationModel volCurCollectorModel { get; set; } = new ShoreBaseStationModel();

        SocketHelper.TcpClients client = new SocketHelper.TcpClients();

        private bool isConnected;


        /// <summary>
        /// Socket通信是否连接
        /// </summary>
        public bool IsConnected
        {
            get { return isConnected; }
            set { isConnected = value; DoNotify(); }
        }


        /// <summary>
        /// 打开客户端连接
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public bool DoConnect(SocketInfo socketInfo)
        {
            //if (!tools.TelnetPort(socketInfo.IP, socketInfo.Port))
            //    return false;
            SI.IP = socketInfo.IP;
            SI.Port = socketInfo.Port;

            client.InitSocket(socketInfo.IP, socketInfo.Port);  //初始化设备的IP和端口号
            IsConnected = client.Start();
            if (IsConnected)
            {
                SocketHelper.pushSockets = new SocketHelper.PushSockets(ReceiveMess);
                //tools.Logging("连接客户端成功,IP:" + socketInfo.IP + "端口号:" + socketInfo.Port);
                //开始进行心跳包检查
                //将是否接收到心跳包判断位 置于false
                IsReturnMsg = DateTime.Now;
                //检测当前连接状态
                //CheckConnect();
            }
            else
            {
                //tools.Logging("连接客户端失败,IP:" + socketInfo.IP + "端口号:" + socketInfo.Port);
            }
            return IsConnected;
        }

        public bool DisConnect()
        {
            client.Stop();
            IsConnected = false;
            return IsConnected;
        }


        private void ReceiveMess(SocketHelper.Sockets sks)
        {
            if (sks.ex != null)
            {
                if (sks.ClientDispose == true)
                {
                    //由于未知原因引发异常.导致客户端下线.   比如网络故障.或服务器断开连接.
                    //SetClientState(string.Format("客户端下线.!异常消息：{0}\r\n", sks.ex));

                    IsConnected = false;
                    client.Stop();
                }
            }
            else if (sks.Offset == 0)
            {
                //客户端主动下线
                // SetClientState("客户端下线.!");

                IsConnected = false;
                client.Stop();
            }
            else
            {
                byte[] buffer = new byte[sks.Offset];
                Array.Copy(sks.RecBuffer, buffer, sks.Offset);
                try
                {
                    if (SI.IP == Tools.GetAppSetting("SYZ_Client_IP1") && SI.Port == int.Parse(Tools.GetAppSetting("SYZ_Client_Port1")))
                    {
                        volCurCollectorModel.ParsingData(new List<byte>(buffer));
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine("ReceiveMessError:" + ex.ToString());
                    return;
                }

            }
        }


        /// <summary>
        /// 发送消息
        /// </summary>
        public bool SendMessage(byte[] SendData)
        {
            return client.SendData(SendData);
        }


        //用于记录心跳包的返回时间
        public DateTime IsReturnMsg = DateTime.Now;

        //用于记录当前是否在检查连接状态  初始值为false
        bool IsCheckConnect = false;


        /// <summary>
        /// 用于检查当前连接状态
        /// </summary>
        private async void CheckConnect()
        {
            await Task.Run(() =>
            {
                //将检查连接状态置为开
                IsCheckConnect = true;
                //连接成功等待10秒后 发送心跳包
                Thread.Sleep(10000);
                //tools.Logging("开始发送心跳包");
                while ((DateTime.Now - IsReturnMsg).TotalSeconds < 150)
                {
                    //发送一次Get
                    SendMessage(new byte[] { (byte)'G', (byte)'E', (byte)'T' });
                    //tools.Logging("发送一次心跳包GET,上一次收到心跳包的时间差为" + (System.DateTime.Now - IsReturnMsg).TotalSeconds + "秒");
                    //等待30秒钟
                    Thread.Sleep(30000);
                }
                //tools.Logging("心跳包超时，主动断开链接，停止发送心跳包GET");

                //先断开链接
                DisConnect();
                IsConnected = false;

                //等待2秒钟
                Thread.Sleep(2000);
                //tools.Logging("心跳包超时，开始初始化并重新链接！");

                //重新链接
                while (!DoConnect(SI))
                {
                    //tools.Logging("心跳包超时，重新链接失败！");
                    Thread.Sleep(30000);
                    IsConnected = false;
                }
                //tools.Logging("心跳包超时，重新链接成功！");
                IsConnected = true;
            });
        }
    }



    public class SocketInfo : NotifyBase
    {
        private string ip;
        /// <summary>
        /// IP
        /// </summary>
        public string IP
        {
            get { return ip; }
            set { ip = value; DoNotify(); }
        }

        private int port;
        /// <summary>
        /// 端口号
        /// </summary>
        public int Port
        {
            get { return port; }
            set { port = value; DoNotify(); }
        }
    }
}