albummake.cs

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

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

namespace Com.SMS.Dal
{
	/// <summary>
	/// Album 的摘要说明。
	/// </summary>
	public class AlbumMake
	{
		/// <summary>
		/// 创建相册
		/// </summary>
		/// <param name="am"></param>
		/// <returns></returns>
		public bool Insert(Entity.Album am)
		{
			SqlParameter[] parms=
			{
				new SqlParameter("@alName",am.AlName),
				new SqlParameter("@typeId",am.TypeId),
				new SqlParameter("@userId",am.UserId),
				new SqlParameter("@alFace",am.AlFace),
			};

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

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

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

			try
			{
				SqlBasic.ExecuteNonQuery(
					trans,
					CommandType.Text,
					SqlCollections.SQL_PHOTOS_DELETEBYALBUM,
					new SqlParameter("@abId",abId)
					);

				SqlBasic.ExecuteNonQuery(
					trans,
					CommandType.Text,
					SqlCollections.SQL_ALBUM_DELETE,
					new SqlParameter("@abId",abId)
					);

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

		/// <summary>
		/// 修改相册
		/// </summary>
		/// <param name="am"></param>
		/// <param name="alId"></param>
		/// <returns></returns>
		public bool Update(Entity.Album am,int alId)
		{
			SqlParameter[] parms=
			{
				new SqlParameter("@abId",alId),
				new SqlParameter("@alName",am.AlName),
				new SqlParameter("@userId",am.UserId),
				new SqlParameter("@typeId",am.TypeId),
				new SqlParameter("@alFace",am.AlFace),
			};

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

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

		/// <summary>
		/// 按条件查询相册
		/// </summary>
		/// <param name="currentPage"></param>
		/// <param name="pageSize"></param>
		/// <param name="pageCount"></param>
		/// <param name="alName"></param>
		/// <param name="typeId"></param>
		/// <param name="userId"></param>
		/// <returns></returns>
		public DataTable FindWhere(int currentPage,int pageSize,out int pageCount,string alName,int typeId,int userId)
		{
			SqlParameter p=new SqlParameter("@count",SqlDbType.Int);
			p.Direction=ParameterDirection.Output;

			DataTable dt=new DataTable();

			SqlParameter[] parms=
			{
				new SqlParameter("@currentPage",currentPage),
				new SqlParameter("@pageSize",pageSize),
				p,
				new SqlParameter("@abName",alName),
				new SqlParameter("@typeId",typeId),
				new SqlParameter("@userId",userId),
			};

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.StoredProcedure,SqlCollections.SQL_ALBUM_SELECTWHERE,dt,parms);

			int recordCount = Convert.ToInt32(p.Value);
			pageCount =  recordCount / pageSize;
			if (recordCount % pageSize != 0)
				pageCount++;

			return dt;
		}

		/// <summary>
		/// 没有分页的条件查询相册
		/// </summary>
		/// <param name="alName"></param>
		/// <param name="typeId"></param>
		/// <param name="userId"></param>
		/// <returns></returns>
		public DataTable FindWhere(string alName,int typeId,int userId)
		{
			SqlParameter p=new SqlParameter("@count",SqlDbType.Int);
			p.Direction=ParameterDirection.Output;

			DataTable dt=new DataTable();

			SqlParameter[] parms=
			{
				new SqlParameter("@alName",alName),
				new SqlParameter("@typeId",typeId),
				new SqlParameter("@userId",userId),
			};

			SqlBasic.FillDatatable(SqlBasic.CONN_STRING,CommandType.StoredProcedure,SqlCollections.SQL_ALBUM_SELECTWHERENOPAGE,dt,parms);

			return dt;
		}

		/// <summary>
		/// 查询某个分类下的相册
		/// </summary>
		/// <param name="typeId"></param>
		/// <returns></returns>
		public DataTable FindByType(int typeId)
		{
			DataTable dt=new DataTable();
			SqlBasic.FillDatatable(
				SqlBasic.CONN_STRING,
				CommandType.Text,
				SqlCollections.SQL_ALBUM_SELECTBYTYPE,
				dt,
				new SqlParameter("@typeId",typeId)
				);

			return dt;
		}

		/// <summary>
		/// 查询某个用户的相册
		/// </summary>
		/// <param name="userId"></param>
		/// <returns></returns>
		public DataTable FindByUser(int userId)
		{
			DataTable dt=new DataTable();
			SqlBasic.FillDatatable(
				SqlBasic.CONN_STRING,
				CommandType.Text,
				SqlCollections.SQL_ALBUM_SELECTBYUSER,
				dt,
				new SqlParameter("@userId",userId)
				);

			return dt;
		}

		/// <summary>
		/// 按编号查询相册
		/// </summary>
		/// <param name="abId"></param>
		/// <returns></returns>
		public Entity.Album FindById(int abId)
		{
			SqlDataReader reader=SqlBasic.ExecuteReader(
				SqlBasic.CONN_STRING,
				CommandType.Text,
				SqlCollections.SQL_ALBUM_SELECTBYID,
				new SqlParameter("@abId",abId)
				);
			
			Entity.Album am=new Com.SMS.Entity.Album();
			while(reader.Read())
			{
				am.AbId=reader.GetInt32(0);
				am.AlName=reader.GetString(1);
				am.TypeId=reader.GetInt32(2);
				am.UserId=reader.GetInt32(3);
				am.AlFace=reader.GetString(4);
			}
			return am;
		}
	}
}