addressbooksmake.cs

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

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

namespace Com.SMS.Dal
{
	/// <summary>
	/// AddressBooksMake 的摘要说明。
	/// </summary>
	public class AddressBooksMake
	{
		/// <summary>
		/// 创建地址本
		/// </summary>
		/// <param name="ab"></param>
		/// <returns></returns>
		public void Insert(Entity.AddressBook ab,ArrayList users)
		{
			SqlConnection con=new SqlConnection(SqlBasic.CONN_STRING);
			con.Open();
			SqlTransaction stt=con.BeginTransaction();
			
			try
			{
				SqlParameter[] parms=
				{
					new SqlParameter("@userId",ab.UserId),
					new SqlParameter("@AddressBookName",ab.AddressBookName),
					new SqlParameter("@bz",ab.Bz),
				};

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

				int id = Convert.ToInt32(SqlBasic.ExecuteScalar(
					stt,
					CommandType.Text,
					"select @@identity"
					));
				
				foreach (int userid in users)
				{
					SqlBasic.ExecuteNonQuery(
						stt,
						CommandType.Text,
						SqlCollections.SQL_AADDRESSBOOKDETAIL_INSERT,
						new SqlParameter("@AddressBookId", id),
						new SqlParameter("@userId", userid)
						);
				}
				stt.Commit();
			}
			catch(Exception ex)
			{
				stt.Rollback();
				throw ex;
			}
			finally
			{
				con.Close();
			}
		}

		/// <summary>
		/// 删除地址本
		/// </summary>
		/// <param name="abId"></param>
		/// <returns></returns>
		public void Delete(int abId)
		{
			SqlConnection scon=new SqlConnection(SqlBasic.CONN_STRING);
			scon.Open();
			SqlTransaction tran=scon.BeginTransaction();

			try
			{
				SqlBasic.ExecuteNonQuery(
					tran,
					CommandType.Text,
					SqlCollections.SQL_AADDRESSBOOKDETAIL_DELETEBYBOOK,
					new SqlParameter("@AddressBookId",abId)
					);

				SqlBasic.ExecuteNonQuery(
					tran,
					CommandType.Text,
					SqlCollections.SQL_ADDRESSBOOK_DELETE,
					new SqlParameter("@AddressBookId",abId)
					);
				tran.Commit();
			}
			catch(Exception)
			{
				tran.Rollback();
			}
			finally
			{
				scon.Close();
			}
		}

		/// <summary>
		/// 修改地址本
		/// </summary>
		/// <param name="ab"></param>
		/// <param name="abId"></param>
		/// <returns></returns>
		public bool Update(Entity.AddressBook ab,int abId)
		{
			SqlParameter[] parms=
			{
				new SqlParameter("@userId",ab.UserId),
				new SqlParameter("@AddressBookName",ab.AddressBookName),
				new SqlParameter("@bz",ab.Bz),
				new SqlParameter("@AddressBookId",abId),
			};

			int i=SqlBasic.ExecuteNonQuery(SqlBasic.CONN_STRING,CommandType.Text,SqlCollections.SQL_ADDRESSBOOK_UPDATE,parms);

			if(i==1)
			{
				return true;
			}
			else
				return false;
		}

		/// <summary>
		/// 查询某个用户的地址本
		/// </summary>
		/// <param name="userId"></param>
		/// <returns></returns>
		public DataTable SelectByUser(int userId)
		{
			DataTable dt=new DataTable();

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.Text,SqlCollections.SQL_ADDRESSBOOK_SELECTBYUSER,dt,new SqlParameter("@userId",userId));

			return dt;
		}

		/// <summary>
		/// 查询所有的地址本
		/// </summary>
		/// <returns></returns>
		public DataTable SelectALL()
		{
			DataTable dt=new DataTable();

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.Text,SqlCollections.SQL_ADDRESSBOOK_SELECTALL,dt);

			return dt;
		}

		/// <summary>
		/// 按编号查询地址本
		/// </summary>
		/// <returns></returns>
		public DataTable SelectById(int bookId)
		{
			DataTable dt=new DataTable();

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.Text,SqlCollections.SQL_ADDRESSBOOK_SELECTBYID,dt,new SqlParameter("@AddressBookId",bookId));

			return dt;
		}
	}
}