using LB_VisionProcesses;
using LB_VisionProcesses.Communicators;
using System.IO.Ports;

namespace LB_VisionProcesses.Communicators.Modbus
{
    public class ModbusTCPMaster : BaseCommunicator
    {
        public SerialPort SerialPort = new SerialPort();

        // 构造函数
        public ModbusTCPMaster(string name = "ModbusTCP主站")
        {
            CommunicatorConnections.Add("地址", "COM1");
            CommunicatorConnections.Add("端口", "9600");
            CommunicatorBrand = CommunicatorBrand.ModbusTCPMaster;
            CommunicatorName = name;
        }

        public void SetConfigure(string portName, int baudRate = 9600, Parity parity = Parity.None,
            int dataBits = 8, StopBits stopBits = StopBits.One)
        {
            SerialPort.PortName = portName;
            SerialPort.BaudRate = baudRate;
            SerialPort.Parity = parity;
            SerialPort.DataBits = dataBits;
            SerialPort.StopBits = stopBits;
            SerialPort.NewLine = "\r\n";  // 设置行结束符
            SerialPort.ReadTimeout = 500; // 设置读取超时
            SerialPort.WriteTimeout = 500; // 设置写入超时
        }

        public override bool Connect()
        {
            try
            {
                Disconnect();

                //波特率
                int PORT = 0;
                if (!int.TryParse(this.CommunicatorConnections["端口"].ToString(), out PORT))
                {
                    Msg = string.Format("端口未设置");
                    return false;
                }
                if (!CommunicatorConnections.Contains("地址"))
                {
                    Msg = string.Format("地址未设置");
                    return false;
                }
                //串口号
                string IP = CommunicatorConnections["地址"].ToString();

                if (!SerialPort.IsOpen)
                {
                    SerialPort = new SerialPort();
                    SetConfigure(IP, PORT);
                    SerialPort.Open();
                    bConnected = true;
                    //SerialPort.DataReceived += SerialPort_DataReceived;

                    // 启动心跳线程
                    bHeart = true;
                    //heartbeatThread = new Thread(SendHeartbeat);
                    //heartbeatThread.IsBackground = true;
                    //heartbeatThread.Start();

                    IProcess.lstCommunicators.Add(this);
                    return true;
                }
                else
                {
                    Msg = $"原串口关闭失败无法重新打开";
                    return false;
                }
            }
            catch (Exception ex)
            {
                Msg = $"失败,串口已经启动: {ex.Message}";
                return false;
            }
        }

        public override bool Disconnect()
        {
            try
            {
                bConnected = false;
                if (SerialPort == null)
                {
                    SerialPort = new SerialPort();
                    return true;
                }

                if (SerialPort.IsOpen)
                {
                    //SerialPort.DataReceived -= SerialPort_DataReceived;
                    SerialPort.Close(); // 关闭串口
                }

                SerialPort = new SerialPort();
                IProcess.lstCommunicators.Remove(this);
                return true;
            }
            catch (Exception ex)
            {
                bConnected = false;
                Msg = $"断开串口时出错: {ex.Message}";
                return true;
            }
        }


        public override bool SendMessage(byte[] sBytes)
        {
            bool bret = false;
            if (SerialPort == null || !SerialPort.IsOpen) return bret;
            try
            {
                SerialPort.Write(sBytes, 0, sBytes.Length);
                bret = true;
            }
            catch { }
            return bret;
        }

        public override bool SendMessage(string message)
        {
            if (bConnected)
            {
                try
                {
                    //空消息不发送
                    if (string.IsNullOrEmpty(message) || message.Trim() == "")
                        return true;

                    //发送前清空接收消息
                    strReceiveMsg = string.Empty;
                    SerialPort.Write(message); // 发送消息
                    return true;
                }
                catch (Exception ex)
                {
                    Msg = $"发送消息时出错: {ex.Message}";
                    return false;
                }
            }
            else
            {
                Msg = "串口未打开";
                return false;
            }
        }

        public override string ReceiveMsg()
        {
            string msg = string.Empty;
            for (int i = 0; i <= 3; i++)
            {
                if (string.IsNullOrEmpty(strReceiveMsg))
                    Thread.Sleep(50);
                else
                {
                    lock (strReceiveMsg)
                    {
                        msg += strReceiveMsg;
                        strReceiveMsg = string.Empty;
                    }
                    //串口数据需要使用累加方式
                    //return msg;
                }
            }
            return msg;
        }
    }
}