productcommon.cs

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

namespace PowerEasy.SqlServerDal.Shop
{
    using PowerEasy.Common;
    using PowerEasy.Enumerations;
    using PowerEasy.IDal.Shop;
    using PowerEasy.Model.Shop;
    using PowerEasy.SqlServerDal;
    using PowerEasy.SqlServerDal.Contents;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Text;

    public class ProductCommon : IProductCommon
    {
        private const string m_FieldParameters = "@ProductID,@TableName,@ProductName,@ProductType,@ProductPic,@ProductThumb,@Unit,@ProductNum,@ServiceTermUnit,@ServiceTerm,@Price,@Price_Market,@Price_Member,@Price_Agent,@EnableWholesale,@Price_Wholesale1,@Price_Wholesale2,@Price_Wholesale3,@Number_Wholesale1,@Number_Wholesale2,@Number_Wholesale3,@PresentID,@PresentNumber,@PresentPoint,@PresentExp,@PresentMoney,@StocksProject,@SalePromotionType,@MinNumber,@Discount,@IncludeTax,@TaxRate,@Properties,@Weight,@LimitNum,@EnableSingleSell,@DependentProducts,@ProductKind,@ProductCharacter,@EnableBuyWhenOutofstock,@Keyword,@ProducerName,@TrademarkName,@BarCode,@ProductIntro,@ProductExplain,@IsNew,@IsHot,@IsBest,@Stars,@EnableSale,@Stocks,@DownloadUrl,@Remark,@AlarmNum,@OrderNum";
        private const string m_Fields = "ProductID,TableName,ProductName,ProductType,ProductPic,ProductThumb,Unit,ProductNum,ServiceTermUnit,ServiceTerm,Price,Price_Market,Price_Member,Price_Agent,EnableWholesale,Price_Wholesale1,Price_Wholesale2,Price_Wholesale3,Number_Wholesale1,Number_Wholesale2,Number_Wholesale3,PresentID,PresentNumber,PresentPoint,PresentExp,PresentMoney,StocksProject,SalePromotionType,MinNumber,Discount,IncludeTax,TaxRate,Properties,Weight,LimitNum,EnableSingleSell,DependentProducts,ProductKind,ProductCharacter,EnableBuyWhenOutofstock,Keyword,ProducerName,TrademarkName,BarCode,ProductIntro,ProductExplain,IsNew,IsHot,IsBest,Stars,EnableSale,Stocks,DownloadUrl,Remark,AlarmNum,OrderNum";

        public bool Add(ProductInfo info, string tableName)
        {
            string strSql = Query.GetInsertTableSql("PE_CommonProduct", "ProductID,TableName,ProductName,ProductType,ProductPic,ProductThumb,Unit,ProductNum,ServiceTermUnit,ServiceTerm,Price,Price_Market,Price_Member,Price_Agent,EnableWholesale,Price_Wholesale1,Price_Wholesale2,Price_Wholesale3,Number_Wholesale1,Number_Wholesale2,Number_Wholesale3,PresentID,PresentNumber,PresentPoint,PresentExp,PresentMoney,StocksProject,SalePromotionType,MinNumber,Discount,IncludeTax,TaxRate,Properties,Weight,LimitNum,EnableSingleSell,DependentProducts,ProductKind,ProductCharacter,EnableBuyWhenOutofstock,Keyword,ProducerName,TrademarkName,BarCode,ProductIntro,ProductExplain,IsNew,IsHot,IsBest,Stars,EnableSale,Stocks,DownloadUrl,Remark,AlarmNum,OrderNum", "@ProductID,@TableName,@ProductName,@ProductType,@ProductPic,@ProductThumb,@Unit,@ProductNum,@ServiceTermUnit,@ServiceTerm,@Price,@Price_Market,@Price_Member,@Price_Agent,@EnableWholesale,@Price_Wholesale1,@Price_Wholesale2,@Price_Wholesale3,@Number_Wholesale1,@Number_Wholesale2,@Number_Wholesale3,@PresentID,@PresentNumber,@PresentPoint,@PresentExp,@PresentMoney,@StocksProject,@SalePromotionType,@MinNumber,@Discount,@IncludeTax,@TaxRate,@Properties,@Weight,@LimitNum,@EnableSingleSell,@DependentProducts,@ProductKind,@ProductCharacter,@EnableBuyWhenOutofstock,@Keyword,@ProducerName,@TrademarkName,@BarCode,@ProductIntro,@ProductExplain,@IsNew,@IsHot,@IsBest,@Stars,@EnableSale,@Stocks,@DownloadUrl,@Remark,@AlarmNum,@OrderNum");
            Parameters cmdParams = GetParameters(info, tableName);
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool AddBuyTimes(int productId, string tableName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@TableName", DbType.String, tableName);
            cmdParams.AddInParameter("@ProductID", DbType.Int32, productId);
            return DBHelper.ExecuteSql("update dbo.PE_CommonProduct set BuyTimes = Isnull(BuyTimes,0)+1 where  TableName=@TableName and ProductID=@ProductID", cmdParams);
        }

        public bool AddOrderNum(int id, int quantity)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@Quantity", DbType.Int32, quantity);
            cmdParams.AddInParameter("@ID", DbType.Int32, id);
            return DBHelper.ExecuteSql("update PE_CommonProduct set OrderNum=isnull(OrderNum,0)+@Quantity where ProductID=@ID", cmdParams);
        }

        public bool AddOrderNum(int productId, string tableName, int quantity)
        {
            string strSql = "update PE_CommonProduct set OrderNum=isnull(OrderNum,0)+@Quantity where productId=@ProductId and tableName=@TableName";
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@Quantity", DbType.Int32, quantity);
            cmdParams.AddInParameter("@ProductId", DbType.Int32, productId);
            cmdParams.AddInParameter("@TableName", DbType.String, tableName);
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool AddStocks(int productId, int quantity)
        {
            string strSql = "update dbo.PE_CommonProduct set Stocks = Isnull(Stocks,0)+@Quantity where  ProductID=@ProductID";
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@Quantity", DbType.Int32, quantity);
            cmdParams.AddInParameter("@ProductID", DbType.Int32, productId);
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

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

        public bool ExistsPresent(int presentId)
        {
            return DBHelper.ExistsSql("select top 1 ProductID from PE_CommonProduct where PresentID=@PresentID", new Parameters("@PresentID", DbType.Int32, presentId));
        }

        public string GetGeneralIdList(string nodeIdList, string modelIdList)
        {
            StringBuilder sb = new StringBuilder();
            StringBuilder builder2 = new StringBuilder("select C.GeneralID from PE_CommonProduct P inner join PE_CommonModel C on C.ItemID = P.ProductID and C.TableName = P.TableName where NodeID in(" + nodeIdList + ")");
            if (!string.IsNullOrEmpty(modelIdList))
            {
                builder2.Append(" and ModelID in (" + modelIdList + ")");
            }
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql(builder2.ToString()))
            {
                while (reader.Read())
                {
                    StringHelper.AppendString(sb, reader.GetInt32("GeneralID").ToString());
                }
            }
            return sb.ToString();
        }

        private static Parameters GetParameters(ProductInfo productInfo, string tableName)
        {
            Parameters parameters = new Parameters();
            parameters.AddInParameter("@ProductID", DbType.Int32, productInfo.ProductId);
            parameters.AddInParameter("@TableName", DbType.String, tableName);
            parameters.AddInParameter("@ProductName", DbType.String, productInfo.ProductName);
            parameters.AddInParameter("@ProductType", DbType.Int32, productInfo.ProductType);
            parameters.AddInParameter("@ProductPic", DbType.String, productInfo.ProductPic);
            parameters.AddInParameter("@ProductThumb", DbType.String, productInfo.ProductThumb);
            parameters.AddInParameter("@Unit", DbType.String, productInfo.Unit);
            parameters.AddInParameter("@ProductNum", DbType.String, productInfo.ProductNum);
            parameters.AddInParameter("@ServiceTermUnit", DbType.Int32, productInfo.ServiceTermUnit);
            parameters.AddInParameter("@ServiceTerm", DbType.Int32, productInfo.ServiceTerm);
            parameters.AddInParameter("@Price", DbType.Currency, productInfo.PriceInfo.Price);
            parameters.AddInParameter("@Price_Market", DbType.Currency, productInfo.PriceMarket);
            parameters.AddInParameter("@Price_Member", DbType.Currency, productInfo.PriceInfo.PriceMember);
            parameters.AddInParameter("@Price_Agent", DbType.Currency, productInfo.PriceInfo.PriceAgent);
            parameters.AddInParameter("@EnableWholesale", DbType.Boolean, productInfo.EnableWholesale);
            parameters.AddInParameter("@Price_Wholesale1", DbType.Currency, productInfo.PriceInfo.PriceWholesale1);
            parameters.AddInParameter("@Price_Wholesale2", DbType.Currency, productInfo.PriceInfo.PriceWholesale2);
            parameters.AddInParameter("@Price_Wholesale3", DbType.Currency, productInfo.PriceInfo.PriceWholesale3);
            parameters.AddInParameter("@Number_Wholesale1", DbType.Int32, productInfo.PriceInfo.NumberWholesale1);
            parameters.AddInParameter("@Number_Wholesale2", DbType.Int32, productInfo.PriceInfo.NumberWholesale2);
            parameters.AddInParameter("@Number_Wholesale3", DbType.Int32, productInfo.PriceInfo.NumberWholesale3);
            parameters.AddInParameter("@PresentID", DbType.String, productInfo.PresentId);
            parameters.AddInParameter("@PresentNumber", DbType.Int32, productInfo.PresentNumber);
            parameters.AddInParameter("@PresentPoint", DbType.Int32, productInfo.PresentPoint);
            parameters.AddInParameter("@PresentExp", DbType.Int32, productInfo.PresentExp);
            parameters.AddInParameter("@PresentMoney", DbType.Currency, productInfo.PresentMoney);
            parameters.AddInParameter("@StocksProject", DbType.Int32, (int) productInfo.StocksProject);
            parameters.AddInParameter("@SalePromotionType", DbType.Int32, productInfo.SalePromotionType);
            parameters.AddInParameter("@MinNumber", DbType.Int32, productInfo.MinNumber);
            parameters.AddInParameter("@Discount", DbType.Double, productInfo.Discount);
            parameters.AddInParameter("@IncludeTax", DbType.Int32, (int) productInfo.IncludeTax);
            parameters.AddInParameter("@TaxRate", DbType.Double, productInfo.TaxRate);
            parameters.AddInParameter("@Properties", DbType.String, productInfo.Properties);
            parameters.AddInParameter("@Weight", DbType.Double, productInfo.Weight);
            parameters.AddInParameter("@LimitNum", DbType.Int32, productInfo.LimitNum);
            parameters.AddInParameter("@EnableSingleSell", DbType.Boolean, productInfo.EnableSingleSell);
            parameters.AddInParameter("@DependentProducts", DbType.String, productInfo.DependentProducts);
            parameters.AddInParameter("@ProductKind", DbType.Int32, productInfo.ProductKind);
            parameters.AddInParameter("@ProductCharacter", DbType.Int32, (int) productInfo.ProductCharacter);
            parameters.AddInParameter("@EnableBuyWhenOutofstock", DbType.Boolean, productInfo.EnableBuyWhenOutofstock);
            parameters.AddInParameter("@Keyword", DbType.String, productInfo.Keyword);
            parameters.AddInParameter("@ProductIntro", DbType.String, productInfo.ProductIntro);
            parameters.AddInParameter("@ProducerName", DbType.String, productInfo.ProducerName);
            parameters.AddInParameter("@ProductExplain", DbType.String, productInfo.ProductExplain);
            parameters.AddInParameter("@TrademarkName", DbType.String, productInfo.TrademarkName);
            parameters.AddInParameter("@BarCode", DbType.String, productInfo.BarCode);
            parameters.AddInParameter("@Stars", DbType.String, productInfo.Stars);
            parameters.AddInParameter("@IsNew", DbType.Boolean, productInfo.IsNew);
            parameters.AddInParameter("@IsHot", DbType.Boolean, productInfo.IsHot);
            parameters.AddInParameter("@IsBest", DbType.Boolean, productInfo.IsBest);
            parameters.AddInParameter("@EnableSale", DbType.Boolean, productInfo.EnableSale);
            parameters.AddInParameter("@Stocks", DbType.Int32, productInfo.Stocks);
            parameters.AddInParameter("@DownloadUrl", DbType.String, productInfo.DownloadUrl);
            parameters.AddInParameter("@Remark", DbType.String, productInfo.Remark);
            parameters.AddInParameter("@AlarmNum", DbType.Int32, productInfo.AlarmNum);
            parameters.AddInParameter("@OrderNum", DbType.Int32, productInfo.OrderNum);
            return parameters;
        }