Hidistro.SqlDal/Comments/ProductReviewDao.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

namespace Hidistro.SqlDal.Comments
{
    using Hidistro.Core;
    using Hidistro.Core.Entities;
    using Hidistro.Entities;
    using Hidistro.Entities.Comments;
    using Hidistro.Entities.Orders;
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using System;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;
    using System.Runtime.InteropServices;
    using System.Text;

    public class ProductReviewDao
    {
        private Database database = DatabaseFactory.CreateDatabase();

        public int DeleteProductReview(long reviewId)
        {
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("DELETE FROM Hishop_ProductReviews WHERE ReviewId = @ReviewId");
            this.database.AddInParameter(sqlStringCommand, "ReviewId", DbType.Int64, reviewId);
            return this.database.ExecuteNonQuery(sqlStringCommand);
        }

        public LineItemInfo GetLatestOrderItemByProductIDAndUserID(int productid, int userid)
        {
            string query = string.Format(string.Concat(new object[] { "select top 1 a.* from Hishop_OrderItems a left join Hishop_ProductReviews b on a.skuid= b.skuid and a.orderid=b.orderid left join Hishop_Orders c on a.orderid=c.orderid where c.userid=", userid, " and a.productid=", productid, " and a.OrderItemsStatus = {0} and b.orderid is null order by a.Id desc" }), 5);
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand(query);
            using (IDataReader reader = this.database.ExecuteReader(sqlStringCommand))
            {
                return ReaderConvert.ReaderToModel<LineItemInfo>(reader);
            }
        }

        public IList<LineItemInfo> GetOrderItemsList(int userid)
        {
            string query = string.Format("select a.* from Hishop_OrderItems a left join Hishop_ProductReviews b on a.skuid= b.skuid and a.orderid=b.orderid left join Hishop_Orders c on a.orderid=c.orderid where c.userid=" + userid + " and  a.OrderItemsStatus = {0} and b.orderid is null order by a.Id desc", 5);
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand(query);
            using (IDataReader reader = this.database.ExecuteReader(sqlStringCommand))
            {
                return ReaderConvert.ReaderToList<LineItemInfo>(reader);
            }
        }

        public ProductReviewInfo GetProductReview(int reviewId)
        {
            ProductReviewInfo info = new ProductReviewInfo();
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("SELECT * FROM Hishop_ProductReviews WHERE ReviewId=@ReviewId");
            this.database.AddInParameter(sqlStringCommand, "ReviewId", DbType.Int32, reviewId);
            using (IDataReader reader = this.database.ExecuteReader(sqlStringCommand))
            {
                if (reader.Read())
                {
                    info = ReaderConvert.ReaderToModel<ProductReviewInfo>(reader);
                }
            }
            return info;
        }