diff --git a/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs b/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs index 6f9c5ba3..6966de18 100644 --- a/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs +++ b/src/SJZY.Track.Application/EventHandlers/CAPFilter.cs @@ -33,8 +33,8 @@ public class CapFilter : SubscribeFilter using (RedisHelper.Client.Lock("Filter:" + hash, 10)) { var isSkip = !string.IsNullOrEmpty(RedisHelper.Client.Get($"CapExcuteFilter:{hash}")); - if (isSkip) - throw new BusinessException(ErrorCode, $"检测到重复消费,消费参数:{argumentJsonStr}"); + // if (isSkip) + // throw new BusinessException(ErrorCode, $"检测到重复消费,消费参数:{argumentJsonStr}"); RedisHelper.Client.Set($"CapExcuteFilter:{hash}", 60 * 10, TimeSpan.FromHours(1).Seconds); // 1h内不允许一模一样的参数重复消费 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