// Admin.NET 项目的版æƒã€å•†æ ‡ã€ä¸“利和其他相关æƒåˆ©å‡å—ç›¸åº”æ³•å¾‹æ³•è§„çš„ä¿æŠ¤ã€‚ä½¿ç”¨æœ¬é¡¹ç›®åº”éµå®ˆç›¸å…³æ³•律法规和许å¯è¯çš„è¦æ±‚。 // // 本项目主è¦éµå¾ª MIT 许å¯è¯å’Œ Apache 许å¯è¯ï¼ˆç‰ˆæœ¬ 2.0)进行分å‘和使用。许å¯è¯ä½äºŽæºä»£ç æ ‘æ ¹ç›®å½•ä¸çš„ LICENSE-MIT å’Œ LICENSE-APACHE 文件。 // // ä¸å¾—利用本项目从事å±å®³å›½å®¶å®‰å…¨ã€æ‰°ä¹±ç¤¾ä¼šç§©åºã€ä¾µçŠ¯ä»–äººåˆæ³•æƒç›Šç‰æ³•å¾‹æ³•è§„ç¦æ¢çš„æ´»åЍï¼ä»»ä½•基于本项目二次开å‘è€Œäº§ç”Ÿçš„ä¸€åˆ‡æ³•å¾‹çº çº·å’Œè´£ä»»ï¼Œæˆ‘ä»¬ä¸æ‰¿æ‹…ä»»ä½•è´£ä»»ï¼ using System.Security.Claims; namespace Admin.NET.Core; /// <summary> /// 防æ¢é‡å¤è¯·æ±‚过滤器特性 /// </summary> [SuppressSniffer] [AttributeUsage(AttributeTargets.All, AllowMultiple = true, Inherited = true)] public class IdempotentAttribute : Attribute, IAsyncActionFilter { /// <summary> /// 请求间隔时间/ç§’ /// </summary> public int IntervalTime { get; set; } = 5; /// <summary> /// 错误æç¤ºå†…容 /// </summary> public string Message { get; set; } = "ä½ æ“作频率过快,请ç¨åŽé‡è¯•ï¼"; /// <summary> /// 缓å˜å‰ç¼€: Key+请求路由+用户Id+è¯·æ±‚å‚æ•° /// </summary> public string CacheKey { get; set; } /// <summary> /// 是å¦ç›´æŽ¥æŠ›å‡ºå¼‚常:Ture是,False返回上次请求结果 /// </summary> public bool ThrowBah { get; set; } public IdempotentAttribute() { } public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate next) { var httpContext = context.HttpContext; var path = httpContext.Request.Path.Value.ToString(); var userId = httpContext.User?.FindFirstValue(ClaimConst.UserId); var cacheExpireTime = TimeSpan.FromSeconds(IntervalTime); var parameters = ""; foreach (var parameter in context.ActionDescriptor.Parameters) { parameters += parameter.Name; parameters += context.ActionArguments[parameter.Name].ToJson(); } var cacheKey = MD5Encryption.Encrypt($"{CacheKey}{path}{userId}{parameters}"); var sysCacheService = App.GetRequiredService<SysCacheService>(); if (sysCacheService.ExistKey(cacheKey)) { if (ThrowBah) throw Oops.Oh(Message); try { var cachedResult = sysCacheService.Get<ResponseData>(cacheKey); context.Result = new ObjectResult(cachedResult.Value); } catch (Exception ex) { throw Oops.Oh($"{Message}-{ex}"); } } else { // å…ˆåŠ å…¥ä¸€ä¸ªç©ºç¼“å˜ï¼Œé˜²æ¢ç¬¬ä¸€æ¬¡è¯·æ±‚结果没回æ¥å¯¼è‡´è¿žç»è¯·æ±‚ sysCacheService.Set(cacheKey, "", cacheExpireTime); var resultContext = await next(); if (resultContext.Result is ObjectResult objectResult) { var valueType = objectResult.Value.GetType(); var responseData = new ResponseData { Type = valueType.Name, Value = objectResult.Value }; sysCacheService.Set(cacheKey, responseData, cacheExpireTime); } } } /// <summary> /// è¯·æ±‚ç»“æžœæ•°æ® /// </summary> private class ResponseData { /// <summary> /// 结果类型 /// </summary> public string Type { get; set; } /// <summary> /// 请求结果 /// </summary> public dynamic Value { get; set; } } }