using System;
using System.IO.Ports;
 
class SerialPortCommunication
{
    private SerialPort serialPort;
 
    public SerialPortCommunication(string portName, int baudRate)
    {
        // 創(chuàng)建 SerialPort 實例并配置基本參數(shù)
        serialPort = new SerialPort
        {
            PortName = portName,        // 串口號
            BaudRate = baudRate,        // 波特率
            DataBits = 8,               // 數(shù)據(jù)位
            Parity = Parity.None,       // 校驗位
            StopBits = StopBits.One,    // 停止位
            Handshake = Handshake.None  // 無握手協(xié)議
        };
        
        // 設置事件處理程序，當接收到數(shù)據(jù)時觸發(fā)事件
        serialPort.DataReceived += new SerialDataReceivedEventHandler(DataReceivedHandler);
    }
 
    // 打開串口
    public void Open()
    {
        if (!serialPort.IsOpen)
        {
            serialPort.Open();
            Console.WriteLine("串口已打開");
        }
    }
 
    // 關閉串口
    public void Close()
    {
        if (serialPort.IsOpen)
        {
            serialPort.Close();
            Console.WriteLine("串口已關閉");
        }
    }
 
    // 發(fā)送數(shù)據(jù)到串口
    public void WriteData(string data)
    {
        if (serialPort.IsOpen)
        {
            serialPort.WriteLine(data);
            Console.WriteLine("數(shù)據(jù)發(fā)送: " + data);
        }
        else
        {
            Console.WriteLine("串口未打開，無法發(fā)送數(shù)據(jù)");
        }
    }
 
    // 讀取串口數(shù)據(jù)并觸發(fā)事件
    private void DataReceivedHandler(object sender, SerialDataReceivedEventArgs e)
    {
        string data = serialPort.ReadLine();
        Console.WriteLine("接收到數(shù)據(jù): " + data);
        
        // 根據(jù)接收到的數(shù)據(jù)進行控制
        ProcessReceivedData(data);
    }
 
    // 處理接收到的數(shù)據(jù)
    private void ProcessReceivedData(string data)
    {
        if (data.Contains("ERROR"))
        {
            Console.WriteLine("設備錯誤，采取控制措施");
            // 執(zhí)行相應的控制命令
            // 比如發(fā)送關閉命令
            WriteData("CLOSE");
        }
        else
        {
            Console.WriteLine("設備狀態(tài)正常");
            // 執(zhí)行其他控制命令
        }
    }
}
 
class Program
{
    static void Main()
    {
        SerialPortCommunication spComm = new SerialPortCommunication("COM1", 9600);
 
        try
        {
            // 打開串口并開始接收數(shù)據(jù)
            spComm.Open();
            
            // 主循環(huán)：模擬持續(xù)監(jiān)控
            while (true)
            {
                // 模擬實時采集數(shù)據(jù)
                spComm.WriteData("REQUEST_DATA");
 
                // 每2秒請求一次數(shù)據(jù)
                System.Threading.Thread.Sleep(2000);
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("出現(xiàn)錯誤: " + ex.Message);
        }
        finally
        {
            // 程序結束時關閉串口
            spComm.Close();
        }
    }
}