addressbookmessage.cs

企业短信收发系统

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

namespace MessageLibrary
{
	/// <summary>
	/// AddressBookMessage 的摘要说明。
	/// </summary>
	public class AddressBookMessage
	{
		public AddressBookMessage()
		{
			
		}
		DataAccess da=new DataAccess();
		//插入信息
		public bool insertSendMessage(string sendUserId,string Message)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[2];
			objSqlParameter.SetValue(new SqlParameter("@SendUserId",sendUserId),0);
			objSqlParameter.SetValue(new SqlParameter("@Message",Message),1);
			if(da.ExcuteUpdateProcedure("InsertSendMessage",objSqlParameter))
			{
				return true;
			}
			else
			{
				return false;
			}
		}
		//插入详细信息
		public bool insertSendMessageDetail(string ReceiverId)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@ReceiverId",ReceiverId),0);
			if(da.ExcuteUpdateProcedure("InsertSendMessageDetail",objSqlParameter))
			{
				return true;
			}
			else
			{
				return false;
			}
		}
		//插入收件信息
		public bool insertInboxMessage(string sendUserId,string ReceiverId,string Message)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[3];
			objSqlParameter.SetValue(new SqlParameter("@SendUserId",sendUserId),0);
			objSqlParameter.SetValue(new SqlParameter("@Message",Message),1);
			objSqlParameter.SetValue(new SqlParameter("@ReceiverId",ReceiverId),2);
			if(da.ExcuteUpdateProcedure("InsertInboxMessage",objSqlParameter))
			{
				return true;
			}
			else
			{
				return false;
			}
			

	}
		//获得信息
		public DataSet GetSendMessage(string userid)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@SendUserId",userid),0);
			DataSet ds=da.ExcuteProcedure("SelectSendMessage",objSqlParameter);
			return ds;
		}
		//获得详细信息
		public DataSet GetSendMessageDetail(string outboxid)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@OutBoxId",outboxid),0);
			DataSet ds=da.ExcuteProcedure("SelectMessageDetail",objSqlParameter);
			return ds;
		}
		//删除已发送信息
		public bool DelSendMessage(string OutBoxId)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@OutBoxId",OutBoxId),0);
			if(da.ExcuteUpdateProcedure("DelSendMessage",objSqlParameter))
			{
				return true;
			}
			else
			{
				return false;
			}
		}
		//接收未读信息
		public DataSet UnReadMessage(string ReceiveUserId)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@ReceiveUserId",ReceiveUserId),0);
			DataSet ds=da.ExcuteProcedure("SelectUnReadMessage",objSqlParameter);
			return ds;
		}
		//接收所有信息
		public DataSet SelectAllMessage(string ReceiveUserId)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@ReceiveUserId",ReceiveUserId),0);
			DataSet ds=da.ExcuteProcedure("SelectAllMessage",objSqlParameter);
			return ds;
		}
		//更新已读状态
		public bool UpdateMessageStatus(string InBoxId)
		{
			SqlParameter[] objSqlParameter=new SqlParameter[1];
			objSqlParameter.SetValue(new SqlParameter("@InBoxId",InBoxId),0);
			if(da.ExcuteUpdateProcedure("UpdateMessageStatus",objSqlParameter))
			{
				return true;
			}
			else
			{
				return false;
			}
		}
	}
}