C# 单线程扫描数据库短信监听程序源码(含数据库脚本)

【实例简介】线程循环读取数据库

【实例截图】

【核心代码】public void ThreadProc(object sender, DoWorkEventArgs e) {
            BackgroundWorker backgroundWorker = sender as BackgroundWorker;
            System.Data.DataSet ds = new DataSet();
            //赋值maxbysql
            strSql = "select maxidbysql from maxid where 1=1";
            maxBySql=SqlHelper.ExecuteScalarText(strSql, null).ToString();
            OutputLog("本次执行数据 index= " maxBySql);

            while (allready) {
                #region 从数据库中取出短信
                try {
                    strSql = "select [index],substring(phonenumber,0,4) '****' substring(phonenumber,8,4) as phonenumber,fromsmsnumber,fromsmscontent,time from smsreceive where [index]>@Index and [time] > dateadd(dd,@Count,getdate())";

                    SqlParameter sqlParameter1 = new SqlParameter("@Index", DbType.Int16);
                    SqlParameter sqlParameter2 = new SqlParameter("@Count", DbType.Int16);

                    sqlParameter1.Value = maxBySql;
                    sqlParameter2.Value = -70;
                    SqlParameter[] sqlParameter = { sqlParameter1, sqlParameter2, };
                    ds = SqlHelper.ExecuteDataSetText(strSql, sqlParameter);
                    if (ds.Tables.Count > 0) {

                        if (ds.Tables[0].Rows.Count > 0) {

                            for (int i = 0; i < ds.Tables[0].Rows.Count; i ) {

                                if (backgroundWorker.CancellationPending == true) {
                                    e.Cancel = true;
                                    allready = false;
                                    break;
                                }
                                string content = ds.Tables[0].Rows[i]["fromsmscontent"].ToString();     //(sqlDatareader.IsDBNull(0))?-1:sqlDatareader.GetInt32(0);
                                string mmsurl = ds.Tables[0].Rows[i]["phonenumber"].ToString();                         //(sqlDatareader.IsDBNull(3))?"":sqlDatareader.GetString(3);
                                string smssender = ds.Tables[0].Rows[i]["fromsmsnumber"].ToString();
                                string arrivaltime = ds.Tables[0].Rows[i]["time"].ToString();       //(sqlDatareader.IsDBNull(1))?"":sqlDatareader.GetString(1);
                                string id = ds.Tables[0].Rows[i]["index"].ToString();
                                string ruleSmsCode = "";
                                string smsCode = string.Empty;
                                //oratr = this.oraCon.BeginTransaction();
                                int index = 0;
                                switch (smssender) {
                                    case "95516"://银联
                                        ruleSmsCode = "款验证码";
                                        index = content.IndexOf(ruleSmsCode);
                                        if (index > 0) {
                                            smsCode = content.Substring(index 4, 6);//短信内容

                                        }
                                        this.toolStripStatusLabel1.Text = smsCode;
                                        break;
                                    case "95566"://中行
                                        ruleSmsCode = "验证码是";
                                        index = content.IndexOf(ruleSmsCode);
                                        if (index > 0) {
                                            smsCode = content.Substring(index 4, 6);//短信内容                 
                                        }
                                        break;
                                    case "95533"://建行
                                        ruleSmsCode = "验证码：";
                                        index = content.IndexOf(ruleSmsCode);
                                        if (index > 0) {
                                            smsCode = content.Substring(index 4, 6);//短信内容               
                                        }
                                        break;
                                }

                                string allContent = "from:" smssender ",to: " mmsurl "," arrivaltime;
                                this.toolStripStatusLabel1.Text = allContent;

                                if (showFlag) {
                                    this.Invoke(new Action(() => {
                                        CDO_Control.SoftSingle<Form1>();
                                    }));
                                }
                                content = content " \r\n [" allContent "]";
                                OutputLog(content);
                                strSql = "update maxid set maxidbysql=" id;
                                int result;

                                result = SqlHelper.ExecteNonQueryText(strSql, null);
                                maxBySql = id;
                                if (result != 1) {
                                    OutputLog("update maxid error!");
                                }
                                int sleepS = Convert.ToInt16(sleepSecond);
                                Thread.Sleep(sleepS);
                                

                            }

                        }
                    }

                } catch (Exception ex) {
                    OutputLog(ex.Message);
                } finally {
                }
                #endregion

            }

        }