串口讀取地磅電子秤C#源代碼

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.IO.Ports;
using System.Threading;
using Microsoft.Win32;
using System.IO;

namespace 串口端口讀取地磅
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        private SerialPort SerialPort1 = new SerialPort();//串口資源對象
        public delegate void HandleInterfaceUpdataDelegate(string text); //委托，此為重點 
        private HandleInterfaceUpdataDelegate interfaceUpdataHandle;
        private int FanChongQuChangDu = 15;//讀取緩沖區指定長度

        /* 
         *特別注意：地磅電子秤如果輸出接口接錯,收到的則是亂碼
         */

        public void Sp_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
        {
            try
            {
                if (SerialPort1.IsOpen)//端口打開中
                {
                    string strTemp = "";
                    //程序等待0.5秒讓緩沖區獲取串口數據
                    double iSecond = 0.5;

                    DateTime dtOld = System.DateTime.Now;
                    DateTime dtNow = System.DateTime.Now;
                    TimeSpan dtInter;
                    dtInter = dtNow - dtOld;

                    int i = SerialPort1.BytesToRead;
                    if (i > 0)
                    {
                        try
                        {
                            strTemp = SerialPort1.ReadExisting();
                        }
                        catch
                        { }
                        if (strTemp.ToLower().IndexOf("\r") < 0)
                        {
                            i = 0;
                        }
                        else
                        {
                            this.Invoke(interfaceUpdataHandle, strTemp);
                        }
                    }
                    while (dtInter.TotalSeconds < iSecond && i <= 0)
                    {
                        dtNow = System.DateTime.Now;
                        dtInter = dtNow - dtOld;
                        i = SerialPort1.BytesToRead;
                        if (i > 0)
                        {
                            try
                            {
                                strTemp += SerialPort1.ReadExisting();
                            }
                            catch
                            { }
                            if (strTemp.ToLower().IndexOf("\r") < 0)
                            {
                                i = 0;
                            }
                            else
                            {
                                this.Invoke(interfaceUpdataHandle, strTemp);
                            }
                        }
                    }
                }
            }
            catch (Exception cw)
            {
                MessageBox.Show(cw.ToString());
                return ;
            }
            
        }

        private void UpdateTextBox(string text)
        {

            txtShiShiZhongLiang.Text = text;
          
            if (SerialPort1.IsOpen)//端口打開
            {
                txtState.Text = "端口連接中"; 
            }
            else
            {
                txtState.Text = "端口已斷開";
            } 
        }

        /// <summary> 
        /// 執行AT指令並返回 成功失敗 
        /// </summary> 
        /// <param name="ATCmd">AT指令</param> 
        /// <param name="StCmd">AT指令標准結束標識</param> 
        /// <returns></returns> 
        private void ATCommand3(string ATCmd, string StCmd)
        {
            string response = "";
            response = ATCommand(ATCmd, StCmd);  
        }

        /// <summary> 
        /// 執行AT指令並返回結果字符 
        /// </summary> 
        /// <param name="ATCmd">AT指令</param> 
        /// <param name="StCmd">AT指令標准結束標識</param> 
        /// <returns></returns> 
        private string ATCommand(string ATCmd, string StCmd)
        {
            string response = "";
            int i;
            if (!ATCmd.EndsWith("\x01a"))
            {
                if (!(ATCmd.EndsWith("\r") || ATCmd.EndsWith("\r\n")))
                {
                    ATCmd = ATCmd + "\r";
                }
            }
            SerialPort1.WriteLine(ATCmd);

            //第一次讀響應數據 
            if (SerialPort1.BytesToRead > 0)
            {
                response = SerialPort1.ReadExisting();

                //去除前端多可能多讀取的字符 
                if (response.IndexOf(ATCmd) > 0)
                {
                    response = response.Substring(response.IndexOf(ATCmd));
                }
                else
                {

                }

                if (response == "" || response.IndexOf(StCmd) < 0)
                {
                    if (response != "")
                    {
                        if (response.Trim() == "ERROR")
                        {
                            //throw vError = new UnknowException("Unknown exception in sending command:" + ATCmd); 
                        }
                        if (response.IndexOf("+CMS ERROR") >= 0)
                        {
                            string[] cols = new string[100];
                            cols = response.Split(';');
                            if (cols.Length > 1)
                            {
                                string errorCode = cols[1];
                            }
                        }
                    }
                }
            }

            //讀第一次沒有讀完的響應數據，直到讀到特征數據或超時 
            for (i = 0; i < 3; i++)
            {
                Thread.Sleep(1000);
                response = response + SerialPort1.ReadExisting();
                if (response.IndexOf(StCmd) >= 0)
                {
                    break;
                }
            }

            return response;


        }

        /// <summary> 
        /// 從注冊表獲取系統串口列表 
        /// </summary> 
        private void GetComList()
        {
            RegistryKey keyCom = Registry.LocalMachine.OpenSubKey("Hardware\\DeviceMap\\SerialComm");
            if (keyCom != null)
            {
                string[] sSubKeys = keyCom.GetValueNames();
                this.cbxDuanKouHao.Items.Clear();
                foreach (string sName in sSubKeys)
                {
                    string sValue = (string)keyCom.GetValue(sName);
                    this.cbxDuanKouHao.Items.Add(sValue);
                }
            }
        }

        private void cmID_DropDown(object sender, EventArgs e)
        {
            GetComList();
        }
         
        private void Form1_Load(object sender, EventArgs e)
        {

            GetComList();
            btPause.Enabled = false;
        }
         
        //暫停監聽讀取數值
        private void btPause_Click(object sender, EventArgs e)
        {
            SerialPort1.Close();
            if (SerialPort1.IsOpen)//端口打開
            {
                txtState.Text = "端口連接中";
            }
            else
            {
                txtState.Text = "端口已斷開";
            }
            btENT.Enabled = true;
            btPause.Enabled = false;

        }
        //一直監聽讀取數值
        private void btENT_Click(object sender, EventArgs e)
        {
            if ((this.cbxDuanKouHao.Text.Trim() != "") && (this.cbxBoTeLv.Text != ""))
            {
                if (SerialPort1 != null )
                {
                    interfaceUpdataHandle = new HandleInterfaceUpdataDelegate(UpdateTextBox);//實例化委托對象 
                    SerialPort1.DataReceived += new SerialDataReceivedEventHandler(Sp_DataReceived);
                    //串口更改
                    if (SerialPort1.PortName != this.cbxDuanKouHao.Text.Trim())
                    {
                        SerialPort1.Close();
                        SerialPort1.Dispose();
                        SerialPort1 = new SerialPort();//串口資源對象
                        interfaceUpdataHandle = new HandleInterfaceUpdataDelegate(UpdateTextBox);//實例化委托對象 
                        SerialPort1.PortName = this.cbxDuanKouHao.Text.Trim();
                        SerialPort1.BaudRate = Convert.ToInt32(this.cbxBoTeLv.Text.Trim());
                        SerialPort1.Parity = JiaoYanWei(cbxJiaoYanWei.Text);
                        SerialPort1.StopBits = TingZhiWei(cbxTingZhiWei.Text);
                        SerialPort1.Encoding = Encoding.ASCII;//獲取傳輸字符編碼
                        SerialPort1.DataReceived += new SerialDataReceivedEventHandler(Sp_DataReceived);
                        SerialPort1.ReceivedBytesThreshold = 1;
                        try
                        {
                            SerialPort1.Open();

                            ATCommand3("AT+CLIP=1\r", "OK");


                            btPause.Enabled = true;
                            btENT.Enabled = false;
                        }
                        catch (Exception)
                        {
                            MessageBox.Show("端口" + this.cbxDuanKouHao.Text.Trim() + "打開失敗！");
                        }
                    }
                    else//串口未更改
                    {
                        if(SerialPort1.IsOpen)//端口已打開
                        {
                            btPause.Enabled = true;
                            btENT.Enabled = false;
                        }
                        else
                        {
                            SerialPort1.Open();
                            btPause.Enabled = true;
                            btENT.Enabled = false;
                        } 
                    }
                }
                else
                {
                    interfaceUpdataHandle = new HandleInterfaceUpdataDelegate(UpdateTextBox);//實例化委托對象 
                    SerialPort1.PortName = this.cbxDuanKouHao.Text.Trim();
                    SerialPort1.BaudRate = Convert.ToInt32(this.cbxBoTeLv.Text.Trim());
                    SerialPort1.Parity = JiaoYanWei(cbxJiaoYanWei.Text);
                    SerialPort1.StopBits = TingZhiWei(cbxTingZhiWei.Text);
                    SerialPort1.Encoding = Encoding.ASCII;//獲取傳輸字符編碼
                    SerialPort1.DataReceived += new SerialDataReceivedEventHandler(Sp_DataReceived);
                    SerialPort1.ReceivedBytesThreshold = 1;
                    try
                    {
                        SerialPort1.Open();

                        ATCommand3("AT+CLIP=1\r", "OK");


                        btPause.Enabled = true;
                        btENT.Enabled = false;
                    }
                    catch (Exception)
                    {
                        MessageBox.Show("端口" + this.cbxDuanKouHao.Text.Trim() + "打開失敗！");
                    }
                } 
            }
            else
            {
                MessageBox.Show("請輸入正確的端口號和波特率！");
                this.cbxDuanKouHao.Focus(); 
            }
        }
        
        /// <summary>
        /// 讀一次數:注意電子秤設置的發送信息規則：如果不是連續發送，是穩定后發送，則有時候讀不到數
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnDuYiCi_Click(object sender, EventArgs e)
        {
            try
            {
                if ((this.cbxDuanKouHao.Text.Trim() != "") && (this.cbxBoTeLv.Text != ""))
                {
                    if (SerialPort1 != null)
                    {
                        SerialPort1.Close();
                        SerialPort1.Dispose();
                        SerialPort1 = new SerialPort();//重新創建串口資源對象，否則導致程序卡死
                        //串口更改
                        if (SerialPort1.PortName != this.cbxDuanKouHao.Text.Trim())
                        {
                            SerialPort1.PortName = this.cbxDuanKouHao.Text.Trim();
                            SerialPort1.BaudRate = Convert.ToInt32(this.cbxBoTeLv.Text.Trim());
                            SerialPort1.Parity = JiaoYanWei(cbxJiaoYanWei.Text);
                            SerialPort1.StopBits = TingZhiWei(cbxTingZhiWei.Text);
                            SerialPort1.Encoding = Encoding.ASCII;//獲取傳輸字符編碼
                            SerialPort1.ReceivedBytesThreshold = 1;
                            try
                            {
                                SerialPort1.Open();

                                ATCommand3("AT+CLIP=1\r", "OK");
                                this.txtShiShiZhongLiang.Text = dushu();
                            }
                            catch (Exception)
                            {
                                MessageBox.Show("端口" + this.cbxDuanKouHao.Text.Trim() + "打開失敗！");
                            }
                        }
                        else//串口未更改
                        {
                            if (SerialPort1.IsOpen)//端口已打開
                            {
                                ATCommand3("AT+CLIP=1\r", "OK");
                                this.txtShiShiZhongLiang.Text = dushu();
                            }
                            else
                            {
                                SerialPort1.Open();
                                ATCommand3("AT+CLIP=1\r", "OK");
                                this.txtShiShiZhongLiang.Text = dushu();
                            }
                        }
                    }
                    else
                    {

                        SerialPort1.PortName = this.cbxDuanKouHao.Text.Trim();
                        SerialPort1.BaudRate = Convert.ToInt32(this.cbxBoTeLv.Text.Trim());
                        SerialPort1.Parity = JiaoYanWei(cbxJiaoYanWei.Text);
                        SerialPort1.StopBits = TingZhiWei(cbxTingZhiWei.Text);

                        SerialPort1.ReceivedBytesThreshold = 1;
                        try
                        {
                            SerialPort1.Open();

                            ATCommand3("AT+CLIP=1\r", "OK");
                            this.txtShiShiZhongLiang.Text = dushu();
                        }
                        catch (Exception)
                        {
                            MessageBox.Show("端口" + this.cbxDuanKouHao.Text.Trim() + "打開失敗！");
                        }
                    }
                }
                else
                {
                    MessageBox.Show("請輸入正確的端口號和波特率！");
                    this.cbxDuanKouHao.Focus();
                }
                if (SerialPort1.IsOpen)
                {
                    SerialPort1.Close();
                }  
            }
            catch (Exception)
            {
                
                return;
            }
            
        }
        /// <summary>
        /// 讀取緩沖區指定長度數值
        /// </summary>
        /// <param name="changdu"></param>
        /// <returns></returns>
        private string dushu()
        {
            string strTemp = "";
            try
            {
                if (SerialPort1.IsOpen)//端口打開中
                {

                    int i = SerialPort1.BytesToRead;//獲取緩沖區字節數

                    #region 程序等待0.5秒讓緩沖區獲取串口數據
                    double iSecond = 0.5;

                    DateTime dtOld = System.DateTime.Now;
                    DateTime dtNow = System.DateTime.Now;
                    TimeSpan dtInter;
                    dtInter = dtNow - dtOld; 

                    while (dtInter.TotalSeconds < iSecond && i <= 0)
                    {
                        dtNow = System.DateTime.Now;
                        dtInter = dtNow - dtOld;
                        i = SerialPort1.BytesToRead;
                    }
                    #endregion
                    if (i > 0)
                    {
                        try
                        {

                            byte[] buf = new byte[FanChongQuChangDu];//  定義接收緩沖區 
                            SerialPort1.Read(buf, 0, FanChongQuChangDu); 
                            for (int j = 0; j < FanChongQuChangDu; j++)
                            {

                                 ASCIIEncoding ASCIITochar = new ASCIIEncoding();
                                 char[] ascii = ASCIITochar.GetChars(buf); 　　　　 // 將接收字節解碼為ASCII字符數組
                                 strTemp += ascii[j];
                                 //已讀到換行符就跳出
                                 if (strTemp.ToLower().IndexOf("\r") > 0)
                                 {
                                     break;
                                 }
                             } 
                        }
                        catch
                        { } 
                    }
                } 
            }
            catch (Exception)
            {

                return strTemp;
            }
            return strTemp;
        }

        private void btnZhuaQu_Click(object sender, EventArgs e)
        {
            this.txtZhuaQuZhi.Text = this.txtShiShiZhongLiang.Text;
        }
        /// <summary>
        /// 返回校驗位
        /// </summary>
        /// <param name="zhi"></param>
        /// <returns></returns>
        private Parity JiaoYanWei(string zhi)
        {
            switch (zhi)
            { 
                case "Even": return Parity.Even;
                case "Mark": return Parity.Mark;
                case "None": return Parity.None;
                case "Odd": return Parity.Odd;
                case "Space": return Parity.Space;
                default: return Parity.None;
            }
        }
        /// <summary>
        /// 返回停止位
        /// </summary>
        /// <param name="zhi"></param>
        /// <returns></returns>
        private StopBits TingZhiWei(string zhi)
        {
            switch (zhi)
            {
                case "0": return StopBits.None;
                case "1": return StopBits.One;
                case "1.5": return StopBits.OnePointFive;
                case "2": return StopBits.Two;
                default: return StopBits.One;
            }
        }
        /// <summary>
        /// ASCII碼轉字符
        /// </summary>
        /// <param name="asciiCode"></param>
        /// <returns></returns>
        public static string asciiToString(int asciiCode)
        {
            if (asciiCode >= 0 && asciiCode <= 255)
            {
                System.Text.ASCIIEncoding asciiEncoding = new System.Text.ASCIIEncoding();
                byte[] byteArray = new byte[] { (byte)asciiCode };
                string strCharacter = asciiEncoding.GetString(byteArray);
                return (strCharacter);
            }
            else
            {
                throw new Exception("ASCII Code is not valid.");
            }
        }
        //用封裝對象來實現
        private void button1_Click(object sender, EventArgs e)
        {
            try
            {
                mycom mycom1 = new mycom();
                mycom1.PortNum = cbxDuanKouHao.Text;
                mycom1.BaudRate = Convert.ToInt32(cbxBoTeLv.Text);
                mycom1.StopBits = 8;
                mycom1.Parity = 0;
                mycom1.StopBits = Convert.ToByte(cbxTingZhiWei.Text);
                mycom1.ReadTimeout = 10;

                mycom1.Open();
                string dushu = "";
                byte[] buf = mycom1.Read(12);

                for (int j = 0; j < 12; j++)
                {

                    ASCIIEncoding ASCIITochar = new ASCIIEncoding();
                    char[] ascii = ASCIITochar.GetChars(buf); 　　　　 // 將接收字節解碼為ASCII字符數組
                    dushu += ascii[j];

                }

                txtShiShiZhongLiang.Text = dushu;

                mycom1.Close(); 
            }
            catch (Exception cuowu)
            {
                MessageBox.Show(cuowu.Message);
                return ;
            }
            
        }
    }
}