diff --git a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs index fa52d7b6..8ba62e32 100644 --- a/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs +++ b/src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs @@ -79,6 +79,10 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe @event.TrackCode); if (config is { IsAllPush: true }) { + // 推断 本次推送 是否可行 + config = await _trackPushCacheService.IsValidPushAsync(order.SubSystemId, order.CustomId, + order.LatestPushTrackCode, @event.TrackCode); + allPush = true; } } @@ -172,7 +176,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe if (history != default) { body = JObject.Parse(history.PushContent); - ((JArray)body["data"]!).Add(track); + ((JArray)body["data"]!).Add(JObject.FromObject(track)); } }