From e21a4b03c14a8cfe2eb90cf67098f52c67debc9e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com> Date: Mon, 1 Apr 2024 18:44:42 +0800 Subject: [PATCH] =?UTF-8?q?change=EF=BC=9A=E5=85=A8=E9=87=8F=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E5=8D=B3=E4=BD=BF=E6=98=AF=E6=89=8B=E5=B7=A5=E6=8E=A8?= =?UTF-8?q?=E4=B9=9F=E8=A6=81=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../EventHandlers/TrackPushEventHandler.cs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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)); } }