686 lines
23 KiB
C#
686 lines
23 KiB
C#
using IRaCIS.Application.Contracts;
|
|
using IRaCIS.Core.Domain.Share;
|
|
using IRaCIS.Core.Infrastructure;
|
|
using System.Text.RegularExpressions;
|
|
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Panda.DynamicWebApi.Attributes;
|
|
using Microsoft.AspNetCore.Authorization;
|
|
using Microsoft.Extensions.Options;
|
|
using Microsoft.Extensions.Caching.Memory;
|
|
using Microsoft.Extensions.Logging;
|
|
using static IRaCIS.Core.Domain.Share.StaticData;
|
|
|
|
namespace IRaCIS.Application.Services
|
|
{
|
|
[ApiExplorerSettings(GroupName = "Management")]
|
|
public class UserService : BaseService, IUserService
|
|
{
|
|
private readonly IRepository<User> _userRepository;
|
|
private readonly IMailVerificationService _mailVerificationService;
|
|
private readonly IRepository<VerificationCode> _verificationCodeRepository;
|
|
private readonly IRepository<Doctor> _doctorRepository;
|
|
private readonly IRepository<TrialUser> _userTrialRepository;
|
|
|
|
private readonly IMemoryCache _cache;
|
|
|
|
private ILogger<UserService> _logger;
|
|
|
|
private readonly IOptionsMonitor<ServiceVerifyConfigOption> _verifyConfig;
|
|
public UserService(IRepository<User> userRepository,
|
|
|
|
IMailVerificationService mailVerificationService,
|
|
IRepository<VerificationCode> verificationCodeRepository,
|
|
IRepository<Doctor> doctorRepository,
|
|
IMemoryCache cache,
|
|
IRepository<TrialUser> userTrialRepository,
|
|
IOptionsMonitor<ServiceVerifyConfigOption> verifyConfig,
|
|
ILogger<UserService> logger
|
|
|
|
)
|
|
{
|
|
_logger=logger;
|
|
_verifyConfig = verifyConfig;
|
|
_cache = cache;
|
|
_userRepository = userRepository;
|
|
_mailVerificationService = mailVerificationService;
|
|
_verificationCodeRepository = verificationCodeRepository;
|
|
_doctorRepository = doctorRepository;
|
|
_userTrialRepository = userTrialRepository;
|
|
}
|
|
|
|
|
|
|
|
private async Task VerifyUserNameAsync(Guid? userId, string userName)
|
|
{
|
|
if (await _userRepository.WhereIf(userId != null, t => t.Id != userId).AnyAsync(t => t.UserName == userName))
|
|
{
|
|
//---用户名已经存在。
|
|
throw new BusinessValidationFailedException(_localizer["User_UsernameExist"]);
|
|
}
|
|
}
|
|
|
|
private async Task VerifyUserPhoneAsync(Guid? userId, Guid userTypeId, string phone)
|
|
{
|
|
if (await _userRepository.WhereIf(userId != null, t => t.Id != userId).AnyAsync(t => (t.Phone == phone && t.UserTypeId == userTypeId)))
|
|
{
|
|
//---该用户类型中已存在具有相同的电话的用户。
|
|
throw new BusinessValidationFailedException(_localizer["User_PhoneDup"]);
|
|
}
|
|
}
|
|
|
|
|
|
private async Task VerifyUserEmailAsync(Guid? userId, Guid userTypeId, string email)
|
|
{
|
|
if (await _userRepository.WhereIf(userId != null, t => t.Id != userId).AnyAsync(t => (t.EMail == email && t.UserTypeId == userTypeId)))
|
|
{
|
|
//---该用户类型中已存在具有相同邮箱的用户。
|
|
throw new BusinessValidationFailedException(_localizer["User_EmailDup"]);
|
|
}
|
|
}
|
|
|
|
private async Task VerifyUserPwdAsync(Guid userId, string newPwd, string? oldPwd = null)
|
|
{
|
|
//var dbUser = (await _userRepository.FirstOrDefaultAsync(t => t.Id == userId)).IfNullThrowException();
|
|
|
|
if (_verifyConfig.CurrentValue.OpenUserComplexPassword)
|
|
{
|
|
|
|
if (oldPwd != null && oldPwd == newPwd)
|
|
{
|
|
//---新密码与旧密码相同。
|
|
throw new BusinessValidationFailedException(_localizer["User_NewOldPwdSame"]);
|
|
}
|
|
|
|
|
|
var dbUser = (await _userRepository.Where(t => t.Id == userId).FirstOrDefaultAsync()).IfNullThrowException();
|
|
|
|
if (oldPwd != null && dbUser.Password != oldPwd)
|
|
{
|
|
//---旧密码验证失败。
|
|
throw new BusinessValidationFailedException(_localizer["User_OldPwdInvalid"]);
|
|
}
|
|
|
|
if (dbUser.Password == newPwd)
|
|
{
|
|
//---新密码与旧密码相同。
|
|
throw new BusinessValidationFailedException(_localizer["User_NewOldPwdSame"]);
|
|
}
|
|
|
|
|
|
}
|
|
|
|
await Task.CompletedTask;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
[HttpGet("{email}")]
|
|
public async Task<IResponseOutput> SendVerificationCode(string email)
|
|
{
|
|
|
|
//检查手机或者邮箱是否有效
|
|
if (!Regex.IsMatch(email, @"^[a-zA-Z0-9_-]+@[a-zA-Z0-9_-]+(\.[a-zA-Z0-9_-]+)+$"))
|
|
{
|
|
//---Please input a legal email
|
|
return ResponseOutput.NotOk(_localizer["User_LegalEmail"]);
|
|
}
|
|
|
|
|
|
//验证码 6位
|
|
int verificationCode = new Random().Next(100000, 1000000);
|
|
|
|
await _mailVerificationService.SendMailEditEmail(_userInfo.Id, _userInfo.RealName, email, verificationCode);
|
|
|
|
return ResponseOutput.Ok();
|
|
|
|
}
|
|
|
|
|
|
[HttpPut("{newEmail}/{verificationCode}")]
|
|
[UnitOfWork]
|
|
public async Task<IResponseOutput> SetNewEmail(string newEmail, string verificationCode)
|
|
{
|
|
|
|
|
|
var verificationRecord = await _verificationCodeRepository
|
|
.FirstOrDefaultAsync(t => t.UserId == _userInfo.Id && t.Code == verificationCode && t.CodeType == 0);
|
|
|
|
//检查数据库是否存在该验证码
|
|
if (verificationRecord == null)
|
|
{
|
|
|
|
//---验证码错误。
|
|
return ResponseOutput.NotOk(_localizer["User_VerificationCodeError"]);
|
|
|
|
}
|
|
else
|
|
{
|
|
//检查验证码是否失效
|
|
if (verificationRecord.ExpirationTime < DateTime.Now)
|
|
{
|
|
//---验证码已经过期。
|
|
return ResponseOutput.NotOk(_localizer["User_VerificationCodeExpired"]);
|
|
|
|
}
|
|
else //验证码正确 并且 没有超时
|
|
{
|
|
|
|
|
|
await VerifyUserEmailAsync(_userInfo.Id, _userInfo.UserTypeId, newEmail);
|
|
|
|
|
|
await _userRepository.UpdatePartialNowNoQueryAsync(_userInfo.Id, u => new User()
|
|
{
|
|
EMail = newEmail
|
|
});
|
|
|
|
//删除验证码历史记录
|
|
await _verificationCodeRepository.BatchDeleteNoTrackingAsync(t => t.UserId == _userInfo.Id && t.CodeType == 0);
|
|
|
|
|
|
return ResponseOutput.Ok();
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
[HttpPut("{newPhone}")]
|
|
public async Task<IResponseOutput> SetNewPhone(string newPhone)
|
|
{
|
|
|
|
await VerifyUserPhoneAsync(_userInfo.Id, _userInfo.UserTypeId, newPhone);
|
|
|
|
await _userRepository.UpdatePartialNowNoQueryAsync(_userInfo.Id, u => new User()
|
|
{
|
|
Phone = newPhone
|
|
});
|
|
|
|
return ResponseOutput.Ok();
|
|
}
|
|
|
|
|
|
[HttpPut("{newUserName}")]
|
|
public async Task<IResponseOutput> SetNewUserName(string newUserName)
|
|
{
|
|
await VerifyUserNameAsync(_userInfo.Id, newUserName);
|
|
|
|
|
|
await _userRepository.UpdatePartialNowNoQueryAsync(_userInfo.Id, u => new User()
|
|
{
|
|
UserName = newUserName
|
|
});
|
|
|
|
return ResponseOutput.Ok();
|
|
}
|
|
|
|
///// <summary>
|
|
/////
|
|
///// </summary>
|
|
///// <param name="userId"></param>
|
|
///// <returns></returns>
|
|
//[HttpGet]
|
|
//public async Task<IResponseOutput> VerifyCanInitSetUserNameAndPwd(Guid userId)
|
|
//{
|
|
// return ResponseOutput.Ok(await _userRepository.AnyAsync(t => t.Id == userId && t.EmailToken == _userInfo.UserToken && t.IsFirstAdd));
|
|
//}
|
|
|
|
|
|
[HttpGet]
|
|
public async Task<IResponseOutput> InitSetUserNameAndPwd(Guid userId, string newUserName, string newPWd)
|
|
{
|
|
|
|
|
|
|
|
|
|
await VerifyUserPwdAsync(userId, newPWd);
|
|
|
|
await VerifyUserNameAsync(userId, newUserName);
|
|
|
|
await _userRepository.UpdatePartialFromQueryAsync(userId, u => new User()
|
|
{
|
|
UserName = newUserName,
|
|
|
|
Password = newPWd,
|
|
|
|
IsFirstAdd = false,
|
|
|
|
EmailToken = String.Empty
|
|
|
|
}, true);
|
|
|
|
return ResponseOutput.Ok();
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userId"></param>
|
|
/// <returns></returns>
|
|
[HttpGet("{userId:guid}")]
|
|
[UnitOfWork]
|
|
public async Task<IResponseOutput> ResetPassword(Guid userId)
|
|
{
|
|
|
|
var pwd = AppSettings.DefaultPassword;
|
|
|
|
if (_hostEnvironment.EnvironmentName != "Development")
|
|
{
|
|
pwd = string.Empty + new Random().Next(100000, 1000000)+ new Random().Next(100000, 1000000);
|
|
|
|
}
|
|
|
|
try
|
|
{
|
|
await _mailVerificationService.AdminResetPwdSendEmailAsync(userId, pwd);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
throw new BusinessValidationFailedException(_localizer["User_CreateFailed"]);
|
|
}
|
|
|
|
|
|
await _userRepository.UpdatePartialNowNoQueryAsync(userId, u => new User()
|
|
{
|
|
Password = MD5Helper.Md5(pwd),
|
|
IsFirstAdd = true
|
|
});
|
|
|
|
return ResponseOutput.Ok();
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="email"></param>
|
|
/// <returns></returns>
|
|
[AllowAnonymous]
|
|
[HttpGet("{email}")]
|
|
public async Task<IResponseOutput> AnonymousSendVerificationCode(string email)
|
|
{
|
|
|
|
//检查手机或者邮箱是否有效
|
|
if (!Regex.IsMatch(email, @"^[a-zA-Z0-9_-]+@[a-zA-Z0-9_-]+(\.[a-zA-Z0-9_-]+)+$"))
|
|
{
|
|
|
|
return ResponseOutput.NotOk(_localizer["User_InvalidEmail"]);
|
|
|
|
}
|
|
|
|
////查找改邮箱或者手机的用户
|
|
var exist = await _userRepository.AnyAsync(t => t.EMail == email);
|
|
|
|
if (!exist)
|
|
{
|
|
return ResponseOutput.NotOk(_localizer["User_EmailError"]);
|
|
|
|
}
|
|
|
|
|
|
//验证码 6位
|
|
int verificationCode = new Random().Next(100000, 1000000);
|
|
|
|
await _mailVerificationService.AnolymousSendEmailForResetAccount(email, verificationCode);
|
|
|
|
return ResponseOutput.Ok();
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="email"></param>
|
|
/// <param name="verifyCode"></param>
|
|
/// <returns></returns>
|
|
/// <exception cref="BusinessValidationFailedException"></exception>
|
|
[AllowAnonymous]
|
|
[HttpGet("{email}/{verifyCode}")]
|
|
public async Task<List<UserAccountDto>> VerifyAnonymousVerifyCode(string email, string verifyCode)
|
|
{
|
|
var verificationRecord = await _verificationCodeRepository
|
|
.Where(t => t.UserId == Guid.Empty && t.Code == verifyCode && t.CodeType == VerifyType.Email && t.EmailOrPhone == email).OrderByDescending(t => t.CreateTime).FirstOrDefaultAsync();
|
|
|
|
//检查数据库是否存在该验证码
|
|
if (verificationRecord == null)
|
|
{
|
|
|
|
throw new BusinessValidationFailedException(_localizer["User_VerificationCodeError"]);
|
|
}
|
|
else
|
|
{
|
|
//检查验证码是否失效
|
|
if (verificationRecord.ExpirationTime < DateTime.Now)
|
|
{
|
|
|
|
throw new BusinessValidationFailedException(_localizer["User_VerificationCodeError"]);
|
|
}
|
|
else //验证码正确 并且 没有超时
|
|
{
|
|
|
|
//删除验证码历史记录
|
|
await _verificationCodeRepository.BatchDeleteNoTrackingAsync(t => t.Id == verificationRecord.Id);
|
|
}
|
|
}
|
|
|
|
var list = await _userRepository.Where(t => t.EMail == email).Select(t => new UserAccountDto() { UserId = t.Id, UserName = t.UserName, UserRealName = t.FullName, UserType = t.UserTypeRole.UserTypeShortName }).ToListAsync();
|
|
|
|
|
|
|
|
return list;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userId"></param>
|
|
/// <param name="newPwd"></param>
|
|
/// <returns></returns>
|
|
[AllowAnonymous]
|
|
[HttpGet("{userId:guid}/{newPwd}")]
|
|
public async Task<IResponseOutput> AnonymousSetPassword(Guid userId, string newPwd)
|
|
{
|
|
|
|
|
|
await VerifyUserPwdAsync(userId, newPwd);
|
|
|
|
var success = await _userRepository.BatchUpdateNoTrackingAsync(t => t.Id == userId, u => new User()
|
|
{
|
|
Password = newPwd,
|
|
IsFirstAdd = false
|
|
});
|
|
|
|
return ResponseOutput.Result(success);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
[UnitOfWork]
|
|
public async Task<IResponseOutput> ModifyPassword(EditPasswordCommand editPwModel)
|
|
{
|
|
|
|
await VerifyUserPwdAsync(_userInfo.Id, editPwModel.NewPassWord, editPwModel.OldPassWord);
|
|
|
|
|
|
if (!string.IsNullOrEmpty(editPwModel.NewUserName))
|
|
{
|
|
|
|
await VerifyUserNameAsync(_userInfo.Id, editPwModel.NewUserName);
|
|
|
|
await _userRepository.BatchUpdateNoTrackingAsync(t => t.Id == _userInfo.Id, u => new User()
|
|
{
|
|
UserName = editPwModel.NewUserName,
|
|
});
|
|
|
|
}
|
|
|
|
var success = await _userRepository.BatchUpdateNoTrackingAsync(t => t.Id == _userInfo.Id, u => new User()
|
|
{
|
|
Password = editPwModel.NewPassWord,
|
|
IsFirstAdd = false
|
|
});
|
|
|
|
|
|
return ResponseOutput.Result(success);
|
|
|
|
|
|
////医生密码
|
|
//if (await _doctorRepository.AnyAsync(t => t.Id == _userInfo.Id && t.Password == editPwModel.OldPassWord))
|
|
//{
|
|
// var success = await _doctorRepository.BatchUpdateNoTrackingAsync(t => t.Id == _userInfo.Id, u => new Doctor()
|
|
// {
|
|
|
|
// Password = editPwModel.NewPassWord
|
|
// });
|
|
|
|
// return ResponseOutput.Result(success);
|
|
//}
|
|
|
|
//return ResponseOutput.NotOk("Old password is wrong.");
|
|
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="param"></param>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task<PageOutput<UserListDTO>> GetUserList(UserListQueryDTO param)
|
|
{
|
|
var userQueryable = _userRepository.Where(x => x.UserTypeEnum != UserTypeEnum.SuperAdmin)
|
|
.WhereIf(!string.IsNullOrWhiteSpace(param.UserName), t => t.UserName.Contains(param.UserName) )
|
|
.WhereIf(!string.IsNullOrWhiteSpace(param.RealName), t => t.FullName.Contains(param.RealName))
|
|
.WhereIf(!string.IsNullOrWhiteSpace(param.Phone), t => t.Phone.Contains(param.Phone))
|
|
.WhereIf(!string.IsNullOrWhiteSpace(param.OrganizationName), t => t.OrganizationName.Contains(param.OrganizationName))
|
|
.WhereIf(param.UserType != null, t => t.UserTypeId == param.UserType)
|
|
.WhereIf(param.UserState != null, t => t.Status == param.UserState)
|
|
.WhereIf(param.IsTestUser != null, t => t.IsTestUser == param.IsTestUser)
|
|
.WhereIf(param.IsZhiZhun != null, t => t.IsZhiZhun == param.IsZhiZhun)
|
|
.ProjectTo<UserListDTO>(_mapper.ConfigurationProvider);
|
|
|
|
return await userQueryable.ToPagedListAsync(param.PageIndex, param.PageSize, param.SortField == string.Empty ? "UserName" : param.SortField, param.Asc);
|
|
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns></returns>xiuga
|
|
[HttpGet("{id:guid}")]
|
|
public async Task<UserDetailDTO> GetUser(Guid id)
|
|
{
|
|
var userQuery = _userRepository.Where(t => t.Id == id).ProjectTo<UserDetailDTO>(_mapper.ConfigurationProvider);
|
|
return await (userQuery.FirstOrDefaultAsync()).IfNullThrowException();
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userAddModel"></param>
|
|
/// <returns></returns>
|
|
[UnitOfWork]
|
|
public async Task<IResponseOutput<UserAddedReturnDTO>> AddUser(UserCommand userAddModel)
|
|
{
|
|
|
|
|
|
await VerifyUserNameAsync(null, userAddModel.UserName);
|
|
|
|
await VerifyUserEmailAsync(null, userAddModel.UserTypeId, userAddModel.EMail);
|
|
|
|
//await VerifyUserPhoneAsync(null, userAddModel.UserTypeId, userAddModel.Phone);
|
|
|
|
|
|
var saveItem = _mapper.Map<User>(userAddModel);
|
|
|
|
saveItem.Code = await _userRepository.Select(t => t.Code).DefaultIfEmpty().MaxAsync() + 1;
|
|
|
|
saveItem.UserCode = AppSettings.GetCodeStr(saveItem.Code, nameof(User));
|
|
|
|
|
|
|
|
saveItem.Password = MD5Helper.Md5(AppSettings.DefaultPassword);
|
|
|
|
await _userRepository.AddAsync(saveItem);
|
|
|
|
var success = await _userRepository.SaveChangesAsync();
|
|
|
|
try
|
|
{
|
|
await _mailVerificationService.AddUserSendEmailAsync(saveItem.Id, userAddModel.BaseUrl, userAddModel.RouteUrl);
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError(ex.Message);
|
|
throw new BusinessValidationFailedException(_localizer["User_CreateFailed"]);
|
|
}
|
|
|
|
|
|
|
|
return ResponseOutput.Result(success, new UserAddedReturnDTO { Id = saveItem.Id, UserCode = saveItem.UserCode });
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="model"></param>
|
|
/// <returns></returns>
|
|
public async Task<IResponseOutput> UpdateUser(UserCommand model)
|
|
{
|
|
|
|
|
|
await VerifyUserNameAsync(model.Id, model.UserName);
|
|
|
|
await VerifyUserEmailAsync(model.Id, model.UserTypeId, model.EMail);
|
|
|
|
//await VerifyUserPhoneAsync(model.Id, model.UserTypeId, model.Phone);
|
|
|
|
var user = await _userRepository.FirstOrDefaultAsync(t => t.Id == model.Id);
|
|
|
|
if (user == null) return Null404NotFound(user);
|
|
|
|
_mapper.Map(model, user);
|
|
|
|
|
|
var success = await _userRepository.SaveChangesAsync();
|
|
|
|
return ResponseOutput.Ok(success);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userId"></param>
|
|
/// <returns></returns>
|
|
[HttpDelete("{userId:guid}")]
|
|
public async Task<IResponseOutput> DeleteUser(Guid userId)
|
|
{
|
|
if (await _userTrialRepository.AnyAsync(t => t.Id == userId))
|
|
{
|
|
return ResponseOutput.NotOk(_localizer["User_InProject"]);
|
|
}
|
|
|
|
var success = await _userRepository.BatchDeleteNoTrackingAsync(t => t.Id == userId);
|
|
|
|
return ResponseOutput.Result(success);
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userId"></param>
|
|
/// <param name="state"></param>
|
|
/// <returns></returns>
|
|
|
|
[HttpPost("{userId:guid}/{state:int}")]
|
|
public async Task<IResponseOutput> UpdateUserState(Guid userId, UserStateEnum state)
|
|
{
|
|
var success = await _userRepository.BatchUpdateNoTrackingAsync(u => u.Id == userId, t => new User
|
|
{
|
|
Status = state
|
|
});
|
|
return ResponseOutput.Result(success);
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
/// <param name="userName"></param>
|
|
/// <param name="password"></param>
|
|
/// <returns></returns>
|
|
[NonDynamicMethod]
|
|
public async Task<IResponseOutput<LoginReturnDTO>> Login(string userName, string password)
|
|
{
|
|
var userLoginReturnModel = new LoginReturnDTO();
|
|
|
|
#region 错误验证
|
|
// 生成缓存键
|
|
string cacheKey = userName+"LoginError";
|
|
|
|
int lockoutMinutes = 30;
|
|
int maxFailures = 5;
|
|
// 从缓存中获取登录失败次数
|
|
int? failCount = (int?)_cache.Get(cacheKey);
|
|
|
|
if (failCount == null)
|
|
{
|
|
failCount = 0;
|
|
}
|
|
|
|
//每次登录 都重置缓存时间
|
|
_cache.Set(cacheKey, failCount, TimeSpan.FromMinutes(lockoutMinutes));
|
|
|
|
|
|
if (failCount >= maxFailures)
|
|
{
|
|
string error = $"The password has been entered incorrectly for {maxFailures} times. The current account has been restricted from logging in. Please wait {lockoutMinutes} minutes and try again.";
|
|
|
|
|
|
//$"密码连续错误{maxFailures}次,当前账号已被限制登录，请等待 {lockoutMinutes} 分钟后再试。"
|
|
throw new BusinessValidationFailedException(error);
|
|
}
|
|
#endregion
|
|
|
|
var loginUser = await _userRepository.Where(u => EF.Functions.Collate(u.UserName, "SQL_Latin1_General_CP1_CS_AS") == userName && u.Password == password).ProjectTo<UserBasicInfo>(_mapper.ConfigurationProvider).FirstOrDefaultAsync();
|
|
|
|
if (loginUser == null)
|
|
{
|
|
|
|
failCount++;
|
|
_cache.Set(cacheKey, failCount, TimeSpan.FromMinutes(lockoutMinutes));
|
|
//此处下面 代码 为了支持医生也能登录 而且前端不加选择到底是管理用户 还是医生用户 奇怪的需求 无法理解
|
|
|
|
var loginDoctor = await _doctorRepository.Where(u => u.Phone == userName && u.Password == password).ProjectTo<UserBasicInfo>(_mapper.ConfigurationProvider).FirstOrDefaultAsync();
|
|
|
|
if (loginDoctor == null)
|
|
{
|
|
return ResponseOutput.NotOk(_localizer["User_CheckNameOrPw"], new LoginReturnDTO());
|
|
|
|
}
|
|
|
|
userLoginReturnModel.BasicInfo = loginDoctor;
|
|
|
|
// 登录 清除缓存
|
|
_cache.Remove(userLoginReturnModel.BasicInfo.Id.ToString());
|
|
return ResponseOutput.Ok(userLoginReturnModel);
|
|
|
|
}
|
|
|
|
if (loginUser.Status == 0)
|
|
{
|
|
return ResponseOutput.NotOk(_localizer["User_Disabled"], new LoginReturnDTO());
|
|
}
|
|
|
|
userLoginReturnModel.BasicInfo = loginUser;
|
|
|
|
// 登录 清除缓存
|
|
_cache.Remove(userLoginReturnModel.BasicInfo.Id.ToString());
|
|
return ResponseOutput.Ok(userLoginReturnModel);
|
|
|
|
}
|
|
|
|
}
|
|
}
|