sendboxmake.cs

企业内部的短信交流管理平台。 设计详细

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

namespace Com.SMS.Dal
{
	/// <summary>
	/// SendBoxMake 的摘要说明。
	/// </summary>
	public class SendBoxMake
	{
		/// <summary>
		/// 添加发信箱
		/// </summary>
		/// <param name="sb"></param>
		/// <returns></returns>
		public void Insert(Entity.SendBox sb,string content,ArrayList users)
		{
			SqlConnection con=new SqlConnection(SqlBasic.CONN_STRING);
			con.Open();
			SqlTransaction stt=con.BeginTransaction();

			try
			{
				SqlBasic.ExecuteNonQuery(
					stt,
					CommandType.Text,
					SqlCollections.SQL_CONTENTS_INSERT,
					new SqlParameter("@Content",content)
					);

				int id = Convert.ToInt32(SqlBasic.ExecuteScalar(
					stt,
					CommandType.Text,
					"select @@identity"
					));

				SqlParameter[] parms=
				{
					new SqlParameter("@senderId",sb.SenderId),
					new SqlParameter("@conId",id),
					new SqlParameter("@SendTime",sb.SendTime),
					new SqlParameter("@ReciveUsers",sb.ReciveUsers),
				};

				SqlBasic.ExecuteNonQuery(
					stt,
					CommandType.Text,
					SqlCollections.SQL_SENDBOX_INSERT,
					parms
					);

				foreach (int userid in users)
				{
					Entity.ReciveBox rb=new Com.SMS.Entity.ReciveBox();
					rb.ReciveId=userid;
					rb.ConId=id;
					rb.SenduserId=sb.SenderId;
					rb.IsDel=false;
					rb.IsRead=false;

					SqlParameter[] parmsa=
					{
						new SqlParameter("@ReciveuserId",rb.ReciveId),
						new SqlParameter("@conId",rb.ConId),
						new SqlParameter("@senduserId",rb.SenduserId),
						new SqlParameter("@isDel",rb.IsDel),
						new SqlParameter("@isRead",rb.IsRead),
						new SqlParameter("@reciveTime",DateTime.Now),
					};

					SqlBasic.ExecuteNonQuery(
						stt,
						CommandType.Text,
						SqlCollections.SQL_RECIVEBOX_INSERT,
						parmsa
						);
				}
				stt.Commit();
			}
			catch(Exception ee)
			{
				Exception ex=ee;
				stt.Rollback();
				throw ex;
			}
			finally
			{
				con.Close();
			}
		}

		/// <summary>
		/// 删除发信箱记录
		/// </summary>
		/// <param name="sId"></param>
		/// <returns></returns>
		public void Delete(int sId,int conId)
		{
			SqlConnection scon=new SqlConnection(SqlBasic.CONN_STRING);
			scon.Open();
			SqlTransaction trans=scon.BeginTransaction();

			try
			{	
				SqlBasic.ExecuteNonQuery(
					trans,
					CommandType.Text,
					SqlCollections.SQL_SENDBOX_DELETE,
					new SqlParameter("@sendId",sId)
					);
				
				int  reader=Convert.ToInt32(
						SqlBasic.ExecuteScalar(
							trans,
							CommandType.Text,
							SqlCollections.SQL_CONTENTS_ISHAVEINRECIVE,
							new SqlParameter("@conId",conId)
						)
					);

				if(reader==0)
				{
					SqlBasic.ExecuteNonQuery(
						trans,
						CommandType.Text,
						SqlCollections.SQL_CONTENTS_DELETE,
						new SqlParameter("@conId",conId)
						);
				}

				trans.Commit();
			}
			catch(Exception)
			{
				trans.Rollback();
			}
			finally
			{
				scon.Close();
			}
		}

		/// <summary>
		/// 根据发送人查看发送信笺
		/// </summary>
		/// <param name="sId"></param>
		/// <returns></returns>
		public DataTable FindBySender(int sId)
		{
			DataTable dt=new DataTable();

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.Text,SqlCollections.SQL_SENDBOX_SELECTBYSENDER,dt,new SqlParameter("@senderId",sId));

			return dt;
		}
	}
}