🍒 feat(auth): 实现 session 自动刷新
This commit is contained in:
parent
14be6adacc
commit
96164b3328
@ -440,4 +440,15 @@ public class SysAuthService : IDynamicApiController, ITransient
|
|||||||
return 401;
|
return 401;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 刷新token
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="userId"></param>
|
||||||
|
[NonAction]
|
||||||
|
public async Task RefreshToken(long userId)
|
||||||
|
{
|
||||||
|
var user = await _sysUserRep.AsQueryable().IgnoreTenant().Includes(u => u.SysOrg).FirstAsync(u => u.Id == userId);
|
||||||
|
await CreateToken(user);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@ -457,6 +457,17 @@ public class SysCacheService : IDynamicApiController, ISingleton
|
|||||||
return _cacheProvider.Cache.ContainsKey($"{_cacheOptions.Prefix}{key}");
|
return _cacheProvider.Cache.ContainsKey($"{_cacheOptions.Prefix}{key}");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 检查缓存是否不存在
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="key">键</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
[NonAction]
|
||||||
|
public bool NotExistKey(string key)
|
||||||
|
{
|
||||||
|
return !_cacheProvider.Cache.ContainsKey($"{_cacheOptions.Prefix}{key}");
|
||||||
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// 根据键名前缀删除缓存 🔖
|
/// 根据键名前缀删除缓存 🔖
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|||||||
@ -168,6 +168,9 @@ public class SysUserService : IDynamicApiController, ITransient
|
|||||||
// 更新域账号
|
// 更新域账号
|
||||||
await _sysUserLdapService.AddUserLdap(user.TenantId!.Value, user.Id, user.Account, input.DomainAccount);
|
await _sysUserLdapService.AddUserLdap(user.TenantId!.Value, user.Id, user.Account, input.DomainAccount);
|
||||||
|
|
||||||
|
// 清除用户session
|
||||||
|
_userManager.RemoveSession(input.Id);
|
||||||
|
|
||||||
// 发布更新用户事件
|
// 发布更新用户事件
|
||||||
await _eventPublisher.PublishAsync(UserEventTypeEnum.Update, input);
|
await _eventPublisher.PublishAsync(UserEventTypeEnum.Update, input);
|
||||||
}
|
}
|
||||||
@ -246,8 +249,11 @@ public class SysUserService : IDynamicApiController, ITransient
|
|||||||
[DisplayName("更新用户基本信息")]
|
[DisplayName("更新用户基本信息")]
|
||||||
public virtual async Task<int> UpdateBaseInfo(SysUser user)
|
public virtual async Task<int> UpdateBaseInfo(SysUser user)
|
||||||
{
|
{
|
||||||
return await _sysUserRep.AsUpdateable(user)
|
var count = await _sysUserRep.AsUpdateable(user)
|
||||||
.IgnoreColumns(u => new { u.CreateTime, u.Account, u.Password, u.AccountType, u.OrgId, u.PosId }).ExecuteCommandAsync();
|
.IgnoreColumns(u => new { u.CreateTime, u.Account, u.Password, u.AccountType, u.OrgId, u.PosId }).ExecuteCommandAsync();
|
||||||
|
// 清除用户session
|
||||||
|
_userManager.RemoveSession(user.Id);
|
||||||
|
return count;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@ -492,5 +498,8 @@ public class SysUserService : IDynamicApiController, ITransient
|
|||||||
|
|
||||||
// 强制下线账号
|
// 强制下线账号
|
||||||
await _sysOnlineUserService.ForceOfflineByUserId(user.Id);
|
await _sysOnlineUserService.ForceOfflineByUserId(user.Id);
|
||||||
|
|
||||||
|
// 清除用户session
|
||||||
|
_userManager.RemoveSession(user.Id);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -62,7 +62,7 @@ namespace Admin.NET.Web.Core
|
|||||||
// 验证Token黑名单
|
// 验证Token黑名单
|
||||||
var userId = httpContext.User.FindFirst(ClaimConst.UserId)?.Value;
|
var userId = httpContext.User.FindFirst(ClaimConst.UserId)?.Value;
|
||||||
var version = httpContext.User.FindFirst(ClaimConst.TokenVersion)?.Value;
|
var version = httpContext.User.FindFirst(ClaimConst.TokenVersion)?.Value;
|
||||||
if (sysCacheService.ExistKey($"{CacheConst.KeyTokenBlacklist}{userId}:{version}") || !sysCacheService.ExistKey($"{CacheConst.KeyUserSession}{userId}"))
|
if (sysCacheService.ExistKey($"{CacheConst.KeyTokenBlacklist}{userId}:{version}"))
|
||||||
{
|
{
|
||||||
context.Fail(new AuthorizationFailureReason(this, "令牌已失效,请重新登录。"));
|
context.Fail(new AuthorizationFailureReason(this, "令牌已失效,请重新登录。"));
|
||||||
context.StatusCode(StatusCodes.Status401Unauthorized);
|
context.StatusCode(StatusCodes.Status401Unauthorized);
|
||||||
@ -70,6 +70,14 @@ namespace Admin.NET.Web.Core
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 刷新 Session
|
||||||
|
if (sysCacheService.NotExistKey($"{CacheConst.KeyUserSession}{userId}"))
|
||||||
|
{
|
||||||
|
var sysAuthService = serviceScope.ServiceProvider.GetRequiredService<SysAuthService>();
|
||||||
|
await sysAuthService.RefreshToken(long.Parse(userId!));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if (!string.IsNullOrWhiteSpace(userId))
|
if (!string.IsNullOrWhiteSpace(userId))
|
||||||
{
|
{
|
||||||
// 查库并缓存用户Token版本
|
// 查库并缓存用户Token版本
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user