测试

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>
     /// 轨迹推送后触发更新订单主表

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)