using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using XImageSystem.Service.Exceptions;
using XImaging.Automation.Library.HxDriverLib;

namespace HxDriverService.Runtime.Peripheral
{
    public class ConveyerControl
    {
        /// <summary>
        /// 网络是否连接
        /// </summary>
        private bool m_bIsNetConnect = false;
        /// <summary>
        /// 接收线程
        /// </summary>
        private Thread tRevTcp;
        /// <summary>
        /// 读写输入输出的流
        /// </summary>
        private NetworkStream m_nsClient;
        /// <summary>
        /// 客户端
        /// </summary>
        private TcpClient m_tcpClient;
        /// <summary>
        /// ip地址
        /// </summary>
        private string m_strIPAddress = "192.168.0.7";
        /// <summary>
        /// 端口号
        /// </summary>
        private int m_nPortNumber = 2022;
        /// <summary>
        /// 当前命令
        /// </summary>
        public string m_strCommand = "";
        /// <summary>
        /// 是否做完(error或正常做完皆认为做完）
        /// </summary>
        private bool m_bDone;

        public ConveyerControl(string strIP, int nPort)
        {
            m_strIPAddress = strIP;
            m_nPortNumber = nPort;
        }

        public bool Start()
        {
            try
            {
                if (!m_bIsNetConnect)
                {
                    m_tcpClient = new TcpClient();
                    m_tcpClient.Connect(m_strIPAddress, m_nPortNumber);
                    m_bIsNetConnect = true;
                    m_nsClient = m_tcpClient.GetStream();

                    LogConstant.logger.Print("Connect to conveyer");

                    tRevTcp = new Thread(RevTcp);
                    tRevTcp.IsBackground = true;
                    tRevTcp.Start();
                }
            }
            catch (Exception ex)
            {
                throw new ConveyerException(ex.Message);
            }
            return m_bIsNetConnect && (m_tcpClient != null);
        }

        public void Close()
        {
            if (m_tcpClient != null)
            {
                m_tcpClient.Close();
                m_tcpClient = null;
            }
            m_bIsNetConnect = false;
            LogConstant.logger.Print("Disconnected to the conveyer");
        }

        public bool SendCommand(string strMsg)
        {
            if (m_nsClient == null)
            {
                return false;
            }
            try
            {
                LogConstant.logger.Print("SendCommand: " + strMsg);
                byte[] dataSend = Encoding.ASCII.GetBytes(strMsg);
                m_nsClient.Write(dataSend, 0, dataSend.Length);
                return true;
            }
            catch (Exception ex)
            {
                Close();
                LogConstant.logger.Print("Send:" + strMsg + " failed");
                return false;
            }
        }

        public void RevTcp()
        {
            while (true)
            {
                if (!m_bIsNetConnect) break;
                if (m_tcpClient == null || m_nsClient == null) break;

                byte[] byteRev = new byte[1024];
                int byteRead = m_nsClient.Read(byteRev, 0, 1024);
                byte[] byText = new byte[byteRead];
                Array.Copy(byteRev, 0, byText, 0, byteRead);

                string strMsg = Encoding.ASCII.GetString(byText);
                LogConstant.logger.Print("Received resp:" + strMsg);
                if (strMsg.Contains("ERROR"))
                {
                    m_bDone = true;
                    throw new ConveyerException("Command: " + m_strCommand + " failed");
                }
                else if (strMsg == m_strCommand)
                {
                    m_bDone = true;
                }
            }

            //避免接收不全
            Thread.Sleep(200);
        }

        public void STOP()
        {
            m_strCommand = "STOP\r\n";
            try
            {
                SendCommand(m_strCommand);
                //等待做完
                while (!m_bDone)
                {
                    Thread.Sleep(500);
                }
                //置回false
                m_bDone = false;
            }
            catch (Exception ex)
            {
                throw new ConveyerException(ex.Message);
            }
        }
        public void HOME()
        {
            m_strCommand = "HOME\r\n";
            try
            {
                SendCommand(m_strCommand);
                //等待做完
                while (!m_bDone)
                {
                    Thread.Sleep(500);
                }
                //置回false
                m_bDone = false;
            }
            catch (Exception ex)
            {
                //置回false
                m_bDone = false;
                throw new ConveyerException(ex.Message);
            }
        }

        public void STEPS(int x = 329500)
        {
            m_strCommand = "STEPS" + x.ToString() + "\r\n";
            try
            {
                SendCommand(m_strCommand);
                //等待做完
                while (!m_bDone)
                {
                    Thread.Sleep(500);
                }
                //置回false
                m_bDone = false;
            }
            catch (Exception ex)
            {
                //置回false
                m_bDone = false;
                throw new ConveyerException(ex.Message);
            }
        }
    }
}