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 Pay_ScoreRecordDAL : IPay_ScoreRecordDAL
    {
        private Database _dataBase = null;

        public Pay_ScoreRecordDAL()
        {
            _dataBase = new Database();
        }
        public Pay_ScoreRecordDAL(Database database)
        {
            _dataBase = database;
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@PayId",trueModel.PayId),
					new SqlParameter("@TradingName",trueModel.TradingName),
					new SqlParameter("@TradingType",trueModel.TradingType),
					new SqlParameter("@TradingState",trueModel.TradingState),
					new SqlParameter("@TradingScore",trueModel.TradingScore),
					new SqlParameter("@ResidualScore",trueModel.ResidualScore),
					new SqlParameter("@CreateTime",trueModel.CreateTime),
					new SqlParameter("@Remark",trueModel.Remark) 
            };
            try
            {
                _dataBase.Query("sp_Pay_ScoreRecord_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.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {	new SqlParameter("@Keyid",trueModel.Keyid),
                new SqlParameter("@PayId",trueModel.PayId),
					new SqlParameter("@TradingName",trueModel.TradingName),
					new SqlParameter("@TradingType",trueModel.TradingType),
					new SqlParameter("@TradingState",trueModel.TradingState),
					new SqlParameter("@TradingScore",trueModel.TradingScore),
					new SqlParameter("@ResidualScore",trueModel.ResidualScore),
					new SqlParameter("@CreateTime",trueModel.CreateTime),
					new SqlParameter("@Remark",trueModel.Remark) 
            };
            try
            {
                _dataBase.Query("sp_Pay_ScoreRecord_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.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_Pay_ScoreRecord_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.Pay_ScoreRecord> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

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

        /// <summary>
        /// 全部查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.Pay_ScoreRecord> SelectOrderMemberByTopNum(int? TopNum)
        {
            return _dataBase.SelectModel<Model.Pay_ScoreRecord>(" * ", " Pay_ScoreRecord ") as IList<Model.Pay_ScoreRecord>;//执行查询
        }

        /// <summary>
        /// 积分记录
        /// </summary>
        /// <param name="pagination"></param>
        /// <param name="PayId"></param>
        /// <param name="TradingType"></param>
        /// <param name="TradingState"></param>
        /// <param name="CreatStartTime"></param>
        /// <param name="CreatEndTime"></param>
        /// <returns></returns>
        public IEnumerable<Model.Pay_ScoreRecord> SelectAllModel(Infrastructure.Query.Pagination pagination, int? PayId, int? TradingType, int? TradingState, DateTime? CreatStartTime, DateTime? CreatEndTime)
        {
            if (PayId == null || PayId <= 0)
                return null;//错误数据返会空 
            try
            {
                string condtion = " 1=1 ";
                if (PayId > 0)
                {
                    condtion = condtion + " and PayId ='" + PayId + "' ";
                }
                if (TradingType > 0)
                {
                    condtion = condtion + " and TradingType ='" + TradingType + "' ";
                }
                if (TradingState > 0)
                {
                    condtion = condtion + " and TradingState ='" + TradingState + "' ";
                }
                if (CreatStartTime != null)
                {
                    condtion = condtion + " and CreateTime >='" + CreatStartTime + "' ";
                }
                if (CreatEndTime != null)
                {
                    condtion = condtion + " and CreateTime <='" + CreatEndTime.Value.AddDays(1) + "' ";
                }

                IList<Pay_ScoreRecord> result = _dataBase.SelectModelPage<Model.Pay_ScoreRecord>(pagination, "*", "Pay_ScoreRecord", "CreateTime DESC", "CreateTime DESC", condtion) as IList<Pay_ScoreRecord>;//执行查询
                return null == result ? null : result;//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }

        }

        public IEnumerable<Model.Pay_ScoreRecord> SelectAllModel(Infrastructure.Query.Pagination pagination, int TradingType, string startDate, string endDate, string province, string city, string country)
        {
            IEnumerable<Model.Pay_ScoreRecord> list = null;
            string selectTarget = " a.*,c.Name as MemberName ";
            string fromSouce = " dbo.Pay_ScoreRecord a INNER JOIN dbo.Pay_PaymentAccount b ON a.Payid=b.Keyid INNER JOIN dbo.EC_MemberBasic c ON c.MemberId=b.MemberId ";
            fromSouce += " where 1=1 and a.TradingState=-1 ";
            fromSouce += " and a.tradingType=" + TradingType;
            if (!string.IsNullOrEmpty(startDate))
                fromSouce += " And a.CreateTime >= '" + startDate + "' ";
            if (!string.IsNullOrEmpty(endDate))
                fromSouce += " And a.CreateTime < '" + endDate + "' ";

            if (!string.IsNullOrEmpty(province))
            {
                fromSouce += " and c.Province='" + province + "'";
            }

            if (!string.IsNullOrEmpty(city))
            {
                fromSouce += " and c.City='" + city + "'";
            }

            if (!string.IsNullOrEmpty(country))
            {
                fromSouce += " and c.County='" + country + "'";
            }

            list = _dataBase.SelectModelPage<Pay_ScoreRecord>(pagination, selectTarget, fromSouce, " a.CreateTime desc ", " CreateTime desc ", string.Empty);
            return list;
        }
    }
}