JwtHandler.cs 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  1. // 大名科技(天津)有限公司版权所有 电话:18020030720 QQ:515096995
  2. //
  3. // 此源代码遵循位于源代码树根目录中的 LICENSE 文件的许可证
  4. using Admin.NET.Core;
  5. using Admin.NET.Core.Service;
  6. using Furion;
  7. using Furion.Authorization;
  8. using Furion.DataEncryption;
  9. using Microsoft.AspNetCore.Authorization;
  10. using Microsoft.AspNetCore.Http;
  11. using Microsoft.Extensions.DependencyInjection;
  12. using System;
  13. using System.Threading.Tasks;
  14. namespace Admin.NET.Web.Core
  15. {
  16. public class JwtHandler : AppAuthorizeHandler
  17. {
  18. private readonly IServiceProvider _serviceProvider;
  19. public JwtHandler(IServiceProvider serviceProvider)
  20. {
  21. _serviceProvider = serviceProvider;
  22. }
  23. /// <summary>
  24. /// 自动刷新Token
  25. /// </summary>
  26. /// <param name="context"></param>
  27. /// <returns></returns>
  28. public override async Task HandleAsync(AuthorizationHandlerContext context)
  29. {
  30. // var serviceProvider = context.GetCurrentHttpContext().RequestServices;
  31. using var serviceScope = _serviceProvider.CreateScope();
  32. // 若当前账号存在黑名单中则授权失败
  33. var sysCacheService = serviceScope.ServiceProvider.GetService<SysCacheService>();
  34. if (sysCacheService.ExistKey($"{CacheConst.KeyBlacklist}{context.User.FindFirst(ClaimConst.UserId)?.Value}"))
  35. {
  36. context.Fail();
  37. context.GetCurrentHttpContext().SignoutToSwagger();
  38. return;
  39. }
  40. var sysConfigService = serviceScope.ServiceProvider.GetService<SysConfigService>();
  41. var tokenExpire = await sysConfigService.GetTokenExpire();
  42. var refreshTokenExpire = await sysConfigService.GetRefreshTokenExpire();
  43. if (JWTEncryption.AutoRefreshToken(context, context.GetCurrentHttpContext(), tokenExpire, refreshTokenExpire))
  44. {
  45. await AuthorizeHandleAsync(context);
  46. }
  47. else
  48. {
  49. context.Fail(); // 授权失败
  50. var currentHttpContext = context.GetCurrentHttpContext();
  51. if (currentHttpContext == null)
  52. return;
  53. // 跳过由于 SignatureAuthentication 引发的失败
  54. if (currentHttpContext.Items.ContainsKey(SignatureAuthenticationDefaults.AuthenticateFailMsgKey))
  55. return;
  56. currentHttpContext.SignoutToSwagger();
  57. }
  58. }
  59. public override async Task<bool> PipelineAsync(AuthorizationHandlerContext context, DefaultHttpContext httpContext)
  60. {
  61. // 已自动验证 Jwt Token 有效性
  62. return await CheckAuthorizeAsync(httpContext);
  63. }
  64. /// <summary>
  65. /// 权限校验核心逻辑
  66. /// </summary>
  67. /// <param name="httpContext"></param>
  68. /// <returns></returns>
  69. private static async Task<bool> CheckAuthorizeAsync(DefaultHttpContext httpContext)
  70. {
  71. // 登录模式判断PC、APP
  72. if (App.User.FindFirst(ClaimConst.LoginMode)?.Value == ((int)LoginModeEnum.APP).ToString())
  73. return true;
  74. // 排除超管
  75. if (App.User.FindFirst(ClaimConst.AccountType)?.Value == ((int)AccountTypeEnum.SuperAdmin).ToString())
  76. return true;
  77. // 路由名称
  78. var routeName = httpContext.Request.Path.StartsWithSegments("/api")
  79. ? httpContext.Request.Path.Value[5..].Replace("/", ":")
  80. : httpContext.Request.Path.Value[1..].Replace("/", ":");
  81. // 获取用户拥有按钮权限集合
  82. var ownBtnPermList = await App.GetService<SysMenuService>().GetOwnBtnPermList();
  83. // 获取系统所有按钮权限集合
  84. var allBtnPermList = await App.GetService<SysMenuService>().GetAllBtnPermList();
  85. // 已拥有该按钮权限或者所有按钮集合里面不存在
  86. var exist1 = ownBtnPermList.Exists(u => routeName.Equals(u, StringComparison.CurrentCultureIgnoreCase));
  87. var exist2 = allBtnPermList.TrueForAll(u => !routeName.Equals(u, StringComparison.CurrentCultureIgnoreCase));
  88. return exist1 || exist2;
  89. }
  90. }
  91. }