From d8f594f19318a33935a7bfc89a91f6ab126ad3a6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Thu, 25 Apr 2024 17:22:41 +0800
Subject: [PATCH] try abort

---
 .../Repositories/TrackDetailsRepository.cs                     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
index be3e4d85..97133bfb 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
@@ -236,12 +236,13 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
     public async Task DeleteTrackAsync(int[] orderIds, List<string> trackCodes)
     {
         var r = await Context.DeleteByQueryAsync<TrackDetailsIndex>(x => x
-            .Conflicts(Conflicts.Proceed)
+            .Conflicts(Conflicts.Abort)
             .Query(
                 q =>
                     q.Terms(t => t.Field(f => f.OrderId).Terms(orderIds))
                     && q.Term(t => t.IsCanDelete, true)
                     && q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
+            .WaitForCompletion()
         );
 
         if (!r.IsValid)