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

add-param:推送完成结果广播增加接口通请求服务商后结果数据

Browse Source
This commit is contained in:
hardstylewyl 2025-06-05 14:43:58 +08:00
parent e2e4aa3948
commit 64911d9394
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/SJZY.Track.Application.Contract/Dtos/TrackPush/TrackPushRecordDto.cs
View File

@ -87,4 +87,9 @@ public class TrackPushRecordDto
/// 轨迹的额外新 /// 轨迹的额外新
/// </summary> /// </summary>
public string? Extra { get; set; } public string? Extra { get; set; }
/// <summary>
/// 接口通请求服务商后拿到的数据，和日志记录中的一样
/// </summary>
public string? InterfaceRelayData { get; set; }
} }

7
src/SJZY.Track.Application/Rabbit/TrackPushCompletedEventHandler.cs
View File

@ -84,7 +84,7 @@ public class TrackPushCompletedEventHandler : ITransientDependency, IRabbitHandl
// 推送广播 // 推送广播
if (logs.First().IsToMq) if (logs.First().IsToMq)
_broadcastingService.TrackPushCompletedPublicTopic(logs.Select(BuildDto).ToList()); _broadcastingService.TrackPushCompletedPublicTopic(logs.Select(log => BuildDto(log, @event.Data)).ToList());
// 写入推送日志 // 写入推送日志
await _trackPushRecordEsRepository.AddManyAsync(logs); await _trackPushRecordEsRepository.AddManyAsync(logs);
@ -190,7 +190,7 @@ public class TrackPushCompletedEventHandler : ITransientDependency, IRabbitHandl
} }
} }
private TrackPushRecordDto BuildDto(TrackPushRecordIndex log) private static TrackPushRecordDto BuildDto(TrackPushRecordIndex log, string interfaceRelayData)
{ {
return new TrackPushRecordDto return new TrackPushRecordDto
{ {
@ -210,7 +210,8 @@ public class TrackPushCompletedEventHandler : ITransientDependency, IRabbitHandl
TrackTime = log.TrackTime, TrackTime = log.TrackTime,
TrackPlace = log.TrackPlace, TrackPlace = log.TrackPlace,
TrackCode = log.TrackCode, TrackCode = log.TrackCode,
Extra = log.Extra Extra = log.Extra,
InterfaceRelayData = interfaceRelayData
}; };
} }
} }