diff --git a/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs b/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs index 6f9c5ba3..d6186324 100644 --- a/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs +++ b/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs @@ -24,6 +24,12 @@ public class CapFilter : SubscribeFilter if (context.DeliverMessage.Headers["cap-msg-name"]!.EndsWith(GlobalConst.TrackRefreshSubscribe)) return Task.CompletedTask; + // 本地调试不做幂等 + if (System.Diagnostics.Debugger.IsAttached) + { + return Task.CompletedTask; + } + var argumentJsonStr = context.Arguments.ToJson(); context.DeliverMessage.Headers["sjzy-arguments"] = argumentJsonStr; diff --git a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs index 15232caf..fa52d7b6 100644 --- a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs +++ b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs @@ -48,8 +48,6 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe var log = new TrackPushRecordIndex { IndexName = $"{GlobalConst.TrackPushRecordsIndex}-{DateTime.Now:yyyy.MM.dd}", - RequestId = res.RequestId, - Message = res.Msg, OptionType = @event.OptionType.ToString(), OrderId = @event.OrderId, TrackStatus = @event.TrackStatus, @@ -183,6 +181,8 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe log.PushContent = body.ToJson(); log.IsSuccess = res.Code == InterfaceRelayConst.SuccessCode; + log.RequestId = res.RequestId; + log.Message = res.Msg; } private async Task DoUpdateAsync(TrackPushEvent @event, @@ -215,5 +215,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe log.PushContent = data.ToJson(); log.IsSuccess = res.Code == InterfaceRelayConst.SuccessCode; + log.RequestId = res.RequestId; + log.Message = res.Msg; } } \ No newline at end of file