message.cs

来自「ASP C#代码实例 适合初学人士学习使用」· CS 代码 · 共 90 行

using System;
using System.Data;
using System.Data.SqlClient;

namespace OfficeAuto.Components
{
	/// <summary>
	/// Message 的摘要说明。
	/// </summary>
	public class Message
	{
		/// <summary>
		/// 根据用户ID获取用户的所有短信
		/// </summary>
		/// <param name="nStaffID"></param>
		/// <returns></returns>
		public SqlDataReader GetMessageByUser(int nStaffID)
		{
			Database db = new Database();
			SqlDataReader dataReader = null;
			SqlParameter[] prams = {
									   db.CreateInParam("@StaffID", SqlDbType.Int, 4, nStaffID)									   
								   };
			try 
			{	
				///获取用户信息
				db.RunProc("Pr_GetMsgByUser",prams,out dataReader);
				return dataReader;
			}
			catch (Exception ex) 
			{
				SystemError.SystemLog(ex.ToString());
				throw new Exception("人员信息读取出错!",ex);
			}			
		}

		/// <summary>
		/// 根据短信ID获取短信
		/// </summary>
		/// <param name="nStaffID"></param>
		/// <returns></returns>
		public SqlDataReader GetSingleMsg(int nMessageID)
		{
			Database db = new Database();
			SqlDataReader dataReader = null;
			SqlParameter[] param = {
									   db.CreateInParam("@MessageID",SqlDbType.Int,4,nMessageID)
								   };
			try 
			{	
				///获取用户信息
				db.RunProc("Pr_GetSingleMsg",param,out dataReader);
				return dataReader;
			}
			catch (Exception ex) 
			{
				SystemError.SystemLog(ex.ToString());
				throw new Exception("人员信息读取出错!",ex);
			}			
		}

		/// <summary>
		/// 发送短消息
		/// </summary>
		/// <param name="sender">发送者用户名</param>
		/// <param name="receivers">接受者用户名</param>		
		public int SendMsg(string sSender,string sReceiver,string sBody, string sMobile)
		{
			Database db = new Database();
			SqlParameter[] param = {
									   db.CreateInParam("@Sender",SqlDbType.VarChar,100,sSender),
									   db.CreateInParam("@Receiver",SqlDbType.VarChar,100,sReceiver),
									   db.CreateInParam("@Body",SqlDbType.VarChar,8000,sBody),
									   db.CreateInParam("@Mobile",SqlDbType.VarChar,100,sMobile)
								   };
			return(db.RunProc("Pr_AddMessage",param));			
		}

		public void UpdateMsgRead(int nMessageID)
		{
			Database db = new Database();
			SqlParameter[] param = {
									   db.CreateInParam("@MessageID",SqlDbType.Int,4,nMessageID)
								   };
			db.RunProc("Pr_UpdateMsgRead",param);
		}

	}
}