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

fix：推送bug

Browse Source
This commit is contained in:
李鹏军 2024-04-01 18:52:42 +08:00
parent e21a4b03c1
commit 11e64a07d3
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/SJZY.Track.Application/EventHandlers/TrackPushEventHandler.cs
View File

@ -34,8 +34,6 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
[CapSubscribe(GlobalConst.TrackPushSubscribe, Group = GlobalConst.TrackPushSubscribe)] [CapSubscribe(GlobalConst.TrackPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
public async Task ConsumerAsync(TrackPushEvent @event) public async Task ConsumerAsync(TrackPushEvent @event)
{ {
InterfaceRelayUnifyResultDto res = null!;
var order = await _orderRepository.GetFirstAsync(x => var order = await _orderRepository.GetFirstAsync(x =>
x.Id == @event.OrderId, x => new x.Id == @event.OrderId, x => new
{ {
@ -101,8 +99,6 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
throw new ArgumentOutOfRangeException(); throw new ArgumentOutOfRangeException();
} }
if (config == null) return;
// 往es 写推送日志 // 往es 写推送日志
await _trackPushRecordsRepository.AddAsync(log); await _trackPushRecordsRepository.AddAsync(log);
@ -113,7 +109,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
OrderId = @event.OrderId, OrderId = @event.OrderId,
TrackCode = @event.TrackCode, TrackCode = @event.TrackCode,
IsSuccess = log.IsSuccess, IsSuccess = log.IsSuccess,
Message = res.Msg Message = log.Message
}); });
} }