From 6aee0d60d437b96ff3fe49b30853c750c81a6c46 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BA=91=E9=BE=99=20=E7=8E=8B?= <w15604079545@outlook.com>
Date: Wed, 27 Nov 2024 10:07:21 +0800
Subject: [PATCH] =?UTF-8?q?update:=20=E4=BC=98=E5=8C=96BulkApi=E6=9E=84?=
 =?UTF-8?q?=E5=BB=BA=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Repositories/TrackDetailsEsRepository.cs  | 55 +++++++++----------
 1 file changed, 26 insertions(+), 29 deletions(-)

diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs
index 69ec223a..246cfa7e 100644
--- a/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs
+++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs
@@ -270,13 +270,11 @@ public class TrackDetailsEsRepository : ElasticSearchContextAbstract<TrackDetail
         if (indexes.Count == 0) return;
 
         //构建批量更新操作描述符
-        var desc = new BulkDescriptor(GlobalConst.TrackDetailsIndex);
-        foreach (var track in indexes)
-        {
-            desc = desc.AddOperation(new BulkUpdateDescriptor<TrackDetailsIndex, object>()
-                .Id(track.Id)
-                .Index(track.IndexName)
-                .Script(s => s.Source(@"
+        var desc = new BulkDescriptor().UpdateMany(indexes,
+            (u, track) =>
+                u.Id(track.Id)
+                    .Index(track.IndexName)
+                    .Script(s => s.Source(@"
                     ctx._source.trackPlace = params.trackPlace;
                     ctx._source.trackTime = params.trackTime;
                     ctx._source.trackTimeZone = params.trackTimeZone;
@@ -297,28 +295,27 @@ public class TrackDetailsEsRepository : ElasticSearchContextAbstract<TrackDetail
                     ctx._source.destinationTimeZone = params.destinationTimeZone;
                     ctx._source.estimatedDeliveryDate = params.estimatedDeliveryDate;
                 ").Params(p => p
-                    .Add("trackPlace", track.TrackPlace)
-                    .Add("trackTime", track.TrackTime)
-                    .Add("trackTimeZone", track.TrackTimeZone)
-                    .Add("updateUser", track.UpdateUser)
-                    .Add("updateTime", DateTime.Now)
-                    //S06新增字段更新
-                    .Add("trackContent", track.TrackContent)
-                    .Add("trackEnContent", track.TrackEnContent)
-                    .Add("isVisibility", track.IsVisibility)
-                    .Add("remarks", track.Remarks)
-                    .Add("files", track.Files)
-                    .Add("trackPlaceCity", track.TrackPlaceCity)
-                    .Add("trackPlaceCityId", track.TrackPlaceCityId)
-                    .Add("trackPlaceProvince", track.TrackPlaceProvince)
-                    .Add("trackPlaceProvinceId", track.TrackPlaceProvinceId)
-                    .Add("trackPlaceNation", track.TrackPlaceNation)
-                    .Add("trackPlaceNationId", track.TrackPlaceNationId)
-                    .Add("trackPlacePostcode", track.TrackPlacePostcode)
-                    .Add("destinationTimeZone", track.DestinationTimeZone)
-                    .Add("estimatedDeliveryDate", track.EstimatedDeliveryDate))
-                ));
-        }
+                        .Add("trackPlace", track.TrackPlace)
+                        .Add("trackTime", track.TrackTime)
+                        .Add("trackTimeZone", track.TrackTimeZone)
+                        .Add("updateUser", track.UpdateUser)
+                        .Add("updateTime", DateTime.Now)
+                        //S06新增字段更新
+                        .Add("trackContent", track.TrackContent)
+                        .Add("trackEnContent", track.TrackEnContent)
+                        .Add("isVisibility", track.IsVisibility)
+                        .Add("remarks", track.Remarks)
+                        .Add("files", track.Files)
+                        .Add("trackPlaceCity", track.TrackPlaceCity)
+                        .Add("trackPlaceCityId", track.TrackPlaceCityId)
+                        .Add("trackPlaceProvince", track.TrackPlaceProvince)
+                        .Add("trackPlaceProvinceId", track.TrackPlaceProvinceId)
+                        .Add("trackPlaceNation", track.TrackPlaceNation)
+                        .Add("trackPlaceNationId", track.TrackPlaceNationId)
+                        .Add("trackPlacePostcode", track.TrackPlacePostcode)
+                        .Add("destinationTimeZone", track.DestinationTimeZone)
+                        .Add("estimatedDeliveryDate", track.EstimatedDeliveryDate))
+                    ));
 
         var retryCount = 0;
         var updateSuccessful = false;