xiaowei/DMS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改触发器相关的内容

Browse Source
This commit is contained in:
David P.G
2025-09-23 09:28:08 +08:00
parent 2d457ae248
commit eb4bee8963
6 changed files with 60 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
DMS.Application/Services/Management/ITriggerManagementService.cs
View File

@@ -1,52 +0,0 @@
using DMS.Application.DTOs;
namespace DMS.Application.Services.Management
{
/// <summary>
/// 触发器管理服务接口 (负责 CRUD 操作)
/// </summary>
public interface ITriggerManagementService
{
/// <summary>
/// 获取所有触发器定义
/// </summary>
/// <returns>触发器定义列表</returns>
Task<List<TriggerDefinitionDto>> GetAllTriggersAsync();
/// <summary>
/// 根据 ID 获取触发器定义
/// </summary>
/// <param name="id">触发器 ID</param>
/// <returns>触发器定义 DTO，如果未找到则返回 null</returns>
Task<TriggerDefinitionDto?> GetTriggerByIdAsync(int id);
/// <summary>
/// 创建一个新的触发器定义
/// </summary>
/// <param name="triggerDto">要创建的触发器定义 DTO</param>
/// <returns>创建成功的触发器定义 DTO</returns>
Task<TriggerDefinitionDto> CreateTriggerAsync(TriggerDefinitionDto triggerDto);
/// <summary>
/// 更新一个已存在的触发器定义
/// </summary>
/// <param name="id">要更新的触发器 ID</param>
/// <param name="triggerDto">包含更新信息的触发器定义 DTO</param>
/// <returns>更新后的触发器定义 DTO，如果未找到则返回 null</returns>
Task<TriggerDefinitionDto?> UpdateTriggerAsync(int id, TriggerDefinitionDto triggerDto);
/// <summary>
/// 删除一个触发器定义
/// </summary>
/// <param name="id">要删除的触发器 ID</param>
/// <returns>删除成功返回 true，否则返回 false</returns>
Task<bool> DeleteTriggerAsync(int id);
/// <summary>
/// 获取与指定变量关联的所有触发器定义
/// </summary>
/// <param name="variableId">变量 ID</param>
/// <returns>该变量关联的触发器定义列表</returns>
Task<List<TriggerDefinitionDto>> GetTriggersForVariableAsync(int variableId);
}
}

30
DMS.Application/Services/Management/TriggerManagementService.cs
View File

@@ -1,5 +1,7 @@
using AutoMapper;
using DMS.Application.DTOs;
using DMS.Application.Interfaces;
using DMS.Application.Interfaces.Management;
using DMS.Application.Services.Triggers;
using DMS.Core.Interfaces;
using DMS.Core.Models.Triggers;
@@ -13,11 +15,13 @@ namespace DMS.Application.Services.Management
{
private readonly IRepositoryManager _repositoryManager;
private readonly IMapper _mapper;
private readonly IAppDataStorageService _appDataStorageService;
public TriggerManagementService(IRepositoryManager repositoryManager, IMapper mapper)
public TriggerManagementService(IRepositoryManager repositoryManager, IMapper mapper, IAppDataStorageService appDataStorageService)
{
_repositoryManager = repositoryManager ?? throw new ArgumentNullException(nameof(repositoryManager));
_mapper = mapper ?? throw new ArgumentNullException(nameof(mapper));
_appDataStorageService = appDataStorageService ?? throw new ArgumentNullException(nameof(appDataStorageService));
}
/// <summary>
@@ -55,7 +59,12 @@ namespace DMS.Application.Services.Management
var createdTrigger = await _repositoryManager.Triggers.AddAsync(triggerEntity);
// 4. 转换回 DTO 并返回
return _mapper.Map<TriggerDefinitionDto>(createdTrigger);
var result = _mapper.Map<TriggerDefinitionDto>(createdTrigger);
// 5. 同步更新AppDataStorageService中的Triggers字典
_appDataStorageService.Triggers[result.Id] = result;
return result;
}
/// <summary>
@@ -81,7 +90,12 @@ namespace DMS.Application.Services.Management
return null;
// 5. 转换回 DTO 并返回
return _mapper.Map<TriggerDefinitionDto>(updatedTrigger);
var result = _mapper.Map<TriggerDefinitionDto>(updatedTrigger);
// 6. 同步更新AppDataStorageService中的Triggers字典
_appDataStorageService.Triggers[result.Id] = result;
return result;
}
/// <summary>
@@ -89,7 +103,15 @@ namespace DMS.Application.Services.Management
/// </summary>
public async Task<bool> DeleteTriggerAsync(int id)
{
return await _repositoryManager.Triggers.DeleteAsync(id);
var result = await _repositoryManager.Triggers.DeleteAsync(id);
// 如果删除成功，也从AppDataStorageService中的Triggers字典中移除
if (result)
{
_appDataStorageService.Triggers.TryRemove(id, out _);
}
return result;
}
/// <summary>