ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt：美化代码

Browse Source
This commit is contained in:
李鹏军 2024-03-27 11:09:14 +08:00
parent b81733b011
commit dcc7ec5918
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/SJZY.Track.Application/EventHandlers/CAPFilter.cs
View File

@ -7,9 +7,9 @@ using SJZY.Track.Domain.Consts;
namespace SJZY.Track.Application.EventHandlers; namespace SJZY.Track.Application.EventHandlers;
public class CAPFilter : SubscribeFilter public class CapFilter : SubscribeFilter
{ {
const string _ERROR_CODE = "Error599"; const string ErrorCode = "Error599";
/// <summary> /// <summary>
/// 执行前 /// 执行前
@ -32,7 +32,7 @@ public class CAPFilter : SubscribeFilter
{ {
var isSkip = !string.IsNullOrEmpty(RedisHelper.Client.Get($"CapExcuteFilter:{hash}")); var isSkip = !string.IsNullOrEmpty(RedisHelper.Client.Get($"CapExcuteFilter:{hash}"));
if (isSkip) if (isSkip)
throw new BusinessException(_ERROR_CODE, $"检测到重复消费,消费参数：{argumentJsonStr}"); throw new BusinessException(ErrorCode, $"检测到重复消费,消费参数：{argumentJsonStr}");
RedisHelper.Client.Set($"CapExcuteFilter:{hash}", 60 * 10, RedisHelper.Client.Set($"CapExcuteFilter:{hash}", 60 * 10,
TimeSpan.FromHours(1).Seconds); // 1h内不允许一模一样的参数重复消费 TimeSpan.FromHours(1).Seconds); // 1h内不允许一模一样的参数重复消费
@ -54,7 +54,7 @@ public class CAPFilter : SubscribeFilter
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId); context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId);
BuildLog(receiveTime, receiveName, arguments, false, messageId); BuildLog(receiveTime!, receiveName!, arguments!, false, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -70,7 +70,7 @@ public class CAPFilter : SubscribeFilter
context.ExceptionHandled = true; context.ExceptionHandled = true;
context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId); context.DeliverMessage.Headers.TryGetValue("cap-msg-id", out var messageId);
if (context.Exception is BusinessException ex && ex.Code == _ERROR_CODE) if (context.Exception is BusinessException ex && ex.Code == ErrorCode)
LogHelper.Warn(ex.ToString()); LogHelper.Warn(ex.ToString());
else else
LogHelper.Error($"cap-msg-id：{messageId}\n{context.Exception}"); LogHelper.Error($"cap-msg-id：{messageId}\n{context.Exception}");
@ -80,7 +80,7 @@ public class CAPFilter : SubscribeFilter
context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName); context.DeliverMessage.Headers.TryGetValue("cap-msg-name", out var receiveName);
context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments); context.DeliverMessage.Headers.TryGetValue("sjzy-arguments", out var arguments);
BuildLog(receiveTime, receiveName, arguments, true, messageId); BuildLog(receiveTime!, receiveName!, arguments!, true, messageId!);
return Task.CompletedTask; return Task.CompletedTask;
} }

2
src/SJZY.Track.Application/SjzyTrackApplicationModule.cs
View File

@ -111,7 +111,7 @@ namespace SJZY.Track.Application
LogHelper.Error("【严重】CAP失败回调事件发生未处理异常" + ex); LogHelper.Error("【严重】CAP失败回调事件发生未处理异常" + ex);
} }
}; };
}).AddSubscribeFilter<CAPFilter>(); }).AddSubscribeFilter<CapFilter>();
} }
public override void PreConfigureServices(ServiceConfigurationContext context) public override void PreConfigureServices(ServiceConfigurationContext context)