From 79059116246bc0501df3d2ae7bd15b00245745d1 Mon Sep 17 00:00:00 2001 From: chenchun Date: Fri, 29 Aug 2025 14:11:50 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B3=A8=E5=86=8C=E7=94=A8=E6=88=B7?= =?UTF-8?q?=E6=97=B6=E6=94=AF=E6=8C=81=E4=BC=A0=E5=85=A5=E5=A4=B4=E5=83=8F?= =?UTF-8?q?=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Managers/AccountManager.cs | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Domain/Managers/AccountManager.cs b/Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Domain/Managers/AccountManager.cs index d8475991..dad88ed4 100644 --- a/Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Domain/Managers/AccountManager.cs +++ b/Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Domain/Managers/AccountManager.cs @@ -37,11 +37,14 @@ namespace Yi.Framework.Rbac.Domain.Managers private UserManager _userManager; private ISqlSugarRepository _roleRepository; private RefreshJwtOptions _refreshJwtOptions; + /// /// 缓存前缀 /// - private string CacheKeyPrefix => LazyServiceProvider.LazyGetRequiredService>() + private string CacheKeyPrefix => LazyServiceProvider + .LazyGetRequiredService>() .Value.KeyPrefix; + public IDistributedLockProvider DistributedLock => LazyServiceProvider.LazyGetService(); @@ -304,7 +307,9 @@ namespace Yi.Framework.Rbac.Domain.Managers } //制作幂等 - await using (var handle = await DistributedLock.TryAcquireLockAsync($"{CacheKeyPrefix}Register:Lock:{userName}", TimeSpan.FromSeconds(60))) + await using (var handle = + await DistributedLock.TryAcquireLockAsync($"{CacheKeyPrefix}Register:Lock:{userName}", + TimeSpan.FromSeconds(60))) { if (handle is null) { @@ -312,12 +317,13 @@ namespace Yi.Framework.Rbac.Domain.Managers } var userUpName = userName.ToUpper(); - if (await _userManager._repository._DbQueryable.Where(x => x.UserName.ToUpper() == userUpName).AnyAsync()) + if (await _userManager._repository._DbQueryable.Where(x => x.UserName.ToUpper() == userUpName) + .AnyAsync()) { throw new UserFriendlyException($"{userName}用户已注册"); } - - var user = new UserAggregateRoot(userName, password, phone, email, nick); + + var user = new UserAggregateRoot(userName, password, phone, email, nick, icon); var userId = await _userManager.CreateAsync(user); await _userManager.SetDefautRoleAsync(user.Id); return userId;