分享一個GSM短信貓接口程序

筆錄收藏 2013-04-17

展開全文

GSM短信貓編程的難點在與“程序與GSM”通訊是異步的。

例如：

AT+CSQ 查詢信號指令，ＰＣ通過ＲＳ２３２串口發(fā)送后，GSM短信貓要等一小會才回答，而且還可能不回答。

這樣一來就導致編程復雜了。

下面的程序采用了串口中斷接收、定時器、線程的方式配合。實現(xiàn)了接收短信，并把接收到的短信存在數(shù)據(jù)庫中。然后定期發(fā)送短信

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace SMS
{
public class GSMModem
{
private string protName;
private int BaudRate;
private System.Collections.ArrayList alRecevingSM;// 短信接收緩沖區(qū)
private System.Collections.ArrayList alSendSM; // 短信【待】發(fā)送緩沖區(qū)
private System.Collections.ArrayList alAuthorizationNumber; //授權(quán)號碼，系統(tǒng)只會回復授權(quán)號碼
int WORK_STATE;//短信貓工作狀態(tài)
//錯誤的短信數(shù)，主要是未經(jīng)授權(quán)的號碼發(fā)來的短信
private int ErrorSMCount = 0;
public int _ErrorSMCount
{
get
{
return ErrorSMCount;
}
}
/// <summary>
/// 0=自檢
/// 1=接收
/// 2=發(fā)送
/// </summary>
public int _WORK_STATE
{
get
{
return WORK_STATE;
}
}
//接收和發(fā)送定時器不能同時工作，切記
//短信接收輪詢定時器，定時發(fā)送 AT+CGMR={0}
System.Windows.Forms.Timer revTimer = new System.Windows.Forms.Timer();
//短信發(fā)送隊列定時器，定時發(fā)送 AT+CMGS={0}
System.Windows.Forms.Timer sendTimer = new System.Windows.Forms.Timer();
//短信貓自檢
System.Windows.Forms.Timer selfCheckingTimer = new System.Windows.Forms.Timer();
//短信貓連接設(shè)備端口
System.IO.Ports.SerialPort Port = new System.IO.Ports.SerialPort();
//短信貓串口接收緩沖
/*備注：該緩沖變量由串口DataReceived事件負責接收，具體的處理過程由
* Timer 定時器內(nèi)的代碼具體執(zhí)行
*/
string temp_gsm_str_buf = "";
//
int CMGD_MAX_ID = 0;//短信卡最大SM容量，通常情況下設(shè)置為25
int CMGD_ID = 1; //當前串口發(fā)送讀取的短信ID號
int GSM_RST_ACT = 0;
int GSM_MAX_RST_ACT = 8;
int CGMS_Count = 0; //短信發(fā)送數(shù)量
public int _CGMS_Count
{
get
{
return CGMS_Count;
}
}
public int _CMGD_MAX_ID
{
get
{
return CMGD_MAX_ID;
}
}
public int _CMGD_ID
{
get
{
return CMGD_ID;
}
}
public int _GSM_RST_ACT
{
get
{
return GSM_RST_ACT;
}
}
public int _GSM_MAX_RST_ACT
{
get
{
return GSM_MAX_RST_ACT;
}
}
#region 短信貓工作狀態(tài)
string INF_GSM_CSQ;
string INF_GSM_CSCS;
string INF_GSM_CSCA;
string INF_GSM_CNMI;
bool INF_GSM_State;
public string _INF_GSM_CSQ
{
get
{
return INF_GSM_CSQ;
}
}
public string _INF_GSM_CSCS
{
get
{
return INF_GSM_CSCS;
}
}
public string _INF_GSM_CSCA
{
get
{
return INF_GSM_CSCA;
}
}
public string _INF_GSM_CNMI
{
get
{
return INF_GSM_CNMI;
}
}
public bool _INF_GSM_State
{
get
{
return INF_GSM_State;
}
}
#endregion
private int _CmgsSleepTime;
public GSMModem(string protName,
string BaudRate,
int CMGD_MAX_ID,
System.Collections.ArrayList RecevingSM,
System.Collections.ArrayList SendSM,
int revTimerInterval,
int sendTimerInterval,
int selfCheckingTimerInterval,
int CmgsSleepTime,
System.Collections.ArrayList alAuthorizationNumber
)
{
_CmgsSleepTime = CmgsSleepTime;//AT+CMGS 指令發(fā)送后，稍微延遲一定時間，讓短信貓做出反應
this.alAuthorizationNumber = alAuthorizationNumber;//保存授權(quán)號碼
this.CMGD_MAX_ID = CMGD_MAX_ID;
this.protName = protName;
this.BaudRate = int.Parse(BaudRate);
this.alRecevingSM = RecevingSM;
this.alSendSM = SendSM;
selfCheckingTimer.Enabled = false;
revTimer.Interval = revTimerInterval;
revTimer.Enabled = false;
sendTimer.Interval = sendTimerInterval;
sendTimer.Enabled = false;
revTimer.Tick += revTimer_Tick; //掛接短信輪詢定時器
sendTimer.Tick += sendTimer_Tick;
selfCheckingTimer.Interval = selfCheckingTimerInterval;
selfCheckingTimer.Tick += selfCheckingTimer_Tick;
Port.DataReceived += Port_DataReceived;
}
public bool Start()
{
try
{
Port.PortName = protName;
Port.BaudRate = BaudRate;
Port.Open();//打開串口
//短信貓先自檢，自檢成功了，才能進行接收或發(fā)送
selfCheckingTimer.Enabled = true;
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
return false;
}
return false;
}
public bool Stop()
{
sendTimer.Enabled = false;
revTimer.Enabled = false;
selfCheckingTimer.Enabled = false;
Port.Close();
CMGD_ID = 1;
alRecevingSM.Clear();
alSendSM.Clear();
ErrorSMCount = 0;
return true;
}
void Port_DataReceived(object sender, System.IO.Ports.SerialDataReceivedEventArgs e)
{
System.IO.Ports.SerialPort serialPort = Port;
int len = serialPort.BytesToRead;
byte[] bs = new byte[len];
serialPort.Read(bs, 0, len);
if (len == 0)
{
return;
}
else
{
//接收處理
string r = Encoding.ASCII.GetString(bs, 0, len);
temp_gsm_str_buf += r;
//接收數(shù)據(jù)處理
//txtGsmRevLog.Invoke(new EventHandler(DoUpdate), r); //線程處理
Console.Write(r);
}
}
private bool AuthorizationPhoneNumber(string phoneID)
{
for (int i = 0; i < alAuthorizationNumber.Count; i++)
{
string s = alAuthorizationNumber[i].ToString();
if (phoneID.Equals(s))
return true;
}
return false;
}
bool DoGsmDataReceived()
{
//短信貓發(fā)回數(shù)據(jù)處理
string str = temp_gsm_str_buf;
if (str.Trim().StartsWith("+CMGR"))
{
int P1 = str.IndexOf("0891");
if (P1 != -1)
{
str = str.Substring(P1);
int P2 = str.IndexOf("\r\n");
if (P2 != -1)
{
string uPDU = str.Substring(0, P2);
string decMsg = PDUDecoding.DecodingMsg(uPDU);
string[] content = decMsg.Split(',');
string stime = content[1].ToString();
string sphoneId = content[0].ToString().Replace("+86", "");
string sgsmtxt = content[2].ToString();
//object[] row = { stime, sphoneId, sgsmtxt };
if (AuthorizationPhoneNumber(sphoneId))
{
SMDATA sm = new SMDATA();
sm.sTime = stime;
sm.sPoneID = sphoneId;
sm.sContent = sgsmtxt;
sm.pdu = uPDU;
sm.sType = "Admin";
alRecevingSM.Add(sm);
}
else
{
//未經(jīng)授權(quán)的用戶，10086短信，廣告信息，垃圾短信，用戶手機號碼
string[] gsmCmd = sgsmtxt.Trim().Split('+');
string cmd = gsmCmd[0].ToString();
if (cmd == "CX")
{
if (gsmCmd.Length == 1)
{
//僅限用戶手機號碼
SMDATA sm = new SMDATA();
sm.sTime = stime;
sm.sPoneID = sphoneId;
sm.sContent = "CX"; //讓BI查詢車輛信息
sm.pdu = uPDU;
sm.sType = "User";
alRecevingSM.Add(sm);
}
}
else
{
Console.WriteLine("Error:" + stime + " " + sphoneId + " " + sgsmtxt);
ErrorSMCount++;
}
}
return true;
}
}
}
else
{
}
return false;
}
bool DoGsmDataSend()
{
//短信貓發(fā)回數(shù)據(jù)處理
string str = temp_gsm_str_buf;
if (str.Trim().IndexOf("+CMGS") > -1)
{
temp_gsm_str_buf = "";
CGMS_Count++;
return true;
}
else
{
//接收到錯誤信息，可能是短信發(fā)送失敗
}
temp_gsm_str_buf = "";
return false;
}
//短信發(fā)送指令發(fā)送定時器
int SendID;
int AT_CMGS_LEN;
void sendTimer_Tick(object sender, EventArgs e)
{
WORK_STATE = 2;//設(shè)置短信貓工作模式為發(fā)送
if (DoGsmDataSend())
{
alSendSM.RemoveAt(SendID);
}
//沒有發(fā)送的短信了
if (alSendSM.Count == 0)
{
CMGD_ID = 1;
sendTimer.Enabled = false; //關(guān)閉發(fā)送
revTimer.Enabled = true; //打開接收
}
else
{
SendID = 0;
SMDATA sendSM = (SMDATA)alSendSM[SendID];
string sPoneID = sendSM.sPoneID;
string sContent = sendSM.sContent;
string msg = sContent;
string pdu = PDUDecoding.GetPDUMsg(sPoneID, msg);
AT_CMGS_LEN = PDUDecoding.getLenght(msg);
GsmWrite(string.Format("AT+CMGS={0}\r", AT_CMGS_LEN.ToString()));
Thread.Sleep(_CmgsSleepTime); //500延時，如果短信貓反應慢，設(shè)置為1000
GsmWrite(pdu + "\r");
}
}
//短信輪詢指令發(fā)送定時器
void revTimer_Tick(object sender, EventArgs e)
{
//定時器每中斷1次，接收1條指令
WORK_STATE = 1;//設(shè)置短信貓工作模式為接收
if (DoGsmDataReceived())
{
int old_CMGD_ID = CMGD_ID - 1;
GsmWrite("AT+CMGD=" + old_CMGD_ID.ToString() + "\r");
Thread.Sleep(1000);
}
if (CMGD_ID > CMGD_MAX_ID)
{
revTimer.Enabled = false;//停止接收
sendTimer.Enabled = true;//啟動短信發(fā)送
}
else
{
//再讀取下一條
temp_gsm_str_buf = "";
GsmWrite("AT+CMGR=" + CMGD_ID.ToString() + "\r");
CMGD_ID++;
}
}
#region 短信貓初始信息
private void selfCheckingTimer_Tick(object sender, EventArgs e)
{
//先處理串口接收的數(shù)據(jù)
//Console.WriteLine(temp_gsm_str_buf);
WORK_STATE = 0; //設(shè)置工作狀態(tài)為自檢
string str = "";
if (temp_gsm_str_buf.Length > 0)
{
int CSQ = temp_gsm_str_buf.IndexOf("+CSQ");
if (CSQ > -1)
{
str = temp_gsm_str_buf.Substring(CSQ);
string[] content = str.Trim().Split(':');
if (content.Length > 1)
{
INF_GSM_CSQ = content[1].ToString().Replace("OK", "").Replace("\r\n", "").Replace("\"", "");
GSM_RST_ACT++;
}
temp_gsm_str_buf = "";
}
int CSCS = temp_gsm_str_buf.IndexOf("+CSCS");
if (CSCS > -1)
{
str = temp_gsm_str_buf.Substring(CSCS);
string[] content = str.Trim().Split(':');
if (content.Length > 1)
{
INF_GSM_CSCS = content[1].ToString().Replace("OK", "").Replace("\r\n", "").Replace("\"", "");
GSM_RST_ACT++;
}
temp_gsm_str_buf = "";
}
int CSCA = temp_gsm_str_buf.IndexOf("+CSCA");
if (CSCA > -1)
{
str = temp_gsm_str_buf.Substring(CSCA);
string[] content = str.Trim().Split(':');
if (content.Length > 1)
{
INF_GSM_CSCA = content[1].ToString().Replace("OK", "").Replace("\r\n", "").Replace("\"", "");
GSM_RST_ACT++;
}
temp_gsm_str_buf = "";
}
int CNMI = temp_gsm_str_buf.IndexOf("+CNMI");
if (CNMI > -1)
{
str = temp_gsm_str_buf.Substring(CNMI);
string[] content = str.Trim().Split(':');
if (content.Length > 1)
{
INF_GSM_CNMI = content[1].ToString().Replace("OK", "").Replace("\r\n", "");
GSM_RST_ACT++;
}
temp_gsm_str_buf = "";
}
}
//
switch (GSM_RST_ACT)
{
case 0: { GsmWrite("ATE0\r"); GSM_RST_ACT++; break; }
case 1: { GsmWrite("AT+CSQ\r"); break; }
case 2: { GsmWrite("AT+CMGF=1\r"); GSM_RST_ACT++; break; }
case 3: { GsmWrite("AT+CSCS?\r"); break; }
case 4: { GsmWrite("AT+CSCA?\r"); break; }
case 5: { GsmWrite("AT+CMGF=0\r"); GSM_RST_ACT++; break; }
//AT+CNMI=0,0,0,0
//case 6: { GsmWrite("AT+CNMI=3,1,0,0\r"); GSM_ACT++; break; }
case 6: { GsmWrite("AT+CNMI=0,0,0,0\r"); GSM_RST_ACT++; break; }
case 7: { GsmWrite("AT+CNMI?\r"); break; }
case 8:
{
INF_GSM_State = true;
selfCheckingTimer.Enabled = false;
revTimer.Enabled = true;//啟動接收
//btnSendTestSM.Enabled = true;
//checkBox1.Enabled = true;
//btnSendTestSM.Enabled = true;
//timer_gsm_REST.Enabled = false;
break;
}
default:
{
selfCheckingTimer.Enabled = false;
//timer_gsm_REST.Enabled = false;
INF_GSM_State = false;
MessageBox.Show("短信貓自檢失敗!");
break;
}
}
}
#endregion
private void GsmWrite(string str)
{
Port.Write(str);
Console.Write(str);
}
public int GetSMCount()
{
return alRecevingSM.Count;
}
}
}