/**  
* EC_OrderExtendDAL.cs
*
* 功 能： 订单扩展信息数据访问接口实现类
* 类 名： EC_OrderExtendDAL
*
* Ver    变更日期             负责人  变更内容
* ───────────────────────────────────
* V0.01  2013-4-23 10:09    吴崎均    更改InsertModel以及UpdateModel以与存储相匹配
* V0.02  2013-4-23 14:45    吴崎均    增加初始化构造
* V0.03  2013-5-29 14:38    吴崎均    修改更新数据方法:不更新剩余印刷数量
* V0.04  2013-6-1  14:14    吴崎均    修改更新数据方法:更新时更新订单印刷选项
*
*
*
*/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CY.IDAL;
using System.Data.SqlClient;
using System.Data;
using CY.Model;
using System.Transactions;

namespace CY.SQLDAL
{
    /// <summary>
    /// 订单扩展信息数据访问接口实现类
    /// </summary>
    internal class EC_OrderExtendDAL : IEC_OrderExtendDAL
    {

        private Database _dataBase = null;

        /// <summary>
        /// 初始化构造
        /// </summary>
        /// <param name="database"></param>
        public EC_OrderExtendDAL(Database database)
        {
            _dataBase = database;
        }

        /// <summary>
        /// 默认构造
        /// </summary>
        public EC_OrderExtendDAL()
        {
            _dataBase = new Database();
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_OrderExtend trueModel = model as Model.EC_OrderExtend;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter delayTime = null;
            if (trueModel.DelayTime.HasValue)
            {
                delayTime = new SqlParameter("@DelayTime", trueModel.DelayTime);
            }
            else
            {
                delayTime = new SqlParameter("@DelayTime", DBNull.Value);
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid),
					new SqlParameter("@FileId",trueModel.FileId),
					new SqlParameter("@ProofreadWayId",trueModel.ProofreadWayId),
					new SqlParameter("@ProofreadState",trueModel.ProofreadState),
					new SqlParameter("@ProofreadFileId",trueModel.ProofreadFileId),
					new SqlParameter("@PrintNum",trueModel.PrintNum),
					new SqlParameter("@ExigencyCaseId",trueModel.ExigencyCaseId),
					new SqlParameter("@BusinessManagerId",trueModel.BusinessManagerId),
					new SqlParameter("@CustomerManagerId",trueModel.CustomerManagerId),
					new SqlParameter("@CustomerLevelId",trueModel.CustomerLevelId),
					new SqlParameter("@Contacts",trueModel.Contacts),
					new SqlParameter("@ContactPhone",trueModel.ContactPhone),
					new SqlParameter("@InvoiceId",trueModel.InvoiceId),
					new SqlParameter("@SurplusPrintNum",trueModel.SurplusPrintNum),
					new SqlParameter("@Operate",trueModel.Operate),
					new SqlParameter("@Remark",trueModel.Remark),
                    new SqlParameter("@BookNum",trueModel.BookNum),
                    new SqlParameter("@BookPrice",trueModel.BookPrice),
                    new SqlParameter("@NumPerBag",trueModel.NumPerBag),
                    new SqlParameter("@BagNum",trueModel.BagNum),
                     delayTime,
                      new SqlParameter("@Productionprogress",trueModel.Productionprogress),
                       new SqlParameter("@PrintPackDeliveryRequir",trueModel.PrintPackDeliveryRequir),
                       new SqlParameter("@printunit",trueModel.printunit)

            };
            int i = -1;
            while (++i < sqlParms.Count)
            {
                sqlParms[i].Value = null == sqlParms[i].Value ? DBNull.Value : sqlParms[i].Value;
            }
            try
            {
                _dataBase.Query("sp_EC_OrderExtend_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool OldUpdate(Infrastructure.Domain.IAggregateRoot model)
        {
            EC_OrderBasic basic = model as Model.EC_OrderBasic;
            Model.EC_OrderExtend trueModel = basic.OrderExtend;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter unitPricePar = null;
            if (basic.UnitPrice.HasValue)
            {
                unitPricePar = new SqlParameter("@UnitPrice", basic.UnitPrice);
            }
            else
            {
                unitPricePar = new SqlParameter("@UnitPrice", DBNull.Value);
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid),
					new SqlParameter("@ProofreadWayId",trueModel.ProofreadWayId),
					new SqlParameter("@ExigencyCaseId",trueModel.ExigencyCaseId),
					new SqlParameter("@BusinessManagerId",trueModel.BusinessManagerId),
					new SqlParameter("@CustomerManagerId",trueModel.CustomerManagerId),
					new SqlParameter("@CustomerLevelId",trueModel.CustomerLevelId),
					new SqlParameter("@Contacts",trueModel.Contacts),
					new SqlParameter("@ContactPhone",trueModel.ContactPhone),
                    new SqlParameter("@SurplusPrintNum",trueModel.SurplusPrintNum),
					unitPricePar,
					new SqlParameter("@SumPrice",basic.SumPrice),
                    //new SqlParameter("@SurplusPrintNum",trueModel.SurplusPrintNum),
					new SqlParameter("@Operate",trueModel.Operate),
					new SqlParameter("@Remark",trueModel.Remark), 
                    new SqlParameter("@BookNum",trueModel.BookNum),
                    new SqlParameter("@BookPrice",trueModel.BookPrice),
                    new SqlParameter("@NumPerBag",trueModel.NumPerBag),
                    new SqlParameter("@BagNum",trueModel.BagNum),
                       new SqlParameter("@PrintPackDeliveryRequir",trueModel.PrintPackDeliveryRequir),
                       new SqlParameter("@printunit",trueModel.printunit)
            };
            try
            {
                _dataBase.Query("sp_EC_OrderExtend_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model">订单扩展信息</param>
        /// <param name="orderParam">订单印刷选项</param>
        /// <returns></returns>
        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model, EC_OrderPrintParameter orderParam = null)
        {
            EC_OrderBasic trueModel = model as Model.EC_OrderBasic;
            if (trueModel == null)
            {
                return false;
            }
            EC_AcceptWayByOrderDAL _eC_AcceptWayByOrderDAL = new EC_AcceptWayByOrderDAL(_dataBase);
            EC_OrderPrintParameterDAL eC_OrderPrintParameterDAL = null == orderParam ? null : new EC_OrderPrintParameterDAL();
            using (TransactionScope tran = new TransactionScope())
            {
                if (trueModel.AcceptWayByOrder == null || !_eC_AcceptWayByOrderDAL.UpdateModel(trueModel.AcceptWayByOrder))
                {
                    return false;
                }
                if (trueModel.OrderTypeId == 1)
                {
                    if (null == orderParam || eC_OrderPrintParameterDAL.UpdateModel(orderParam))
                    {
                    }
                    else
                        return false;

                    if (!this.OldUpdate(trueModel))
                    {
                        return false;
                    }

                    if (!new EC_OrderBasicDAL(_dataBase).UpdateModel(trueModel))
                    {
                        return false;
                    }
                }
                tran.Complete();
            }

            return true;
        }

        /// <summary>
        /// 修改外协订单
        /// </summary>
        /// <param name="orderBasic"></param>
        /// <param name="orderExtend"></param>
        /// <param name="orderParam"></param>
        /// <returns></returns>
        public bool UpdateOutOrderInfo(EC_OrderBasic orderBasic, EC_OrderExtend orderExtend, EC_OrderPrintParameter orderParam = null)
        {
            EC_OrderBasic trueModel = orderBasic as Model.EC_OrderBasic;
            if (trueModel == null)
            {
                return false;
            }

            EC_AcceptWayByOrderDAL _eC_AcceptWayByOrderDAL = new EC_AcceptWayByOrderDAL(_dataBase);
            EC_OrderPrintParameterDAL eC_OrderPrintParameterDAL = null == orderParam ? null : new EC_OrderPrintParameterDAL();
            using (TransactionScope tran = new TransactionScope())
            {
                if (trueModel.AcceptWayByOrder == null)
                {
                    return false;
                }
                if (trueModel.AcceptWayByOrder.Keyid == null)
                {
                    if (!_eC_AcceptWayByOrderDAL.InserModel(trueModel.AcceptWayByOrder))
                    {
                        return false;
                    }
                }
                else
                {
                    if (!_eC_AcceptWayByOrderDAL.UpdateModel(trueModel.AcceptWayByOrder))
                    {
                        return false;
                    }
                }


                if (trueModel.OrderTypeId == 2 || trueModel.OrderTypeId == 4)
                {
                    if (null == orderParam || eC_OrderPrintParameterDAL.UpdateModel(orderParam))
                    {
                    }
                    else
                        return false;

                    if (!this.OldUpdate(trueModel))
                    {
                        return false;
                    }
                    if (!new EC_OrderBasicDAL(_dataBase).UpdateModel(trueModel))
                    {
                        return false;
                    }
                }
                tran.Complete();
            }

            return true;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_OrderExtend trueModel = model as Model.EC_OrderExtend;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_EC_OrderExtend_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.EC_OrderExtend> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

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

        /// <summary>
        /// 更新订单扩展表剩余印刷数量
        /// </summary>
        /// <param name="Keyid"></param>
        /// <param name="SurplusPrintNum"></param>
        /// <param name="Operator"></param>
        /// <returns></returns>
        public bool UpSurplusPrintNum(int? Keyid, int? SurplusPrintNum, string Operator)
        {
            bool result = false;
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",Keyid),
					new SqlParameter("@SurplusPrintNum",SurplusPrintNum),
					new SqlParameter("@Operator",Operator),
                    new SqlParameter(){ParameterName="@result",Direction=ParameterDirection.ReturnValue,SqlDbType=SqlDbType.Int}
            };
            try
            {
                _dataBase.Query("sp_EC_OrderExtend_Update_SurplusPrintNum", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
                result = 1.Equals(sqlParms[3].Value);
                return result;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            throw new NotImplementedException();
        }
    }
}