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;

namespace CY.SQLDAL
{
    public class Integrity_EvaluationRecordsDAL : IIntegrity_EvaluationRecordsDAL
    {

        private Database _dataBase = null;

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

        public Integrity_EvaluationRecordsDAL(Database dDatabase)
        {
            _dataBase = dDatabase;
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Integrity_EvaluationRecords trueModel = model as Model.Integrity_EvaluationRecords;
            if (trueModel == null)
            {
                return false;
            }
            if (trueModel.SellerEvaluation == null)
            {
                IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                        new SqlParameter("@MemberId",trueModel.MemberId),
					    new SqlParameter("@SellerId",trueModel.SellerId),
					    new SqlParameter("@BuyerEvaluation",trueModel.BuyerEvaluation),
					    new SqlParameter("@ScoringSeller",trueModel.ScoringSeller),
					    new SqlParameter("@BuyerComment",trueModel.BuyerComment),
					    new SqlParameter("@BuyerCommentDate",trueModel.BuyerCommentDate),
					    new SqlParameter("@SellerEvaluation",DBNull.Value),
					    new SqlParameter("@ScoringBuyer",DBNull.Value),
					    new SqlParameter("@SellerComment",DBNull.Value),
					    new SqlParameter("@SellerCommentDate",DBNull.Value),
					    new SqlParameter("@EffectiveDate",DBNull.Value),
					    new SqlParameter("@OrderId",trueModel.OrderId),
					    new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					    new SqlParameter("@Operate",trueModel.Operate),
					    new SqlParameter("@Remark",trueModel.Remark) 
                };
                try
                {
                    _dataBase.Query("sp_Integrity_EvaluationRecords_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
            else
            {
                IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                        new SqlParameter("@MemberId",trueModel.MemberId),
					    new SqlParameter("@SellerId",trueModel.SellerId),
					    new SqlParameter("@BuyerEvaluation",DBNull.Value),
					    new SqlParameter("@ScoringSeller",DBNull.Value),
					    new SqlParameter("@BuyerComment",DBNull.Value),
					    new SqlParameter("@BuyerCommentDate",DBNull.Value),
					    new SqlParameter("@SellerEvaluation",trueModel.SellerEvaluation),
					    new SqlParameter("@ScoringBuyer",trueModel.ScoringBuyer),
					    new SqlParameter("@SellerComment",trueModel.SellerComment),
					    new SqlParameter("@SellerCommentDate",trueModel.SellerCommentDate),
					    new SqlParameter("@EffectiveDate",DBNull.Value),
					    new SqlParameter("@OrderId",trueModel.OrderId),
					    new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					    new SqlParameter("@Operate",trueModel.Operate),
					    new SqlParameter("@Remark",trueModel.Remark) 
                };
                try
                {
                    _dataBase.Query("sp_Integrity_EvaluationRecords_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.Integrity_EvaluationRecords trueModel = model as Model.Integrity_EvaluationRecords;
            if (trueModel == null)
            {
                return false;
            }
            object obj_BuyerEvaluation = null;
            object obj_ScoringSeller = null;
            object obj_BuyerComment = null;
            object obj_BuyerCommentDate = null;
            object obj_SellerEvaluation = null;
            object obj_ScoringBuyer = null;
            object obj_SellerComment = null;
            object obj_SellerCommentDate = null;
            object obj_EffectiveDate = null;

            if (trueModel.BuyerEvaluation == null)
                obj_BuyerEvaluation = DBNull.Value;
            else
                obj_BuyerEvaluation = trueModel.BuyerEvaluation;

            if (trueModel.ScoringSeller == null)
                obj_ScoringSeller = DBNull.Value;
            else
                obj_ScoringSeller = trueModel.ScoringSeller;

            if (trueModel.BuyerComment == null)
                obj_BuyerComment = DBNull.Value;
            else
                obj_BuyerComment = trueModel.BuyerComment;

            if (trueModel.BuyerCommentDate == null)
                obj_BuyerCommentDate = DBNull.Value;
            else
                obj_BuyerCommentDate = trueModel.BuyerCommentDate;

            if (trueModel.SellerEvaluation == null)
                obj_SellerEvaluation = DBNull.Value;
            else
                obj_SellerEvaluation = trueModel.SellerEvaluation;

            if (trueModel.ScoringBuyer == null)
                obj_ScoringBuyer = DBNull.Value;
            else
                obj_ScoringBuyer = trueModel.ScoringBuyer;

            if (trueModel.SellerComment == null)
                obj_SellerComment = DBNull.Value;
            else
                obj_SellerComment = trueModel.SellerComment;

            if (trueModel.SellerCommentDate == null)
                obj_SellerCommentDate = DBNull.Value;
            else
                obj_SellerCommentDate = trueModel.SellerCommentDate;

            if (trueModel.EffectiveDate == null)
                obj_EffectiveDate = DBNull.Value;
            else
                obj_EffectiveDate = trueModel.EffectiveDate;

            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {       
                    new SqlParameter("@Keyid",trueModel.Keyid),
                    new SqlParameter("@MemberId",trueModel.MemberId),
					new SqlParameter("@SellerId",trueModel.SellerId),
					new SqlParameter("@BuyerEvaluation",obj_BuyerEvaluation),
					new SqlParameter("@ScoringSeller",obj_ScoringSeller),
					new SqlParameter("@BuyerComment",obj_BuyerComment),
					new SqlParameter("@BuyerCommentDate",obj_BuyerCommentDate),
					new SqlParameter("@SellerEvaluation",obj_SellerEvaluation),
					new SqlParameter("@ScoringBuyer",obj_ScoringBuyer),
					new SqlParameter("@SellerComment",obj_SellerComment),
					new SqlParameter("@SellerCommentDate",obj_SellerCommentDate),
					new SqlParameter("@EffectiveDate",obj_EffectiveDate),
					new SqlParameter("@OrderId",trueModel.OrderId),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Operate",trueModel.Operate),
					new SqlParameter("@Remark",trueModel.Remark) };
            try
            {
                _dataBase.Query("sp_Integrity_EvaluationRecords_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.Integrity_EvaluationRecords trueModel = model as Model.Integrity_EvaluationRecords;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_Integrity_EvaluationRecords_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.Integrity_EvaluationRecords> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

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

        /// <summary>
        /// 根据编号获得信息
        /// </summary>
        /// <param name="Keyid">编号</param>
        /// <returns></returns>
        public Integrity_EvaluationRecords GetModelByKeyid(int? Keyid)
        {
            try
            {
                if (Keyid == null || Keyid < 0)
                    return null;//错误数据返会空 

                IList<Integrity_EvaluationRecords> result = _dataBase.SelectModel<Integrity_EvaluationRecords>("*", "Integrity_EvaluationRecords", string.Format(" Keyid='{0}'", Keyid)) as IList<Integrity_EvaluationRecords>;//执行查询

                return (null == result || result.Count == 0) ? null : result[0];//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据订单编号获得信息
        /// </summary>
        /// <param name="OrderId">订单编号</param>
        /// <returns></returns>
        public Integrity_EvaluationRecords GetModelByOrderId(int? OrderId)
        {
            try
            {
                if (OrderId == null || OrderId <= 0)
                    return null;//错误数据返会空 

                IList<Integrity_EvaluationRecords> result = _dataBase.SelectModel<Integrity_EvaluationRecords>("*", "Integrity_EvaluationRecords", string.Format(" OrderId='{0}'", OrderId)) as IList<Integrity_EvaluationRecords>;//执行查询

                return (null == result || result.Count == 0) ? null : result[0];//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }
}