C#骏鹏自动售货机接口

MachineJP类：

第1部分：串口初始化，串口数据读写

using System;using System.Collections.Generic;using System.IO.Ports;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;using System.Windows.Forms;using MachineJPDll.Models;using MachineJPDll.Utils;namespace MachineJPDll{    /// <summary>    /// 售货机接口(骏鹏接口)    /// </summary>    public partial class MachineJP    {        #region 变量        /// <summary>        /// 串口资源        /// </summary>        PRivate SerialPort m_SerialPort = null;        /// <summary>        /// 待发送给串口的命令列表        /// </summary>        private List<Cmd> m_CommandList = new List<Cmd>();        /// <summary>        /// 等待ACK_RPT或NAK_RPT的PC端向VMC端发送的消息列表        /// </summary>        private List<MT> m_WaitResultMTList = new List<MT>();        /// <summary>        /// 从串口接收的数据集合(数据已通过验证)        /// </summary>        private ReceiveDataCollection m_ReceiveDataCollection = new ReceiveDataCollection();        #endregion        #region 构造函数与析构函数        /// <summary>        /// 售货机接口(骏鹏接口)        /// </summary>        public MachineJP()        {        }        ~MachineJP()        {            if (m_SerialPort != null)            {                m_SerialPort.Close();                m_SerialPort.Dispose();                m_SerialPort = null;            }        }        #endregion        #region 读取串口数据        /// <summary>        /// 读取串口数据        /// </summary>        /// <returns>从串口读取的数据</returns>        private byte[] ReadPort()        {            //读取串口数据            DateTime dt = DateTime.Now;            while (m_SerialPort.BytesToRead < 2)            {                Thread.Sleep(1);                if (DateTime.Now.Subtract(dt).TotalMilliseconds > 1500) //超时                {                    return new byte[0];                }            }            List<byte> recList = new List<byte>();            byte[] recData = new byte[m_SerialPort.BytesToRead];            m_SerialPort.Read(recData, 0, recData.Length);            recList.AddRange(recData);            int length = recData[1] + 2; //报文数据总长度            while (recList.Count < length)            {                if (m_SerialPort.BytesToRead > 0)                {                    recData = new byte[m_SerialPort.BytesToRead];                    m_SerialPort.Read(recData, 0, recData.Length);                    recList.AddRange(recData);                }                Thread.Sleep(1);            }            return recList.ToArray();        }        #endregion        #region 向串口发送数据        /// <summary>        ///  向串口发送数据        /// </summary>        /// <param name="cmd">待发送的命令</param>        /// <param name="SN">序列号</param>        private void WritePort(Cmd cmd, byte SN)        {            //发送数据            List<byte> sendData = cmd.Data;            sendData[1] = (byte)sendData.Count;            sendData[2] = SN;            byte[] checkCode = CommonUtil.CalCheckCode(sendData, sendData.Count);            sendData.AddRange(checkCode);            if (cmd.Mt != null)            {                m_WaitResultMTList.Add(cmd.Mt);            }            m_SerialPort.Write(sendData.ToArray(), 0, sendData.Count);            LogHelper.Log(LogMsgType.Info, true, sendData.ToArray());        }        #endregion        #region 发送ACK消息        /// <summary>        /// 发送ACK消息        /// </summary>        /// <param name="SN">序列号</param>        private void SendACK(byte SN)        {            List<byte> sendData = new List<byte>() { 0xE5, 0x00, 0x00, 0x40, 0x80 };            WritePort(new Cmd(sendData), SN);        }        #endregion        #region Init 初始化        /// <summary>        /// 初始化        /// </summary>        /// <param name="com">串口号(例：COM1)</param>        public void Init(string com)        {            if (m_SerialPort == null)            {                m_SerialPort = new SerialPort(com, 9600, Parity.None, 8, StopBits.One);                m_SerialPort.ReadBufferSize = 1024;                m_SerialPort.WriteBufferSize = 1024;                m_SerialPort.DataReceived += new SerialDataReceivedEventHandler(serialPort_DataReceived);            }            if (!m_SerialPort.IsOpen)            {                m_SerialPort.Open();            }            GET_SETUP();            CONTROL_IND(0x13, new byte[] { 0x00 }); //初始化完成标志            GET_STATUS();            SetDecimalPlaces(2); //设置小数点位数        }        #endregion        #region Close 关闭连接        /// <summary>        /// 关闭连接        /// </summary>        public void Close()        {            m_SerialPort.Close();        }        #endregion        #region 接收串口数据        /// <summary>        /// 接收串口数据        /// </summary>        /// <param name="type">消息类型</param>        /// <param name="subtype">消息子类型</param>        public byte[] Receive(byte type, byte subtype)        {            return m_ReceiveDataCollection.Get(type, subtype);        }        /// <summary>        /// 接收串口数据        /// </summary>        /// <param name="type">消息类型</param>        /// <param name="subtype">消息子类型</param>        public byte[] WaitReceive(byte type, byte subtype)        {            DateTime time = DateTime.Now;            while (true)            {                byte[] receiveData = m_ReceiveDataCollection.Get(type, subtype);                if (receiveData != null) return receiveData;                if (DateTime.Now.Subtract(time).TotalMinutes > 3) return null;                Thread.Sleep(50);            }        }        /// <summary>        /// 接收串口数据        /// </summary>        /// <param name="type">消息类型</param>        public byte[] WaitReceive(byte type)        {            DateTime time = DateTime.Now;            while (true)            {                byte[] receiveData = m_ReceiveDataCollection.Get(type);                if (receiveData != null) return receiveData;                if (DateTime.Now.Subtract(time).TotalMinutes > 3) return null;                Thread.Sleep(50);            }        }        #endregion        #region 判断消息是否发送成功        /// <summary>        /// 判断消息是否发送成功        /// </summary>        public bool SendSuccess(byte type, byte subtype)        {            DateTime time = DateTime.Now;            while (true)            {                if (DateTime.Now.Subtract(time).TotalMinutes > 3)                {                    return false;                }                byte[] ack = m_ReceiveDataCollection.Get(type, subtype);                byte[] nak = m_ReceiveDataCollection.Get(type, subtype);                if (ack != null) return true;                if (nak != null) return false;                Thread.Sleep(1);            }        }        #endregion    }}

第2部分：接收串口数据，并响应货机，向货机发送数据

using System;using System.Collections.Generic;using System.IO.Ports;using System.Linq;using System.Text;using MachineJPDll.Models;using MachineJPDll.Utils;/* * VMC->PC数据的接收,货机事件的分发 */namespace MachineJPDll{    partial class MachineJP    {