using LB_VisionProcesses.Communicators;
using LB_VisionProcesses.Communicators.TCom;
using ReaLTaiizor.Forms;
using RJCP.IO.Ports;
using System.Diagnostics;

namespace LB_SmartVision.Forms.Pages.CommunicatorPage
{
    public partial class CommunicatorForm : MaterialForm
    {
        BaseCommunicator communicator { get; set; }

        public CommunicatorForm()
        {
            InitializeComponent();
        }

        public CommunicatorForm(BaseCommunicator communicator, string name)
        {
            InitializeComponent();
            if (communicator == null)
                return;

            cmbIP.Enabled = false;
            txtIP.Enabled = false;
            txtPort.Enabled = false;
            this.Text = name;

            if (communicator is UARTPort)
            {
                //统计可用端口
                SerialPortStream temp = new SerialPortStream();
                string[] ArryPort = temp.GetPortNames();
                for (int i = 0; i < ArryPort.Length; i++)
                    cmbIP.Items.Add(ArryPort[i]);

                cmbIP.Text = communicator.CommunicatorConnections["地址"]?.ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"]?.ToString();
                txtIP.Visible = false;
                cmbIP.Visible = true;

                lblIP.Text = "COM口";
                lblPort.Text = "波特率";
            }
            else if (communicator is TCPClient || communicator is TCPServer)
            {
                txtIP.Text = communicator.CommunicatorConnections["地址"]?.ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"]?.ToString();
                txtIP.Visible = true;
                cmbIP.Visible = false;

                lblIP.Text = "地址";
                lblPort.Text = "端口";
            }
            else if (communicator is LocalMonitor)
            {
                txtIP.Text = communicator.CommunicatorConnections["地址"]?.ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"]?.ToString();
                txtIP.Visible = true;
                cmbIP.Visible = false;

                lblIP.Text = "监控文件";
                lblPort.Text = "写入文件";
            }

            this.communicator = communicator;
            //加载回调函数
            Subscribe();
        }

        private void CommunicatorForm_FormClosing(object sender, FormClosingEventArgs e) => Unsubscribe();

        public void Unsubscribe()
        {
            try
            {
                if (communicator == null)
                    return;
                //取消回调函数
                communicator.MessageReceived -= ShowReceiveMsg;
            }
            catch (Exception ex)
            {
                // 记录错误信息
                Debug.WriteLine($"错误: {ex.Message}");
            }

        }

        public void Subscribe()
        {
            try
            {
                if (communicator == null)
                    return;

                //取消回调函数
                communicator.MessageReceived -= ShowReceiveMsg;
                //加载回调函数
                communicator.MessageReceived += ShowReceiveMsg;
            }
            catch (Exception ex)
            {
                // 记录错误信息
                Debug.WriteLine($"错误: {ex.Message}");
            }
        }

        /// <summary>
        /// 通讯回调运行
        /// </summary>
        /// <param name="CCDName"></param>
        /// <param name="image"></param>
        private void ShowReceiveMsg(string strReceiveMsg)
        {
            // 如果当前不是 UI 线程，则通过 Invoke 将操作调度到 UI 线程
            if (this.InvokeRequired)
            {
                this.Invoke(new Action<string>((msg) =>
                {
                    // 更新 UI 控件，比如显示接收到的消息
                    this.txtReceiveMsg.AppendText(("[接收]" + DateTime.Now.ToString() + "：" + msg));
                    this.txtReceiveMsg.AppendText("\r\n");
                    this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
                    this.txtReceiveMsg.ScrollToCaret();
                }), strReceiveMsg);
            }
            else
            {
                // 如果已经在 UI 线程上，直接更新 UI
                this.txtReceiveMsg.AppendText(("[接收]" + DateTime.Now.ToString() + "：" + strReceiveMsg));
                this.txtReceiveMsg.AppendText("\r\n");
                this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
                this.txtReceiveMsg.ScrollToCaret();
            }
        }

        private void ShowSendMsg(string strSendMsg)
        {
            // 如果当前不是 UI 线程，则通过 Invoke 将操作调度到 UI 线程
            if (this.InvokeRequired)
            {
                this.Invoke(new Action<string>((msg) =>
                {
                    // 更新 UI 控件，比如显示接收到的消息
                    this.txtReceiveMsg.AppendText(("[发送]" + DateTime.Now.ToString() + "：" + msg));
                    this.txtReceiveMsg.AppendText("\r\n");
                    this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
                    this.txtReceiveMsg.ScrollToCaret();
                }), strSendMsg);
            }
            else
            {
                // 如果已经在 UI 线程上，直接更新 UI
                this.txtReceiveMsg.AppendText(("[发送]" + DateTime.Now.ToString() + "：" + strSendMsg));
                this.txtReceiveMsg.AppendText("\r\n");
                this.txtReceiveMsg.SelectionStart = this.txtReceiveMsg.Text.Length;
                this.txtReceiveMsg.ScrollToCaret();
            }
        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            if (communicator == null)
                return;

            if (communicator.SendMessage(txtSendMsg.Text))
                ShowSendMsg(txtSendMsg.Text);
        }

        private void btnRuleSend_Click(object sender, EventArgs e)
        {
            if (communicator == null)
                return;

            string SendMsg = txtSendMsg.Text;

            byte[] HexByte = BaseCommunicator.strToHexByte(SendMsg);
            ushort crcHexByte = BaseCommunicator.CRC16Calculate(HexByte, HexByte.Length);

            string crcString = crcHexByte.ToString("X4");
            //HexByte = strToHexByte(strSendMsg + crcString);
            SendMsg = SendMsg + crcString;

            if (communicator.SendMessage(SendMsg))
                ShowSendMsg(SendMsg);
        }
    }
}