orderfeedback.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 OrderFeedback : IOrderFeedback
    {
        private int m_TotalOfOrderFeedback;

        public bool Add(OrderFeedbackInfo orderFeedbackInfo)
        {
            Parameters cmdParams = GetParameters(orderFeedbackInfo);
            return DBHelper.ExecuteSql("insert into PE_OrderFeedback (OrderID,UserName,Content,WriteTime,ReplyName,ReplyContent,ReplyTime) values (@OrderID,@UserName,@Content,@WriteTime,@ReplyName,@ReplyContent,@ReplyTime)", cmdParams);
        }

        public bool Delete(string id)
        {
            return DBHelper.ExecuteSql("delete from PE_OrderFeedback Where ID in (" + id + ")");
        }

        public IList<OrderFeedbackInfo> GetList(int orderId)
        {
            IList<OrderFeedbackInfo> list = new List<OrderFeedbackInfo>();
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("select * from PE_OrderFeedback where OrderID=@OrderID order by ID desc", new Parameters("@orderId", DbType.Int32, orderId)))
            {
                while (reader.Read())
                {
                    list.Add(GetOrderFeedbackInfoFromrdr(reader));
                }
            }
            return list;
        }

        public IList<OrderFeedbackInfo> GetList(int startRowIndexId, int maxNumberRows)
        {
            Database database = DatabaseFactory.CreateDatabase();
            IList<OrderFeedbackInfo> list = new List<OrderFeedbackInfo>();
            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, "ID");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "*");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "DESC");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "PE_OrderFeedback");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    list.Add(GetOrderFeedbackInfoFromrdr(reader));
                }
            }
            this.m_TotalOfOrderFeedback = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return list;
        }

        public OrderFeedbackInfo GetOrderFeedbackById(int id)
        {
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("select * from PE_OrderFeedback where ID=@ID", new Parameters("@ID", DbType.Int32, id)))
            {
                if (reader.Read())
                {
                    return GetOrderFeedbackInfoFromrdr(reader);
                }
                return new OrderFeedbackInfo(true);
            }
        }

        private static OrderFeedbackInfo GetOrderFeedbackInfoFromrdr(NullableDataReader rdr)
        {
            OrderFeedbackInfo info = new OrderFeedbackInfo();
            info.Id = rdr.GetInt32("ID");
            info.OrderId = rdr.GetInt32("OrderID");
            info.UserName = rdr.GetString("UserName");
            info.Content = rdr.GetString("Content");
            info.WriteTime = rdr.GetDateTime("WriteTime");
            info.ReplyName = rdr.GetString("ReplyName");
            info.ReplyContent = rdr.GetString("ReplyContent");
            info.ReplyTime = rdr.GetDateTime("ReplyTime");
            return info;
        }

        private static Parameters GetParameters(OrderFeedbackInfo orderFeedbackInfo)
        {
            Parameters parameters = new Parameters();
            parameters.AddInParameter("@OrderID", DbType.Int32, orderFeedbackInfo.OrderId);
            parameters.AddInParameter("@UserName", DbType.String, orderFeedbackInfo.UserName);
            parameters.AddInParameter("@Content", DbType.String, orderFeedbackInfo.Content);
            parameters.AddInParameter("@WriteTime", DbType.DateTime, orderFeedbackInfo.WriteTime);
            parameters.AddInParameter("@ReplyName", DbType.String, orderFeedbackInfo.ReplyName);
            parameters.AddInParameter("@ReplyContent", DbType.String, orderFeedbackInfo.ReplyContent);
            parameters.AddInParameter("@ReplyTime", DbType.DateTime, orderFeedbackInfo.ReplyTime);
            return parameters;
        }

        public int GetTotalOfOrderFeedback()
        {
            return this.m_TotalOfOrderFeedback;
        }

        public bool Update(OrderFeedbackInfo orderFeedbackInfo)
        {
            Parameters cmdParams = GetParameters(orderFeedbackInfo);
            cmdParams.AddInParameter("@ID", DbType.Int32, orderFeedbackInfo.Id);
            return DBHelper.ExecuteSql("update PE_OrderFeedback set OrderID=@OrderID,UserName=@UserName,Content=@Content,WriteTime=@WriteTime,ReplyName=@ReplyName,ReplyContent=@ReplyContent,ReplyTime=@ReplyTime where ID = @ID ", cmdParams);
        }
    }
}