实例介绍
【实例简介】对于硬件短信猫，可实现多端口管理，数据库及网络通讯，实现短信猫自动值守
ps:缺少数据库，可参考其功能
【实例截图】【核心代码】
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Threading;
namespace SMS.Entity
{
/// <summary>
/// 管理卡的加载，数据分发
/// </summary>
public class CardManager : ThreadCore, IdataManager
{
/// <summary>
/// 加载界面管理类
/// </summary>
FormManager FM;
/// <summary>
/// 短信猫是否全部失效
/// </summary>
Boolean gsmFail;
Form1 F;
//当前单独调试端口号
public static string debuggingPort = "100";
//分发策略
static int cl;
public static int Cl
{
get { return CardManager.cl; }
set { CardManager.cl = value; }
}
public Boolean GsmFail
{
get { return gsmFail; }
set { gsmFail = value; }
}
/// <summary>
/// 平台是否全部失效
/// </summary>
Boolean pTFail;
public Boolean PTFail
{
get { return pTFail; }
set { pTFail = value; }
}
List<gsmSender> gsmGroup;
List<SMSplat> RdsG;
//可用端口列表
List<String> PortGP;
/// <summary>
/// 构造函数
/// </summary>
/// <param name="f">引用界面</param>
public CardManager(Form1 f)
{
string[] tempSMSp = Properties.Settings.Default.SMSplat1.Split(',');
this.PortGP = this.getPortAva();
F = f;
FM = new FormManager();
FM.setForm(F, this.PortGP, tempSMSp);
gsmGroup = new List<gsmSender>();
RdsG = new List<SMSplat>();
this.creatGroup();
for (int i = 0; i < gsmGroup.Count; i )
{
gsmGroup[i].StarRun();
}
for (int i = 0; i < RdsG.Count; i )
{
RdsG[i].StarRun();
}
}
/// <summary>
/// 启动线程
/// </summary>
public void StarRunCM()
{
base.StarRun();
}
//端口检测方法
public List<String> getPortAva()
{
//尝试打开端口
List<String> Portgp = new List<string>();
for (int i = 4; i < 40; i )
{
GsmModem tempGM = new GsmModem();
tempGM.ComPort = "com" i.ToString();
try
{
tempGM.Open();
Portgp.Add(i.ToString());
tempGM.Close();
}
catch (Exception e)
{
log.Log(e.ToString(), "tempPort.open");
}
}
return Portgp;
}
//创建发送类组
public void creatGroup()
{
//启动所有短信猫端口
for (int i = 0; i < this.PortGP.Count; i )
{
gsmSender temp = new gsmSender(PortGP[i]);
//可用状态为真
temp.ReadCardSign = true;
//标明在集合中的位置
temp.FreshCardIndex = i;
temp.Working = false;
temp.ProgressEvent = new ProgressEventHandler(FM.gsmFlushMsg);
temp.UpdateTimeEvent = new UpdateTimeEventHandler(FM.updatetime);
temp.FeedBackEvent = new FeedBackEventHandler(FM.updateFeedback);
gsmGroup.Add(temp);
}
//短信猫组中有可用端口
if (gsmGroup.Count > 0) this.gsmFail = false; else this.gsmFail = true;
//加载所有短信平台类
string[] tempSMSp = Properties.Settings.Default.SMSplat1.Split(',');
for (int i = 0; i < tempSMSp.Length; i )
{
SMSplat ly = new SMSplat(((i 1) * 100).ToString());
ly.ReadCardSign = true;
ly.FreshCardIndex = this.PortGP.Count i;
ly.ProgressEvent = new ProgressEventHandler(FM.gsmFlushMsg);
ly.UpdateTimeEvent = new UpdateTimeEventHandler(FM.updatetime);
ly.FeedBackEvent = new FeedBackEventHandler(FM.updateFeedback);
RdsG.Add(ly);
}
if (tempSMSp.Length > 0) this.pTFail = false; else pTFail = true;
}
#region 过滤非法字符
public static string encoding(string src)
{
if (src == null)
return "";
StringBuilder result = new StringBuilder();
if (src != null)
{
src = src.Trim();
for (int pos = 0; pos < src.Length; pos )
{
switch (src[pos])
{
case '\"': result.Append(" "); break;
case '<': result.Append(" "); break;
case '>': result.Append(" "); break;
case '\'': result.Append(" "); break;
case '&': result.Append(" "); break;
case '%': result.Append(" "); break;
case '_': result.Append(" "); break;
case '#': result.Append(" "); break;
case '?': result.Append(" "); break;
default: result.Append(src[pos]); break;
}
}
}
return result.ToString();
}
#endregion
/// <summary>
/// 从数据库从取发送数据
/// </summary>
/// <returns></returns>
public string getData()
{
DateTime tempDateTime = base.smsObject.GetDBDateTime();//获取服务器时间
DataTable dataTable = smsObject.GetListByDateTime(this.syncDateTime);//获取服务器短信数据
this.syncDateTime = tempDateTime;//更新服务器时间
smsObject.UpdateSendDate(successlist, 3);//发送成功队列
smsObject.UpdateSendDate(faillist, 4);//发送失败队列
if (dataTable != null && dataTable.Rows.Count > 0)
{
for (int i = 0; i < dataTable.Rows.Count; i )
{//写入数据
DataRow dataRow = base.sendlist.NewRow();
dataRow["Id"] = dataTable.Rows[i]["SMSInfo_Id"];
dataRow["Type"] = dataTable.Rows[i]["SMSTemplate_Type"];
dataRow["Level"] = dataTable.Rows[i]["SMSTemplate_SendLevel"];
String PhoneNoSpace = null;
PhoneNoSpace = dataTable.Rows[i]["SMSInfo_SendMobilePhone"].ToString().Trim();
//判断是否为手机号
if ((IsNum(PhoneNoSpace) && PhoneNoSpace.Length == 11) || PhoneNoSpace == "10010" || PhoneNoSpace == "10086")
{
dataRow["MobilePhone"] = PhoneNoSpace;
dataRow["Description"] = CardManager.encoding(dataTable.Rows[i]["SMSInfo_Description"].ToString());
dataRow["SendTimes"] = "0";
dataRow["PortNumber"] = "0";
if (dataTable.Rows[i]["SMSTemplate_Type"].ToString() == "0")
{
if (base.sendlist.Rows.Count > 0)
{
base.sendlist.Rows.InsertAt(dataRow, 1);
}
else
{
base.sendlist.Rows.InsertAt(dataRow, 0);
}
}
else
{
base.sendlist.Rows.Add(dataRow);
}
}
else
{
dataRow["MobilePhone"] = PhoneNoSpace;
dataRow["Description"] = "短信内容：" dataTable.Rows[i]["SMSInfo_Description"].ToString() ". " "手机号" dataTable.Rows[i]["SMSInfo_SendMobilePhone"].ToString() "格式不正确";
//写入操作错误数据库
SMSsenderWrong(dataRow["MobilePhone"].ToString(), dataRow["Description"].ToString());
}
}
}
//返回取到的数量
return base.sendlist.Rows.Count.ToString();
}
/// <summary>
/// 数据分发
/// </summary>
/// <param name="DistributionStrategy">分发策略</param>
/// <returns>共分发条数</returns>
public int setData(int DistributionStrategy)
{
switch (DistributionStrategy)
{
//全部短信猫
case 0:
{
DataRow DR = sendlist.NewRow();
while (sendlist.Rows.Count != 0)
{
for (int i = 0; i < gsmGroup.Count; i )
{
if (sendlist.Rows.Count != 0 && gsmGroup[i].ReadCardSign == true)
{
DR = sendlist.Rows[0];
gsmGroup[i].addData(DR);
sendlist.Rows.Remove(DR);
}
else { break; }
}
}
} break;
//全部平台
case 1:
{
DataRow DR = sendlist.NewRow();
while (sendlist.Rows.Count != 0)
{
for (int i = 0; i < RdsG.Count; i )
{
if (sendlist.Rows.Count != 0)
{
DR = sendlist.Rows[0];
RdsG[i].addData(DR);
sendlist.Rows.Remove(DR);
}
else { break; }
}
}
} break;
//混合
case 2:
{
DataRow DR = sendlist.NewRow();
List<ThreadCore> hhgropu = new List<ThreadCore>();
for (int i = 0; i < gsmGroup.Count; i )
{
hhgropu.Add(gsmGroup[i]);
}
for (int i = 0; i < RdsG.Count; i )
{
hhgropu.Add(RdsG[i]);
}
while (sendlist.Rows.Count != 0)
{
for (int i = 0; i < hhgropu.Count; i )
{
if (sendlist.Rows.Count != 0)
{
DR = sendlist.Rows[0];
hhgropu[i].addData(DR);
sendlist.Rows.Remove(DR);
}
else { break; }
}
}
} break;
//单端口
case 3:
{
DataRow DR = sendlist.NewRow();
List<ThreadCore> hhgropu = new List<ThreadCore>();
for (int i = 0; i < gsmGroup.Count; i )
{
hhgropu.Add(gsmGroup[i]);
}
for (int i = 0; i < RdsG.Count; i )
{
hhgropu.Add(RdsG[i]);
}
while (sendlist.Rows.Count != 0)
{
for (int i = 0; i < hhgropu.Count; i )
{
if (sendlist.Rows.Count != 0)
{
DR = sendlist.Rows[0];
if (hhgropu[i].Name == CardManager.debuggingPort) {
hhgropu[i].addData(DR);
sendlist.Rows.Remove(DR);
}
}
else { break; }
}
}
}break;
} return 0;
}
public void closeThread()
{
}
protected override void R1()
{
Thread.Sleep(8000);
this.getData();
}
protected override void R2()
{
Thread.Sleep(1000);
this.setData(CardManager.Cl);
}
//测试全部短信猫是否失效
protected override void R3()
{
int failnumber = 0;
for (int i = 0; i < gsmGroup.Count; i )
{
if (gsmGroup[i].ReadCardSign == false)
{
failnumber ;
}
}
if (gsmGroup.Count == failnumber) this.gsmFail = true; else this.gsmFail = false;
}
}
相关软件
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论