/***********************************************************************
 *            Project: baifenBinfa
 *        ProjectName: 百分兵法管理系统                               
 *                Web: http://chuanyin.com                     
 *             Author:                                        
 *              Email:                               
 *         CreateTime: 202403/02   
 *        Description: 暂无
 ***********************************************************************/

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Threading.Tasks;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.IServices.baifenbingfa;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.Entities.baifenbingfa.apply;
using CoreCms.Net.Model.Entities.Distribution;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.DTO.Distribution;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.SS.Formula.Functions;
using Org.BouncyCastle.Asn1.Cmp;
using SqlSugar;
using static CoreCms.Net.Configuration.GlobalEnumVars;


namespace CoreCms.Net.Services
{
    /// <summary>
    /// 经销商表 接口实现
    /// </summary>
    public class CoreCmsDistributionServices : BaseServices<CoreCmsDistribution>, ICoreCmsDistributionServices
    {
        private readonly ICoreCmsDistributionRepository _dal;
        private readonly ICoreCmsDistributionOrderRepository _distributionOrderRepository;
        private readonly ICoreCmsDistributionGradeRepository _distributionGradeRepository;
        private readonly ICoreCmsDistributionResultRepository _distributionResultRepository;
        private readonly ICoreCmsDistributionConditionServices _coreCmsDistributionConditionServices;
        private readonly ICoreCmsUserRepository _userRepository;
        private readonly ICoreCmsGoodsRepository _goodsRepository;
        private readonly ICoreCmsUserGradeRepository _userGradeRepository;
        private readonly ICoreCmsOrderRepository _orderRepository;
        private readonly ICoreCmsSettingServices _settingServices;
        private readonly IUnitOfWork _unitOfWork;
        private readonly ICoreCmsUserBalanceServices _userBalanceServices;
        private readonly ICoreCmsUserServices _coreCmsUserServices;
        private readonly IBfbfComAPIService _bfbfComAPIService;
 
     

        public CoreCmsDistributionServices(IBfbfComAPIService bfbfComAPIService, IUnitOfWork unitOfWork, ICoreCmsDistributionRepository dal, ICoreCmsDistributionOrderRepository distributionOrderRepository, ICoreCmsUserRepository userRepository, ICoreCmsGoodsRepository goodsRepository, ICoreCmsUserGradeRepository userGradeRepository, ICoreCmsSettingServices settingServices, ICoreCmsOrderRepository orderRepository, ICoreCmsDistributionGradeRepository distributionGradeRepository, ICoreCmsDistributionResultRepository distributionResultRepository, ICoreCmsDistributionConditionServices coreCmsDistributionConditionServices, ICoreCmsUserBalanceServices userBalanceServices
              , ICoreCmsUserServices coreCmsUserServices) 
        {
            this._dal = dal;
            _distributionOrderRepository = distributionOrderRepository;
            _userRepository = userRepository;
            _goodsRepository = goodsRepository;
            _userGradeRepository = userGradeRepository;
            _settingServices = settingServices;
            _orderRepository = orderRepository;
            _distributionGradeRepository = distributionGradeRepository;
            _distributionResultRepository = distributionResultRepository;
            _coreCmsDistributionConditionServices = coreCmsDistributionConditionServices;
            base.BaseDal = dal;
            _unitOfWork = unitOfWork;
            _userBalanceServices = userBalanceServices;
            _coreCmsUserServices = coreCmsUserServices;


            _bfbfComAPIService = bfbfComAPIService;
          

        }

        #region 获取经销商信息
        /// <summary>
        /// 获取经销商信息
        /// </summary>
        /// <param name="userId">用户id</param>
        /// <param name="checkStatus">是否检查满足条件</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> GetInfo(int userId, bool checkStatus = false)
        {
            var jm = new WebApiCallBack();

            var allConfigs = await _settingServices.GetConfigDictionaries();

            var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (info != null && info.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes)
            {
                //总金额
                info.TotalSettlementAmount = await _distributionOrderRepository.GetSumAsync(
                    p => p.isSettlement != (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementCancel && p.userId == userId,
                    p => p.amount);
                //已结算金额
                info.SettlementAmount = await _distributionOrderRepository.GetSumAsync(
                    p => p.isSettlement == (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementYes && p.userId == userId,
                    p => p.amount);
                //冻结金额
                info.FreezeAmount = await _distributionOrderRepository.GetSumAsync(
                    p => p.isSettlement == (int)GlobalEnumVars.DistributionOrderSettlementStatus.SettlementNo && p.userId == userId,
                    p => p.amount);
                var dt = DateTime.Now;
                //本月第一天时间
                DateTime dtFirst = dt.AddDays(1 - (dt.Day));
                dtFirst = new DateTime(dtFirst.Year, dtFirst.Month, dtFirst.Day, 0, 0, 0);

                //获得某年某月的天数
                int year = dt.Year;
                int month = dt.Month;
                int dayCount = DateTime.DaysInMonth(year, month);
                DateTime dtLast = dtFirst.AddDays(dayCount - 1);
                //本月订单数
                info.CurrentMonthOrder = await _distributionOrderRepository.GetCountAsync(p =>
                    p.createTime >= dtFirst && p.createTime < dtLast && p.userId == userId);

                info.Store = UserHelper.GetShareCodeByUserId(userId).ToString();

                //本日开始结束时间
                var day = dt.Day;
                var dayStart = new DateTime(year, month, day, 0, 0, 0);
                var datEnd = new DateTime(year, month, day, 23, 59, 59);
                //今日收益
                info.TodayFreezeAmount = await _distributionOrderRepository.GetSumAsync(
                    p => p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId,
                    p => p.amount);
                //今日订单
                info.TodayOrder = await _distributionOrderRepository.GetCountAsync(
                    p => p.createTime > dayStart && p.createTime <= datEnd && p.userId == userId);
                //今日会员
                info.TodayUser = await _userRepository.GetCountAsync(p =>
                    p.parentId == userId && p.createTime > dayStart && p.createTime <= datEnd);
            }
            else if (info == null)
            {
                info = new CoreCmsDistribution();
            }
            info.TotalGoods = await _goodsRepository.GetCountAsync(p => p.isMarketable == true);
            if (info.gradeId > 0)
            {
                var userGrade = await _userGradeRepository.QueryByIdAsync(info.gradeId);
                if (userGrade != null)
                {
                    info.GradeName = userGrade.title;
                }
            }
            //检查是否满足条件
            if ((checkStatus == true && info.id == 0) || info.verifyStatus != (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes)
            {
                info.NeedApply = true; //是否需要申请
                info.ConditionMsg = "您的条件已满足。（点击申请）";

                //无需审核,但是需要满足条件
                var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
                if (distributionType > 0 && distributionType == 3)
                {
                    info.NeedApply = false;
                    info.ConditionStatus = false;//条件状态
                    info.ConditionProgress = 0;

                    //满足条件，直接成为会员
                    await CheckCondition(allConfigs, info, userId);
                    if (info.ConditionStatus == true && info.ConditionProgress == 100)
                    {
                        //添加用户
                        var userModel = await _userRepository.QueryByIdAsync(userId);
                        if (userModel != null)
                        {
                            var iData = new CoreCmsDistribution();
                            iData.name = !string.IsNullOrEmpty(userModel.nickName)
                                ? userModel.nickName
                                : userModel.mobile;
                            iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes;
                            iData.verifyTime = DateTime.Now;

                            await AddData(iData, userId);
                            info.ConditionProgress = 100;
                            info.ConditionStatus = true;//条件状态
                        }
                    }
                }
                else
                {
                    //无条件，但是需要审核
                    if (distributionType > 0 && distributionType == 1)
                    {
                        info.NeedApply = true;
                        info.ConditionProgress = 100;
                        info.ConditionStatus = true;//条件状态
                        info.ConditionMsg = "您的条件已满足。（前往申请）";
                    }
                    else if (distributionType > 0 && distributionType == 2)
                    {
                        await CheckCondition(allConfigs, info, userId);
                    }
                }
            }

            jm.msg = "获取成功";
            jm.status = true;
            jm.data = info;

            return jm;
        }
        #endregion

        #region 添加用户信息
        /// <summary>
        /// 添加用户信息
        /// </summary>
        /// <param name="iData"></param>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> AddData(CoreCmsDistribution iData, int userId)
        {
            var jm = new WebApiCallBack();
            if (string.IsNullOrEmpty(iData.mobile))
            {
                jm.msg = "请填写手机号";
                return jm;
            }
            if (CommonHelper.IsMobile(iData.mobile) == false)
            {
                jm.msg = "请填写正确的手机号";
                return jm;
            }
            if (string.IsNullOrEmpty(iData.name))
            {
                jm.msg = "请填写您的姓名";
                return jm;
            }
            iData.userId = userId;
            var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (info != null)
            {
                jm.status = false;
                jm.msg = "您已申请，请勿重复提交";
                return jm;
            }
            //默认等级处理
            if (iData.gradeId == 0)
            {
                var disGradeModel = await _distributionGradeRepository.QueryByClauseAsync(p => p.isDefault == true);
                if (disGradeModel != null)
                {
                    iData.gradeId = disGradeModel.id;
                }
            }

            var allConfigs = await _settingServices.GetConfigDictionaries();
            var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(0);
            if (distributionType == (int)GlobalEnumVars.DistributionConditionType.NoReview)
            {
                iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes;
            }
            else
            {
                iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyWait;
            }

            iData.isDelete = false;
            iData.createTime = DateTime.Now;

            //判断是否存在
            var bl = await _dal.InsertAsync(iData) > 0;
            jm.status = bl;
            jm.msg = bl ? "申请成功" : "申请失败";

            return jm;
        }
        #endregion

        #region 检查是否可以成为经销商
        //检查是否可以成为经销商
        public async Task CheckCondition(Dictionary<string, DictionaryKeyValues> allConfigs, CoreCmsDistribution info, int userId = 0)
        {
            //判断消费
            info.ConditionStatus = false;//条件状态
            info.ConditionProgress = 0;
            //获取成为经销商条件
            //var DistributionType = CommonHelper.GetConfigDictionary(allConfigs, GlobalSettingConstVars.DistributionType).ObjectToInt(0);
            var distributionMoney = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionMoney).ObjectToInt(0);
            //支付金额
            var payed = await _orderRepository.GetSumAsync(
                p => p.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes && p.userId == userId, p => p.payedAmount);
            if (payed < distributionMoney && distributionMoney > 0)
            {
                info.ConditionMsg = "您的消费额度未满足" + distributionMoney + "元无法申请，快去下单吧~";
            }
            else
            {
                info.ConditionProgress = 50;
                //判断是否需要购买商品
                var distributionGoods = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionGoods).ObjectToInt(0);
                if (distributionGoods is > 0 and 1)
                {
                    info.ConditionProgress += 50;
                    info.ConditionStatus = true;//条件状态
                    info.ConditionMsg = "您的条件已满足，马上申请。";
                }
                else
                {
                    //任意商品
                    if (distributionGoods is > 0 and 2)
                    {
                        var orderCount = await _orderRepository.GetCountAsync(p =>
                            p.userId == userId && p.payStatus == (int)GlobalEnumVars.OrderPayStatus.Yes);
                        if (orderCount >= 1)
                        {
                            info.ConditionProgress += 50;
                            info.ConditionStatus = true;//条件状态
                            info.ConditionMsg = "您的条件已满足，马上申请。";
                        }
                        else
                        {
                            info.ConditionMsg = "您的条件未满足，请任意购买一件商品即可成为经销商。";
                        }
                    }
                    else if (distributionGoods is > 0 and 3) //购买指定商品
                    {
                        //判断是否购买指定商品
                        var distributionGoodsId = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionGoodsId).ObjectToInt(0);
                        var orderNum = _orderRepository.GetOrderNum(userId, distributionGoodsId);
                        if (orderNum >= 1)
                        {
                            info.ConditionProgress += 50;
                            info.ConditionStatus = true;//条件状态
                            info.ConditionMsg = "您的条件已满足，马上申请。";
                        }
                        else
                        {
                            var goodsInfo = await _goodsRepository.QueryByIdAsync(distributionGoodsId);
                            if (goodsInfo != null)
                            {
                                info.ConditionMsg = "您的条件未满足，请购买指定的【" + goodsInfo.name + "】商品即可成为经销商。";
                            }
                            else
                            {
                                info.ConditionMsg = "您的条件未满足，请购买指定的商品即可成为经销商。";

                            }
                        }

                    }

                }
            }
        }

        #endregion

        #region 获取我的推广订单

        /// <summary>
        /// 获取我的推广订单
        /// </summary>
        /// <param name="userId"></param>
        /// <param name="page"></param>
        /// <param name="limit"></param>
        /// <param name="typeId">类型</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> GetMyOrderList(int userId, int page, int limit = 10, int typeId = 0)
        {
            var jm = new WebApiCallBack();

            jm.status = true;
            jm.msg = "获取成功";
            var pageList = await _dal.QueryOrderPageAsync(userId, page, limit, typeId);
            jm.data = pageList;
            jm.code = pageList.TotalCount;

            return jm;
        }
        #endregion

        #region 获取店铺信息
        /// <summary>
        /// 获取店铺信息
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> GetStore(int userId)
        {
            var jm = new WebApiCallBack();

            jm.status = true;
            var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (info != null)
            {
                info.TotalGoods = await _goodsRepository.GetCountAsync(p => p.isMarketable == true && p.isDel == false);
                jm.data = new
                {
                    info.createTime,
                    info.name,
                    info.storeBanner,
                    info.storeDesc,
                    info.storeLogo,
                    info.storeName,
                    info.TotalGoods
                };
            }

            return jm;
        }
        #endregion

        #region 获取当前用户返佣设置
        /// <summary>
        /// 获取当前用户返佣设置
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<WebApiCallBack> GetGradeAndCommission(int userId)
        {
            var jm = new WebApiCallBack();
            //百分兵法判断是否是经销商
             if(!await _bfbfComAPIService.IsDictionary(userId))
            {
                jm.msg = "不是经销商的，不返利";
                return jm;
            }

            var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (info == null)
            {
                jm.msg = "不是经销商的，不返利";
                return jm;
            }
            var allConfigs = await _settingServices.GetConfigDictionaries();
            var dto = new DistributionDto();
            if (info.gradeId > 0)
            {
                var res = await _distributionResultRepository.QueryListByClauseAsync(p => p.gradeId == info.gradeId, p => p.id, OrderByType.Asc, true, true);
                if (res != null && res.Any())
                {
                    dto.grade_id = info.gradeId;
                    res.ForEach(p =>
                    {
                        var obj = JObject.Parse(p.parameters);
                        switch (p.code)
                        {
                            case "COMMISSION_1":
                                dto.commission_1 = new Commission()
                                {
                                    type = obj["commissionType"].ObjectToInt(0),
                                    discount = obj["discount"].ObjectToDecimal(0)
                                };
                                break;
                            case "COMMISSION_2":
                                dto.commission_2 = new Commission()
                                {
                                    type = obj["commissionType"].ObjectToInt(0),
                                    discount = obj["discount"].ObjectToDecimal(0)
                                };
                                break;
                            case "COMMISSION_3":
                                dto.commission_3 = new Commission()
                                {
                                    type = obj["commissionType"].ObjectToInt(0),
                                    discount = obj["discount"].ObjectToDecimal(0)
                                };
                                break;
                        }
                    });
                }
                else
                {
                    jm.msg = "未获取到佣金设置，不返利";
                    return jm;
                }
            }
            jm.status = true;
            jm.data = dto;
            jm.msg = "获取成功";

            return jm;
        }
        #endregion

        #region 检查当前用户是否可以升级

        /// <summary>
        /// 检查当前用户是否可以升级
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<AdminUiCallBack> CheckUpdate(int userId)
        {
            var jm = new AdminUiCallBack();

            var info = await _dal.QueryByClauseAsync(p => p.userId == userId);
            if (info is { gradeId: > 0 })
            {
                //找下有没有可以升级的经销商等级（一次只升一级）
                var grade = await _distributionGradeRepository.QueryByClauseAsync(p => p.sortId > info.gradeId && p.isAutoUpGrade == true, p => p.sortId, OrderByType.Asc, true);
                if (grade == null) return jm;
                {
                    var condition = true;//默认满足升级
                    var conditionList = await _coreCmsDistributionConditionServices.QueryListByClauseAsync(p => p.gradeId == grade.id);
                    if (!conditionList.Any())
                    {
                        jm.msg = "未设置条件，无法升级";
                        return jm;
                    }
                    //循环所有条件，判断是否可以升级
                    foreach (var item in conditionList)
                    {
                        var parameters = (JObject)JsonConvert.DeserializeObject(item.parameters);
                        if (parameters == null)
                        {
                            condition = false;
                            break;
                        }

                        //只要购买了商品并且订单完结。
                        if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.GOODS_ALL.ToString(), StringComparison.CurrentCultureIgnoreCase))
                        {
                            if (!parameters.ContainsKey("num"))
                            {
                                condition = false;
                                break;
                            }
                            var num = parameters["num"].ObjectToInt(0);
                            var getCount = await _orderRepository.GetCountAsync(p =>
                                p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED);
                            condition = getCount > num;
                            if (condition == false)
                            {
                                break;
                            }
                        }
                        //购买了指定的商品
                        if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.GOODS_IDS.ToString(), StringComparison.CurrentCultureIgnoreCase))
                        {
                            //goodsId
                            if (!parameters.ContainsKey("goodsId"))
                            {
                                condition = false;
                                break;
                            }
                            var goodsId = parameters["goodsId"].ObjectToInt(0);
                            var getCount = _orderRepository.GetOrderNum(userId, goodsId, (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED);
                            condition = getCount > 0;
                            if (condition == false)
                            {
                                break;
                            }
                        }
                        //个人消费总额(已完成的订单)
                        if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.USER_ORDERS.ToString(), StringComparison.CurrentCultureIgnoreCase))
                        {
                            if (!parameters.ContainsKey("money") || !parameters.ContainsKey("limit_day"))
                            {
                                condition = false;
                                break;
                            }
                            var money = parameters["money"].ObjectToInt(0);
                            var limitDay = parameters["limit_day"].ObjectToInt(0);

                            var startTime = DateTime.Now.AddDays(-limitDay);
                            var endTime = DateTime.Now;

                            var getAmount = await _orderRepository.GetSumAsync(p => p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED && p.paymentTime > startTime && p.paymentTime < endTime, p => p.orderAmount);

                            condition = getAmount > money;

                            if (condition == false)
                            {
                                break;
                            }
                        }
                        //个人订单数量(已完成的订单)
                        if (string.Equals(item.code, GlobalEnumVars.DistributionConditionsCode.USER_ORDERSNUM.ToString(), StringComparison.CurrentCultureIgnoreCase))
                        {

                            if (!parameters.ContainsKey("num") || !parameters.ContainsKey("limit_day"))
                            {
                                condition = false;
                                break;
                            }
                            var num = parameters["num"].ObjectToInt(0);
                            var limitDay = parameters["limit_day"].ObjectToInt(0);

                            var startTime = DateTime.Now.AddDays(-limitDay);
                            var endTime = DateTime.Now;

                            var getCount = await _orderRepository.GetCountAsync(p => p.userId == userId && p.status == (int)GlobalEnumVars.OrderAllStatusType.ALL_COMPLETED && p.paymentTime > startTime && p.paymentTime < endTime);

                            condition = getCount > num;
                            if (condition == false)
                            {
                                break;
                            }
                        }
                    }
                    if (condition)
                    {
                        await _dal.UpdateAsync(p => new CoreCmsDistribution() { gradeId = grade.id }, p => p.userId == userId);
                        jm.msg = "升级成功";
                    }
                    else
                    {
                        jm.msg = "条件暂不满足，无法升级";
                    }
                }
            }
            return jm;
        }
        #endregion


        /// <summary>
        ///     获取代理商排行
        /// </summary>
        /// <param name="pageIndex">当前页面索引</param>
        /// <param name="pageSize">分布大小</param>
        /// <returns></returns>
        public async Task<IPageList<DistributionRankingDTO>> QueryRankingPageAsync(int pageIndex = 1, int pageSize = 20)
        {
            return await _dal.QueryRankingPageAsync(pageIndex, pageSize);
        }


        #region 重写根据条件查询分页数据
        /// <summary>
        ///     重写根据条件查询分页数据
        /// </summary>
        /// <param name="predicate">判断集合</param>
        /// <param name="orderByType">排序方式</param>
        /// <param name="pageIndex">当前页面索引</param>
        /// <param name="pageSize">分布大小</param>
        /// <param name="orderByExpression"></param>
        /// <param name="blUseNoLock">是否使用WITH(NOLOCK)</param>
        /// <returns></returns>
        public async Task<IPageList<CoreCmsDistribution>> QueryPageAsync(Expression<Func<CoreCmsDistribution, bool>> predicate,
            Expression<Func<CoreCmsDistribution, object>> orderByExpression, OrderByType orderByType, int pageIndex = 1,
            int pageSize = 20, bool blUseNoLock = false)
        {
            return await _dal.QueryPageAsync(predicate, orderByExpression, orderByType, pageIndex, pageSize, blUseNoLock);
        }


        #endregion

        public async Task<(decimal,DateTime?, DateTime?)> AchievementTotal(int UserId)
        {
         var StartTime=   await  _unitOfWork.GetDbClient()
                .Queryable<DistributionAchievement>()
                .Where(x=>x.userID == UserId&&x.isdelete==false)
                .Select(x=>x.endTime)
                .OrderByDescending(x=>x)
                .FirstAsync();
            if (StartTime == null)
                ///最多统计两年内的业绩
                StartTime = DateTime.Now.AddYears(-2);
            else
                StartTime= StartTime.Value.AddSeconds(1);
            var endTime = DateTime.Now;
            //payStatus = (int)GlobalEnumVars.OrderPayStatus.Refunded,
            //        status = (int)GlobalEnumVars.OrderStatus.Complete
            //var result = await _balanceServices.Change(item.userId, (int)GlobalEnumVars.UserBalanceSourceTypes.Distribution,
            //       item.amount, item.orderId);
            var total=  await _unitOfWork.GetDbClient().Queryable<CoreCmsOrder>().Where(x => x.status == (int)GlobalEnumVars.OrderStatus.Complete
            && (x.payStatus != (int)GlobalEnumVars.OrderPayStatus.No || x.payStatus != (int)GlobalEnumVars.OrderPayStatus.Refunded)
            && x.isdel == false
            && x.updateTime > StartTime
            && x.updateTime < endTime
            ).SumAsync(x => x.orderAmount);

            var orderToler= await _unitOfWork.GetDbClient().Queryable<DistributionAchievementOrder>().Where(x => x.userID == UserId            
              && x.createTime > StartTime
              && x.createTime < endTime).SumAsync(x => x.achievementTotal);
            total = total + orderToler;
            if (total==0)
                return (total,null, null);
            else
            return (total, StartTime, endTime);
        }

        public async Task<decimal> AchievementBonus(decimal AttributeTotal)
        {
          
            var allConfigs =  await _settingServices.GetConfigDictionaries();
            var key = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DictionaryAchievementSet).ObjectToInt(0);
            return AttributeTotal *(decimal)key / 100;
        }

        public async Task<bool> SettledAchievement(int UserId)
        {
            //非供应商，停止
            var da = await _dal.GetCountAsync(x => x.userId == UserId && x.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes, isDataCache: true, cacheTimes: 1);
            if (da == 0)
                return true;
            var att = await AchievementTotal(UserId);
            if(att.Item1>0)
            {
                DistributionAchievement oder = new DistributionAchievement
                {
                    achievementTotals = att.Item1,
                    achievementBonus = await AchievementBonus(att.Item1),
                     createBy="系统结算",
                      createTime=DateTime.Now,
                       startTime=att.Item2,
                    endTime = att.Item3,
                     userID = UserId

                };
                //建立结算单
             var id=    await _unitOfWork.GetDbClient().Insertable(oder).ExecuteCommandIdentityIntoEntityAsync();
              var a=  await _userBalanceServices.Change(UserId, (int )UserBalanceSourceTypes.DistributionAchievement,
                    oder.achievementBonus,id.ToString());
                if(a.code!=0)
                {
                    NLogUtil.WriteAll(NLog.LogLevel.Fatal, LogType.DataBase, "经销商业绩提成写入余额失败", a.msg);
                    return false;
                }
                return true;
            }
            return true;
        }



        public async Task<bool> SettledAllAchievement()
        {
           

            //查询用户  
            var coreCmsUsers = await _userRepository.QueryListByClauseAsync(x => x.isDelete == false && x.status == 1);

            foreach(var coreCmsUser in coreCmsUsers)
            {  //非供应商，停止
                var da = await _dal.GetCountAsync(x => x.userId == coreCmsUser.id && x.verifyStatus == (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes, isDataCache: true, cacheTimes: 1);
                if (da == 0)
                    continue;

                //查询是否已经计算过了
                DateTime StartTime = new DateTime(DateTime.Now.AddYears(-1).Year, 1, 1);
                DateTime endTime = new DateTime(DateTime.Now.Year, 1, 1).AddDays(-1);
                var total = _unitOfWork.GetDbClient().Queryable<DistributionAchievement>().Where(x =>
          x.isdelete == false
          && x.userID == coreCmsUser.id
          && x.startTime == StartTime
          && x.endTime == endTime
          ).ToList();
                if (total != null && total.Count > 0)
                    continue;

                var att = await AchievementTotalAll(coreCmsUser.id);
                if (att.Item1 > 0)
                {
                    DistributionAchievement oder = new DistributionAchievement
                    {
                        achievementTotals = att.Item1,
                        achievementBonus = await AchievementBonuscount(att.Item1),
                        createBy = "系统结算",
                        createTime = DateTime.Now,
                        startTime = att.Item2,
                        endTime = att.Item3,
                        userID = coreCmsUser.id

                    };
                    //建立结算单
                    var id = await _unitOfWork.GetDbClient().Insertable(oder).ExecuteCommandIdentityIntoEntityAsync();
                    if (oder.achievementBonus > 0)
                    {
                        var jm = await _coreCmsUserServices.UpdateBalance(coreCmsUser.id, oder.achievementBonus, "经销商推广费用写入余额");
                        if (jm.code != 0)
                        {
                            NLogUtil.WriteAll(NLog.LogLevel.Fatal, LogType.DataBase, "经销商推广费用写入余额失败", jm.msg);
                            return false;
                        }
                    }
                   
                    return true;
                }

            }


          
            return true;
        }




        public async Task<(decimal, DateTime?, DateTime?)> AchievementTotalAll(int UserId)
        {


            DateTime StartTime = new DateTime(DateTime.Now.AddYears(-1).Year, 1, 1);
            DateTime endTime = new DateTime(DateTime.Now.Year, 1, 1);


            var total = await _unitOfWork.GetDbClient().Queryable<CoreCmsOrder>().Where(x => x.status == (int)GlobalEnumVars.OrderStatus.Complete
            && (x.payStatus != (int)GlobalEnumVars.OrderPayStatus.No || x.payStatus != (int)GlobalEnumVars.OrderPayStatus.Refunded)
            && x.isdel == false
            && x.userId == UserId
            && x.updateTime > StartTime
            && x.updateTime < endTime
            ).SumAsync(x => x.orderAmount);

            return (total, StartTime, endTime.AddDays(-1));
        }


        public async Task<decimal> AchievementBonuscount(decimal AttributeTotal)
        {

            var allConfigs = await _settingServices.GetConfigDictionaries();
            var tuiGuangFeiYong = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DictionaryTuiGuangFeiYong).ObjectToInt(0);
            var yeJiMenKan = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DictionaryYeJiMenKan).ObjectToInt(0);
            if(AttributeTotal <= yeJiMenKan)
            {
                return 0;
            }
            return (AttributeTotal - (decimal)yeJiMenKan) * (decimal)tuiGuangFeiYong / 100;
        }


        public async Task<bool> CreateDistributionAchievementOrder(CreateDAOrderInParam Parma)
        {
           //非供应商，停止
         var da=  await  _dal.GetCountAsync(x=>x.userId== Parma.UserID && x.verifyStatus== (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes,isDataCache:true,cacheTimes:1);
            if (da == 0)
                return true;
            DistributionAchievementOrder oder = new DistributionAchievementOrder
            {
                achievementTotal = Parma.Money,
                createBy = "经销商业绩写入",
                createTime = DateTime.Now,
                orderId = Parma.OderId,
                userID = Parma.UserID,
                 orderType=(int ) Parma.SourceTypes
                



            };

          return   await  _unitOfWork.GetDbClient().Updateable(oder).ExecuteCommandAsync()>0;
             
        }

        /// <summary>
        ///     获取经销商推广费
        /// </summary>
        /// <returns></returns>
        public  List<DistributionRankingDTO> QueryAchievement(int UserId)
        {
            var totals = _unitOfWork.GetDbClient().Queryable<DistributionAchievement>().Where(x =>
        x.isdelete == false
        && x.userID == UserId
        ).OrderByDescending(x=>x.startTime).ToList();

            var distributionRankingDTOs = new List<DistributionRankingDTO>();
            foreach(var distributionAchievement in totals)
            {
                var distributionRankingDTO = new DistributionRankingDTO();
                distributionRankingDTO.startTime = distributionAchievement.startTime.HasValue ? distributionAchievement.startTime.Value.ToString("yyyy-MM-dd") : "";
                distributionRankingDTO.endTime = distributionAchievement.endTime.HasValue ? distributionAchievement.endTime.Value.ToString("yyyy-MM-dd") : "";
                distributionRankingDTO.achievementTotals = distributionAchievement.achievementTotals.ToString("F2");
                distributionRankingDTO.achievementBonus = distributionAchievement.achievementBonus.ToString("F2");
                distributionRankingDTOs.Add(distributionRankingDTO);
            }

            return distributionRankingDTOs;
        }
    }
}