Hidistro.SqlDal/zbCommodities/TaobaoProductDao.cs

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

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

namespace Hidistro.SqlDal.zbCommodities
{
    using Hidistro.Core;
    using Hidistro.Entities.Commodities;
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using System;
    using System.Data;
    using System.Data.Common;

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

        public DataSet GetTaobaoProductDetails(int productId)
        {
            DataTable table;
            DataTable table2;
            DataTable table3;
            DataTable table4;
            DataTable table5;
            DataSet set = new DataSet();
            DbCommand sqlStringCommand = this.database.GetSqlStringCommand("SELECT ProductId, HasSKU, ProductName, ProductCode, MarketPrice, (SELECT [Name] FROM Hishop_zbCategories WHERE CategoryId = p.CategoryId) AS CategoryName, (SELECT [Name] FROM Hishop_zbProductLines WHERE LineId = p.LineId) AS ProductLineName, (SELECT BrandName FROM Hishop_zbBrandCategories WHERE BrandId = p.BrandId) AS BrandName, (SELECT MIN(SalePrice) FROM Hishop_zbSKUs WHERE ProductId = p.ProductId) AS SalePrice, (SELECT MIN(CostPrice) FROM Hishop_zbSKUs WHERE ProductId = p.ProductId) AS CostPrice, (SELECT SUM(Stock) FROM Hishop_zbSKUs WHERE ProductId = p.ProductId) AS Stock FROM Hishop_zbProducts p WHERE ProductId = @ProductId SELECT AttributeName, ValueStr FROM Hishop_zbProductAttributes pa join Hishop_zbAttributes a ON pa.AttributeId = a.AttributeId JOIN Hishop_zbAttributeValues v ON a.AttributeId = v.AttributeId AND pa.ValueId = v.ValueId WHERE ProductId = @ProductId ORDER BY a.DisplaySequence DESC, v.DisplaySequence DESC SELECT Weight AS '重量', Stock AS '库存', CostPrice AS '成本价', SalePrice AS '一口价', SkuId AS '条形码' FROM Hishop_zbSKUs s WHERE ProductId = @ProductId; SELECT SkuId AS '条形码',AttributeName,UseAttributeImage,ValueStr,ImageUrl FROM Hishop_zbSKUItems s join Hishop_zbAttributes a on s.AttributeId = a.AttributeId join Hishop_zbAttributeValues av on s.ValueId = av.ValueId WHERE SkuId IN (SELECT SkuId FROM Hishop_zbSKUs WHERE ProductId = @ProductId) ORDER BY a.DisplaySequence DESC SELECT * FROM Taobao_Products WHERE ProductId = @ProductId");
            this.database.AddInParameter(sqlStringCommand, "ProductId", DbType.Int32, productId);
            using (IDataReader reader = this.database.ExecuteReader(sqlStringCommand))
            {
                table = DataHelper.ConverDataReaderToDataTable(reader);
                reader.NextResult();
                table2 = DataHelper.ConverDataReaderToDataTable(reader);
                reader.NextResult();
                table3 = DataHelper.ConverDataReaderToDataTable(reader);
                reader.NextResult();
                table4 = DataHelper.ConverDataReaderToDataTable(reader);
                reader.NextResult();
                table5 = DataHelper.ConverDataReaderToDataTable(reader);
            }
            if (((table3 != null) && (table3.Rows.Count > 0)) && ((table4 != null) && (table4.Rows.Count > 0)))
            {
                foreach (DataRow row in table4.Rows)
                {
                    DataColumn column = new DataColumn {
                        ColumnName = (string) row["AttributeName"]
                    };
                    if (!table3.Columns.Contains(column.ColumnName))
                    {
                        table3.Columns.Add(column);
                    }
                }
                foreach (DataRow row2 in table3.Rows)
                {
                    foreach (DataRow row in table4.Rows)
                    {
                        if (string.Compare((string) row2["条形码"], (string) row["条形码"]) == 0)
                        {
                            row2[(string) row["AttributeName"]] = row["ValueStr"];
                        }
                    }
                }
            }
            set.Tables.Add(table);
            set.Tables.Add(table2);