From 1f115bad3ebeed633a4bd8524aa2aa6aea09d598 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:34:39 +0800 Subject: [PATCH 1/2] =?UTF-8?q?change=EF=BC=9Aes=20=E8=8E=B7=E5=8F=96list?= =?UTF-8?q?=20size=E6=94=B9=E4=B8=BA1000?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Repositories/TrackDetailsRepository.cs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs index 238a9fd0..81d2bd06 100644 --- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs +++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs @@ -17,6 +17,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract(s => s .Source() + .Size(1000) .Query(q => q .Bool(b => b .Must( @@ -165,6 +166,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract f.OrderType, orderType) ) + .Size(1000) ); return data.Documents.ToList(); 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 2/2] =?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(); 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