opt:压缩订单主表更新事件
This commit is contained in:
parent
a28a9ac5db
commit
0fb2690efd
@ -170,22 +170,24 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
|
|||||||
};
|
};
|
||||||
|
|
||||||
await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
|
await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
|
||||||
|
|
||||||
// step3、触发订单主表更新事件(异步)
|
|
||||||
await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
|
|
||||||
new TrackChangeAfterUpdateOrderEvent
|
|
||||||
{
|
|
||||||
OrderIds = new[] { track.OrderId },
|
|
||||||
IsCompleted = @event.TrackRefreshData.IsCompleted,
|
|
||||||
TrackCode = track.TrackCode,
|
|
||||||
TrackContent = track.TrackContent,
|
|
||||||
TrackEnContent = track.TrackEnContent,
|
|
||||||
TrackPlace = track.TrackPlace,
|
|
||||||
TrackTime = track.TrackTime,
|
|
||||||
TrackTimeZone = track.TrackTimeZone
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var firstTrack = insertTracks.FirstOrDefault();
|
||||||
|
if (firstTrack == null) return;
|
||||||
|
// step3、触发订单主表更新事件(异步)
|
||||||
|
await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
|
||||||
|
new TrackChangeAfterUpdateOrderEvent
|
||||||
|
{
|
||||||
|
OrderIds = orderIds,
|
||||||
|
IsCompleted = @event.TrackRefreshData.IsCompleted,
|
||||||
|
TrackCode = firstTrack.TrackCode,
|
||||||
|
TrackContent = firstTrack.TrackContent,
|
||||||
|
TrackEnContent = firstTrack.TrackEnContent,
|
||||||
|
TrackPlace = firstTrack.TrackPlace,
|
||||||
|
TrackTime = firstTrack.TrackTime,
|
||||||
|
TrackTimeZone = firstTrack.TrackTimeZone
|
||||||
|
});
|
||||||
|
|
||||||
await _trackDetailsRepository.AddManyAsync(insertTracks);
|
await _trackDetailsRepository.AddManyAsync(insertTracks);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Loading…
Reference in New Issue
Block a user