From 9bf4150990d073c324f56edfb585f7ff3bfe0037 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=B9=8F=E5=86=9B?= <2357729423@qq.com>
Date: Wed, 24 Apr 2024 11:13:05 +0800
Subject: [PATCH] =?UTF-8?q?try=EF=BC=9Aes=E6=89=B9=E9=87=8Fdel=E7=A6=81?=
 =?UTF-8?q?=E6=AD=A2=E5=86=B2=E7=AA=81=E6=A3=80=E6=B5=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Repositories/TrackDetailsRepository.cs                 | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
index 3e12410f..4622534e 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
@@ -1,3 +1,4 @@
+using Elasticsearch.Net;
 using Nest;
 using SJZY.Expand.ElasticSearch.Services;
 using SJZY.Track.Domain.Aggregates.TrackDetailsAggregate;
@@ -217,10 +218,8 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
 
     public async Task DeleteTrackAsync(int[] orderIds, List<string> trackCodes)
     {
-        var r = await Context.UpdateByQueryAsync<TrackDetailsIndex>(x => x
-            .Script(s => s
-                .Source("ctx.op = 'delete'")
-            )
+        var r = await Context.DeleteByQueryAsync<TrackDetailsIndex>(x => x
+            .Conflicts(Conflicts.Proceed)
             .Query(
                 q =>
                     q.Terms(t => t.Field(f => f.OrderId).Terms(orderIds))