开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > WEB源码(ASP,PHP,...) > 查看源码
SMS.cs
资源名称：OA.rar　[点击查看]
上传用户：xuming1973
上传日期：2014-02-27
资源大小：17511k
文件大小：15k
源码类别：

WEB源码(ASP,PHP,...)

开发平台：

C#

SMS.cs：源码内容
  1. using System;
  2. using System.Data;
  3. using System.Data.SqlClient;
  4. using System.Collections;
  5. using System.Runtime.InteropServices;
  7. namespace UDS.Components
  8. {
  9. /// <summary>
  10. /// SMS 
  11. /// </summary>
  12. public class SMS
  13. {
  16. int CommIndex = 1;
  18. /*
  19. #region 引用组件
  20. [DllImport("../bin/AscendSMS.dll")]
  21. public static extern int OpenComm(int CommIndex);
  22. [DllImport("../bin/AscendSMS.dll")]
  23. public static extern int CloseComm(int CommIndex);
  24. [DllImport("../bin/AscendSMS.dll")]
  25. public static extern int ForceCloseComm(int CommIndex);
  26. [DllImport("../bin/AscendSMS.dll")]
  27. public static extern int SendMsg(int CommIndex,string Msg,string MobileNo,int Msg_Index,bool Chinese);
  28. [DllImport("../bin/AscendSMS.dll")]
  29. public static extern int GetUnSendCount(int CommIndex);
  30. [DllImport("../bin/AscendSMS.dll")]
  31. public static extern bool GetNextSendMsg(int CommIndex, string Msg,bool DeleteAfterRead);
  32. [DllImport("../bin/AscendSMS.dll")]
  33. public static extern bool GetNewMsg(int CommIndex,  string Msg);
  34. #endregion
  37. /// <summary>
  38. /// 发送短消息
  39. /// 返回操作码 0 成功 -2 消息超过长度 -3 手机号码不正确 -4 发送阵列已满 -8 模块未打开 -1 串口未打开
  40. /// </summary>
  41. /// <param name="Msg">短消息内容</param>
  42. /// <param name="MobileNo">目标端手机号码,包括一般号码及特殊号码</param>
  43. /// <param name="MsgIndex">短消息标志位</param>
  44. /// <param name="IsZh">是否中文(中文为True,否则为False)</param>
  45. /// <returns>操作码</returns>
  46. public int SendMobileMsg(string Msg, string MobileNo, int MsgIndex,bool IsZh) 
  47. {
  48. CloseComm(CommIndex);
  49. OpenComm(CommIndex); 
  50. String[] MoA = MobileNo.Split(',');
  51. String[] RtnCodeA = MoA;
  52. for(int i=0;i<MoA.Length;i++)
  53. {
  54. int RtnCode = SendMsg(CommIndex,Msg,MoA[i],MsgIndex,IsZh);
  55. RtnCodeA[i] = RtnCode.ToString();
  56. }
  57. CloseComm(CommIndex);
  58. if(RtnCodeA[0]=="0")
  59. return 0;
  60. else
  61. return -1;
  62. }
  64. */
  66. public SMS()
  67. {
  68. //
  69. // TODO: 
  70. //
  71. }
  72. /// <summary>
  73. /// 得到在线人数
  74. /// </summary>
  75. /// <returns>返回int</returns>
  76. public int GetOnlineCount()
  77. {
  78. Database data = new Database();
  79. SqlDataReader dataReader = null;
  80. try 
  81. {
  82. data.RunProc("SP_SMS_GetOnlineCount",out dataReader);
  83. if(dataReader.Read()) return Int32.Parse(dataReader[0].ToString());
  84. else return 0;
  85. }
  86. catch(Exception ex)
  87. {
  88. Error.Log(ex.ToString());
  89. throw new Exception("读取在线人数出错!",ex);
  90. }
  91. finally
  92. {
  93. data    = null;
  94. dataReader = null;
  95. }
  96. }
  98. /// <summary>
  99. /// 得到新消息总数
  100. /// </summary>
  101. /// <returns>返回int</returns>
  102. public int GetNewMsgCount(string Username)
  103. {
  104. Database data = new Database();
  105. SqlDataReader dataReader = null;
  106. SqlParameter[] prams = {
  107.    data.MakeInParam("@username",    SqlDbType.VarChar, 50, Username)
  108.    };
  109. try 
  110. {
  111. data.RunProc("SP_SMS_GetNewMsgCount",prams,out dataReader);
  112. if(dataReader.Read()) return Int32.Parse(dataReader[0].ToString());
  113. else return 0;
  114. }
  115. catch(Exception ex)
  116. {
  117. Error.Log(ex.ToString());
  118. throw new Exception("得到新消息总数出错!",ex);
  119. }
  120. finally
  121. {
  122. data    = null;
  123. dataReader = null;
  124. }
  125. }
  127. /// <summary>
  128. /// 读消息
  129. /// </summary>
  130. public bool ReadMsg(string MsgIDS,string Username)
  131. {
  132. Database data = new Database();
  133. SqlParameter[] prams = {
  134.    data.MakeInParam("@MsgIDS",    SqlDbType.VarChar, 2000, MsgIDS),
  135.    data.MakeInParam("@Username",    SqlDbType.VarChar, 20, Username),
  136.    };
  137. try 
  138. {
  139. data.RunProc("SP_SMS_ReadMsg",prams);
  140. return true;
  141. }
  142. catch(Exception ex)
  143. {
  144. Error.Log(ex.ToString());
  145. // throw new Exception("读消息出错!",ex);
  146. return false;
  147. }
  148. finally
  149. {
  150. data    = null;
  151. }
  152. }
  155. /// <summary>
  156. /// 更新在线记录表.添加新的在线人员
  157. /// </summary>
  158. public void UpdateOnlineInfo(string Username,string HostAddr,string SessionID)
  159. {
  160. Database data = new Database();
  161. SqlParameter[] prams = {
  162.    data.MakeInParam("@username",    SqlDbType.VarChar, 50, Username),
  163.    data.MakeInParam("@hostaddr",    SqlDbType.VarChar, 50, HostAddr),
  164.    data.MakeInParam("@sessionid",   SqlDbType.VarChar, 50, SessionID)
  165.    };
  166. try 
  167. {
  168. data.RunProc("SP_SMS_UpdateOnlineInfo",prams);
  169. }
  170. catch(Exception ex)
  171. {
  172. Error.Log(ex.ToString());
  173. throw new Exception("更新在线记录表出错!",ex);
  174. }
  175. finally
  176. {
  177. data    = null;
  178. }
  179. }
  181. /// <summary>
  182. /// 更新活动记录及检测未活动人员
  183. /// </summary>
  184. public string CheckUpdate(string Username,string SessionID,int ActiveNodeID)
  185. {
  186. string ReturnStr = "";
  187. int ReturnID = 0;
  188. int NewMsgFlag = 0;
  189. Database data = new Database();
  190. SqlParameter[] prams = {
  191.    data.MakeInParam("@username",    SqlDbType.VarChar, 100, Username),
  192.    data.MakeInParam("@sessionid",   SqlDbType.VarChar, 100, SessionID),
  193.    data.MakeInParam("@ActiveNodeID",   SqlDbType.Int, 4, ActiveNodeID),
  194.    data.MakeOutParam("@ReturnID", SqlDbType.Int, 4),
  195.    data.MakeOutParam("@NewMsgFlag", SqlDbType.Int, 4)
  196. };
  197. try 
  198. {
  199. data.RunProc("SP_SMS_CheckUpdate",prams);
  200. ReturnID =  Int32.Parse(prams[3].Value.ToString()); 
  201. if(ReturnID==-1)
  202. NewMsgFlag = 0;
  203. else
  204.                     NewMsgFlag =  Int32.Parse(prams[4].Value.ToString()); 
  205. ReturnStr = ReturnID.ToString()+"|"+NewMsgFlag.ToString();
  206. data = null;
  207. return ReturnStr;
  208. }
  209. catch(Exception ex)
  210. {
  211. Error.Log(ex.ToString());
  212. throw new Exception("更新活动记录及检测未活动人员出错!",ex);
  213. }
  214. finally
  215. {
  216. data    = null;
  217. }
  218. }
  220. /// <summary>
  221. /// 得到所有在线人员
  222. /// </summary>
  223. /// <returns></returns>
  224. public SqlDataReader GetOnlinePerson()
  225. {
  226. Database data = new Database();
  227. SqlDataReader dr = null;
  228. try 
  229. {
  230. data.RunProc("sp_SMS_GetOnlinePerson",out dr);
  231. return dr;
  232. }
  233. catch(Exception ex)
  234. {
  235. Error.Log(ex.ToString());
  236. throw new Exception("读取在线人员数据出错!",ex);
  237. }
  238. finally
  239. {
  240. data    = null;
  241. dr    = null;
  242. }
  243. }
  245. /// <summary>
  246. /// 得到聊天记录
  247. /// </summary>
  248. /// <returns></returns>
  249. public SqlDataReader GetHistory(string Receiver,string Sender)
  250. {
  251. Database data = new Database();
  252. SqlDataReader dr = null;
  253. SqlParameter[] prams = {
  254.    data.MakeInParam("@Sender",    SqlDbType.VarChar, 50, Sender),
  255.    data.MakeInParam("@Receiver",   SqlDbType.VarChar, 50, Receiver)
  256. };
  257. try 
  258. {
  259. data.RunProc("SP_SMS_GetHistory",prams,out dr);
  260. return dr;
  261. }
  262. catch(Exception ex)
  263. {
  264. Error.Log(ex.ToString());
  265. throw new Exception("得到聊天记录出错!",ex);
  266. }
  267. finally
  268. {
  269. data    = null;
  270. dr    = null;
  271. }
  272. }
  274. /// <summary>
  275. /// 得到我所接收的所有短讯
  276. /// </summary>
  277. /// <returns></returns>
  278. public SqlDataReader GetMyReceive(string Username)
  279. {
  280. Database data = new Database();
  281. SqlDataReader dr = null;
  282. SqlParameter[] prams = {
  283.    data.MakeInParam("@Username",    SqlDbType.VarChar, 50, Username)
  284.     };
  285. try 
  286. {
  287. data.RunProc("SP_SMS_GetMyAllMsg",prams,out dr);
  288. return dr;
  289. }
  290. catch(Exception ex)
  291. {
  292. Error.Log(ex.ToString());
  293. throw new Exception("得到我所接收的所有短讯出错!",ex);
  294. }
  295. finally
  296. {
  297. data    = null;
  298. dr    = null;
  299. }
  300. }
  302. /// <summary>
  303. /// 得到我所发送的所有短讯
  304. /// </summary>
  305. /// <returns></returns>
  306. public SqlDataReader GetMySent(string Username)
  307. {
  308. Database data = new Database();
  309. SqlDataReader dr = null;
  310. SqlParameter[] prams = {
  311.    data.MakeInParam("@Username",    SqlDbType.VarChar, 50, Username)
  312.    };
  313. try 
  314. {
  315. data.RunProc("SP_SMS_GetMySent",prams,out dr);
  316. return dr;
  317. }
  318. catch(Exception ex)
  319. {
  320. Error.Log(ex.ToString());
  321. throw new Exception("得到我所接收的所有短讯出错!",ex);
  322. }
  323. finally
  324. {
  325. data    = null;
  326. dr    = null;
  327. }
  329. }
  330. /// <summary>
  331. /// 得到某个人的最新一条消息
  332. /// </summary>
  333. /// <returns></returns>
  334. public SqlDataReader GetNewLocalMsg(string Username)
  335. {
  336. Database data = new Database();
  337. SqlDataReader dr = null;
  338. SqlParameter[] prams = {
  339.    data.MakeInParam("@username",    SqlDbType.VarChar, 50, Username)
  340. };
  341. try 
  342. {
  343. data.RunProc("sp_SMS_GetNewMsg",prams,out dr);
  344. return dr;
  345. }
  346. catch(Exception ex)
  347. {
  348. Error.Log(ex.ToString());
  349. throw new Exception("得到某个人的最新一条消息出错!",ex);
  350. }
  351. finally
  352. {
  353. data    = null;
  354. dr    = null;
  355. }
  356. }
  359. /// <summary>
  360. /// 发送站内短消息
  361. /// </summary>
  362. /// <param name="sender">发送者用户名</param>
  363. /// <param name="receivers">接受者用户名，可用逗号相隔多人</param>
  364. /// <param name="msg">短消息内容</param>
  365. /// <param name="sendtime">短消息发送时间</param>
  366. /// <returns>无返回值</returns>
  367. public void SendLocalMsg(string sender,string receivers,string msg,DateTime sendtime)
  368. {
  369. string newmsgid = "0";
  370. Database data = new Database();
  372. #region 存消息至数据库，返回MsgID
  373. SqlParameter[] prams1 = {
  374.    data.MakeInParam("@sender",    SqlDbType.VarChar, 50, sender),
  375.    data.MakeInParam("@content",   SqlDbType.VarChar, 255, msg),
  376.    data.MakeInParam("@type",   SqlDbType.Int, 1, 1),
  377.    data.MakeInParam("@sendtime",   SqlDbType.DateTime, 30, sendtime),
  378.    data.MakeOutParam("@newmsgid", SqlDbType.Int, 4)
  379.    };
  380. try 
  381. {
  382. data.RunProc("SP_SMS_SendLocalMsg",prams1);
  383. newmsgid =  prams1[4].Value.ToString();   
  384. }
  385. catch(Exception ex)
  386. {
  387. Error.Log(ex.ToString());
  388. throw new Exception("存消息至数据库出错!",ex);
  389. }
  390. #endregion
  392. #region 将消息与接收者关联
  393. SqlParameter[] prams2 = {
  394.    data.MakeInParam("@MsgID",    SqlDbType.Int, 4, Int32.Parse(newmsgid)),
  395.    data.MakeInParam("@Receivers",SqlDbType.VarChar, 5000, receivers),
  396.    data.MakeInParam("@MobileNo",   SqlDbType.VarChar, 4, ""),
  397.   data.MakeInParam("@type",   SqlDbType.Int, 1, 1)
  398.    };
  399. try 
  400. {
  401. data.RunProc("SP_SMS_SetMsgReceiver",prams2);
  402. }
  403. catch(Exception ex)
  404. {
  405. Error.Log(ex.ToString());
  406. throw new Exception("将消息与接收者关联出错!",ex);
  407. }
  408. #endregion
  411. }
  414. /// <summary>
  415. ///  发站用户站内手机短消息
  416. /// </summary>
  417. /// <param name="Sender">发送者用户名</param>
  418. /// <param name="RecipientMobileNo">接受者手机号码，可用逗号相隔多人</param>
  419. /// <param name="Content">短消息内容</param>
  420. /// <param name="Sendtime">短消息发送时间</param>
  421. /// <param name="RepeatTimes">短消息重复发送次数</param>
  422. /// <param name="RepeatPeriod">重复发送周期，以分钟为单位</param>
  423. /// <returns>返回执行代码 1 正常 2 错误</returns>
  424. public static int SaveMobileMsgToBuffer(string Sender,string RecipientMobileNo,string Content,DateTime Sendtime,int RepeatTimes,int RepeatPeriod)
  425. {
  426. Database data = new Database();
  427. #region 存消息至数据库，返回MsgID
  428. SqlParameter[] prams1 = {
  429. data.MakeInParam("@Sender",    SqlDbType.VarChar, 50, Sender),
  430. data.MakeInParam("@RecipientMobileNo",   SqlDbType.VarChar, 255, RecipientMobileNo),
  431. data.MakeInParam("@Content",   SqlDbType.VarChar, 255, Content),
  432. data.MakeInParam("@Sendtime",   SqlDbType.DateTime, 30, Sendtime),
  433. data.MakeInParam("@RepeatTimes", SqlDbType.Int, 4,RepeatTimes),
  434. data.MakeInParam("@RepeatPeriod", SqlDbType.Int, 4,RepeatPeriod)
  435. };
  436. try 
  437. {
  438. data.RunProc("SP_SMS_SaveMobileMsgToBuffer",prams1);
  439. return 1;
  440. }
  441. catch(Exception ex)
  442. {
  443. Error.Log(ex.ToString());
  444. throw new Exception("存消息至数据库出错!",ex);
  445. }
  446. #endregion
  448. }
  453. /// <summary>
  454. /// 发送短消息
  455. /// </summary>
  456. /// <param name="sender">发送者用户名</param>
  457. /// <param name="receivers">接受者用户名，可用逗号相隔多人</param>
  458. /// <param name="msg">短消息内容</param>
  459. /// <param name="type">短消息类型 1为站内消息 2为手机短讯 3为站外手机(取mobileno)</param>
  460. /// <param name="sendtime">短消息发送时间</param>
  461. /// <param name="mobileno">如果是站外用户时用。表示站外用户的手机号</param>
  462. /// <param name="repeattimes">如果是手机短讯时用。表示此条讯息的重复发送次数</param>
  463. /// <param name="repeattimes">如果是手机短讯时用。表示此条讯息的重复发送时间间隔(以分钟为单位)</param>
  464. /// <returns>返回操作结束代码</returns>
  465. public int SendMsg(string sender,string recipients,string msg,int type,DateTime sendtime,string mobileno,int repeattimes,int repeatperiod)
  466. {
  467. int RtnCode = 1;
  468. //去除最后一位的逗号,并替换全角至半角
  469. if(recipients.EndsWith(",")) recipients = recipients.Substring(0,recipients.Length-1);
  470. recipients = recipients.Replace("，",",");
  472. switch (type)
  473. {
  474. case 1://站内用户的站内短讯
  475. SendLocalMsg(sender,recipients,msg,sendtime);
  476. return RtnCode;
  478. case 2: //站内用户的手机短讯
  479. string MobileNoStr = GetMobileNoByUsername(recipients);
  480. RtnCode =  SaveMobileMsgToBuffer(sender,MobileNoStr,msg,sendtime,repeattimes,repeatperiod);
  481. return RtnCode;
  483. case 3: //站外用户的手机短讯
  484. RtnCode = SaveMobileMsgToBuffer(sender,mobileno,msg,sendtime,repeattimes,repeatperiod);
  485. return RtnCode;
  487. default:
  488. return RtnCode;
  490. }
  494. }
  496. #region 根据用户名字符串获取手机号码字符串
  497. /// <summary>
  498. /// 根据用户名字符串获取手机号码字符串
  499. /// <param name="Username">用户名字符串，用逗号相隔</param>
  500. /// <returns>返回手机字符串</returns>
  501. /// </summary>
  502. public string GetMobileNoByUsername(string Username)
  503. {
  504. string MobileNoStr = "";
  505. Database data = new Database();
  506. SqlParameter[] prams = {
  507.    data.MakeInParam("@UserNameStr",    SqlDbType.VarChar, 3000, Username),
  508.    data.MakeOutParam("@MobileNoStr", SqlDbType.VarChar, 3000)
  509. };
  510. try 
  511. {
  512. data.RunProc("SP_SMS_GetMobileNoByUsername",prams);
  513. MobileNoStr =  prams[1].Value.ToString();   
  514. return MobileNoStr;
  515. }
  516. catch(Exception ex)
  517. {
  518. Error.Log(ex.ToString());
  519. throw new Exception("根据用户名字符串获取手机号码字符串出错!",ex);
  520. }
  521. finally
  522. {
  523. data    = null;
  524. }
  525. }
  526. #endregion
  530. /// <summary>
  531. /// 删除一组短讯
  532. /// </summary>
  533. /// <param name="MsgIDS">消息ID的连接字符串，用逗号相隔开</param>
  534. public bool MsgDelete(string MsgIDS)
  535. {
  536. Database data = new Database();
  537. SqlParameter[] prams = {
  538.    data.MakeInParam("@MsgIDS",   SqlDbType.VarChar,4000, MsgIDS)
  539.    };
  540. try
  541. {
  542. data.RunProc("SP_SMS_DelMsg",prams);
  543. data = null;
  544. return true;
  545. }
  546. catch(Exception ex)
  547. {
  548. Error.Log(ex.ToString());
  549. return false;
  550. }
  552. }
  555. }
  556. }