using System.IO.Ports;
using System.Text;

namespace SerialPortCommunication
{
    class Program
    {
        private static SerialPort serialPort;

        public static void Main()
        {
            #region 串口通信
            ConnectSerialPort("COM2");
            ClosePort();
            ReciveData();
            SendData();

            Console.ReadKey();
            #endregion
        }

        /// <summary>
        /// 接收串口數(shù)據(jù)
        /// </summary>
        /// <exception cref="NotImplementedException"></exception>
        private static void ReciveData()
        {
            // 連接串口
            var result = ConnectSerialPort("COM2");
            while(true)
            {
                if (result)
                {
                    // BytesToRead 代表串口中的字節(jié)大小
                    // 串口中的數(shù)據(jù)接收后，數(shù)據(jù)就被移除了。
                    var buffer = new byte[serialPort.BytesToRead];
                    // 接收發(fā)送的數(shù)據(jù)
                    #region 主動接收
                    serialPort.Read(buffer, 0, buffer.Length);
                    var resultString = Encoding.UTF8.GetString(buffer, 0, buffer.Length);
                    Console.WriteLine($"接收到結(jié)果: {resultString}");
                }
            }
            
            serialPort.Close();
            
            #endregion
        }

        /// <summary>
        /// 發(fā)送數(shù)據(jù)的方法
        /// </summary>
        /// <exception cref="NotImplementedException"></exception>
        private static void SendData()
        {
            // 連接串口
            var result = ConnectSerialPort("COM1");
            if (result)
            {
                // 發(fā)送數(shù)據(jù)
                //serialPort.Write("Hello SerialPort");
                //var buffer = new byte[] { 0x01, 0x02,0x03 };
                // 發(fā)送數(shù)據(jù)
                var buffer = Encoding.UTF8.GetBytes("中文");
                serialPort.Write(buffer, 0, buffer.Length);
                //serialPort.WriteBufferSize = 65535; // modbus 250
                //serialPort.WriteLine("Don't type chinese");
            }
            serialPort.Close();
        }

        /// <summary>
        /// 關(guān)閉串口的方法
        /// </summary>
        /// <exception cref="NotImplementedException"></exception>
        private static void ClosePort()
        {
            if (serialPort == null)
            {
                return;                                
            }
            serialPort.Close();
        }

        /// <summary>
        /// 連接串口的方法
        /// </summary>
        /// <returns></returns>
        private static bool ConnectSerialPort(string portName)
        {
            // 創(chuàng)建串口對象
            serialPort = new SerialPort();
            // 設置連接串口名稱
            serialPort.PortName = portName;
            // 設置波特率
            serialPort.BaudRate = 9600;
            // 設置數(shù)據(jù)位
            serialPort.DataBits = 8;
            // 設置停止位
            serialPort.StopBits = StopBits.One;
            // 設置校驗位
            serialPort.Parity = Parity.None;
            serialPort.DataReceived += SerialPort_DataReceived;
            // 打開串口
            serialPort.Open();
            // 判斷串口是否成功打開
            if (serialPort.IsOpen)
            {
                Console.WriteLine("串口連接成功");
                return true;
            }
            else
            {
                Console.WriteLine("串口連接失敗");
            }

            return false;
        }

        /// <summary>
        /// 接收事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        /// <exception cref="NotImplementedException"></exception>
        private static void SerialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            var serialPort1 = sender as SerialPort;
            var buffer = new byte[serialPort1!.BytesToRead];
            serialPort1.Read(buffer, 0, buffer.Length);
            var resultString = Encoding.UTF8.GetString(buffer, 0, buffer.Length);
            Console.WriteLine($"接收到結(jié)果: {resultString}");

        }
    }
}