collectionitem.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

namespace PowerEasy.SqlServerDal.Collection
{
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using PowerEasy.IDal.Collection;
    using PowerEasy.Model.Collection;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;

    public class CollectionItem : ICollectionItem
    {
        private int m_CountNumber;

        public bool Add(PowerEasy.Model.Collection.CollectionItemInfo collectionItemInfo)
        {
            string strSql = "INSERT INTO PE_CollectionItem (ItemId,ItemName,UrlName,CodeType,Url,Intro,NodeId,ModelId,OrderType,MaxNum,Detection)VALUES(@ItemId,@ItemName,@UrlName,@CodeType,@Url,@Intro,@NodeId,@ModelId,@OrderType,@MaxNum,@Detection)";
            collectionItemInfo.ItemId = this.GetMaxId() + 1;
            return DBHelper.ExecuteSql(strSql, GetParameters(collectionItemInfo));
        }

        private static PowerEasy.Model.Collection.CollectionItemInfo CollectionItemInfo(NullableDataReader rdr)
        {
            PowerEasy.Model.Collection.CollectionItemInfo info = new PowerEasy.Model.Collection.CollectionItemInfo();
            info.ItemId = rdr.GetInt32("ItemId");
            info.ItemName = rdr.GetString("ItemName");
            info.UrlName = rdr.GetString("UrlName");
            info.CodeType = rdr.GetString("CodeType");
            info.Url = rdr.GetString("Url");
            info.Intro = rdr.GetString("Intro");
            info.NodeId = rdr.GetInt32("NodeId");
            info.ModelId = rdr.GetInt32("ModelId");
            info.OrderType = rdr.GetInt32("OrderType");
            info.MaxNum = rdr.GetInt32("MaxNum");
            info.NewsCollecDate = rdr.GetDateTime("NewsCollecDate");
            return info;
        }

        public bool Delete(int id)
        {
            bool flag = false;
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ItemId", DbType.Int32, id);
            string strSql = "Delete from PE_CollectionItem  where ItemId = @ItemId";
            flag = DBHelper.ExecuteSql(strSql, cmdParams);
            if (flag)
            {
                DBHelper.ExecuteSql("Delete from PE_CollectionFieldRules  where ItemId = @ItemId", cmdParams);
                DBHelper.ExecuteSql("Delete from PE_CollectionHistory  where ItemId = @ItemId", cmdParams);
                DBHelper.ExecuteSql("Delete from PE_CollectionListRules   where ItemId = @ItemId", cmdParams);
                DBHelper.ExecuteSql("Delete from PE_CollectionPagingRules   where ItemId = @ItemId", cmdParams);
            }
            return flag;
        }

        public bool Exists(string itemName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ItemName", DbType.String, itemName);
            return DBHelper.ExistsSql("Select COUNT(*) From PE_CollectionItem Where ItemName=@ItemName", cmdParams);
        }

        public IList<PowerEasy.Model.Collection.CollectionItemInfo> GetCollectionList(string itemId)
        {
            Parameters cmdParams = new Parameters();
            string strCommand = "SELECT * FROM PE_CollectionItem  WHERE ItemId in ( " + itemId + ")";
            IList<PowerEasy.Model.Collection.CollectionItemInfo> list = new List<PowerEasy.Model.Collection.CollectionItemInfo>();
            using (NullableDataReader reader = DBHelper.ExecuteReader(CommandType.Text, strCommand, cmdParams))
            {
                if (reader.Read())
                {
                    list.Add(CollectionItemInfo(reader));
                }
            }
            return list;
        }

        public DataTable GetCollectionList(int startRowIndexId, int maxNumberRows)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Common_GetList");
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "I.ItemId");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "I.*,M.ModelName,N.NodeName");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "((PE_CollectionItem I left JOIN PE_Nodes N ON I.NodeID =N.NodeID) left JOIN PE_Model M ON I.ModelID  =M.ModelID)");
            database.SetParameterValue(storedProcCommand, "@Filter", " I.Detection=1");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            DataSet set = database.ExecuteDataSet(storedProcCommand);
            this.m_CountNumber = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return set.Tables[0];
        }

        public int GetCountNumber()
        {
            return this.m_CountNumber;
        }

        public PowerEasy.Model.Collection.CollectionItemInfo GetInfoById(int id)
        {
            Parameters cmdParams = new Parameters();
            string strCommand = "SELECT * FROM PE_CollectionItem  WHERE ItemId=@ItemId";
            cmdParams.AddInParameter("@ItemId", DbType.Int32, id);
            using (NullableDataReader reader = DBHelper.ExecuteReader(CommandType.Text, strCommand, cmdParams))
            {
                if (reader.Read())
                {
                    return CollectionItemInfo(reader);
                }
                return new PowerEasy.Model.Collection.CollectionItemInfo(true);
            }
        }

        public DataTable GetList(int startRowIndexId, int maxNumberRows)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Common_GetList");
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "I.ItemId");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "I.*,M.ModelName,N.NodeName");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "((PE_CollectionItem I left JOIN PE_Nodes N ON I.NodeID =N.NodeID) left JOIN PE_Model M ON I.ModelID  =M.ModelID)");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            DataSet set = database.ExecuteDataSet(storedProcCommand);
            this.m_CountNumber = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return set.Tables[0];
        }

        public int GetMaxId()
        {
            return DBHelper.GetMaxId("PE_CollectionItem ", "ItemId");
        }

        private static Parameters GetParameters(PowerEasy.Model.Collection.CollectionItemInfo collectionItemInfo)
        {
            Parameters parameters = new Parameters();
            parameters.AddInParameter("@ItemId", DbType.Int32, collectionItemInfo.ItemId);
            parameters.AddInParameter("@ItemName", DbType.String, collectionItemInfo.ItemName);
            parameters.AddInParameter("@UrlName", DbType.String, collectionItemInfo.UrlName);
            parameters.AddInParameter("@CodeType", DbType.String, collectionItemInfo.CodeType);
            parameters.AddInParameter("@Url", DbType.String, collectionItemInfo.Url);
            parameters.AddInParameter("@Intro", DbType.String, collectionItemInfo.Intro);
            parameters.AddInParameter("@NodeId", DbType.Int32, collectionItemInfo.NodeId);
            parameters.AddInParameter("@ModelId", DbType.Int32, collectionItemInfo.ModelId);
            parameters.AddInParameter("@OrderType", DbType.Int32, collectionItemInfo.OrderType);
            parameters.AddInParameter("@MaxNum", DbType.Int32, collectionItemInfo.MaxNum);
            parameters.AddInParameter("@Detection", DbType.Boolean, collectionItemInfo.Detection);
            return parameters;
        }

        public bool Update(PowerEasy.Model.Collection.CollectionItemInfo collectionItemInfo)
        {
            string strSql = "UPDATE PE_CollectionItem  SET  ItemId = @ItemId, ItemName=@ItemName,UrlName=@UrlName,CodeType = @CodeType,Url = @Url,Intro = @Intro,NodeId = @NodeId,ModelId = @ModelId, OrderType = @OrderType, MaxNum = @MaxNum,Detection = @Detection WHERE  ItemId = @ItemId";
            return DBHelper.ExecuteSql(strSql, GetParameters(collectionItemInfo));
        }

        public bool UpdateCollecDate(int id)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ItemId", DbType.Int32, id);
            string strSql = "UPDATE PE_CollectionItem  SET  NewsCollecDate = GetDate() where ItemId = @ItemId";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }
    }
}