stockitem.cs

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

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

    public class StockItem : IStockItem
    {
        private int m_TotalOfStockItem;

        public bool Add(StockItemInfo stockItemInfo)
        {
            return DBHelper.ExecuteSql("INSERT INTO PE_StockItem(ItemID,StockID,ProductID,[TableName],[Property],Amount,Price) VALUES(@ItemID,@StockID,@ProductID,@TableName,@Property,@Amount,@Price)", GetParameters(stockItemInfo));
        }

        public bool Delete(int productId, string tableName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ProductID", DbType.Int32, productId);
            cmdParams.AddInParameter("@TableName", DbType.String, tableName);
            return DBHelper.ExecuteSql("Delete From PE_StockItem where ProductID=@ProductID and TableName=@TableName", cmdParams);
        }

        public bool DeleteByStockIds(string stockIds)
        {
            return DBHelper.ExecuteSql("Delete From PE_StockItem where StockID IN (" + stockIds + ")");
        }

        public IList<StockItemInfo> GetListByStockId(int stockId)
        {
            IList<StockItemInfo> list = new List<StockItemInfo>();
            string strSql = "select P.ProductNum,P.ProductName,P.Unit,S.* from PE_StockItem s inner join PE_CommonProduct p on s.productId=p.productId and s.TableName = P.TableName where StockId=@StockId ; select P.PresentNum as ProductNum,P.PresentName as ProductName,P.Unit,S.* from PE_StockItem s inner join PE_Present P on s.productId=P.PresentID where s.StockId=@StockId";
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql(strSql, new Parameters("@StockId", DbType.Int32, stockId)))
            {
                while (reader.Read())
                {
                    list.Add(StockItemFromrdr(reader));
                }
                if (!reader.NextResult())
                {
                    return list;
                }
                while (reader.Read())
                {
                    list.Add(StockItemFromrdr(reader));
                }
            }
            return list;
        }

        public IList<StockItemInfo> GetListByStockId(int startRowIndexId, int maxNumberRows, int stockId)
        {
            Database database = DatabaseFactory.CreateDatabase();
            IList<StockItemInfo> list = new List<StockItemInfo>();
            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, "ItemID");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "P.ProductNum,P.ProductName,P.Unit,S.* ");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "S.StockID=" + stockId.ToString());
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "PE_StockItem S Inner join PE_CommonProduct P on (S.ProductID=P.ProductID)");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    list.Add(StockItemFromrdr(reader));
                }
            }
            this.m_TotalOfStockItem = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return list;
        }

        public int GetMaxId()
        {
            return DBHelper.GetMaxId("PE_StockItem", "ItemID");
        }

        private static Parameters GetParameters(StockItemInfo stockItemInfo)
        {
            Parameters parameters = new Parameters();
            parameters.AddInParameter("@ItemID", DbType.Int32, stockItemInfo.ItemId);
            parameters.AddInParameter("@StockID", DbType.Int32, stockItemInfo.StockId);
            parameters.AddInParameter("@ProductID", DbType.Int32, stockItemInfo.ProductId);
            parameters.AddInParameter("@TableName", DbType.String, stockItemInfo.TableName);
            parameters.AddInParameter("@Property", DbType.String, stockItemInfo.Property);
            parameters.AddInParameter("@Amount", DbType.Int32, stockItemInfo.Amount);
            parameters.AddInParameter("@Price", DbType.Currency, stockItemInfo.Price);
            return parameters;
        }

        public int GetTotalOfStockItem()
        {
            return this.m_TotalOfStockItem;
        }

        private static StockItemInfo StockItemFromrdr(NullableDataReader rdr)
        {
            StockItemInfo info = new StockItemInfo();
            info.ItemId = rdr.GetInt32("ItemID");
            info.StockId = rdr.GetInt32("StockID");
            info.ProductId = rdr.GetInt32("ProductID");
            info.TableName = rdr.GetString("TableName");
            info.Property = rdr.GetString("Property");
            info.Amount = rdr.GetInt32("Amount");
            info.Price = rdr.GetDecimal("Price");
            info.ProductName = rdr.GetString("ProductName");
            info.ProductNum = rdr.GetString("ProductNum");
            info.Unit = rdr.GetString("Unit");
            return info;
        }
    }
}