using FlexJobApi.Core; using Furion.DatabaseAccessor; using Furion.DataEncryption; using Furion.FriendlyException; using Mapster; using MediatR; using Microsoft.EntityFrameworkCore; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace FlexJobApi.UserServer.Application { /// /// 密码登录 /// public class PasswordLoginCommandHandler( IRepository userAuthRep, IRepository userInfoRep) : IRequestHandler { private readonly IRepository userAuthRep = userAuthRep; private readonly IRepository userInfoRep = userInfoRep; /// public async Task Handle(PasswordLoginCommand request, CancellationToken cancellationToken) { var user = await userInfoRep.AsQueryable().AsNoTracking() .Where(it => it.UserName == request.UserName && it.Type == request.Type) .Select(it => new { it.Id, it.Avatar, it.Level, it.EnterpriseId, it.Name, it.UserName, it.PhoneNumber, it.Password, it.Status }) .FirstOrDefaultAsync(cancellationToken); if (user == null || !PBKDF2Encryption.Compare(request.Password, user.Password)) throw Oops.Oh(EnumUserErrorCodeType.u1000); if (user.Status == EnumUserStatus.Disabled) throw Oops.Oh(EnumUserErrorCodeType.u1001); var logier = new CurrentLogier { Id = user.Id, Avatar = user.Avatar, Name = user.Name, UserName = user.UserName, PhoneNumber = user.PhoneNumber, Level = user.Level, Type = request.Type, ClientType = request.ClientType, EnterpriseId = user.EnterpriseId, }; JwtUtils.GenerateToken(logier); return new PasswordLoginCommandCallback { AccessToken = logier.AccessToken, RefreshToken = logier.RefreshToken, }; } } }