diff --git a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/BatchUpsertTrackInput.cs b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/BatchUpsertTrackInput.cs index 276ad83b..bd7a5c2f 100644 --- a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/BatchUpsertTrackInput.cs +++ b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/BatchUpsertTrackInput.cs @@ -44,9 +44,15 @@ public class BatchUpsertTrackInput : OrderNosInfo /// /// 客户是否可见 /// - [Required] + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外(可选的) + /// 如果未填则按照【轨迹内容】中的【是否可见】做为默认值 + /// + public bool? IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// 批量新增时使用指定轨迹来源，更新时无需指定 diff --git a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetOrderDetailsInput.cs b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetOrderDetailsInput.cs index 23cdaec4..7aab1d65 100644 --- a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetOrderDetailsInput.cs +++ b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetOrderDetailsInput.cs @@ -72,6 +72,12 @@ public class TrackOrderDetailDto /// public float TrackTimeZoneValue { get; set; } + /// + /// 客户是否可见 + /// + [Obsolete("废弃的，请使用IsExternal")] + public bool IsVisibility { get; set; } + /// /// 是否对外 /// @@ -87,11 +93,6 @@ public class TrackOrderDetailDto /// public string? CreateUser { get; set; } - /// - /// 客户是否可见 - /// - public bool IsVisibility { get; set; } - /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetTrackOutput.cs b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetTrackOutput.cs index edf15090..e03a46f0 100644 --- a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetTrackOutput.cs +++ b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/GetTrackOutput.cs @@ -36,13 +36,20 @@ public class TrackDetail /// /// 是否对外 /// + [Obsolete("废弃的，请使用IsExternal")] public bool IsDisplay { get; set; } /// /// 客户是否可见 /// + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外 + /// + public bool IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/UpsertTrackInput.cs b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/UpsertTrackInput.cs index def0e322..961841a6 100644 --- a/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/UpsertTrackInput.cs +++ b/src/SJZY.Track.Application.Contract/Dtos/ProvideServices/UpsertTrackInput.cs @@ -49,9 +49,15 @@ public class UpsertTrackInput : OrderNoInfo /// /// 客户是否可见 /// - [Required] + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外(可选的) + /// 如果未填则按照【轨迹内容】中的【是否可见】做为默认值 + /// + public bool? IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Application.Contract/Events/TrackChangeEto.cs b/src/SJZY.Track.Application.Contract/Events/TrackChangeEto.cs index 6319446e..804ad6d5 100644 --- a/src/SJZY.Track.Application.Contract/Events/TrackChangeEto.cs +++ b/src/SJZY.Track.Application.Contract/Events/TrackChangeEto.cs @@ -72,8 +72,14 @@ public class TrackChangeEto /// /// 客户是否可见 /// + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外 + /// + public bool IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Application.Contract/Events/TrackUpsertEvent.cs b/src/SJZY.Track.Application.Contract/Events/TrackUpsertEvent.cs index fef7ab3f..182672cb 100644 --- a/src/SJZY.Track.Application.Contract/Events/TrackUpsertEvent.cs +++ b/src/SJZY.Track.Application.Contract/Events/TrackUpsertEvent.cs @@ -74,8 +74,14 @@ public class TrackUpsertEvent /// /// 客户是否可见 /// + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外 + /// + public bool? IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Application.Contract/Services/IBroadcastingService.cs b/src/SJZY.Track.Application.Contract/Services/IBroadcastingService.cs index 782126bb..238f015b 100644 --- a/src/SJZY.Track.Application.Contract/Services/IBroadcastingService.cs +++ b/src/SJZY.Track.Application.Contract/Services/IBroadcastingService.cs @@ -10,17 +10,10 @@ public interface IBroadcastingService : ITransientDependency /// 轨迹变更广播(新增/修改) /// /// + /// /// /// - void TrackChangePublicTopic(TrackUpsertEvent eto, string subSystemCode, string trackStatusCode); - - /// - /// 轨迹变更广播（删除） - /// - /// - /// - /// - void TrackChangePublicTopic(TrackDeleteEvent eto, OrderIdentifier[] orderIdentifiers, string trackCode, string trackStatusCode, string subSystemCode); + void TrackChangePublicTopic(TrackUpsertEvent eto,bool contentIsExternal, string subSystemCode, string trackStatusCode); /// /// 轨迹变更广播（删除） diff --git a/src/SJZY.Track.Application/CAP/EventHandlers/TrackDeleteEventHandler.cs b/src/SJZY.Track.Application/CAP/EventHandlers/TrackDeleteEventHandler.cs index e1c416d0..5ce98e81 100644 --- a/src/SJZY.Track.Application/CAP/EventHandlers/TrackDeleteEventHandler.cs +++ b/src/SJZY.Track.Application/CAP/EventHandlers/TrackDeleteEventHandler.cs @@ -339,6 +339,7 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe Remarks = track.Remarks, Source = track.Source, IsVisibility = track.IsVisibility, + IsExternal = track.IsExternal, TrackTimeZone = track.TrackTimeZone, TrackTime = track.TrackTime, TrackPlace = track.TrackPlace, diff --git a/src/SJZY.Track.Application/CAP/EventHandlers/TrackUpsertEventHandler.cs b/src/SJZY.Track.Application/CAP/EventHandlers/TrackUpsertEventHandler.cs index b400bea8..8a657ad2 100644 --- a/src/SJZY.Track.Application/CAP/EventHandlers/TrackUpsertEventHandler.cs +++ b/src/SJZY.Track.Application/CAP/EventHandlers/TrackUpsertEventHandler.cs @@ -56,7 +56,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe // 处理广播事件 if (content != null && (content.IsToMq || @event.IsToMq)) - _ = EnsureWriteAfterPublicTopicAsync(@event, content.SubSystemCode, content.TrackStatusCode); + _ = EnsureWriteAfterPublicTopicAsync(@event, content.IsExternal, content.SubSystemCode, content.TrackStatusCode); if (canNextOrderIds.Count == 0) return; // 根据订单关联关系异步向下刷（异步） @@ -363,6 +363,8 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe track.TrackEnContent = @event.EnStatus ?? trackContent.TrackEnContent; //S06新增 track.IsVisibility = @event.IsVisibility; + //当传入的IsExternal为空，则使用轨迹内容中的IsExternal + track.IsExternal = @event.IsExternal ?? trackContent.IsExternal; track.Remarks = @event.Remarks ?? GlobalConst.EmptyString; track.Files = @event.Files?.Select(x => new FileItem { @@ -410,6 +412,8 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe TrackEnContent = @event.EnStatus ?? trackContent.TrackEnContent, //S06新增轨迹明细字段 IsVisibility = @event.IsVisibility, + //当传入的IsExternal为空，则使用轨迹内容中的IsExternal + IsExternal = @event.IsExternal ?? trackContent.IsExternal, Source = @event.Source, Remarks = @event.Remarks ?? GlobalConst.EmptyString, Files = @event.Files?.Select(x => new FileItem @@ -450,7 +454,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe }; } - private async Task EnsureWriteAfterPublicTopicAsync(TrackUpsertEvent @event, string subSystemCode, string statusCode) + private async Task EnsureWriteAfterPublicTopicAsync(TrackUpsertEvent @event, bool contentIsExternal, string subSystemCode, string statusCode) { //理想情况在写入之后1s会刷盘 https://www.elastic.co/guide/en/elasticsearch/reference/master/indices-refresh.html //增加一个版本号来确定是否真的变更了 @@ -459,6 +463,6 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe //方案2：考虑强制刷盘（对es压力大）后发送 //方案3：采用一个较大延时，不查询直接发 await Task.Delay(1000); - _broadcastingService.TrackChangePublicTopic(@event, subSystemCode, statusCode); + _broadcastingService.TrackChangePublicTopic(@event, contentIsExternal, subSystemCode, statusCode); } } diff --git a/src/SJZY.Track.Application/Localization/Resources/en.json b/src/SJZY.Track.Application/Localization/Resources/en.json index c7d369bc..dd092982 100644 --- a/src/SJZY.Track.Application/Localization/Resources/en.json +++ b/src/SJZY.Track.Application/Localization/Resources/en.json @@ -10,6 +10,7 @@ "TrackFlagExist": "Duplicate code or flag in the current subsystem", "IsExistTrackPullConfig": "Track Pull The template has been bound. Delete the track pull before deleting the template", "IsExistTrackStatus": "The trajectory content has been bound to the trajectory status. Delete the trajectory content before deleting the trajectory status", - "IsExistTrackFlag": "The track content has been bound to the track mark. Delete the track content before deleting the track mark" + "IsExistTrackFlag": "The track content has been bound to the track mark. Delete the track content before deleting the track mark", + "IsTrackPushConfigAny": "This subsystem already has the push mapping of this customer, and it cannot be added repeatedly" } -} \ No newline at end of file +} diff --git a/src/SJZY.Track.Application/Localization/Resources/zh.json b/src/SJZY.Track.Application/Localization/Resources/zh.json index 38db9ebb..b33ac103 100644 --- a/src/SJZY.Track.Application/Localization/Resources/zh.json +++ b/src/SJZY.Track.Application/Localization/Resources/zh.json @@ -10,6 +10,7 @@ "TrackFlagExist": "当前子系统下代码或标记重复", "IsExistTrackPullConfig": "轨迹拉取已绑定了该模版，请先删除轨迹拉取再删除该模版", "IsExistTrackStatus": "轨迹内容已经绑定了该轨迹状态，请先删除轨迹内容后再删除该轨迹状态", - "IsExistTrackFlag": "轨迹内容已经绑定了该轨迹标记，请先删除轨迹内容后再删除该轨迹标记" + "IsExistTrackFlag": "轨迹内容已经绑定了该轨迹标记，请先删除轨迹内容后再删除该轨迹标记", + "IsTrackPushConfigAny": "这个子系统已经存在这个客户的推送映射，无法重复添加" } -} \ No newline at end of file +} diff --git a/src/SJZY.Track.Application/Rabbit/TrackRefreshEventHandler.cs b/src/SJZY.Track.Application/Rabbit/TrackRefreshEventHandler.cs index 14e80f79..2903eb5e 100644 --- a/src/SJZY.Track.Application/Rabbit/TrackRefreshEventHandler.cs +++ b/src/SJZY.Track.Application/Rabbit/TrackRefreshEventHandler.cs @@ -261,7 +261,9 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler IsAdd = true, //S06新增 IsVisibility = false, - Source = (int)TrackSourceEnum.ExternalServiceProvide, + //服务商轨迹默认不对外 + IsExternal = false, + Source = (int) TrackSourceEnum.ExternalServiceProvide, Remarks = null, Files = null, Content = null, @@ -308,6 +310,8 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler TrackEnContent = GlobalConst.EmptyString, //S06新增轨迹明细字段 IsVisibility = false, + //服务商轨迹默认不对外 + IsExternal = false, Source = (int) TrackSourceEnum.ExternalServiceProvide, Remarks = null, Files = null, @@ -315,7 +319,7 @@ public class TrackRefreshEventHandler : ITransientDependency, IRabbitHandler TrackPlaceCityId = null, TrackPlaceProvince = null, TrackPlaceProvinceId = null, - TrackPlaceNation =null, + TrackPlaceNation = null, TrackPlaceNationId = null, TrackPlacePostcode = null, DestinationTimeZone = null, diff --git a/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs b/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs index 48345f81..728fba02 100644 --- a/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs +++ b/src/SJZY.Track.Application/Services/Broadcasting/BroadcastingService.cs @@ -23,10 +23,11 @@ public class BroadcastingService : IBroadcastingService /// 轨迹变更广播 /// /// + /// 轨迹内容中的是否对外 /// 子系统代码 /// 轨迹状态代码 /// - public void TrackChangePublicTopic(TrackUpsertEvent eto, string subSystemCode, string trackStatusCode) + public void TrackChangePublicTopic(TrackUpsertEvent eto, bool contentIsExternal, string subSystemCode, string trackStatusCode) { var data = new TrackChangeEto { @@ -42,6 +43,7 @@ public class BroadcastingService : IBroadcastingService Remarks = eto.Remarks, Source = eto.Source, IsVisibility = eto.IsVisibility, + IsExternal = eto.IsExternal ?? contentIsExternal, TrackTimeZone = eto.TrackTimeZone, TrackTime = eto.TrackTime, TrackPlace = eto.TrackPlace, @@ -66,22 +68,6 @@ public class BroadcastingService : IBroadcastingService Encoding.UTF8.GetBytes(data.ToJson())); } - public void TrackChangePublicTopic(TrackDeleteEvent eto, OrderIdentifier[] orderIdentifiers, string trackCode, string trackStatusCode, string subSystemCode) - { - var data = new TrackChangeEto - { - OrderIdentifiers = orderIdentifiers, - TrackStatusCode = trackStatusCode, - TrackCode = trackCode, - OperationMan = eto.OperationMan, - SubSystemId = eto.SubSystemId, - Option = 2 - }; - - _rabbitClientBus.Publish(GlobalConst.TrackChangeExchange, $"TrackChange.{subSystemCode}", - Encoding.UTF8.GetBytes(data.ToJson())); - } - public void TrackChangePublicTopic(TrackChangeEto eto, string subSystemCode) { eto.Option = 2; diff --git a/src/SJZY.Track.Application/Services/ProvideServices/TrackService.Query.cs b/src/SJZY.Track.Application/Services/ProvideServices/TrackService.Query.cs index 7a7fee72..e5b184cb 100644 --- a/src/SJZY.Track.Application/Services/ProvideServices/TrackService.Query.cs +++ b/src/SJZY.Track.Application/Services/ProvideServices/TrackService.Query.cs @@ -35,25 +35,6 @@ public partial class TrackService //内部子系统不过滤外部轨迹 var isFilterExternal = await HasFilterExternalTrack(); - // 是否对外 - var trackCodes = details.Select(x => x.TrackCode) - .WhereIf(isFilterExternal, x => x != GlobalConst.EmptyString) - .Distinct() - .ToList(); - - var trackContentDic = new Dictionary(); - if (!trackCodes.IsNullOrEmpty()) - { - var trackContents = await _trackContentRepository.GetListAsync(x => - x.SubSystemId == input.SubSystemId && trackCodes.Contains(x.Code), - x => new - { - x.Code, - x.IsExternal - }); - trackContents.ForEach(x => trackContentDic.Add(x.Code, x.IsExternal)); - } - var ossKeys = details .Where(x => x.Files != null && x.Files.Count > 0) .SelectMany(x => x.Files!.Select(y => y.OssKey)) @@ -65,7 +46,7 @@ public partial class TrackService { var item = new GetTrackOutput(); var trackDetails = group - .WhereIf(isFilterExternal, x => trackContentDic.TryGetValue(x.TrackCode, out var isExternal) && isExternal) + .WhereIf(isFilterExternal, x => x.IsExternal) .ToList(); if (trackDetails.Count == 0) continue; @@ -86,8 +67,9 @@ public partial class TrackService TimeZone = Math.Abs(x.TrackTimeZone - GlobalConst.NoneTrackTimeZone) < 1 ? null : input.TimeZone ?? 8, - IsDisplay = trackContentDic.TryGetValue(x.TrackCode, out var isExternal) && isExternal, + IsDisplay = x.IsExternal, IsVisibility = x.IsVisibility, + IsExternal = x.IsExternal, Source = x.Source, Remarks = x.Remarks, Files = x.Files?.Select(y => new FileItemDto @@ -135,25 +117,6 @@ public partial class TrackService //内部子系统不过滤外部轨迹 var isFilterExternal = await HasFilterExternalTrack(); - // 是否对外 - var trackCodes = details.Select(x => x.TrackCode) - .WhereIf(isFilterExternal, x => x != GlobalConst.EmptyString) - .Distinct() - .ToList(); - - var trackContentDic = new Dictionary(); - if (!trackCodes.IsNullOrEmpty()) - { - var trackContents = await _trackContentRepository.GetListAsync(x => - x.SubSystemId == input.SubSystemId && trackCodes.Contains(x.Code), - x => new - { - x.Code, - x.IsExternal - }); - trackContents.ForEach(x => trackContentDic.Add(x.Code, x.IsExternal)); - } - var ossKeys = details .Where(x => x.Files != null && x.Files.Count > 0) .SelectMany(x => x.Files!.Select(y => y.OssKey)) @@ -165,7 +128,7 @@ public partial class TrackService { var item = new GetTrackOutput(); var trackDetails = group - .WhereIf(isFilterExternal, x => trackContentDic.TryGetValue(x.TrackCode, out var isExternal) && isExternal) + .WhereIf(isFilterExternal, x => x.IsExternal) .ToList(); if (trackDetails.Count == 0) continue; @@ -182,8 +145,9 @@ public partial class TrackService Location = x.TrackPlace, Time = x.TrackTime, TimeZone = x.TrackTimeZone, - IsDisplay = trackContentDic.TryGetValue(x.TrackCode, out var isExternal) && isExternal, + IsDisplay = x.IsExternal, IsVisibility = x.IsVisibility, + IsExternal = x.IsExternal, Source = x.Source, Remarks = x.Remarks, Files = x.Files?.Select(y => new FileItemDto diff --git a/src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs b/src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs index f52e1b17..b7b9e305 100644 --- a/src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs +++ b/src/SJZY.Track.Application/Services/ProvideServices/TrackService.cs @@ -399,6 +399,7 @@ public partial class TrackService : ApplicationService, ITrackService OperationMan = userInfo.Data.UserName, OperationManId = userInfo.Data.UserId, IsVisibility = input.IsVisibility, + IsExternal = input.IsExternal, Source = input.Source, Remarks = input.Remarks, Files = input.Files, diff --git a/src/SJZY.Track.Application/Services/TrackOrders/TrackOrderService.cs b/src/SJZY.Track.Application/Services/TrackOrders/TrackOrderService.cs index 53bfc8c3..6e709973 100644 --- a/src/SJZY.Track.Application/Services/TrackOrders/TrackOrderService.cs +++ b/src/SJZY.Track.Application/Services/TrackOrders/TrackOrderService.cs @@ -217,7 +217,7 @@ public class TrackOrderService : ApplicationService foreach (var item in trackDetails) { //如果是外部系统，且轨迹内容不对外则跳过这条轨迹内容 - if (system.SystemProperty == 2 && !item.IsVisibility) + if (system.SystemProperty == 2 && !item.IsExternal) continue; //时间和时区任意一个为空则使用创建时间做为排序参照值 diff --git a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsEsRepository.cs b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsEsRepository.cs index b434e8b6..48eac8cb 100644 --- a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsEsRepository.cs +++ b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/ITrackDetailsEsRepository.cs @@ -35,4 +35,6 @@ public interface ITrackDetailsEsRepository : IElasticsearchClientService> GetDataByIds(string[] ids); Task GetDetailAsync(string orderNo, string trackCode, int orderType, int subSystemId, DateTime trackTime); + + Task MigrateAsync(); } diff --git a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs index 02cb6b51..9cb1adec 100644 --- a/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs +++ b/src/SJZY.Track.Domain/Aggregates/TrackDetailsAggregate/TrackDetailsIndex.cs @@ -125,8 +125,14 @@ public class TrackDetailsIndex : IdBaseIndex /// /// 客户是否可见 /// + [Obsolete("废弃的，请使用IsExternal")] public bool IsVisibility { get; set; } + /// + /// 是否对外 + /// + public bool IsExternal { get; set; } + /// /// 数据来源：1外部服务商创建，2内部系统创建，3人工创建 /// diff --git a/src/SJZY.Track.Domain/Dtos/TrackContents/TrackContentVO.cs b/src/SJZY.Track.Domain/Dtos/TrackContents/TrackContentVO.cs index 374787e5..f9a126fb 100644 --- a/src/SJZY.Track.Domain/Dtos/TrackContents/TrackContentVO.cs +++ b/src/SJZY.Track.Domain/Dtos/TrackContents/TrackContentVO.cs @@ -67,6 +67,11 @@ public class TrackContentVO /// public bool IsToMq { get; set; } + /// + /// 是否对外 + /// + public bool IsExternal { get; set; } + /// /// 轨迹内容code /// diff --git a/src/SJZY.Track.Repository/Repositories/TrackContentRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackContentRepository.cs index 7db9435d..2c49ff0e 100644 --- a/src/SJZY.Track.Repository/Repositories/TrackContentRepository.cs +++ b/src/SJZY.Track.Repository/Repositories/TrackContentRepository.cs @@ -270,6 +270,7 @@ public class TrackContentRepository : BasicRepository, ITrac IsAllowManuallyUpdate = x.IsAllowManuallyUpdate, IsAllowManuallyCreate = x.IsAllowManuallyCreate, IsToMq = y.IsToMq, + IsExternal = x.IsExternal }).ToListAsync(); } } diff --git a/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs b/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs index b9bf22af..46f97255 100644 --- a/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs +++ b/src/SJZY.Track.Repository/Repositories/TrackDetailsEsRepository.cs @@ -162,6 +162,7 @@ public class TrackDetailsEsRepository : ElasticSearchContextAbstract(m => m + .AutoMap()); + //字段迁移，isVisibility => isExternal + await Context.UpdateByQueryAsync(u => u + .Query(q => q.MatchAll()) + .Script(s=>s.Source("ctx._source.isExternal = ctx._source.isVisibility")) + ); + } }