public class SerialPortHelper
{
    private SerialPort serialPort; // 串口對(duì)象
    private List<byte> _buffer = new List<byte>(); // 數(shù)據(jù)緩沖區(qū)
    /// <summary>
    /// 自定義串口消息接收事件
    /// </summary>
    public event ReceiveDataEventHandler ReceiveDataEvent;
    public SerialPortHelper()
    {
        serialPort = new SerialPort();
    }
    /// <summary>
    /// 獲取當(dāng)前計(jì)算機(jī)所有的串行端口名
    /// </summary>
    public static string[] GetPortArray()
    {
        return SerialPort.GetPortNames(); // 獲取所有可用串口
    }
    /// <summary>
    /// 設(shè)置串口參數(shù)
    /// </summary>
    public void SetSerialPort(string portName, int baudrate, Parity parity, int databits, StopBits stopBits)
    {
        serialPort.PortName = portName; // 端口名
        serialPort.BaudRate = baudrate; // 波特率
        serialPort.Parity = parity; // 奇偶校驗(yàn)
        serialPort.DataBits = databits; // 數(shù)據(jù)位
        serialPort.StopBits = stopBits; // 停止位
        serialPort.DataReceived += ReceiveDataMethod; // 訂閱數(shù)據(jù)接收事件
    }
    /// <summary>
    /// 打開(kāi)串口
    /// </summary>
    public void Open()
    {
        try
        {
            serialPort.Open(); // 打開(kāi)串口
        }
        catch (Exception ex)
        {
            Console.WriteLine("Error opening serial port: " + ex.Message);
        }
    }
    /// <summary>
    /// 關(guān)閉串口
    /// </summary>
    public void Close()
    {
        serialPort.Close(); // 關(guān)閉串口
    }
    /// <summary>
    /// 發(fā)送數(shù)據(jù)（字節(jié)數(shù)組）
    /// </summary>
    public void SendDataMethod(byte[] data)
    {
        if (!serialPort.IsOpen)
        {
            Open(); // 如果串口未打開(kāi)，則先打開(kāi)
        }
        serialPort.Write(data, 0, data.Length); // 發(fā)送數(shù)據(jù)
    }
    /// <summary>
    /// 發(fā)送數(shù)據(jù)（字符串）
    /// </summary>
    public void SendDataMethod(string data)
    {
        if (!serialPort.IsOpen)
        {
            Open(); // 如果串口未打開(kāi)，則先打開(kāi)
        }
        serialPort.Write(data); // 發(fā)送字符串
    }
    /// <summary>
    /// 數(shù)據(jù)接收事件處理方法
    /// </summary>
    private void ReceiveDataMethod(object sender, SerialDataReceivedEventArgs e)
    {
        try
        {
            byte[] dataChunk = new byte[serialPort.BytesToRead]; // 讀取緩沖區(qū)中的數(shù)據(jù)
            serialPort.Read(dataChunk, 0, dataChunk.Length);
            _buffer.AddRange(dataChunk); // 將數(shù)據(jù)添加到緩沖區(qū)
            while (_buffer.Count >= 3) // 確保緩沖區(qū)中有足夠的數(shù)據(jù)
            {
                byte thirdByte = _buffer[1]; // 獲取第三個(gè)字節(jié)（功能碼）
                if (thirdByte == 0x03) // 功能碼0x03
                {
                    if (_buffer.Count >= 19) // 檢查是否有完整的數(shù)據(jù)包
                    {
                        byte[] completePacket = _buffer.GetRange(0, 19).ToArray(); // 提取完整數(shù)據(jù)包
                        TriggerReceiveDataEvent(completePacket); // 觸發(fā)接收事件
                        _buffer.RemoveRange(0, 19); // 移除已處理的數(shù)據(jù)
                    }
                    else
                    {
                        break; // 數(shù)據(jù)不足，等待更多數(shù)據(jù)
                    }
                }
                else if (thirdByte == 0x10 || thirdByte == 0x06) // 功能碼0x10或0x06
                {
                    byte[] dataToProcess = _buffer.ToArray(); // 處理整個(gè)緩沖區(qū)
                    TriggerReceiveDataEvent(dataToProcess); // 觸發(fā)接收事件
                    _buffer.Clear(); // 清空緩沖區(qū)
                }
                else
                {
                    _buffer.RemoveRange(0, 3); // 移除無(wú)法識(shí)別的數(shù)據(jù)
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("Error processing serial port data: " + ex.Message);
        }
    }
    /// <summary>
    /// 觸發(fā)接收數(shù)據(jù)事件
    /// </summary>
    private void TriggerReceiveDataEvent(byte[] data)
    {
        if (ReceiveDataEvent != null)
        {
            ReceiveDataEventArg arg = new ReceiveDataEventArg(data); // 創(chuàng)建事件參數(shù)
            ReceiveDataEvent.Invoke(this, arg); // 觸發(fā)事件
        }
    }
}

public class ReceiveDataEventArg : EventArgs
{
    public byte[] Data { get; set; } // 接收到的數(shù)據(jù)
    public ReceiveDataEventArg(byte[] data)
    {
        Data = data; // 初始化數(shù)據(jù)
    }
}

public partial class MainWindow : Window
{
    private SerialPortHelper serialPortHelper;
    public MainWindow()
    {
        InitializeComponent();
        SettingComPorts(); // 初始化串口
    }
    private void SettingComPorts()
    {
        string portName = "COM8"; // 串口名稱(chēng)
        int baudRate = 115200; // 波特率
        Parity parity = Parity.None; // 奇偶校驗(yàn)
        int dataBits = 8; // 數(shù)據(jù)位
        StopBits stopBits = StopBits.One; // 停止位
        serialPortHelper = new SerialPortHelper();
        serialPortHelper.SetSerialPort(portName, baudRate, parity, dataBits, stopBits); // 設(shè)置串口參數(shù)
        serialPortHelper.Open(); // 打開(kāi)串口
        serialPortHelper.ReceiveDataEvent += ReceiveDataEvent; // 訂閱接收數(shù)據(jù)事件
    }
    /// <summary>
    /// 接收數(shù)據(jù)事件處理方法
    /// </summary>
    private void ReceiveDataEvent(object sender, ReceiveDataEventArg e)
    {
        byte[] receivedData = e.Data; // 獲取接收到的數(shù)據(jù)
        if (receivedData[1] == 0x03) // 功能碼0x03
        {
            int receiveDataLength = receivedData[2]; // 獲取有效數(shù)據(jù)長(zhǎng)度
            byte[] receiveDataBuffer = new byte[receiveDataLength];
            Array.Copy(receivedData, 3, receiveDataBuffer, 0, receiveDataLength); // 提取有效數(shù)據(jù)
            ushort[] units = messageData.GetUnitsFromByteArray(receiveDataBuffer); // 解析數(shù)據(jù)
            if (units != null)
            {
                List<ChannelData> channelDatas = databaseHelper.GetUUTInfo(units); // 獲取設(shè)備信息
                UpdateDeviceInfo(channelDatas); // 更新UI
            }
        }
    }
}