ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:修复运输预警场景规则项目在没有任何变更时保存，直接跳过即可

Browse Source
This commit is contained in:
hardstylewyl 2025-03-20 10:30:34 +08:00
parent 653880fb37
commit 9615b6257e
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/SJZY.Track.Application/Services/Warning/Handlers/TransportWarningHandler.cs
View File

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