Merge branch 'S03-轨迹中台优化项' into dev

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

@@ -94,6 +94,9 @@ 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();
+        if (firstTrack == null) return;
+
         var insertTracks = new List<TrackDetailsIndex>();
 
         foreach (var order in @event.OrderIdentifiers)
@@ -172,24 +175,21 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
             canNextOrderIds.Add(order.OrderId);
         }
 
-        var firstTrack = insertTracks.FirstOrDefault();
+        // 批量add to es
-        if (firstTrack == null) return;
-
-        // step1、upsert es轨迹
         await _trackDetailsRepository.AddManyAsync(insertTracks);
 
-        // step3、触发订单主表更新事件（异步）
+        // 触发订单主表更新事件（异步）
         await _capPublisher.PublishAsync(GlobalConst.TrackChangeAfterUpdateOrderSubscribe,
             new TrackChangeAfterUpdateOrderEvent
             {
                 OrderIds = orderIds,
                 IsCompleted = @event.TrackRefreshData.IsCompleted,
-                TrackCode = firstTrack.TrackCode,
+                TrackCode = @event.TrackCode,
                 TrackContent = firstTrack.TrackContent,
                 TrackEnContent = firstTrack.TrackEnContent,
-                TrackPlace = firstTrack.TrackPlace,
+                TrackPlace = @event.TrackPlace,
-                TrackTime = firstTrack.TrackTime,
+                TrackTime = @event.TrackTime,
-                TrackTimeZone = firstTrack.TrackTimeZone
+                TrackTimeZone = @event.TrackTimeZone
             });
     }
 }

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

@@ -17,6 +17,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
     {
         var r = await Context.SearchAsync<TrackDetailsIndex>(s => s
             .Source()
+            .Size(1000)
             .Query(q => q
                 .Bool(b => b
                     .Must(
@@ -165,6 +166,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
                     .Terms(orderNos))
                 && q.Term(f => f.OrderType, orderType)
             )
+            .Size(1000)
         );
 
         return data.Documents.ToList();