ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'S02-轨迹中台' into test

Browse Source
This commit is contained in:
李鹏军 2024-03-16 14:27:56 +08:00
commit 980774fd9f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/SJZY.Track.Application/EventHandlers/TrackRefreshEventHandler.cs
View File

@ -32,11 +32,11 @@ public class TrackRefreshEventHandler : ITransientDependency, ICapSubscribe
public async Task ConsumerAsync(InterfaceRelayForwardReplayEvent @event)
{
// tips：attach返回的是服务商id，必有
var attach = JsonConvert.DeserializeObject<TrackRefreshDto>(@event.Attach);
if (attach is null) return;
var refreshDto = JsonConvert.DeserializeObject<List<TrackRefreshDto>>(@event.RequestParams)?.FirstOrDefault();
if (refreshDto is null) return;
var config =
await _trackPullCacheService.GetPullParamWithContentConfigAsync(attach.SubSystemId,
attach.ServiceProviderId);
await _trackPullCacheService.GetPullParamWithContentConfigAsync(refreshDto.SubSystemId,
refreshDto.ServiceProviderId);
var data = JObject.Parse(@event.Data.ToString()!);
var orderToken = data[config.ParamConfig.OrderPath];
@ -44,12 +44,12 @@ public class TrackRefreshEventHandler : ITransientDependency, ICapSubscribe
{
foreach (var token in orderTokens)
{
await HandleOrderAsync(token, config, attach.OrderType);
await HandleOrderAsync(token, config, refreshDto.OrderType);
}
}
else if (orderToken is JObject)
{
await HandleOrderAsync(orderToken, config, attach.OrderType);
await HandleOrderAsync(orderToken, config, refreshDto.OrderType);
}
}