734 lines
29 KiB
C#
734 lines
29 KiB
C#
/***********************************************************************
|
||
* Project: CoreCms
|
||
* ProjectName: 核心内容管理系统
|
||
* Web: https://www.corecms.net
|
||
* Author: 大灰灰
|
||
* Email: jianweie@163.com
|
||
* CreateTime: 2021/1/31 21:45:10
|
||
* Description: 暂无
|
||
***********************************************************************/
|
||
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.IdentityModel.Tokens.Jwt;
|
||
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.UI;
|
||
using CoreCms.Net.Model.ViewModels.DTO;
|
||
using CoreCms.Net.Utility.Extensions;
|
||
using CoreCms.Net.Utility.Helper;
|
||
using Microsoft.AspNetCore.Authentication.JwtBearer;
|
||
using Microsoft.AspNetCore.Http;
|
||
using SqlSugar;
|
||
|
||
|
||
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 IUnitOfWork _unitOfWork;
|
||
private readonly PermissionRequirement _permissionRequirement;
|
||
private readonly IHttpContextAccessor _httpContextAccessor;
|
||
|
||
|
||
public CoreCmsUserServices(IUnitOfWork unitOfWork
|
||
, ICoreCmsUserRepository dal
|
||
, ICoreCmsUserBalanceServices userBalanceServices
|
||
, ICoreCmsSettingServices settingServices
|
||
, ICoreCmsUserPointLogServices userPointLogServices, ICoreCmsSmsServices smsServices, ICoreCmsUserWeChatInfoServices userWeChatInfoServices, ICoreCmsUserGradeServices userGradeServices, PermissionRequirement permissionRequirement, IHttpContextAccessor httpContextAccessor, ICoreCmsUserLogServices userLogServices)
|
||
{
|
||
this._dal = dal;
|
||
base.BaseDal = dal;
|
||
_unitOfWork = unitOfWork;
|
||
_userBalanceServices = userBalanceServices;
|
||
_settingServices = settingServices;
|
||
_userPointLogServices = userPointLogServices;
|
||
_smsServices = smsServices;
|
||
_userWeChatInfoServices = userWeChatInfoServices;
|
||
_userGradeServices = userGradeServices;
|
||
_permissionRequirement = permissionRequirement;
|
||
_httpContextAccessor = httpContextAccessor;
|
||
_userLogServices = userLogServices;
|
||
}
|
||
|
||
|
||
#region 更新余额
|
||
|
||
/// <summary>
|
||
/// 更新余额
|
||
/// </summary>
|
||
/// <param name="id"></param>
|
||
/// <param name="money"></param>
|
||
/// <returns></returns>
|
||
public async Task<AdminUiCallBack> UpdateBalance(int id, decimal money)
|
||
{
|
||
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 = 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>
|
||
/// <returns></returns>
|
||
public async Task<GetUserPointResult> GetUserPoint(int userId, decimal orderMoney)
|
||
{
|
||
GetUserPointResult 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;
|
||
if (orderMoney != 0)
|
||
{
|
||
//计算可用积分
|
||
var ordersPointProportion = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.OrdersPointProportion).ObjectToInt(10);//订单积分使用比例
|
||
//最多可以抵扣的金额
|
||
var maxPointDeductedMoney = Math.Round((orderMoney * ordersPointProportion) / 100, 2);
|
||
//订单积分折现比例(多少积分可以折现1块钱)
|
||
var pointDiscountedProportion = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.PointDiscountedProportion).ObjectToInt(100);
|
||
//计算需要多少积分
|
||
var needsPoint = maxPointDeductedMoney * pointDiscountedProportion;
|
||
//确定是否有那么多积分去抵扣比例计算出的能抵扣的钱
|
||
dto.availablePoint = Convert.ToInt32(needsPoint > user.point ? user.point : needsPoint);
|
||
dto.pointExchangeMoney = dto.availablePoint / pointDiscountedProportion;
|
||
}
|
||
}
|
||
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);
|
||
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 = 1)
|
||
{
|
||
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;
|
||
userInfo.credit_score = 5;
|
||
userInfo.dove_count = 0;
|
||
userInfo.play_level = 4;
|
||
userInfo.skills_level = 4;
|
||
//没有此用户，创建此用户
|
||
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;
|
||
}
|
||
}
|
||
//如果没有头像和昵称，那么就取系统头像和昵称吧
|
||
if (!string.IsNullOrEmpty(entity.avatar))
|
||
{
|
||
userInfo.avatarImage = entity.avatar;
|
||
}
|
||
else
|
||
{
|
||
var allConfigs = await _settingServices.GetConfigDictionaries();
|
||
var defaultImage = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.UserDefaultImage);
|
||
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;
|
||
}
|
||
userInfo = await _dal.QueryByIdAsync(userId);
|
||
}
|
||
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,
|
||
mobile = userInfo.mobile,
|
||
nickName = userInfo.nickName,
|
||
avatar = userInfo.avatarImage,
|
||
gender = userInfo.sex
|
||
}, p => p.openid == entity.sessionAuthId);
|
||
if (updateAsync)
|
||
{
|
||
//多个微信可能同时授权一个号码登录。
|
||
//如果已经存在微信用户(A)数据绑定了手机号码。
|
||
//使用新微信(B)登录，同时又授权此手机号码绑定。
|
||
//小程序内微信支付时候，因为登录的微信（B）与拉取手机号码绑定后获取到数据是（A）。
|
||
//会导致微信数据报错（）
|
||
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.正常)
|
||
{
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, userInfo.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, userInfo.id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString()) };
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.msg = isReg ? "注册成功" : "登录成功";
|
||
jm.data = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement);
|
||
//录入登录日志
|
||
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;
|
||
}
|
||
|
||
|
||
public async Task<WebApiCallBack> AnonymousLogin(int user_id)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
var userInfo = await _dal.QueryByClauseAsync(p => p.id == user_id);
|
||
if (userInfo != null)
|
||
{
|
||
|
||
if (userInfo.status == (int)GlobalEnumVars.UserStatus.正常)
|
||
{
|
||
var claims = new List<Claim> {
|
||
new Claim(ClaimTypes.Name, userInfo.nickName),
|
||
new Claim(JwtRegisteredClaimNames.Jti, userInfo.id.ToString()),
|
||
new Claim(ClaimTypes.Expiration, DateTime.Now.AddSeconds(_permissionRequirement.Expiration.TotalSeconds).ToString()) };
|
||
//用户标识
|
||
var identity = new ClaimsIdentity(JwtBearerDefaults.AuthenticationScheme);
|
||
identity.AddClaims(claims);
|
||
jm.status = true;
|
||
jm.msg = "登录成功";
|
||
jm.data = JwtToken.BuildJwtToken(claims.ToArray(), _permissionRequirement);
|
||
//录入登录日志
|
||
var log = new CoreCmsUserLog();
|
||
log.userId = userInfo.id;
|
||
log.state = (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 = GlobalEnumVars.UserLogTypes.登录.ToString();
|
||
await _userLogServices.InsertAsync(log);
|
||
}
|
||
else
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11022;
|
||
return jm;
|
||
}
|
||
|
||
}
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
|
||
/// <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);
|
||
}
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 按天统计新会员
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<List<StatisticsOut>> Statistics(int day)
|
||
{
|
||
return await _dal.Statistics(day);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 按天统计当天下单活跃会员
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public async Task<List<StatisticsOut>> StatisticsOrder(int day)
|
||
{
|
||
|
||
return await _dal.StatisticsOrder(day);
|
||
}
|
||
|
||
|
||
}
|
||
}
|