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

fix upsert

Browse Source
This commit is contained in:
李鹏军 2024-03-20 18:36:12 +08:00
parent 39dc2f52f2
commit 0cb30b3d4b
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
View File

@ -61,7 +61,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
var track = await _trackDetailsRepository.GetFirstOrDefaultAsync(@event.OrderId, @event.TrackCode); var track = await _trackDetailsRepository.GetFirstOrDefaultAsync(@event.OrderId, @event.TrackCode);
// step1、upsert es轨迹 // step1、upsert es轨迹
await UpsertTrackAsync(track, @event); track = await UpsertTrackAsync(track, @event);
Debug.Assert(track != null, nameof(track) + " != null"); Debug.Assert(track != null, nameof(track) + " != null");
// step2、触发轨迹推送事件（异步） // step2、触发轨迹推送事件（异步）
@ -103,7 +103,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
/// </summary> /// </summary>
/// <param name="track"></param> /// <param name="track"></param>
/// <param name="event"></param> /// <param name="event"></param>
private async Task UpsertTrackAsync(TrackDetailsIndex? track, TrackUpsertEvent @event) private async Task<TrackDetailsIndex?> UpsertTrackAsync(TrackDetailsIndex? track, TrackUpsertEvent @event)
{ {
if (track == default) if (track == default)
{ {
@ -113,7 +113,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
if (trackContent == default) if (trackContent == default)
{ {
// 订单所绑定的模板，没有一条内容可以匹配发生的轨迹 // 订单所绑定的模板，没有一条内容可以匹配发生的轨迹
return; return null;
} }
track = new TrackDetailsIndex track = new TrackDetailsIndex
@ -146,6 +146,8 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
} }
await _trackDetailsRepository.UpsertAsync(track); await _trackDetailsRepository.UpsertAsync(track);
return track;
} }
/// <summary> /// <summary>