Merge remote-tracking branch 'origin/S03-轨迹中台优化项' into test

src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs

@@ -94,8 +94,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
         var orderIds = @event.OrderIdentifiers.Select(x => x.OrderId).ToArray();
         var tracks = await _trackDetailsRepository.GetListAsync(orderIds, @event.TrackCode);
 
-        var firstTrack = tracks.FirstOrDefault();
+        TrackDetailsIndex firstTrack = null;
-        if (firstTrack == null) return;
 
         var insertTracks = new List<TrackDetailsIndex>();
 
@@ -173,11 +172,15 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             await _capPublisher.PublishAsync(GlobalConst.TrackPushSubscribe, trackPushEvent);
 
             canNextOrderIds.Add(order.OrderId);
+
+            firstTrack ??= track;
         }
 
         // 批量add to es
         await _trackDetailsRepository.AddManyAsync(insertTracks);
 
+        if (firstTrack == null) return;
+
         // 触发订单主表更新事件（异步）
         await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
             new TrackChangeAfterUpdateOrderEvent

src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs

@@ -120,6 +120,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
 
     public async Task AddManyAsync(List<TrackDetailsIndex> tracks)
     {
+        if (!tracks.Any()) return;
         // 按天写入es
         var indexName = $"{GlobalConst.TrackIndex}-{DateTime.Now:yyyy.MM.dd}";
         tracks.ForEach(x => x.IndexName = indexName);