Merge branch 'S03-轨迹中台' into dev
This commit is contained in:
commit
9eae8d64c7
@ -79,6 +79,10 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
@event.TrackCode);
|
@event.TrackCode);
|
||||||
if (config is { IsAllPush: true })
|
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)
|
if (history != default)
|
||||||
{
|
{
|
||||||
body = JObject.Parse(history.PushContent);
|
body = JObject.Parse(history.PushContent);
|
||||||
((JArray)body["data"]!).Add(track);
|
((JArray)body["data"]!).Add(JObject.FromObject(track));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user