message.cs

本系统以采用一种结合B/S和Web的方式开发的中小企业办公自动化系统为例讨论办公自动化系统的设计与实现。

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);
		}

	}
}