using AutoMapper; using DMS.Application.DTOs; using DMS.Application.Interfaces; using DMS.Application.Interfaces.Database; using DMS.Core.Enums; using DMS.Core.Interfaces; using DMS.Core.Models; namespace DMS.Application.Services.Database { /// /// 变量表应用服务,负责处理变量表相关的业务逻辑。 /// 实现 接口。 /// public class VariableTableAppService : IVariableTableAppService { private readonly IRepositoryManager _repositoryManager; private readonly IAppDataService _appDataService; private readonly IMapper _mapper; /// /// 构造函数,注入仓储管理器和AutoMapper。 /// /// 仓储管理器实例。 /// AutoMapper 实例。 public VariableTableAppService(IRepositoryManager repositoryManager, IAppDataService appDataService, IMapper mapper) { _repositoryManager = repositoryManager; _appDataService = appDataService; _mapper = mapper; } /// /// 异步根据ID获取变量表。 /// /// 变量表ID。 /// 变量表数据传输对象。 public async Task GetVariableTableByIdAsync(int id) { var variableTable = await _repositoryManager.VariableTables.GetByIdAsync(id); return _mapper.Map(variableTable); } /// /// 异步获取所有变量表。 /// /// 变量表数据传输对象列表。 public async Task> GetAllVariableTablesAsync() { var variableTables = await _repositoryManager.VariableTables.GetAllAsync(); return _mapper.Map>(variableTables); } /// /// 异步创建变量表,并可选择性地创建关联菜单。 /// /// 包含变量表和菜单信息的创建数据传输对象。 /// 创建后的变量表数据传输对象。 /// 如果添加变量表失败或找不到设备菜单。 public async Task AddAsync(CreateVariableTableWithMenuDto createDto) { await _repositoryManager.BeginTranAsync(); try { createDto.VariableTable = await _repositoryManager.VariableTables.AddAsync(createDto.VariableTable); if (createDto.VariableTable.Id == 0) { throw new ApplicationException($"添加变量表失败,设备ID:{createDto.VariableTable.DeviceId},请检查。"); } if (createDto.Menu is not null) { createDto.Menu.TargetId = createDto.VariableTable.Id; //映射菜单实体并设置关联信息 createDto.Menu = await _repositoryManager.Menus.AddAsync(createDto.Menu); } await _repositoryManager.CommitAsync(); return createDto; } catch { await _repositoryManager.RollbackAsync(); throw; } } /// /// 异步更新变量表。 /// /// 要更新的变量表数据传输对象。 /// 受影响的行数。 /// 如果找不到变量表。 public async Task UpdateAsync(VariableTable variableTable) { int res = await _repositoryManager.VariableTables.UpdateAsync(variableTable); // 更新关联的菜单树 var menu = _appDataService.Menus.Values.FirstOrDefault(m => m.MenuType == MenuType.VariableTableMenu && m.TargetId == variableTable.Id); if (menu is not null && variableTable.Name!= menu.Header) { menu.Header = variableTable.Name; // 更新关联的菜单树 await _repositoryManager.Menus.UpdateAsync(menu); } return res; } /// /// 异步根据ID删除变量表,包括其关联的变量、MQTT别名和菜单(事务性操作)。 /// /// 要删除的变量表ID。 /// 如果删除成功则为 true,否则为 false。 /// 如果删除变量表失败。 /// 如果删除变量表时发生其他错误。 public async Task DeleteAsync(VariableTable variableTable) { try { await _repositoryManager.BeginTranAsync(); var delRes = await _repositoryManager.VariableTables.DeleteAsync(variableTable); // 删除关联的菜单树 var menu = _appDataService.Menus.Values.FirstOrDefault(m => m.MenuType == MenuType.VariableTableMenu && m.TargetId == variableTable.Id); if (menu is not null) { // 删除关联的菜单树 await _repositoryManager.Menus.DeleteAsync(menu); } await _repositoryManager.CommitAsync(); return true; } catch (Exception ex) { await _repositoryManager.RollbackAsync(); // 可以在此记录日志 throw new ApplicationException($"删除变量表时发生错误,操作已回滚,错误信息:{ex.Message}", ex); } } } }