C#SerialPort實作序列槽控制繼電器

最近做了一個小系統，麻雀雖小五髒俱全呀，用到各種線程控制，序列槽控制等技術。其中序列槽控制最麻煩，因為繼電器的響應很快，根據不同的轉接口，傳回的資料品質是不一樣的，是以不能直接wirte，然後馬上read，這樣經常得到的效應狀态是錯誤的。是以需要用到backgroundworker不停地read，校驗資料成功後再設定成功狀态标志，最後讓timer定時擷取改标志，成功後立即控制程式界面上的按鈕等控件。

public void openSerial()
        {
            try
            {
                foreach (GlobaConfig config in GlobaConfigInstance.Instance)
                {
                    if ((!config.SerialPort.IsOpen))
                    {
                        config.SerialPort.Open();
                        config.SerialPort.DiscardInBuffer();
                        config.SerialPort.DiscardOutBuffer();
                    }
                }
            }
            catch(Exception ex)
            {
                //MessageBox.Show("打開失敗！" + ex.Message);
                NotificationManager.Show(this, "打開失敗！" + ex.Message,
                                Color.Gold, 1000);
                return;
            }
        }

private void SendOpenDemand(byte port)
        {
            byte[] buffer = new byte[20];
            byte[] buffer2 = new byte[2];
            buffer[0] = GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr;
            buffer[1] = 5;
            buffer[2] = 0;
            buffer[3] = port;
            buffer[4] = 0xff;
            buffer[5] = 0;
            A101.GetCRC(buffer, 6, buffer2);
            buffer[6] = buffer2[0];
            buffer[7] = buffer2[1];
            if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
            {
                this.SerialSendFrame(buffer, 0, 8);
            }
            else
            {
                //MessageBox.Show("親，你要先打開序列槽哦！");
            }
        }


        private void SendCloseDemand(byte port)
        {
            byte[] buffer = new byte[20];
            byte[] buffer2 = new byte[2];
            buffer[0] = GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr;
            buffer[1] = 5;
            buffer[2] = 0;
            buffer[3] = port;
            buffer[4] = 0;
            buffer[5] = 0;
            A101.GetCRC(buffer, 6, buffer2);
            buffer[6] = buffer2[0];
            buffer[7] = buffer2[1];
            if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
            {
                this.SerialSendFrame(buffer, 0, 8);
            }
            else
            {
                //MessageBox.Show("親，你要先打開序列槽哦！");
            }
        }

private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
        {
            byte[] buffer;
            while (true)
            {
                try
                {

                    if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
                    {
                        int bytesToRead = GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.BytesToRead;
                        buffer = new byte[0xff];
                        if (bytesToRead > 0)
                        {
                            int num2;
                            bytesToRead = 0x45;
                            GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.Read(buffer, 0, bytesToRead);
                            bool isValid = A101.ValidCRC(buffer, (byte)bytesToRead);
                            System.Diagnostics.Debug.WriteLine("isValid: " + isValid);
                            if (isValid)
                            {
                                for (num2 = 0; num2 < bytesToRead; num2++)
                                {
                                    this.SerialRecBuf[num2] = buffer[num2];
                                }

                                this.SerialRecFlag = true;
                            }
                            else
                                this.SerialRecFlag = false;

                        }
                    }
                }
                catch (Exception ex)
                {
                    
                    Console.WriteLine(ex);
                }
                Thread.Sleep(1);
            }
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            if (this.SerialRecFlag)
            {
                this.SerialRecFlag = false;
                if (((this.SerialRecBuf[0] == GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr) && (this.SerialRecBuf[1] == 5)) && (this.SerialRecBuf[4] == 0))
                {
                    this.BtnSendFlag = false;
                    if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
                    {
                        Control[] controls = this.kryptonNavigator1.SelectedPage.Controls.Find("btnRelay" + kryptonNavigator1.SelectedIndex + this.SerialRecBuf[3], true);
                        if (controls.Length > 0)
                        {
                            KryptonCheckButton button = controls[0] as KryptonCheckButton;
                            button.Checked = false;
                            button.Tag = "斷開";
                            button.Enabled = true;
                        }
                    }
                }
                else if (((this.SerialRecBuf[0] == GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr) && (this.SerialRecBuf[1] == 5)) && (this.SerialRecBuf[4] == 0xff))
                {
                    this.BtnSendFlag = false;

                    if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
                    {
                        Control[] controls = this.kryptonNavigator1.SelectedPage.Controls.Find("btnRelay" + kryptonNavigator1.SelectedIndex + this.SerialRecBuf[3], true);
                        if (controls.Length > 0)
                        {
                            KryptonCheckButton button = controls[0] as KryptonCheckButton;
                            button.Checked = true;
                            button.Tag = "閉合";
                            button.Enabled = true;
                        }
                    }
                }
                else if (((this.SerialRecBuf[0] == GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr) && (this.SerialRecBuf[1] == 1)) && (this.SerialRecBuf[2] == 4))
                {
                    uint[] numArray = new uint[4];
                    uint resource = 0;
                    numArray[0] = this.SerialRecBuf[3];
                    numArray[1] = this.SerialRecBuf[4];
                    numArray[2] = this.SerialRecBuf[5];
                    numArray[3] = this.SerialRecBuf[6];
                    resource = (((numArray[3] << 0x18) | (numArray[2] << 0x10)) | (numArray[1] << 8)) | numArray[0];

                    if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
                    {
                        foreach (Control control in this.kryptonNavigator1.SelectedPage.Controls[2].Controls)
                        {
                            KryptonCheckButton button = control as KryptonCheckButton;
                            if (this.GetRegBit(resource, (byte)control.TabIndex) == 0)
                            {
                                button.Checked = false;
                                button.Tag = "斷開";
                            }
                            else
                            {
                                button.Checked = true;
                                button.Tag = "閉合";
                            }
                            button.Enabled = true;
                        }
                    }
                }

            }
        }

        private void timer2_Tick(object sender, EventArgs e)
        {
            if (!this.BtnSendFlag)
            {
                byte[] buffer = new byte[20];
                byte[] buffer2 = new byte[2];
                buffer[0] = GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].Addr;
                buffer[1] = 1;
                buffer[2] = 0;
                buffer[3] = 0;
                buffer[4] = 0;
                buffer[5] = 0x1c;
                A101.GetCRC(buffer, 6, buffer2);
                buffer[6] = buffer2[0];
                buffer[7] = buffer2[1];
                System.Diagnostics.Debug.WriteLine(kryptonNavigator1.SelectedIndex + ":" + GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen);
                if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.IsOpen)
                {
                    this.SerialSendFrame(buffer, 0, 8);
                    this.timer1.Start();
                }
                else
                {
                    if (GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].IsValid == true)
                    {
                        GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].IsValid = false;
                        try
                        {
                            GlobaConfigInstance.Instance[kryptonNavigator1.SelectedIndex].SerialPort.Open();
                            //修復退出的線程
                            //this.timer1 = new System.Windows.Forms.Timer();
                            this.timer1.Start();
                        }
                        catch (Exception ex)
                        {
                            NotificationManager.Show(this, "主機" + (kryptonNavigator1.SelectedIndex + 1) + "出現異常：" + ex.Message, 
                                Color.Gold, 1000);
                            //MessageBox.Show("主機" + (kryptonNavigator1.SelectedIndex + 1) + "出現異常：" + ex.Message);
                        }
                    }
                }
            }
        }