using Furion.Authorization;
|
using Furion.DataEncryption;
|
using Furion;
|
using Furion.DependencyInjection;
|
using Microsoft.AspNetCore.Http;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text;
|
using System.Threading.Tasks;
|
using EzCoreNet.Redis;
|
|
using SqlSugar.Extensions;
|
|
using Furion.FriendlyException;
|
|
namespace cylsg.Authorization
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class EzAuthorizationService : IEzAuthorizationService, IScoped
|
{
|
private IEzCoreNetRedisService _redisCacheSc;
|
private IHttpContextAccessor _Context;
|
public EzAuthorizationService(IEzCoreNetRedisService redisCacheSc, IHttpContextAccessor httpContext)
|
{
|
_redisCacheSc = redisCacheSc;
|
_Context = httpContext;
|
}
|
/// <summary>
|
/// Token
|
/// </summary>
|
/// <returns></returns>
|
public TokenInfo CreateToken<T>(T jwt) where T : EzJwtModel
|
{
|
|
IDictionary<string, object> propertyDictionary = new Dictionary<string, object>();
|
|
PropertyInfo[] properties = jwt.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance);
|
|
foreach (PropertyInfo property in properties)
|
{
|
string propertyName = property.Name;
|
object propertyValue = property.GetValue(jwt);
|
|
propertyDictionary.Add(propertyName.ToLower(), propertyValue);
|
}
|
var expires = DateTime.Now.AddSeconds(Convert.ToInt32(App.GetConfig<JWTSettingsOptions>("JWTSettings").ExpiredTime * 60 ?? 3600));
|
var token = JWTEncryption.Encrypt(propertyDictionary, App.GetConfig<JWTSettingsOptions>("JWTSettings").ExpiredTime ?? 3600);
|
|
DateTimeOffset dto = new DateTimeOffset(DateTime.Now);
|
var Expires = dto.ToUnixTimeSeconds();
|
IDictionary<string, object> REfpropertyDictionary = new Dictionary<string, object>();
|
REfpropertyDictionary.Add(new(
|
"RefTokenID", $"{jwt.ITCode}:{Expires}"
|
));
|
|
var RefExpires = App.Configuration["JWTSettings:RefreshTokenExpires"].ObjToInt();
|
|
var refreshToken = JWTEncryption.Encrypt(REfpropertyDictionary, RefExpires);
|
|
//写入刷新可Token时间
|
_redisCacheSc.Add($"{jwt.ITCode}:{Expires}", jwt, RefExpires * 60);
|
|
return new TokenInfo
|
{
|
accessToken = token,
|
expires = expires,
|
refreshToken = refreshToken
|
};
|
|
}
|
/// <summary>
|
/// 刷新TOKEN
|
/// </summary>
|
/// <typeparam name="T"></typeparam>
|
/// <param name="refToken"></param>
|
/// <returns></returns>
|
/// <exception cref="TAxiosException"></exception>
|
public async Task<TokenInfo?> RefreshToken<T>(string refToken) where T : EzJwtModel
|
{
|
// IDictionary<string, object> REfpropertyDictionary = new Dictionary<string, object>();
|
|
// var tokenInfo = JWTEncryption.ReadJwtToken("token");
|
var (isValid, tokenData, validationResult) = JWTEncryption.Validate(refToken);
|
if (!isValid)
|
new EZCoreException(" 系统错误，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
var user = tokenData.Claims;
|
if (user == null)
|
throw new EZCoreException("参数丢失，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
|
var key = user.Where(x => x.Type == "RefTokenID").Select(x => x.Value).FirstOrDefault();
|
//if (key == null)
|
// throw Oops.Oh("token已过期，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
var jwtConfig = App.GetConfig<JWTSettingsOptions>("JWTSettings");
|
if (jwtConfig == null)
|
throw new EZCoreException(" 系统错误，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
var LoinData = _redisCacheSc.Get<T>(key);
|
if (LoinData == null)
|
|
throw new EZCoreException("token已过期，请重新登录", System.Net.HttpStatusCode.Unauthorized); //Oops.Oh("token已过期，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
var refreshTokenouttimes = _redisCacheSc.GetTtl(key);
|
if (refreshTokenouttimes <= 0)
|
{
|
|
throw new EZCoreException("token已过期，请重新登录", System.Net.HttpStatusCode.Unauthorized);
|
}
|
return await Task.Run<TokenInfo?>(() =>
|
{
|
|
|
|
IDictionary<string, object> propertyDictionary = new Dictionary<string, object>();
|
|
PropertyInfo[] properties = LoinData.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance);
|
|
foreach (PropertyInfo property in properties)
|
{
|
string propertyName = property.Name;
|
object propertyValue = property.GetValue(LoinData);
|
|
propertyDictionary.Add(propertyName.ToLower(), propertyValue);
|
}
|
|
|
var expires = DateTime.Now.AddSeconds(Convert.ToInt32(jwtConfig.ExpiredTime * 60));
|
|
var token = JWTEncryption.Encrypt(propertyDictionary, jwtConfig.ExpiredTime);
|
|
|
IDictionary<string, object> refreshTokenClaims = new Dictionary<string, object>();
|
|
|
refreshTokenClaims.Add(new(
|
"RefTokenID", key
|
));
|
|
var refreshToken = JWTEncryption.Encrypt(refreshTokenClaims, refreshTokenouttimes);
|
|
return new TokenInfo
|
{
|
accessToken = token,
|
expires = expires,
|
refreshToken = refreshToken
|
};
|
});
|
|
|
|
}
|
}
|
}
|
