xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 注册用户时支持传入头像参数

Browse Source
This commit is contained in:
chenchun
2025-08-29 14:11:50 +08:00
parent c5b6b33d8e
commit 7905911624
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
Yi.Abp.Net8/module/rbac/Yi.Framework.Rbac.Domain/Managers/AccountManager.cs
View File

@@ -37,11 +37,14 @@ namespace Yi.Framework.Rbac.Domain.Managers
private UserManager _userManager; private UserManager _userManager;
private ISqlSugarRepository<RoleAggregateRoot> _roleRepository; private ISqlSugarRepository<RoleAggregateRoot> _roleRepository;
private RefreshJwtOptions _refreshJwtOptions; private RefreshJwtOptions _refreshJwtOptions;
/// <summary> /// <summary>
/// 缓存前缀 /// 缓存前缀
/// </summary> /// </summary>
private string CacheKeyPrefix => LazyServiceProvider.LazyGetRequiredService<IOptions<AbpDistributedCacheOptions>>() private string CacheKeyPrefix => LazyServiceProvider
.LazyGetRequiredService<IOptions<AbpDistributedCacheOptions>>()
.Value.KeyPrefix; .Value.KeyPrefix;
public IDistributedLockProvider DistributedLock => public IDistributedLockProvider DistributedLock =>
LazyServiceProvider.LazyGetService<IDistributedLockProvider>(); LazyServiceProvider.LazyGetService<IDistributedLockProvider>();
@@ -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) if (handle is null)
{ {
@@ -312,12 +317,13 @@ namespace Yi.Framework.Rbac.Domain.Managers
} }
var userUpName = userName.ToUpper(); 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}用户已注册"); 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); var userId = await _userManager.CreateAsync(user);
await _userManager.SetDefautRoleAsync(user.Id); await _userManager.SetDefautRoleAsync(user.Id);
return userId; return userId;