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
{
    public class EC_PaymentRecordDAL : IEC_PaymentRecordDAL
    {

        private Database _dataBase = null;

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

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

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_PaymentRecord trueModel = model as Model.EC_PaymentRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                    new SqlParameter("@PayType",trueModel.PayType),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@MemberId",trueModel.MemberId),
					new SqlParameter("@MemberName",trueModel.MemberName),
					new SqlParameter("@BusinessManagerId",trueModel.BusinessManagerId),
					new SqlParameter("@AccountManagerId",trueModel.AccountManagerId),
					new SqlParameter("@Contact",trueModel.Contact),
					new SqlParameter("@CompanyPhone",trueModel.CompanyPhone),
					new SqlParameter("@Email",trueModel.Email),
					new SqlParameter("@QQ",trueModel.QQ),
					new SqlParameter("@PayMoney",trueModel.PayMoney),
					new SqlParameter("@PayAllMoney",trueModel.PayAllMoney),
					new SqlParameter("@PayStartTime",trueModel.PayStartTime),
					new SqlParameter("@PayEndTime",trueModel.PayEndTime),
					new SqlParameter("@PayRole",trueModel.PayRole),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Remark",trueModel.Remark),
					new SqlParameter("@SoftwarePermissions",trueModel.SoftwarePermissions),
					new SqlParameter("@AdForum",trueModel.AdForum),
					new SqlParameter("@AdLocation",trueModel.AdLocation),
					new SqlParameter("@AdSize",trueModel.AdSize),
					new SqlParameter("@AdImg",trueModel.AdImg),
					new SqlParameter("@AdInstallments",trueModel.AdInstallments)
                };
            try
            {
                _dataBase.Query("sp_EC_PaymentRecord_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.EC_PaymentRecord trueModel = model as Model.EC_PaymentRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                    new SqlParameter("@Keyid",trueModel.Keyid),
					new SqlParameter("@PayType",trueModel.PayType),
					new SqlParameter("@Operator",trueModel.Operator),
					new SqlParameter("@MemberId",trueModel.MemberId),
					new SqlParameter("@MemberName",trueModel.MemberName),
					new SqlParameter("@BusinessManagerId",trueModel.BusinessManagerId),
					new SqlParameter("@AccountManagerId",trueModel.AccountManagerId),
					new SqlParameter("@Contact",trueModel.Contact),
					new SqlParameter("@CompanyPhone",trueModel.CompanyPhone),
					new SqlParameter("@Email",trueModel.Email),
					new SqlParameter("@QQ",trueModel.QQ),
					new SqlParameter("@PayMoney",trueModel.PayMoney),
					new SqlParameter("@PayAllMoney",trueModel.PayAllMoney),
					new SqlParameter("@PayStartTime",trueModel.PayStartTime),
					new SqlParameter("@PayEndTime",trueModel.PayEndTime),
					new SqlParameter("@PayRole",trueModel.PayRole),
					new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
					new SqlParameter("@Remark",trueModel.Remark),
					new SqlParameter("@SoftwarePermissions",trueModel.SoftwarePermissions),
					new SqlParameter("@AdForum",trueModel.AdForum),
					new SqlParameter("@AdLocation",trueModel.AdLocation),
					new SqlParameter("@AdSize",trueModel.AdSize),
					new SqlParameter("@AdImg",trueModel.AdImg),
					new SqlParameter("@AdInstallments",trueModel.AdInstallments)
                };
            try
            {
                _dataBase.Query("sp_EC_PaymentRecord_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.EC_PaymentRecord trueModel = model as Model.EC_PaymentRecord;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                    new SqlParameter("@Keyid",trueModel.Keyid)
                };
            try
            {
                _dataBase.Query("sp_EC_PaymentRecord_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_PaymentRecord> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 单个查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.EC_PaymentRecord> SelectAllModel(Infrastructure.Query.Query query)
        {

            throw new NotImplementedException();
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="pagination"></param>
        /// <param name="StartTime"></param>
        /// <param name="EndTime"></param>
        /// <param name="Name"></param>
        /// <param name="MemberType"></param>
        /// <param name="OrderType"></param>
        /// <param name="Province"></param>
        /// <param name="City"></param>
        /// <param name="Country"></param>
        /// <returns></returns>
        public IEnumerable<EC_PaymentRecord> SelectAllModelPage(Infrastructure.Query.Pagination pagination, DateTime? StartTime, DateTime? EndTime, string Name, string MemberType, string OrderType, string Province, string City, string Country)
        {
            try
            {
                string condition = " 1=1 ";
                if (StartTime != null)
                    condition += " And a.PayStartTime >= '" + StartTime + "' ";
                if (EndTime != null)
                    condition += " And a.PayStartTime <= '" + EndTime.Value.AddDays(1) + "' ";
                if (!string.IsNullOrEmpty(Name))
                    condition += " And a.MemberName like '%" + Name + "%' ";
                if (!string.IsNullOrEmpty(MemberType))
                    condition += " And a.PayRole = '" + MemberType + "' ";
                if (!string.IsNullOrEmpty(OrderType))
                    condition += " And a.PayType = '" + OrderType + "' ";
                if (!string.IsNullOrEmpty(Province))
                    condition += " And b.Province = '" + Province + "' ";
                if (!string.IsNullOrEmpty(City))
                    condition += " And b.City = '" + City + "' ";
                if (!string.IsNullOrEmpty(Country))
                    condition += " And b.County = '" + Country + "' ";


                IList<EC_PaymentRecord> result = _dataBase.SelectModelPage<EC_PaymentRecord>(pagination, " a.* ", " dbo.EC_PaymentRecord AS a LEFT JOIN dbo.EC_MemberBasic AS b ON a.MemberId=b.MemberId ", " a.LastUpdateTime desc ", " LastUpdateTime desc ", condition) as IList<EC_PaymentRecord>;//执行查询
                return result;//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="pagination"></param>
        /// <param name="StartTime"></param>
        /// <param name="EndTime"></param>
        /// <param name="Name"></param>
        /// <param name="MemberType"></param>
        /// <param name="OrderType"></param>
        /// <returns></returns>
        public IEnumerable<EC_PaymentRecord> SelectAllModelPage(Infrastructure.Query.Pagination pagination, string StartTime, string EndTime, string OrderType, string selectProvince, string selectCity, string selectCounty)
        {
            IEnumerable<EC_PaymentRecord> list = null;
            string selectTarget = " a.* ";
            string fromSouce = " dbo.EC_PaymentRecord a INNER JOIN EC_MemberBasic b ON a.MemberId=b.MemberId ";

            fromSouce += " where 1=1 and a.PayMoney>0 ";

            if (!string.IsNullOrEmpty(OrderType))
                fromSouce += " And a.PayType = '" + OrderType + "' ";

            if (!string.IsNullOrEmpty(StartTime))
                fromSouce += " And a.PayStartTime >= '" + StartTime + "' ";
            if (!string.IsNullOrEmpty(EndTime))
                fromSouce += " And a.PayStartTime < '" + EndTime + "' ";

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

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

            if (!string.IsNullOrEmpty(selectCounty))
            {
                fromSouce += " and b.County='" + selectCounty + "'";
            }
            list = _dataBase.SelectModelPage<EC_PaymentRecord>(pagination, selectTarget, fromSouce, " a.LastUpdateTime desc ", " LastUpdateTime desc ", string.Empty);
            return list;
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="m_EC_PaymentRecord"></param>
        /// <param name="m_EC_MemberBasic"></param>
        /// <param name="m_Sys_Permissions_UserRoleRelation"></param>
        /// <returns></returns>
        public bool AddModel(EC_PaymentRecord m_EC_PaymentRecord, EC_MemberBasic m_EC_MemberBasic, Sys_Permissions_UserRoleRelation m_Sys_Permissions_UserRoleRelation)
        {
            try
            {
                EC_PaymentRecordDAL dal_EC_PaymentRecordDAL = new EC_PaymentRecordDAL(_dataBase);
                Sys_Permissions_UserRoleRelationDAL dal_Sys_Permissions_UserRoleRelation = new Sys_Permissions_UserRoleRelationDAL(_dataBase);
                EC_MemberBasicDAL dal_EC_MemberBasicDAL = new EC_MemberBasicDAL(_dataBase);
                Sys_Permissions_UserRoleRelation m_Sys_Permissions_UserRoleRelation_del = new Sys_Permissions_UserRoleRelation();
                m_Sys_Permissions_UserRoleRelation_del = dal_Sys_Permissions_UserRoleRelation.SelectModel(m_EC_MemberBasic.MemberId);

                bool result = false;
                using (TransactionScope t_TransactionScope = new TransactionScope())
                {
                    result = this.InserModel(m_EC_PaymentRecord);
                    if (result)
                    {
                        result = dal_EC_MemberBasicDAL.UpdateModel(m_EC_MemberBasic);
                        if (result)
                        {
                            if (m_Sys_Permissions_UserRoleRelation_del != null)
                            {
                                result = dal_Sys_Permissions_UserRoleRelation.DeleteModel(m_Sys_Permissions_UserRoleRelation_del);
                            }
                            if (result)
                            {
                                result = dal_Sys_Permissions_UserRoleRelation.InserModel(m_Sys_Permissions_UserRoleRelation);
                                if (result)
                                {
                                    t_TransactionScope.Complete();
                                }
                            }
                        }
                    }
                }
                return result;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

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

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

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

        /// <summary>
        /// 获取新的订单编号
        /// </summary>
        /// <returns></returns>
        public string GetNewOrderId()
        {
            try
            {
                string OldNum = DateTime.Now.ToString("yyyyMMdd");
                string NewNum = "";

                IList<EC_PaymentRecord> result = _dataBase.SelectModel<EC_PaymentRecord>(" Top(1) * ", " EC_PaymentRecord ", string.Format(" Remark like '%{0}%' order by Keyid DESC ", OldNum)) as IList<EC_PaymentRecord>;//执行查询

                if (result == null || result.Count == 0)
                    NewNum = DateTime.Now.ToString("yyyyMMdd") + "001";
                else
                    NewNum = OldNum + (int.Parse(result[0].Remark.Replace(OldNum, "")) + 1).ToString("000");

                return NewNum;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 更新已付费用，并且修改会员状态
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateModel(Model.EC_PaymentRecord model, CY.Model.Pay.Pay_Request m_Pay_Request, EC_MemberBasic memberBasic)
        {
            try
            {
                Pay_PaymentAccountDAL _pay_PaymentAccount = new Pay_PaymentAccountDAL(_dataBase);
                EC_MemberBasicDAL _EC_MemberBasicDAL = new EC_MemberBasicDAL(_dataBase);
                bool IsSuccess = true;
                using (TransactionScope t_TransactionScope = new TransactionScope())
                {
                    IsSuccess = UpdateModel(model);
                    if (IsSuccess)
                    {
                        IsSuccess = _pay_PaymentAccount.Pay(m_Pay_Request);
                        if (IsSuccess)
                        {
                            if (model.PayType == "个人网店押金" || model.PayType == "印刷厂商注册费" || model.PayType == "印刷厂商续费")
                            {
                                IsSuccess = _EC_MemberBasicDAL.UpdateModel(memberBasic);
                            }

                            if (IsSuccess)
                            {
                                t_TransactionScope.Complete();
                            }
                        }
                    }
                }
                return IsSuccess;
            }
            catch (Exception ex)
            {
                throw ex;
            }

        }

    }
}