sysmsg.cs

某个公司需要维持良好的客户关系

using System;
using System.Collections;
using System.Data;
using System.Data.SqlClient;
using CRM.IDAL;
using CRM.Model;
namespace CRM.SQLServerDAL
{
	/// <summary>
	/// SysMsg 的摘要说明。
	/// </summary>
	public class SysMsg : ISysMsg
	{
		#region ISysMsg 成员

		public DataTable GetSysMsgByReceiveUserId(string userId)
		{
			return DAI.RunProcTable("CRM_SysMsg_GetSysMsgByReceiveUserId",userId);
		}

		public void Insert(SysMsgInfo msg)
		{
			object[] parms = {
								Common.GetNextIdByTable("SysMsgInfo","MsgId","SingleLayer",null,10),
							    msg.Title,
								msg.Content,
								msg.SendUserId,
								msg.ReceiveUserId,
								msg.State
							 };
			DAI.RunProcNonQuery("CRM_SysMsg_Insert",parms);
	}

		public DataTable GetAllSysMsg()
		{
			return DAI.RunProcTable("CRM_SysMsg_GetAllSysMsg");
		}

		public void Delete(string msgId)
		{
			DAI.RunProcNonQuery("CRM_SysMsg_Delete",msgId);
		}

		public void Update(SysMsgInfo msg)
		{
			object[] parms = {
								 msg.MsgId,
								 msg.Title,
								 msg.Content,
								 msg.SendUserId,
								 msg.ReceiveUserId,
								 msg.State
							 };
			DAI.RunProcNonQuery("CRM_SysMsg_Update",parms);
		}

		public SysMsgInfo GetSysMsgById(string msgId)
		{
			SysMsgInfo msg = null;
			using (SqlDataReader rdr = DAI.RunProcReader("CRM_SysMsg_GetSysMsgById",msgId))
			{
				if (rdr.Read())
				{
					msg = new SysMsgInfo();

					msg.MsgId = rdr["MsgId"].ToString();
					msg.Title = rdr["Title"].ToString();
					msg.Content = rdr["Content"].ToString();
					msg.SendTime = rdr["SendTime"].ToString();
					msg.SendUserId = rdr["SendUserId"].ToString();
					msg.ReceiveUserId = rdr["ReceiveUserId"].ToString();
					msg.State = rdr["State"].ToString();
				}
			}
			return msg;
		}

		public DataTable GetSysMsgBySendUserId(string userId)
		{
			return DAI.RunProcTable("CRM_SysMsg_GetSysMsgBySendUserId",userId);
		}

		#endregion
	}
}