From 6580831a4ad1425ae947e0ac420ec3601c81626b Mon Sep 17 00:00:00 2001
From: moyongzhen <2534173414@qq.com>
Date: Fri, 1 Mar 2024 11:54:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BD=A8=E8=BF=B9=E6=98=8E=E7=BB=86=E4=BD=BF?=
 =?UTF-8?q?=E7=94=A8=E8=AE=A2=E5=8D=95id=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ITrackDetailsRepository.cs                  |  1 +
 .../Repositories/TrackDetailsRepository.cs      | 17 ++++++++++++++++-
 2 files changed, 17 insertions(+), 1 deletion(-)

diff --git a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsRepository.cs b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsRepository.cs
index 444dd072..89d812a1 100644
--- a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsRepository.cs
+++ b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsRepository.cs
@@ -13,4 +13,5 @@ public interface ITrackDetailsRepository
     Task<List<TrackDetailsIndex>> GetListAsync(int orderType, List<string> orderNos);
 
     Task<(List<TrackDetailsIndex> list, long total)> GetListAsync(TrackDetailsQueryInput input);
+    Task<List<TrackDetailsIndex>> GetListAsync(int orderId);
 }
\ No newline at end of file
diff --git a/src/SJZY.Track.Infrastructure/Repositories/TrackDetailsRepository.cs b/src/SJZY.Track.Infrastructure/Repositories/TrackDetailsRepository.cs
index 2737c39d..c23a28fd 100644
--- a/src/SJZY.Track.Infrastructure/Repositories/TrackDetailsRepository.cs
+++ b/src/SJZY.Track.Infrastructure/Repositories/TrackDetailsRepository.cs
@@ -37,7 +37,7 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
         var response = await Context.UpdateAsync<TrackDetailsIndex>(index.Id, u => u
                 .Index(IndexName)
                 .Doc(index)
-            //.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
+        //.Refresh(Refresh.True) // 可选：立即刷新索引使更改立即可见
         );
         if (!response.IsValid)
             throw new Exception($"数据修改失败，原因：{response.DebugInformation}");
@@ -73,6 +73,21 @@ internal class TrackDetailsRepository : ElasticSearchContextAbstract<TrackDetail
         return data.Documents.ToList();
     }
 
+    public async Task<List<TrackDetailsIndex>> GetListAsync(int orderId)
+    {
+        var data = await Context.SearchAsync<TrackDetailsIndex>(x => x
+             .Source(s => s.Includes(fd => fd
+                 .Field(f => f.TrackStatus)
+                 .Field(f => f.TrackCode)
+                 .Field(f => f.TrackContent)
+                 .Field(f => f.TrackPlace)
+                 .Field(f => f.TrackTime)
+                 .Field(f => f.TraceTimeZone)
+             )).Query(q => q.Terms(t => t.Field(f => f.OrderId).Terms(orderId))));
+
+        return data?.Documents?.ToList();
+    }
+
     public async Task<(List<TrackDetailsIndex> list, long total)> GetListAsync(TrackDetailsQueryInput input)
     {
         if (input.OrderNos.Count < 1) return default;