From 0bfc8708be1ca0b4ae4c34bc6e243d59eb403d0b 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, 5 Mar 2024 16:01:52 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E8=BD=A8=E8=BF=B9=E5=88=A0=E9=99=A4by?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=EF=BC=8Ccode=E6=9C=AA=E5=8A=A0=E5=85=B3?=
 =?UTF-8?q?=E9=94=AE=E5=AD=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
index a0e6cead..c2dd6340 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsRepository.cs
@@ -44,7 +44,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
 
             if (!r.IsValid)
             {
-                LogHelper.Error($"轨迹数据新增失败，原因：{r.DebugInformation}。");
+                LogHelper.Error($"轨迹新增失败，原因：{r.DebugInformation}。");
             }
         }
         else
@@ -57,7 +57,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
 
             if (!r.IsValid)
             {
-                LogHelper.Error($"轨迹数据更新失败，原因：{r.DebugInformation}。");
+                LogHelper.Error($"轨迹更新失败，原因：{r.DebugInformation}。");
             }
         }
     }
@@ -108,14 +108,17 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
 
     public async Task DeleteTrackAsync(int orderId, List<string> trackCodes)
     {
-        await Context.UpdateByQueryAsync<TrackDetailsIndex>(x => x
+        var r = await Context.UpdateByQueryAsync<TrackDetailsIndex>(x => x
             .Query(
                 q =>
                     q.Term(t => t.OrderId, orderId)
-                    && q.Terms(t => t.Field(f => f.TrackCode).Terms(trackCodes)))
+                    && q.Terms(t => t.Field(f => f.TrackCode.Suffix("keyword")).Terms(trackCodes)))
             .Script(s => s
                 .Source("ctx._source.isDeleted = true"))
         );
+
+        if (!r.IsValid)
+            throw new Exception($"轨迹数据删除失败，原因：{r.DebugInformation}");
     }
 
     public async Task<(List<TrackDetailsIndex> list, long total)> GetListAsync(TrackDetailsQueryInput input)