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() - .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 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;