From 8f1da65c5a684591c92357713f273a02af0f4d22 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, 19 Mar 2024 14:58:53 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/SJZY.Track.Domain/Consts/GlobalConst.MQ.cs      |  4 ++--
 .../Repositories/TrackDetailsRepository.cs          | 13 +++++++------
 2 files changed, 9 insertions(+), 8 deletions(-)

diff --git a/src/SJZY.Track.Domain/Consts/GlobalConst.MQ.cs b/src/SJZY.Track.Domain/Consts/GlobalConst.MQ.cs
index 2685b8b0..b6d27ceb 100644
--- a/src/SJZY.Track.Domain/Consts/GlobalConst.MQ.cs
+++ b/src/SJZY.Track.Domain/Consts/GlobalConst.MQ.cs
@@ -23,9 +23,9 @@ public partial class GlobalConst
     public const string TrackPushSubscribe = "SJZY.Track.TrackPush";
 
     /// <summary>
-    /// 轨迹新增/更新后触发更新订单主表
+    /// 轨迹新增/更新/删除后触发更新订单主表
     /// </summary>
-    public const string TrackChangeAfterUpdateOrderSubscribe = "SJZY.Track.TrackUpsertAfterUpdateOrder";
+    public const string TrackChangeAfterUpdateOrderSubscribe = "SJZY.Track.TrackChangeAfterUpdateOrder";
 
     /// <summary>
     /// 轨迹推送后触发更新订单主表
diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
index 06288928..b3a0b2c6 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
@@ -160,12 +160,13 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
     public async Task<bool> DeleteTrackAsync(int orderId, List<string> trackCodes)
     {
         var r = await Context.DeleteByQueryAsync<TrackDetailsIndex>(x => x
-            .Query(
-                q =>
-                    q.Term(t => t.OrderId, orderId)
-                    && q.Term(t => t.IsCanDelete, true)
-                    && q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
-            .WaitForCompletion()
+                .Query(
+                    q =>
+                        q.Term(t => t.OrderId, orderId)
+                        && q.Term(t => t.IsCanDelete, true)
+                        && q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
+                .WaitForActiveShards("all")
+            //.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
         );
 
         if (!r.IsValid)