using System; using System.Threading.Tasks; using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Mvc.Filters; using Microsoft.Extensions.Caching.Distributed; namespace YYApi.Helpers { /// /// 认证信息获取中间件 /// public class AuthMiddleware { private RequestDelegate Next { get; } public AuthMiddleware(RequestDelegate next) { Next = next; } public Task Invoke(HttpContext httpContext, IDistributedCache cache) { string token = null; if (httpContext.Request.Headers.ContainsKey("Token")) { token = httpContext.Request.Headers["Token"]; } if (!string.IsNullOrEmpty(token)) { var id = cache.GetString(token); if (id != null) { httpContext.Items.Add("LoginId", id); } } return Next(httpContext); } } /// /// 检测登录中间件 /// public class CheckAuthAttribute : ActionFilterAttribute { public override void OnActionExecuting(ActionExecutingContext context) { if (context.HttpContext.Items["LoginId"] == null) { throw new ApiException(401); } } } /// /// 认证助手 /// public class Auth { private IDistributedCache Cache { get; } public Auth(IDistributedCache cache) { Cache = cache; } /// /// 产生一个Token记录并返回Token /// /// /// public string SetId(int id) { var uuid = GetUUID(); Cache.SetString(uuid, id.ToString()); return uuid; } private string GetUUID() { return Guid.NewGuid().ToString(); } } }