From 9615b6257e83bdf2d586f5623e183ccc492a801f Mon Sep 17 00:00:00 2001 From: hardstylewyl <827778732@qq.com> Date: Thu, 20 Mar 2025 10:30:34 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D=E8=BF=90=E8=BE=93?= =?UTF-8?q?=E9=A2=84=E8=AD=A6=E5=9C=BA=E6=99=AF=E8=A7=84=E5=88=99=E9=A1=B9?= =?UTF-8?q?=E7=9B=AE=E5=9C=A8=E6=B2=A1=E6=9C=89=E4=BB=BB=E4=BD=95=E5=8F=98?= =?UTF-8?q?=E6=9B=B4=E6=97=B6=E4=BF=9D=E5=AD=98=EF=BC=8C=E7=9B=B4=E6=8E=A5?= =?UTF-8?q?=E8=B7=B3=E8=BF=87=E5=8D=B3=E5=8F=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Handlers/TransportWarningHandler.cs | 21 ++++++++++++++----- 1 file changed, 16 insertions(+), 5 deletions(-) diff --git a/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs b/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs index a4dd9e6a..5daf8e35 100644 --- a/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs +++ b/src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs @@ -759,12 +759,23 @@ public class TransportWarningHandler : ITransportWarningHandler, ITransientDepen ) { // 新增/修改/删除 实体,稍后做处理 - var addEntities = TransportWarningSceneRuleItemBO.ToEntities(addRuleItems); - var updateEntities = TransportWarningSceneRuleItemBO.ToEntities(updateRuleItems); + if (addRuleItems.Count > 0) + { + var addEntities = TransportWarningSceneRuleItemBO.ToEntities(addRuleItems); + await _warningRuleRepository.BulkInsertTransportSceneRuleItemsAsync(addEntities); + } + + if (updateRuleItems.Count > 0) + { + var updateEntities = TransportWarningSceneRuleItemBO.ToEntities(updateRuleItems); + await _warningRuleRepository.BulkUpdateTransportSceneRuleItemsAsync(updateEntities); + } + var deleteRuleItemIds = deleteRuleItems.Select(x => x.Id).ToHashSet(); - await _warningRuleRepository.BulkInsertTransportSceneRuleItemsAsync(addEntities); - await _warningRuleRepository.BulkUpdateTransportSceneRuleItemsAsync(updateEntities); - await _warningRuleRepository.DeleteTransportSceneRuleItemsAsync(deleteRuleItemIds); + if (deleteRuleItemIds.Count > 0) + await _warningRuleRepository.DeleteTransportSceneRuleItemsAsync(deleteRuleItemIds); + + if (updateRuleItems.Count == 0) return; // 1.查询变更配置相关的预警生成任务(未关闭的) var updateRuleItemIds = updateRuleItems.Select(x => x.Id).ToHashSet();