using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CY.IDAL;
using System.Data.SqlClient;
using System.Data;
using CY.Infrastructure.Query;

namespace CY.SQLDAL
{
    public class OA_BrandDAL : IOA_BrandDAL
    {

        private Database _dataBase = null;

        public OA_BrandDAL()
        {
            _dataBase = new Database();
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Brand trueModel = model as Model.OA_Brand;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@FirmId",trueModel.FirmId),
					new SqlParameter("@Name",trueModel.Name),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@Remark"," "),
                   new SqlParameter("@GoodsId",trueModel.GoodsId),
                   new SqlParameter("@CommodityId",trueModel.CommodityId) 
                   ,new SqlParameter("@OrderNum",trueModel.OrderNum) 
            };
            try
            {
                _dataBase.Query("sp_OA_Brand_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Brand trueModel = model as Model.OA_Brand;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {	new SqlParameter("@Keyid",trueModel.Keyid),
                new SqlParameter("@FirmId",trueModel.FirmId),
					new SqlParameter("@Name",trueModel.Name),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@Remark",""),
                   new SqlParameter("@GoodsId",trueModel.GoodsId),
                   new SqlParameter("@CommodityId",trueModel.CommodityId) 
                   ,new SqlParameter("@OrderNum",trueModel.OrderNum)
            };
            try
            {
                _dataBase.Query("sp_OA_Brand_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Brand trueModel = model as Model.OA_Brand;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_OA_Brand_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="query"></param>
        /// <param name="pagination"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Brand> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

        public IEnumerable<Model.OA_Brand> getAllBrand(Pagination pa, Guid FirmId, string BrandName, string CommodityName, string GoodsName)
        {
            string Condition = "  where D.FirmId='" + FirmId + "'";
            if (!string.IsNullOrEmpty(BrandName))
            {

                Condition += "and  D.Name like '%" + BrandName + "%'";
            }
            if (!string.IsNullOrEmpty(CommodityName))
            {

                Condition += "and  B.CommodityName like '%" + CommodityName + "%'";
            }
            if (!string.IsNullOrEmpty(GoodsName))
            {

                Condition += "and  C.GoodsName like '%" + GoodsName + "%'";
            }
            string selectTarget = " T.* ";
            string fromSource = @"
                                 ( 
                                  select D.*,B.CommodityName as CommodityName,C.GoodsName as GoodsName from 
                                 OA_Brand AS D LEFT JOIN dbo.OA_Commodity AS B ON D.CommodityId = B.Keyid  LEFT JOIN dbo.OA_GoodsInfo AS C ON D.GoodsId = C.Keyid" + Condition + ") T";
            return _dataBase.SelectModelPage<Model.OA_Brand>(pa, selectTarget, fromSource, " T.CommodityId ,T.OrderNum ASC ", "CommodityId ,OrderNum ASC", "");
        }

        public DataTable getAllBrand(Guid FrimId, string CommodityId, string GoodsId)
        {
            string Condition = "  where FirmId='" + FrimId + "'";
            if (!string.IsNullOrEmpty(CommodityId))
            {
                Condition += " and CommodityId='" + CommodityId + "'";
            }
            if (!string.IsNullOrEmpty(GoodsId))
            {

                Condition += " and  GoodsId='" + GoodsId + "'";
            }
            string selectTarget = " * ";
            string fromSource = " OA_Brand " + Condition;
            return _dataBase.SelectModel(selectTarget, fromSource);
        }

        /// <summary>
        /// 单个查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Brand> SelectAllModel(Infrastructure.Query.Query query)
        {
            throw new NotImplementedException();
        }

        public Model.OA_Brand getSingleBrand(string Keyid)
        {
            if (_dataBase.SelectModel<Model.OA_Brand>(" * ", " OA_Brand ", " Keyid='" + Keyid + "' ").Count > 0)
            {
                return _dataBase.SelectModel<Model.OA_Brand>(" * ", " OA_Brand ", " Keyid='" + Keyid + "' ")[0];
            }
            else
            {
                return null;
            }
        }

        public string GetMaxOrderNum(Guid FirmId, string TName)
        {

            string selTarget = " MAX(OrderNum) ";
            string fromSource = TName + " where  FirmId= '" + FirmId + "'";
            DataTable dt = _dataBase.SelectModel(selTarget, fromSource);
            if (dt.Rows.Count > 0)
            {
                if (string.IsNullOrEmpty(dt.Rows[0][0].ToString()))
                {
                    return "0";
                }
                else
                    return (Convert.ToInt32(dt.Rows[0][0]) + 1).ToString();
            }
            else
            {

                return "0";
            }

        }

        public string GetMaxOrderNumMemberId(Guid FirmId, string TName)
        {

            string selTarget = " MAX(OrderNum) ";
            string fromSource = TName + " where  MemberId= '" + FirmId + "'";
            DataTable dt = _dataBase.SelectModel(selTarget, fromSource);
            if (dt.Rows.Count > 0)
            {
                if (string.IsNullOrEmpty(dt.Rows[0][0].ToString()))
                {
                    return "0";
                }
                else
                    return (Convert.ToInt32(dt.Rows[0][0]) + 1).ToString();
            }
            else
            {

                return "0";
            }

        }

        /// <summary>
        /// 获取全部品牌对应的GoodsId、分页
        /// </summary>
        /// <param name="pa"></param>
        /// <param name="FirmId"></param>
        /// <param name="SpecificationName"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Brand> getAllBrandnew(Pagination pa, Guid FirmId, string BrandName, string GoodsName, string CommdityName)
        {
            string Condition = " b.FirmId='" + FirmId + "'";
            if (!string.IsNullOrEmpty(BrandName))
            {
                Condition += "and  b.Name like '%" + BrandName + "%'";
            }
            if (!string.IsNullOrEmpty(GoodsName))
            {
                Condition += "and a.GoodsName like '%" + GoodsName + "%'";
            }
            if (!string.IsNullOrEmpty(CommdityName))
            {
                Condition += "and  c.CommodityName like '%" + CommdityName + "%'";
            }
            string selectTarget = " t.GoodsId ,t.AorDerNum ";
            string fromSource = "(select DISTINCT  a.Keyid as GoodsId ,c.OrderNum AS AorDerNum from dbo.OA_GoodsInfo AS a INNER JOIN  dbo.OA_Brand AS b ON a.Keyid=b.GoodsId LEFT JOIN dbo.OA_Commodity AS c ON a.GoodsTypeId= c.Keyid where " + Condition + ") as t";
            return _dataBase.SelectModelPage<Model.OA_Brand>(pa, selectTarget, fromSource, "t.AorDerNum", "AorDerNum", string.Empty);
        }

        /// <summary>
        /// 获取一个货品下面的全部品牌-分页
        /// </summary>
        /// <param name="pa"></param>
        /// <param name="GoodsId"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Brand> getAllModelByGoodsId(Pagination pa, string GoodsId)
        {
            string Condition = "  where D.GoodsID= " + GoodsId;
            string selTarget = " D.*,B.CommodityName as CommodityName,C.GoodsName as GoodsName ";
            string fromSource = "dbo.OA_Brand  AS D  LEFT JOIN dbo.OA_GoodsInfo AS C ON D.GoodsId = C.Keyid LEFT JOIN dbo.OA_Commodity AS B ON C.GoodsTypeId = B.Keyid" + Condition;
            return _dataBase.SelectModelPage<Model.OA_Brand>(pa, selTarget, fromSource, " D.OrderNum ");
        }

        /// <summary>
        /// 根据货品id返回所有品牌对象-非分页
        /// </summary>
        /// <param name="GoodsId"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Brand> getAllModelByGoodsId(string GoodsId)
        {
            try
            {
                string Condition = "  where D.GoodsID= " + GoodsId;
                string selectTarget = "  D.*,B.CommodityName as CommodityName,C.GoodsName as GoodsName ";
                string fromSource = @" dbo.OA_Brand  AS D LEFT JOIN dbo.OA_GoodsInfo AS C ON D.GoodsId = C.Keyid LEFT JOIN dbo.OA_Commodity AS B ON C.GoodsTypeId = B.Keyid " + Condition;
                return _dataBase.SelectModel<Model.OA_Brand>(selectTarget, fromSource);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

    }
}