diff --git a/src/SJZY.Track.Application/Services/Warning/Handlers/CompleteWarningHandler.cs b/src/SJZY.Track.Application/Services/Warning/Handlers/CompleteWarningHandler.cs index 38a3a3f2..d7f69306 100644 --- a/src/SJZY.Track.Application/Services/Warning/Handlers/CompleteWarningHandler.cs +++ b/src/SJZY.Track.Application/Services/Warning/Handlers/CompleteWarningHandler.cs @@ -29,7 +29,7 @@ public sealed class CompleteWarningHandler : ICompleteWarningHandler, ITransient _warningTaskRepository = warningTaskRepository; } - #region todo: 预警信号批处理-删除轨迹 + #region 预警信号批处理-删除轨迹 public async Task TrackDeletedHandleAsync(List deletedSignals) { @@ -91,11 +91,9 @@ public sealed class CompleteWarningHandler : ICompleteWarningHandler, ITransient detail.MissingTrackStatusIds = expression; updateDetails.Add(detail); } - - // tips:需要处理要求轨迹完整的情况? } - // 6.批量更新轨迹 + // 6.批量更新预警明细 if (updateDetails.Count > 0) await _warningDetailsEsRepository.BulkUpdateCompleteWarningDetailsAsync(updateDetails); diff --git a/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs b/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs index d69f1d9f..ecb9b572 100644 --- a/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs +++ b/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs @@ -548,6 +548,9 @@ public class TransportWarningHandler : ITransportWarningHandler, ITransientDepen if (!CanSceneChange(oldScene, postScene)) return; + // 更新规则主体版本号 + await _warningRuleRepository.UpdateVersionAsync(rule); + // 1.找到该场景下所有的预警生成任务(未关闭的) var generateTasks = await _warningTaskRepository.GetTransportWarningDetailsGenerateTaskAsync(x => !x.IsClosed @@ -649,6 +652,9 @@ public class TransportWarningHandler : ITransportWarningHandler, ITransientDepen public async Task HandleSceneDeletedAsync(WarningRuleEntity rule, TransportWarningSceneBO scene) { + // 更新规则主体版本号 + await _warningRuleRepository.UpdateVersionAsync(rule); + // 1.预警信息状态修改为已关闭(即将超时/已超时) await _warningDetailsEsRepository.BulkCloseTransportWarningDetailsAsync(new BulkCloseTransportWarningDetailsVO { @@ -796,6 +802,9 @@ public class TransportWarningHandler : ITransportWarningHandler, ITransientDepen await HandleDeleteAsync(deleteRuleItemIds); } + // 更新规则主体版本号 + await _warningRuleRepository.UpdateVersionAsync(rule); + // 不存在更新需要关注的 if (updateFollowRuleItems.Count == 0) return;