using LB_VisionProcesses.Communicators;
using LB_VisionProcesses.Communicators.Tcom;
using LB_VisionProcesses.Communicators.USerCommunicator.T306CommandTool;
using RJCP.IO.Ports;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Drawing;
using System.IO.Ports;
using System.Linq;
using System.Net.Sockets;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace LB_VisionProcesses.Communicators
{
    public partial class CommunicatorForm : Form
    {
        UserControl userControl = new UserControl();

        BaseCommunicator communicator = new UARTPort();

        CommunicatorConfig _comConfig = null;

        CommunicatorConfig comConfig
        {
            get { return _comConfig; }
            set
            {
                _comConfig = value;
                if (value is T306CommandTool)
                {
                    cmbType.Enabled = false;
                    txtMsg.Enabled = false;
                    ckbRuleCheck.Enabled = false;
                }
                else
                {
                    cmbType.Enabled = true;
                    txtMsg.Enabled = true;
                    ckbRuleCheck.Enabled = true;
                }
            }
        }

        ConcurrentDictionary<string, BaseCommunicator> dicCommunicators { get; set; }

        string fullPath = string.Empty;

        public CommunicatorForm()
        {
            InitializeComponent();
            //没有传入通讯句柄情况下可自由连接
            btnConnect.Enabled = true;
            btnDisconnect.Enabled = false;
            btnSend.Enabled = false;
            btnRuleSend.Enabled = false;

            //测试功能禁用
            grpTest.Enabled = false;
        }

        public CommunicatorForm(ConcurrentDictionary<string, BaseCommunicator> dicCommunicators, CommunicatorConfig comConfig, string fullPath)
        {
            InitializeComponent();
            //传入通讯句柄后禁用连接/断开按键和输入控件
            grpSetting.Enabled = false;

            this.dicCommunicators = dicCommunicators;
            this.comConfig = comConfig;
            this.fullPath = fullPath;
            this.Text = comConfig.strProcessName;

            foreach (var name in dicCommunicators.Keys)
                cmbCom.Items.Add(name);
        }

        private void CommunicatorForm_Load(object sender, EventArgs e)
        {
            // 使用 Enum.GetValues 获取 enum 类型的所有值
            foreach (CommunicatorType type in Enum.GetValues(typeof(CommunicatorType)))
            {
                cmbType.Items.Add(type.ToString());
            }

            //选择Com会触发ValueChanged事件，没有输入通讯口的情况下选择到-1
            if (comConfig != null)
            {
                string CommunicatorName = comConfig.Params.Inputs["通讯口名"].ToString();
                // 尝试转换字符串为枚举
                if (!Enum.TryParse(comConfig.Params.Inputs["通讯类型"].ToString(), out CommunicatorType type))
                    type = CommunicatorType.Receiver;

                bool bRuleCheck = Convert.ToBoolean(comConfig.Params.Inputs["是否启用CRC校验"].ToString());
                string Msg = comConfig.Params.Inputs["通讯消息"].ToString();

                int Index = cmbCom.FindString(CommunicatorName);
                if (Index == -1 && cmbCom.Items.Count > 0)
                {
                    //如果没有找到对应的通讯口名，则选择第一个可用的通讯口
                    CommunicatorName = cmbCom.Items[0].ToString();
                    Index = 0;
                }
                cmbCom.Text = CommunicatorName;
                cmbCom.SelectedIndex = Index;
                cmbType.Text = type.ToString();
                ckbRuleCheck.Checked = bRuleCheck;
                txtMsg.Text = Msg;

                try
                {
                    //利用反射创建实例，命名规范：Tool+Edit，命名空间也要相同
                    string ClassName = comConfig.GetType().FullName + "Edit";
                    // 获取编辑控件类型
                    Type ClassType = Type.GetType(ClassName)
                        ?? Assembly.GetExecutingAssembly().GetTypes()
                                  .FirstOrDefault(t => t.Name == ClassName);

                    if (ClassType != null)
                    {
                        // 使用Activator.CreateInstance带参数创建
                        userControl = (UserControl)Activator.CreateInstance(ClassType, comConfig);

                        if (userControl != null)
                        {
                            userControl.Dock = DockStyle.Fill;
                            pnlSetting.Controls.Add(userControl);
                        }
                    }
                }
                catch { }
            }
        }

        private void cmbCom_SelectedIndexChanged(object sender, EventArgs e)
        {
            //复原原通讯口设置
            if (comConfig != null)
            {
                communicator.MessageReceived -= ShowReceiveMsg;
            }

            string name = cmbCom.Text;
            if (dicCommunicators == null || !dicCommunicators.ContainsKey(name))
            {
                MessageBox.Show("该通讯口不存在!");
                return;
            }

            //更换通讯口

            communicator = dicCommunicators[name];
            communicator.MessageReceived += ShowReceiveMsg;

            if (communicator is UARTPort)
            {
                btnSend.Enabled = communicator.bConnected;
                btnRuleSend.Enabled = communicator.bConnected;

                cmbIP.Visible = true;
                txtIP.Visible = false;

                lblIP.Text = "串口号";
                lblIP.Text = "波特率";

                cmbIP.Text = communicator.CommunicatorConnections["地址"].ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"].ToString();
            }
            else if (communicator is LocalMonitor)
            {
                btnSend.Enabled = communicator.bConnected;
                btnRuleSend.Enabled = communicator.bConnected;

                cmbIP.Visible = false;
                txtIP.Visible = true;

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

                txtIP.Text = communicator.CommunicatorConnections["地址"].ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"].ToString();
            }
            else
            {
                btnSend.Enabled = communicator.bConnected;
                btnRuleSend.Enabled = false;

                cmbIP.Visible = false;
                txtIP.Visible = true;

                lblIP.Text = " IP";
                lblIP.Text = "端口";

                txtIP.Text = communicator.CommunicatorConnections["地址"].ToString();
                txtPort.Text = communicator.CommunicatorConnections["端口"].ToString();
            }
        }

        private void cmbIP_Click(object sender, EventArgs e)
        {
            //统计可用端口
            SerialPortStream temp = new SerialPortStream();
            string[] ArryPort = temp.GetPortNames();
            for (int i = 0; i < ArryPort.Length; i++)
                cmbIP.Items.Add(ArryPort[i]);
        }

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

            if (communicator is UARTPort)
            {
                communicator.CommunicatorConnections.Add("地址", cmbIP.SelectedItem.ToString());
                communicator.CommunicatorConnections.Add("端口", txtPort.Text);
            }
            else
            {
                communicator.CommunicatorConnections.Add("地址", txtIP.Text);
                communicator.CommunicatorConnections.Add("端口", txtPort.Text);
            }

            bool connectSuccess = communicator.Connect();
            if (connectSuccess)
            {
                communicator.MessageReceived -= ShowReceiveMsg;
                communicator.MessageReceived += ShowReceiveMsg;
            }
            MessageBox.Show(connectSuccess ? "连接成功" : "连接失败,原因是" + communicator.Msg);
        }

        private void ShowReceiveMsg(string strReceiveMsg)
        {
            //if (communicator is UARTPort || communicator is ModbusRTUMaster)
            //{
            //    byte[] HexByte = BaseCommunicator.strToHexByte(strReceiveMsg);

            //    strReceiveMsg = string.Join(" ", HexByte);
            //}

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

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

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

            bool result = communicator.Disconnect();

            if (result)
                communicator.MessageReceived -= ShowReceiveMsg;

            MessageBox.Show(result ? "断开成功" : "断开失败,原因是:" + communicator.Msg);
        }

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

            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 = SendMsg.Split(' ', StringSplitOptions.RemoveEmptyEntries)
                                         .Select(hex => Convert.ToByte(hex, 16))
                                         .ToArray();

            ushort crcHexByte = BaseCommunicator.CRC16Calculate(HexByte, HexByte.Length);

            string crcString = crcHexByte.ToString("X4");
            crcString = crcString.Insert(2, " ");

            HexByte = BaseCommunicator.strToHexByte(SendMsg + " " + crcString);
            //SendMsg = SendMsg + crcString;

            communicator.SendMessage(HexByte);

            ShowSendMsg(SendMsg + " " + crcString);
        }

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

            // 尝试转换字符串为枚举
            if (!Enum.TryParse(cmbType.Text, out CommunicatorType type))
                return;

            if (comConfig is T306CommandTool)
            {
                if (comConfig.Run())
                    btnRun.BackColor = Color.Green;
                else
                    btnRun.BackColor = Color.Red;

                ShowSendMsg(comConfig.Params.Inputs["通讯消息"].ToString());
                this.Refresh();
            }
            else
            {
                CommunicatorConfig OriComConfig = new CommunicatorConfig(dicCommunicators);

                OriComConfig.Params.Inputs.Add("通讯口名", cmbCom.Text);
                OriComConfig.Params.Inputs.Add("通讯类型", type);
                OriComConfig.Params.Inputs.Add("是否启用CRC校验", ckbRuleCheck.Checked);
                OriComConfig.Params.Inputs.Add("通讯消息", txtMsg.Text);

                if (OriComConfig.Run())
                {
                    btnRun.BackColor = Color.Green;
                    if (type == CommunicatorType.Receiver)
                        ShowReceiveMsg(OriComConfig.Params.Outputs["收到消息"].ToString());
                    else
                        ShowSendMsg(txtMsg.Text);
                }
                else
                    btnRun.BackColor = Color.Red;
            }
        }

        private void cmbIP_MouseClick(object sender, MouseEventArgs e)
        {
            cmbIP.Items.Clear();
            //统计可用端口
            SerialPortStream temp = new SerialPortStream();
            string[] ArryPort = temp.GetPortNames();
            for (int i = 0; i < ArryPort.Length; i++)
                cmbIP.Items.Add(ArryPort[i]);
        }

        private void CommunicatorForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            //路径为空说明无需保存
            if (string.IsNullOrEmpty(fullPath))
            {
                e.Cancel = false;  //确认关闭窗体
                return;
            }

            DialogResult res = MessageBox.Show("是否保存？", "提示", MessageBoxButtons.YesNoCancel, MessageBoxIcon.Question);  //保存结果信息
            /// 参数1：显示文本，参数2：标题，参数3：按键类型，参数4：显示图标
            if (res != DialogResult.Yes && res != DialogResult.No)  //取消
            {
                e.Cancel = true;  //取消关闭窗体
                return;
            }

            if (res == DialogResult.Yes)  //保存VPP
            {
                // 尝试转换字符串为枚举
                if (!Enum.TryParse(cmbType.Text, out CommunicatorType type))
                {
                    Debug.WriteLine("保存失败");
                    e.Cancel = false;  //确认关闭窗体
                    return;
                }

                comConfig.Params.Inputs.Add("通讯口名", cmbCom.Text);
                comConfig.Params.Inputs.Add("通讯类型", type);
                comConfig.Params.Inputs.Add("是否启用CRC校验", ckbRuleCheck.Checked);
                comConfig.Params.Inputs.Add("通讯消息", txtMsg.Text);

                string directoryPath = Path.GetDirectoryName(fullPath);
                comConfig.Save(directoryPath);

                e.Cancel = false;  //确认关闭窗体
                return;
            }
        }

        private void CommunicatorForm_FormClosed(object sender, FormClosedEventArgs e)
        {
            if (communicator != null)
                communicator.MessageReceived -= ShowReceiveMsg;

            //路径为空说明为测试模式，需要释放通讯口
            if (string.IsNullOrEmpty(fullPath) && communicator != null)
                communicator.Dispose();
        }
    }
}