add-param:推送完成结果广播增加接口通请求服务商后结果数
This commit is contained in:
parent
4eb1a9872f
commit
b1ee25ec06
@ -87,4 +87,9 @@ public class TrackPushRecordDto
|
||||
/// 轨迹的额外新
|
||||
/// </summary>
|
||||
public string? Extra { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 接口通请求服务商后拿到的数据,和日志记录中的一样
|
||||
/// </summary>
|
||||
public string? InterfaceRelayData { get; set; }
|
||||
}
|
||||
|
||||
@ -85,4 +85,9 @@ public class TrackPushCompletedEvent
|
||||
/// 轨迹的额外新
|
||||
/// </summary>
|
||||
public string? Extra { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 接口通请求服务商后拿到的数据,和日志记录中的一样
|
||||
/// </summary>
|
||||
public string? InterfaceRelayData { get; set; }
|
||||
}
|
||||
|
||||
@ -84,7 +84,7 @@ public class TrackPushCompletedEventHandler : ITransientDependency, IRabbitHandl
|
||||
|
||||
// 推送广播
|
||||
if (logs.First().IsToMq)
|
||||
_broadcastingService.TrackPushCompletedPublicTopic(logs.Select(BuildDto).ToList());
|
||||
_broadcastingService.TrackPushCompletedPublicTopic(logs.Select(log => BuildDto(log, @event.Data)).ToList());
|
||||
|
||||
// 写入推送日志
|
||||
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
|
||||
{
|
||||
@ -210,7 +210,8 @@ public class TrackPushCompletedEventHandler : ITransientDependency, IRabbitHandl
|
||||
TrackTime = log.TrackTime,
|
||||
TrackPlace = log.TrackPlace,
|
||||
TrackCode = log.TrackCode,
|
||||
Extra = log.Extra
|
||||
Extra = log.Extra,
|
||||
InterfaceRelayData = interfaceRelayData
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
@ -130,7 +130,8 @@ public class BroadcastingService : IBroadcastingService
|
||||
TrackTime = log.TrackTime,
|
||||
TrackPlace = log.TrackPlace,
|
||||
TrackCode = log.TrackCode,
|
||||
Extra = log.Extra
|
||||
Extra = log.Extra,
|
||||
InterfaceRelayData = log.InterfaceRelayData
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user