From d73a7ad119d175355a5d9508341df58b18202546 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Tue, 16 Apr 2024 18:38:18 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E4=BF=AE=E6=94=B9=E8=BD=A8?=
 =?UTF-8?q?=E8=BF=B9=E5=BC=95=E5=8F=91=E7=9A=84=E5=88=B7=E6=96=B0=E4=B8=BB?=
 =?UTF-8?q?=E8=A1=A8=E9=80=BB=E8=BE=91bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../EventHandlers/TrackUpsertEventHandler.cs   | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs b/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
index a162428a..56157b2d 100644
--- a/src/SJZY.Track.Application/EventHandlers/TrackUpsertEventHandler.cs
+++ b/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();
-        if (firstTrack == null) return;
-
-        // step1、upsert es轨迹
+        // 批量add to 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,
-                TrackTime = firstTrack.TrackTime,
-                TrackTimeZone = firstTrack.TrackTimeZone
+                TrackPlace = @event.TrackPlace,
+                TrackTime = @event.TrackTime,
+                TrackTimeZone = @event.TrackTimeZone
             });
     }
 }
\ No newline at end of file