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

using System;
using System.Collections.Generic;
using System.Globalization;
using System.IdentityModel.Tokens.Jwt;
using System.Linq;
using System.Linq.Expressions;
using System.Security.Claims;
using System.Threading.Tasks;
using CoreCms.Net.Auth.Policys;
using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.FromBody;
using CoreCms.Net.Model.ViewModels.Basics;
using CoreCms.Net.Model.ViewModels.DTO;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using Microsoft.AspNetCore.Authentication.JwtBearer;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using SqlSugar;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinUserInfoBatchGetRequest.Types;


namespace CoreCms.Net.Services;

/// <summary>
/// 用户表 接口实现
/// </summary>
public class CoreCmsUserServices : BaseServices<CoreCmsUser>, ICoreCmsUserServices
{
    private readonly ICoreCmsUserRepository _dal;
    private readonly ICoreCmsUserBalanceServices _userBalanceServices;
    private readonly ICoreCmsSettingServices _settingServices;
    private readonly ICoreCmsUserPointLogServices _userPointLogServices;
    private readonly ICoreCmsSmsServices _smsServices;
    private readonly ICoreCmsUserWeChatInfoServices _userWeChatInfoServices;
    private readonly ICoreCmsUserGradeServices _userGradeServices;
    private readonly ICoreCmsUserLogServices _userLogServices;

    private readonly IServiceProvider _serviceProvider;

    private readonly IUnitOfWork _unitOfWork;
    private readonly PermissionRequirement _permissionRequirement;
    private readonly IHttpContextAccessor _httpContextAccessor;
    private readonly ICoreCmsBillPaymentsServices _billPaymentsServices;
    private readonly ICoreCmsDistributionGradeRepository _distributionGradeRepository;
    private readonly ICoreCmsDistributionRepository _distributionRepository;

    private readonly ICoreCmsPromotionServices _coreCmsPromotionServices;
    private readonly ICoreCmsCouponServices _coreCmsCouponServices;


    public CoreCmsUserServices(IUnitOfWork unitOfWork
        , ICoreCmsUserRepository dal
        , ICoreCmsUserBalanceServices userBalanceServices
        , ICoreCmsSettingServices settingServices
        , ICoreCmsUserPointLogServices userPointLogServices, ICoreCmsSmsServices smsServices,
        ICoreCmsUserWeChatInfoServices userWeChatInfoServices, ICoreCmsUserGradeServices userGradeServices,
        PermissionRequirement permissionRequirement, IHttpContextAccessor httpContextAccessor,
        ICoreCmsUserLogServices userLogServices, IServiceProvider serviceProvider,
        ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsDistributionGradeRepository distributionGradeRepository, ICoreCmsDistributionRepository distributionRepository, ICoreCmsPromotionServices coreCmsPromotionServices, ICoreCmsCouponServices coreCmsCouponServices)
    {
        _dal = dal;
        BaseDal = dal;
        _unitOfWork = unitOfWork;
        _userBalanceServices = userBalanceServices;
        _settingServices = settingServices;
        _userPointLogServices = userPointLogServices;
        _smsServices = smsServices;
        _userWeChatInfoServices = userWeChatInfoServices;
        _userGradeServices = userGradeServices;
        _permissionRequirement = permissionRequirement;
        _httpContextAccessor = httpContextAccessor;
        _userLogServices = userLogServices;
        _serviceProvider = serviceProvider;
        _billPaymentsServices = billPaymentsServices;
        _distributionGradeRepository = distributionGradeRepository;
        _distributionRepository = distributionRepository;
        _coreCmsPromotionServices = coreCmsPromotionServices;
        _coreCmsCouponServices = coreCmsCouponServices;
    }


    #region 更新余额

    /// <summary>
    /// 更新余额
    /// </summary>
    /// <param name="id"></param>
    /// <param name="money"></param>
    /// <param name="memo"></param>
    /// <returns></returns>
    public async Task<AdminUiCallBack> UpdateBalance(int id, decimal money, string memo)
    {
        var jm = new AdminUiCallBack();

        var model = await _dal.QueryByIdAsync(id);
        if (model == null)
        {
            jm.msg = "不存在此信息";
            return jm;
        }

        var newMoney = model.balance + money;
        var up = await _dal.UpdateAsync(p => new CoreCmsUser() { balance = newMoney }, p => p.id == id);
        if (up)
        {
            var balance = new CoreCmsUserBalance();
            balance.type = (int)GlobalEnumVars.UserBalanceSourceTypes.Admin;
            balance.userId = model.id;
            balance.balance = newMoney;
            balance.createTime = DateTime.Now;
            balance.memo = !string.IsNullOrEmpty(memo) ? memo : UserHelper.GetMemo(balance.type, money);
            balance.money = money;
            balance.sourceId = GlobalEnumVars.UserBalanceSourceTypes.Admin.ToString();

            jm.code = await _userBalanceServices.InsertAsync(balance) > 0 ? 0 : 1;
        }

        jm.msg = jm.code == 0 ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;

        return jm;
    }

    #endregion

    #region 更新积分

    /// <summary>
    /// 更新积分
    /// </summary>
    /// <param name="entity"></param>
    /// <returns></returns>
    public async Task<AdminUiCallBack> UpdatePiont(FMUpdateUserPoint entity)
    {
        var jm = new AdminUiCallBack();

        var model = await _dal.QueryByIdAsync(entity.id);
        if (model == null)
        {
            jm.msg = "不存在此信息";
            return jm;
        }

        var newPoint = model.point + entity.point;
        var up = await _dal.UpdateAsync(p => new CoreCmsUser() { point = newPoint }, p => p.id == entity.id);
        if (up)
        {
            var point = new CoreCmsUserPointLog();
            point.userId = model.id;
            point.type = (int)GlobalEnumVars.UserPointSourceTypes.PointTypeAdminEdit;
            point.num = entity.point;
            point.balance = newPoint;
            point.remarks = entity.memo;
            point.createTime = DateTime.Now;

            jm.code = await _userPointLogServices.InsertAsync(point) > 0 ? 0 : 1;
        }

        jm.msg = jm.code == 0 ? GlobalConstVars.EditSuccess : GlobalConstVars.EditFailure;


        return jm;
    }

    #endregion

    #region 获取用户的积分

    /// <summary>
    /// 获取用户的积分
    /// </summary>
    /// <param name="userId">用户序列</param>
    /// <param name="orderMoney">订单金额</param>
    /// <param name="ids">货品序列</param>
    /// <param name="cartType">购物车类型</param>
    /// <returns></returns>
    public async Task<GetUserPointResult> GetUserPoint(int userId, decimal orderMoney, int[] ids, int cartType)
    {
        var dto = new GetUserPointResult();
        //1是2否
        var allConfigs = await _settingServices.GetConfigDictionaries();

        var pointSwitch = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.PointSwitch)
            .ObjectToInt(); //是否开启积分功能
        if (pointSwitch == 2)
        {
            dto.@switch = 2;
            return dto;
        }

        var user = await _dal.QueryByClauseAsync(p => p.id == userId);
        if (user != null)
        {
            dto.point = user.point;

            var pointExchangeModel = CommonHelper
                .GetConfigDictionary(allConfigs, SystemSettingConstVars.PointExchangeModel)
                .ObjectToInt(); //判断是全局模式还是单品模式
            if (pointExchangeModel == 1)
            {
                if (orderMoney != 0)
                {
                    //计算可用积分//订单积分使用比例
                    var ordersPointProportion = CommonHelper
                        .GetConfigDictionary(allConfigs, SystemSettingConstVars.OrdersPointProportion)
                        .ObjectToDecimal(10);
                    var proportion = Math.Round(ordersPointProportion / 100, 4);
                    //最多可以抵扣的金额
                    var maxPointDeductedMoney = Math.Round(orderMoney * proportion, 4);

                    //订单积分折现比例(多少积分可以折现1块钱)
                    var pointDiscountedProportion = CommonHelper
                        .GetConfigDictionary(allConfigs, SystemSettingConstVars.PointDiscountedProportion)
                        .ObjectToDecimal(100);
                    //计算需要多少积分
                    var needsPoint = maxPointDeductedMoney * pointDiscountedProportion;
                    //确定是否有那么多积分去抵扣比例计算出的能抵扣的钱
                    var availablePoint = needsPoint > user.point ? user.point : needsPoint;
                    dto.availablePoint = Convert.ToInt32(availablePoint);
                    dto.pointExchangeMoney = Math.Round(availablePoint / pointDiscountedProportion, 4);
                    //dto.pointExchangeMoney = dto.availablePoint / pointDiscountedProportion;
                }
            }
            else if (pointExchangeModel == 2)
            {
                using var container = _serviceProvider.CreateScope();

                var cartServices = container.ServiceProvider.GetService<ICoreCmsCartServices>();
                var productsServices = container.ServiceProvider.GetService<ICoreCmsProductsServices>();

                //获取购物车数据
                var cartProducts = await cartServices.QueryListByClauseAsync(p =>
                    p.type == cartType && p.userId == userId && ids.Contains(p.id));
                if (cartProducts.Any())
                {
                    //获取购物车货品序列
                    var cartIds = cartProducts.Select(p => p.productId).ToList();
                    //根据货品序列去找货品
                    var products = await productsServices.QueryListByClauseAsync(p => cartIds.Contains(p.id));
                    if (products.Any())
                    {
                        //可抵扣金额
                        decimal money = 0;
                        //迭代货品，获取到最高可优惠金额，进行累加
                        foreach (var item in products)
                        {
                            var numObj = cartProducts.Find(p => p.productId == item.id);
                            if (numObj != null) money += numObj.nums * item.pointsDeduction;
                        }

                        //计算抵扣这么多金额需要多少积分。
                        //订单积分折现比例(多少积分可以折现1块钱)
                        var pointDiscountedProportion = CommonHelper
                            .GetConfigDictionary(allConfigs, SystemSettingConstVars.PointDiscountedProportion)
                            .ObjectToInt(100);
                        //计算需要多少积分
                        var needsPoint = money * pointDiscountedProportion;

                        //确定是否有那么多积分去抵扣比例计算出的能抵扣的钱
                        var availablePoint = needsPoint > user.point ? 0 : needsPoint;
                        dto.availablePoint = Convert.ToInt32(availablePoint);

                        dto.pointExchangeMoney = user.point > needsPoint ? money : 0;
                    }
                }
            }
        }

        return dto;
    }

    #endregion

    #region 修改用户密码，如果用户之前没有密码，那么就不校验原密码

    /// <summary>
    ///   修改用户密码，如果用户之前没有密码，那么就不校验原密码
    /// </summary>
    public async Task<WebApiCallBack> ChangePassword(int userId, string newPwd, string password = "")
    {
        var jm = new WebApiCallBack();

        //修改密码验证原密码

        var user = await _dal.QueryByIdAsync(userId);
        if (user == null)
        {
            jm.msg = GlobalErrorCodeVars.Code10000;
            return jm;
        }

        if (!string.IsNullOrEmpty(user.passWord))
        {
            if (string.IsNullOrEmpty(password))
            {
                jm.msg = "请输入原密码!";
                return jm;
            }

            if (user.passWord != CommonHelper.EnPassword(password, user.createTime))
            {
                jm.msg = "原密码不正确!";
                return jm;
            }
        }

        if (string.IsNullOrEmpty(newPwd) || newPwd.Length < 6 || newPwd.Length > 16)
        {
            jm.msg = GlobalErrorCodeVars.Code11009;
            return jm;
        }

        var md5Pwd = CommonHelper.EnPassword(newPwd, user.createTime);

        if (!string.IsNullOrEmpty(user.passWord) && user.passWord == md5Pwd)
        {
            jm.msg = "原密码和新密码一样!";
            return jm;
        }

        var bl = await _dal.UpdateAsync(p => new CoreCmsUser() { passWord = md5Pwd, updataTime = DateTime.Now },
            p => p.id == userId);
        jm.status = bl;
        jm.msg = bl ? "密码修改成功!" : "密码修改失败!";
        return jm;
    }

    #endregion

    #region 绑定上级

    /// <summary>
    /// 绑定上级
    /// </summary>
    /// <param name="superiorId"></param>
    /// <param name="userId"></param>
    /// <returns></returns>
    public async Task<WebApiCallBack> SetMyInvite(int superiorId, int userId)
    {
        var jm = new WebApiCallBack() { msg = "填写邀请码失败" };

        jm.otherData = superiorId;

        //自己不能邀请自己
        if (userId == superiorId)
        {
            jm.msg = "自己不能邀请自己";
            return jm;
        }

        var user = await _dal.QueryByIdAsync(userId);
        if (user == null)
        {
            jm.msg = GlobalErrorCodeVars.Code10000;
            return jm;
        }

        if (user.parentId != 0)
        {
            jm.msg = "已有上级邀请，不能绑定其他的邀请";
            return jm;
        }

        var superior = await _dal.QueryByIdAsync(superiorId);
        if (superior == null)
        {
            jm.msg = "不存在这个邀请码";
            return jm;
        }

        if (superior.parentId == user.id)
        {
            jm.msg = "不允许双方互相设置为上级";
            return jm;
        }

        var flag = IsInvited(userId, superiorId);
        if (flag)
        {
            jm.msg = "不允许填写下级的邀请码";
            return jm;
        }

        var bl = await _dal.UpdateAsync(p => new CoreCmsUser() { parentId = superiorId }, p => p.id == userId);

        //增加上级积分
        if (bl)
        {
            var allConfigs = await _settingServices.GetConfigDictionaries();
            var inviterUserIntegral = CommonHelper
                .GetConfigDictionary(allConfigs, SystemSettingConstVars.InviterUserIntegral).ObjectToInt(); //是否开启积分功能
            if (inviterUserIntegral > 0)
                await _userPointLogServices.SetPoint(superiorId, inviterUserIntegral,
                    (int)GlobalEnumVars.UserPointSourceTypes.PointTypeInviterUser, "发展用户：" + userId + "赠送积分");
        }

        jm.status = bl;
        jm.msg = bl ? "填写邀请码成功!" : "填写邀请码失败!";
        return jm;
    }

    #endregion

    #region 获取我的上级邀请人

    /// <summary>
    /// 获取我的上级邀请人
    /// </summary>
    /// <param name="userId"></param>
    /// <returns></returns>
    public async Task<WebApiCallBack> GetMyInvite(int userId)
    {
        var jm = new WebApiCallBack() { status = true };

        var user = await _dal.QueryByIdAsync(userId);
        if (user == null)
        {
            jm.msg = GlobalErrorCodeVars.Code10000;
            return jm;
        }

        if (user.parentId == 0)
        {
            jm.msg = "无上级邀请人";
            return jm;
        }

        var parentUser = await _dal.QueryByClauseAsync(p => p.id == user.parentId);
        if (parentUser != null)
            jm.data = new
            {
                nickname = parentUser.nickName,
                avatar = parentUser.avatarImage,
                mobile = UserHelper.FormatMobile(parentUser.mobile),
                ctime = parentUser.createTime
            };
        return jm;
    }


    /// <summary>
    ///     获取下级推广用户数量
    /// </summary>
    /// <param name="parentId">父类序列</param>
    /// <param name="type">1获取1级，其他为2级</param>
    /// <param name="thisMonth">当月</param>
    /// <returns></returns>
    public async Task<int> QueryChildCountAsync(int parentId, int type = 1, bool thisMonth = false)
    {
        return await _dal.QueryChildCountAsync(parentId, type, thisMonth);
    }

    /// <summary>
    /// 判断userId是否是pid的父节点或者祖父节点,如果是，就返回true，如果不是就返回false
    /// </summary>
    /// <param name="userId"></param>
    /// <param name="pid"></param>
    /// <returns></returns>
    private bool IsInvited(int userId, int pid)
    {
        var info = _dal.QueryById(pid);
        if (info == null || info.parentId == 0)
        {
            return false;
        }
        else
        {
            if (info.parentId == userId)
                return true;
            else
                return IsInvited(userId, info.parentId);
        }
    }

    #endregion

    #region 忘记密码，找回密码

    /// <summary>
    /// 忘记密码，找回密码
    /// </summary>
    /// <param name="userId"></param>
    /// <param name="newPwd"></param>
    /// <param name="cTime"></param>
    /// <returns></returns>
    public async Task<WebApiCallBack> ForgetPassword(string mobile, string code, string newPwd)
    {
        var jm = new WebApiCallBack();

        if (string.IsNullOrEmpty(code))
        {
            jm.msg = GlobalErrorCodeVars.Code10013;
            return jm;
        }

        var smsBool = await _smsServices.Check(mobile, code, "veri");
        if (!smsBool)
        {
            jm.msg = GlobalErrorCodeVars.Code10012;
            return jm;
        }

        var userInfo = await _dal.QueryByClauseAsync(p => p.mobile == mobile);
        if (userInfo == null)
        {
            jm.msg = "没有此手机号码";
            return jm;
        }

        return await EditPwd(userInfo.id, newPwd, userInfo.createTime);
    }

    #endregion

    #region 修改密码

    /// <summary>
    /// 修改密码
    /// </summary>
    /// <param name="userId">用户序列</param>
    /// <param name="newPwd">新密码</param>
    /// <param name="createTime">创建时间</param>
    /// <returns></returns>
    private async Task<WebApiCallBack> EditPwd(int userId, string newPwd, DateTime createTime)
    {
        var jm = new WebApiCallBack();

        if (string.IsNullOrEmpty(newPwd) || newPwd.Length < 6 || newPwd.Length > 16)
        {
            jm.msg = GlobalErrorCodeVars.Code11009;
            return jm;
        }

        var md5Pwd = CommonHelper.EnPassword(newPwd, createTime);
        var up = await _dal.UpdateAsync(p => new CoreCmsUser() { passWord = md5Pwd }, p => p.id == userId);
        if (!up)
        {
            jm.status = false;
            jm.msg = "密码修改失败";
            return jm;
        }

        jm.status = true;
        jm.msg = "密码修改成功";
        return jm;
    }

    #endregion

    #region 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能

    /// <summary>
    /// 手机短信验证码登陆，同时兼有手机短信注册的功能，还有第三方账户绑定的功能
    /// </summary>
    /// <param name="entity">实体数据</param>
    /// <param name="loginType">登录方式(1普通,2短信,3微信小程序拉取手机号)</param>
    /// <param name="platform"></param>
    /// <returns></returns>
    public async Task<WebApiCallBack> SmsLogin(FMWxAccountCreate entity,
        int loginType = (int)GlobalEnumVars.LoginType.WeChatPhoneNumber,
        int platform = (int)GlobalEnumVars.CoreShopSystemCategory.Api)
    {
        var jm = new WebApiCallBack();

        if (string.IsNullOrEmpty(entity.mobile))
        {
            jm.msg = "请输入手机号码";
            return jm;
        }

        if (!CommonHelper.IsMobile(entity.mobile))
        {
            jm.msg = "请输入合法的手机号码";
            return jm;
        }

        //if (loginType == (int)GlobalEnumVars.LoginType.Sms)
        //{
        //    if (string.IsNullOrEmpty(entity.code))
        //    {
        //        jm.msg = "请输入验证码";
        //        return jm;
        //    }

        //    if (!await _smsServices.Check(entity.mobile, entity.code, "login"))
        //    {
        //        jm.msg = "短信验证码错误";
        //        return jm;
        //    }
        //}

        var isReg = false;
        var userInfo = await _dal.QueryByClauseAsync(p => p.mobile == entity.mobile);
        if (userInfo == null)
        {
            isReg = true;
            userInfo = new CoreCmsUser();
            userInfo.userName = entity.mobile;
            userInfo.mobile = entity.mobile;
            userInfo.sex = 3;
            userInfo.isDelete = false;
            userInfo.balance = 0;
            userInfo.point = 0;
            userInfo.userWx = 0;
            userInfo.status = (int)GlobalEnumVars.UserStatus.正常;
            userInfo.createTime = DateTime.Now;

            //没有此用户，创建此用户
            if (!string.IsNullOrEmpty(entity.sessionAuthId))
            {
                var wxUserInfo =
                    await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == entity.sessionAuthId);
                if (wxUserInfo != null)
                {
                    if (string.IsNullOrEmpty(entity.avatar)) entity.avatar = wxUserInfo.avatar;
                    if (string.IsNullOrEmpty(entity.nickname)) entity.nickname = wxUserInfo.nickName;
                    userInfo.sex = wxUserInfo?.gender ?? 3;
                    userInfo.userWx = wxUserInfo?.id ?? 0;
                }
            }

            var allConfigs = await _settingServices.GetConfigDictionaries();

            //如果没有头像和昵称，那么就取系统头像和昵称吧
            if (!string.IsNullOrEmpty(entity.avatar))
            {
                userInfo.avatarImage = entity.avatar;
            }
            else
            {
                var defaultImage =
                    CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShopDefaultImage);
                userInfo.avatarImage = defaultImage;
            }

            userInfo.nickName = !string.IsNullOrEmpty(entity.nickname)
                ? entity.nickname
                : UserHelper.FormatMobile(entity.mobile);

            if (entity.invitecode > 0)
            {
                var pid = UserHelper.GetUserIdByShareCode(entity.invitecode);
                var pInfo = await _dal.QueryByClauseAsync(p => p.id == pid);
                if (pInfo != null)
                {
                    userInfo.parentId = pid;
                }
                //else
                //{
                //    jm.msg = GlobalErrorCodeVars.Code10014;
                //    return jm;
                //}
            }

            if (!string.IsNullOrEmpty(entity.password))
            {
                //判断密码是否符合要求
                if (entity.password.Length < 5 || entity.password.Length > 16)
                {
                    jm.msg = GlobalErrorCodeVars.Code11009;
                    return jm;
                }

                userInfo.passWord = CommonHelper.EnPassword(entity.password, userInfo.createTime);
            }
            else
            {
                userInfo.passWord = "";
            }

            //取默认的用户等级
            var userGradeInfo = await _userGradeServices.QueryByClauseAsync(p => p.isDefault == true);
            userInfo.grade = userGradeInfo?.id ?? 0;

            var userId = await _dal.InsertAsync(userInfo);
            if (userId == 0)
            {
                jm.msg = GlobalErrorCodeVars.Code10000;
                return jm;
            }

            if (userId > 0)
            {
                if (entity.invitecode > 0 && userInfo.parentId > 0)
                {
                    var inviterUserIntegral = CommonHelper
                        .GetConfigDictionary(allConfigs, SystemSettingConstVars.InviterUserIntegral)
                        .ObjectToInt(); //是否开启积分功能
                    if (inviterUserIntegral > 0)
                        await _userPointLogServices.SetPoint(userInfo.parentId, inviterUserIntegral,
                            (int)GlobalEnumVars.UserPointSourceTypes.PointTypeInviterUser, "发展用户：" + userId + "赠送积分");
                }

                //是否默认注册经销商
                var distributionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.DistributionType).ObjectToInt(); //是否默认注册经销商
                if (distributionType == (int)GlobalEnumVars.DistributionConditionType.RegOpen)
                {
                    var iData = new CoreCmsDistribution();
                    iData.userId = userId;

                    var disGradeModel = await _distributionGradeRepository.QueryByClauseAsync(p => p.isDefault == true);
                    iData.gradeId = disGradeModel?.id ?? 0;

                    iData.mobile = entity.mobile;
                    iData.name = userInfo.nickName;
                    iData.weixin = "";
                    iData.qq = "";
                    iData.verifyStatus = (int)GlobalEnumVars.DistributionVerifyStatus.VerifyYes;
                    iData.isDelete = false;
                    iData.createTime = DateTime.Now;

                    await _distributionRepository.InsertAsync(iData);
                }
            }

            userInfo = await _dal.QueryByIdAsync(userId);

            var isAllowGiveCoupon = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.IsAllowGiveCoupon).ObjectToInt(); //是否赠送新人优惠券
            var selectGiveCoupon = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SelectGiveCoupon).ObjectToInt(); //选择注册赠送优惠券
            var giveCouponNumber = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.GiveCouponNumber).ObjectToInt(); //赠送优惠券数量

            if (userId > 0 && isAllowGiveCoupon == 1 && selectGiveCoupon > 0 && giveCouponNumber > 0)
            {
                var promotion = await _coreCmsPromotionServices.QueryByIdAsync(selectGiveCoupon);

                var dt = DateTime.Now;
                if (!promotion.isDel && promotion.isEnable && promotion.startTime < dt && promotion.endTime > dt)
                {
                    await _coreCmsCouponServices.AddData(userId, promotion.id, promotion, giveCouponNumber, "新人注册赠送");
                }
            }
        }
        else
        {
            //如果有这个账号的话，判断一下是不是传密码了，如果传密码了，就是注册，这里就有问题，因为已经注册过
            if (!string.IsNullOrEmpty(entity.password))
            {
                jm.msg = GlobalErrorCodeVars.Code11019;
                return jm;
            }
        }

        //判断是否是小程序里的微信登陆，如果是，就给他绑定微信账号
        if (!string.IsNullOrEmpty(entity.sessionAuthId))
        {
            var updateAsync = await _userWeChatInfoServices.UpdateAsync(p => new CoreCmsUserWeChatInfo() { userId = userInfo.id }, p => p.openid == entity.sessionAuthId);
            if (updateAsync)
            {
                //多个微信可能同时授权一个号码登录。
                //如果已经存在微信用户(A)数据绑定了手机号码。
                //使用新微信(B)登录，同时又授权此手机号码绑定。
                //小程序内微信支付时候，因为登录的微信（B）与拉取手机号码绑定后获取到数据是（A）。
                //会导致微信数据报错（）

                //2023-05-05 屏蔽此代码，是为了让公众号，小程序实现多openid指向同一个账号，但是也存在问题，就是多了之后的解绑问题，应该做个登录设备管理。 

                //await _userWeChatInfoServices.UpdateAsync(p => new CoreCmsUserWeChatInfo() { userId = 0 }, p => p.openid != entity.sessionAuthId && p.userId == userInfo.id);
            }

            //如果是别的未绑定微信用户进来，则反向直接关联。
            var wxUserInfo = await _userWeChatInfoServices.QueryByClauseAsync(p => p.openid == entity.sessionAuthId);
            if (wxUserInfo != null)
            {
                await _dal.UpdateAsync(p => new CoreCmsUser() { userWx = wxUserInfo.id }, p => p.id == userInfo.id);
            }

        }

        if (userInfo.status == (int)GlobalEnumVars.UserStatus.正常)
        {
            jm.status = true;
            jm.msg = "成功";
            jm.otherData = userInfo;

            if (platform == (int)GlobalEnumVars.CoreShopSystemCategory.Api)
            {
                var claims = new List<Claim>
                {
                    new(ClaimTypes.Name, userInfo.nickName),
                    new(JwtRegisteredClaimNames.Jti, userInfo.id.ToString()),
                    new(ClaimTypes.Expiration,
                        DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString())
                };
                //用户标识
                var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
                identity.AddClaims(claims);
                jm.data = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement);
            }
            else
            {
                jm.data = userInfo;
            }

            //录入登录日志
            var log = new CoreCmsUserLog();
            log.userId = userInfo.id;
            log.state = isReg ? (int)GlobalEnumVars.UserLogTypes.注册 : (int)GlobalEnumVars.UserLogTypes.登录;
            log.ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null
                ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString()
                : "127.0.0.1";
            log.createTime = DateTime.Now;
            log.parameters =
                isReg ? GlobalEnumVars.UserLogTypes.注册.ToString() : GlobalEnumVars.UserLogTypes.登录.ToString();
            await _userLogServices.InsertAsync(log);
        }
        else
        {
            jm.msg = GlobalErrorCodeVars.Code11022;
            return jm;
        }

        return jm;
    }

    #endregion

    #region 根据条件查询分页数据

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

    #endregion

    #region 按天统计新会员

    /// <summary>
    /// 按天统计新会员
    /// </summary>
    /// <returns></returns>
    public async Task<List<StatisticsOut>> Statistics(int day)
    {
        return await _dal.Statistics(day);
    }

    #endregion

    #region 按天统计当天下单活跃会员

    /// <summary>
    /// 按天统计当天下单活跃会员
    /// </summary>
    /// <returns></returns>
    public async Task<List<StatisticsOut>> StatisticsOrder(int day)
    {
        return await _dal.StatisticsOrder(day);
    }

    #endregion


    #region 当关闭分销和代理的时候走个人邀请好友分佣

    /// <summary>
    /// 当关闭分销和代理的时候走个人邀请好友分佣
    /// </summary>
    /// <param name="orderId"></param>
    /// <returns></returns>
    public async Task<WebApiCallBack> InviteCommission(string orderId)
    {
        using var container = _serviceProvider.CreateScope();
        var _orderServices = container.ServiceProvider.GetService<ICoreCmsOrderServices>();
        var _billPaymentsServices = container.ServiceProvider.GetService<ICoreCmsBillPaymentsServices>();


        var jm = new WebApiCallBack();
        var allConfigs = await _settingServices.GetConfigDictionaries();
        //分佣类型（1百分比/2固定金额）
        var commissionType = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CommissionType)
            .ObjectToInt(0);
        //一级佣金
        var commissionFirst = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CommissionFirst)
            .ObjectToDecimal(0);
        //二级佣金
        var commissionSecond = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CommissionSecond)
            .ObjectToDecimal(0);
        //三级佣金
        var commissionThird = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.CommissionFirst)
            .ObjectToDecimal(0);
        //是否开启三级分销(1开启，2未开启)
        var openDistribution = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.OpenDistribution)
            .ObjectToInt(0);
        //是否开启代理模块(1开启，2未开启)
        var isOpenAgent = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.IsOpenAgent)
            .ObjectToInt(0);

        //当分销模块和代理模块都关闭的情况下，才去计算邀请好友的操作。
        if (openDistribution != 2 || isOpenAgent != 2) return jm;
        var order = await _orderServices.QueryByClauseAsync(p =>
            p.orderId == orderId && p.status == (int)GlobalEnumVars.OrderStatus.Complete);
        if (order == null)
        {
            jm.msg = "订单查询失败";
            return jm;
        }

        var user = await _dal.QueryByClauseAsync(p => p.id == order.userId, true);

        // 获取付款单，我们只拿付款单的实际金额去计算，不用订单的金额。这样直接不用去计算优惠了，只看用户付了多少。从上面提佣金出来。
        var billPayments = await _billPaymentsServices.QueryByClauseAsync(p =>
            p.sourceId == orderId && p.status == (int)GlobalEnumVars.BillPaymentsStatus.Payed);
        if (billPayments.money <= 0) return jm;
        {
            //1级佣金
            var commissionLevel1 = commissionType == (int)GlobalEnumVars.InviteCommissionType.CommissionTypeFixed
                ? commissionFirst
                : Math.Round(commissionFirst * billPayments.money / 100, 2);
            //2级佣金
            var commissionLevel2 = commissionType == (int)GlobalEnumVars.InviteCommissionType.CommissionTypeFixed
                ? commissionSecond
                : Math.Round(commissionSecond * billPayments.money / 100, 2);
            //3级佣金
            var commissionLevel3 = commissionType == (int)GlobalEnumVars.InviteCommissionType.CommissionTypeFixed
                ? commissionThird
                : Math.Round(commissionThird * billPayments.money / 100, 2);


            //下面存储就不做递归了，三层直接判断了
            if (user.parentId <= 0) return jm;
            var parentLevel1 = await _dal.QueryByClauseAsync(p => p.id == user.parentId, true);
            if (parentLevel1 == null) return jm;
            {
                //钱挪到会员余额里面
                await _userBalanceServices.Change(user.parentId,
                    (int)GlobalEnumVars.UserBalanceSourceTypes.Distribution, commissionLevel1, orderId);
                if (parentLevel1.parentId <= 0) return jm;
                var parentLevel2 = await _dal.QueryByClauseAsync(p => p.id == parentLevel1.parentId, true);
                //钱挪到会员余额里面
                await _userBalanceServices.Change(parentLevel1.parentId,
                    (int)GlobalEnumVars.UserBalanceSourceTypes.Distribution, commissionLevel2, orderId);
                if (parentLevel2.parentId <= 0) return jm;
                {
                    var parentLevel3 = await _dal.QueryByClauseAsync(p => p.id == parentLevel2.parentId, true);
                    if (parentLevel3 != null)
                        //钱挪到会员余额里面
                        await _userBalanceServices.Change(parentLevel2.parentId,
                            (int)GlobalEnumVars.UserBalanceSourceTypes.Distribution, commissionLevel3, orderId);
                }
            }
        }
        return jm;
    }

    #endregion
}