using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace BLL
{
    /// <summary>
    /// 逐鹿的AGV小车
    /// </summary>
    public class BenQ_AGV
    {
        private Socket client;
        private Thread tReceive;
        private Thread tState;
        private Thread tReconn;

        private string _ip;
        private int packetID;
        private byte[] buff;
        private string buffStr;
        private string queryPacket;  //通知询问指令封包ID
        private bool exit = false;
        private bool loop = false;
        private Asa.File.Log log;

        public delegate void StatusEvent(bool status);
        public event StatusEvent Status;

        public BenQ_AGV()
        {
            string path = System.Configuration.ConfigurationManager.AppSettings["LogPath"];
            log = new Asa.File.Log(path, "BenQ_AGV");
            log.OutString("=====程序开始=====");

            _ip = System.Configuration.ConfigurationManager.AppSettings["BenQ_AGV"];
            packetID = 0;
            loop = true;

            tReconn = new Thread(new ThreadStart(Reconnect));
            tReconn.Start();
        }




        public bool IsConn { set; get; }

        /// <summary>
        /// 左侧入料请求
        /// </summary>
        public bool LeftEnter { set; get; }

        /// <summary>
        /// 右侧出料请求
        /// </summary>
        public bool RightLeave { set; get; }

        /// <summary>
        /// 停止动作
        /// </summary>
        public bool Stop { set; get; }

        /// <summary>
        /// RFID两位的文本
        /// </summary>
        public string RFID { set; get; } = "";

        /// <summary>
        /// 可以入料
        /// </summary>
        /// <param name="state"></param>
        public void MayLeftEnter(bool state)
        {
            LeftEnter = false;

            if (IsConn)
            {
                SendResponse(2, state);
                SendEnterState(true);
            }
        }

        /// <summary>
        /// 可以出料
        /// </summary>
        /// <param name="state"></param>
        public void MayLeave(bool state)
        {
            RightLeave = false;

            if (IsConn)
            {
                SendResponse(1, state);
                SendLeaveState(true);
            }
        }

        /// <summary>
        /// 连接
        /// </summary>
        private void Connect()
        {
            try
            {
                System.Net.NetworkInformation.Ping ping = new System.Net.NetworkInformation.Ping();
                System.Net.NetworkInformation.PingReply result = ping.Send(_ip, 1000);
                ping.Dispose();
                if (result.Status == System.Net.NetworkInformation.IPStatus.Success)
                {
                    client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                    client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.SendTimeout, 500);
                    client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 500);
                    client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, 1);
                    client.Connect(System.Net.IPAddress.Parse(_ip), 9800);

                    exit = false;
                    tReceive = new Thread(new ThreadStart(Listen));
                    tReceive.Start();
                    tState = new Thread(new ThreadStart(SendCmd));
                    tState.Start();
                    log.OutString("AGV连接成功");
                    IsConn = true;
                }
                else
                {
                    log.OutString("Ping " + _ip + " 请求没有响应");
                    IsConn = false;
                }
            }
            catch (Exception ex)
            {
                exit = true;
                log.OutError(ex);
                IsConn = false;
            }
        }

        /// <summary>
        /// 关闭连接
        /// </summary>
        public void Close()
        {
            exit = true;
            loop = false;
            IsConn = false;
            log.OutString("=====程序结束=====\r\n");
            log.Dispose();
        }






        /// <summary>
        /// 发送入口状态
        /// </summary>
        /// <param name="roll"></param>
        private void SendEnterState(bool roll)
        {
            string s;
            string msg = "@1";

            //封包ID
            packetID++;
            if (packetID == 500)
                packetID = 1;
            s = packetID.ToString().PadLeft(3, '0');
            msg += s;

            //设备编码
            msg += "002";

            //工作状态
            if (Stop)
                msg += "3";
            else
                msg += "1";

            //RFID，入口没有
            msg += "0000";

            //外侧内测
            msg += "00";

            //动力滚筒
            if (roll)
                msg += "3";
            else
                msg += "1";




            //11个0
            msg += "00000000000";

            //校验和
            msg += "00";

            msg += "!";

            try
            {
                client.Send(Encoding.ASCII.GetBytes(msg));
                log.OutString("SendEnterState " + msg);
            }
            catch (Exception ex)
            {
                log.OutError(ex);
                IsConn = false;
                exit = true;
            }
        }

        /// <summary>
        /// 发送出口状态
        /// </summary>
        /// <param name="roll"></param>
        private void SendLeaveState(bool roll)
        {
            string s;
            string msg = "@1";

            //封包ID
            packetID++;
            if (packetID == 500)
                packetID = 1;
            s = packetID.ToString().PadLeft(3, '0');
            msg += s;

            //设备编码
            msg += "001";

            //工作状态
            if (Stop)
                msg += "3";
            else
                msg += "1";

            //RFID
            if (Stop)
                msg += "0000";
            else
                msg += RFID.PadLeft(4, '0');

            //外侧内测
            msg += "00";

            //动力滚筒
            if (Stop)
                msg += "1";
            else
            {
                if (roll)
                    msg += "2";
                else
                    msg += "1";
            }

            //11个0
            msg += "00000000000";

            //校验和
            msg += "00";

            msg += "!";

            try
            {
                client.Send(Encoding.ASCII.GetBytes(msg));
                log.OutString("SendLeaveState " + msg);
            }
            catch (Exception ex)
            {
                log.OutError(ex);
                IsConn = false;
                exit = true;
            }
        }

        /// <summary>
        /// 发送设备询问应答
        /// </summary>
        /// <param name="dev"></param>
        /// <param name="sta"></param>
        private void SendResponse(int dev, bool sta)
        {
            string msg = "@2";

            //封包ID
            msg += queryPacket;

            //设备编码
            msg += "00" + dev;

            //执行结果
            msg += sta ? "1" : "2";

            //18个0
            msg += "000000000000000000";

            //校验和
            msg += "00";

            //结束符号
            msg += "!";
            try
            {
                client.Send(Encoding.ASCII.GetBytes(msg));
                log.OutString("SendResponse " + msg);
            }
            catch (Exception ex)
            {
                log.OutError(ex);
                IsConn = false;
                exit = true;
            }
        }

        private void Reconnect()
        {
            int count = 0;

            while (loop)
            {
                if (IsConn)
                {
                    Thread.Sleep(5000);
                }
                else
                {
                    Thread.Sleep(1000);
                    Connect();

                    if (IsConn)
                    {
                        count = 0;
                        Status?.Invoke(true);
                    }
                    else
                    {
                        log.OutString("AGV连接失败" + ++count + "次");
                        Status?.Invoke(false);
                    }

                    //Thread.Sleep(2000);
                }
            }
        }

        private void SendCmd()
        {
            while (true)
            {
                if (IsConn) SendEnterState(false);
                Thread.Sleep(1500);
                if (IsConn) SendLeaveState(false);
                Thread.Sleep(1500);
                if (exit) break;
            }
        }

        private void Listen()
        {
            byte[] temp = new byte[50];

            while (true)
            {
                Thread.Sleep(50);
                try
                {
                    if (client.Available > 0)
                    {
                        int count = client.Receive(temp);
                        buff = new byte[count];
                        Array.Copy(temp, 0, buff, 0, count);
                        buffStr = Encoding.ASCII.GetString(buff);
                        log.OutString("Received " + buffStr);

                        if (temp[1] == 65)  //A
                            CodeA();
                        else if (temp[1] == 66)  //B
                            CodeB();
                    }
                }
                catch (Exception ex)
                {
                    log.OutError(ex);
                    IsConn = false;
                    exit = true;
                }
                if (exit) break;
            }
        }

        private void CodeA()
        {
            if (buffStr[7] == '1')  //出口
                SendLeaveState(false);
            else if (buffStr[7] == '2')  //入口
                SendEnterState(false);
        }

        private void CodeB()
        {
            queryPacket = buffStr.Substring(2, 3);

            if (Stop)
            {
                SendResponse(buff[8], false);
            }
            else
            {
                if (buffStr[8] == '2')  //入口
                    LeftEnter = true;
                else if (buffStr[8] == '1')  //出口
                    RightLeave = true;
            }

        }


    }

}