87 lines
2.8 KiB
C#
87 lines
2.8 KiB
C#
using AutoMapper;
|
||
using DMS.Core.Interfaces;
|
||
using DMS.Core.Models;
|
||
using DMS.Application.DTOs;
|
||
using DMS.Application.Interfaces;
|
||
|
||
namespace DMS.Application.Services;
|
||
|
||
/// <summary>
|
||
/// 实现MQTT别名管理的应用服务。
|
||
/// </summary>
|
||
public class MqttAliasAppService : IMqttAliasAppService
|
||
{
|
||
private readonly IRepositoryManager _repoManager;
|
||
private readonly IMapper _mapper;
|
||
|
||
public MqttAliasAppService(IRepositoryManager repoManager, IMapper mapper)
|
||
{
|
||
_repoManager = repoManager;
|
||
_mapper = mapper;
|
||
}
|
||
|
||
public async Task<VariableMqttAliasDto> GetMqttAliasByIdAsync(int id)
|
||
{
|
||
var mqttAlias = await _repoManager.VariableMqttAliases.GetByIdAsync(id);
|
||
return _mapper.Map<VariableMqttAliasDto>(mqttAlias);
|
||
}
|
||
|
||
public async Task<List<VariableMqttAliasDto>> GetAllMqttAliasesAsync()
|
||
{
|
||
var mqttAliases = await _repoManager.VariableMqttAliases.GetAllAsync();
|
||
return _mapper.Map<List<VariableMqttAliasDto>>(mqttAliases);
|
||
}
|
||
|
||
public async Task<int> CreateMqttAliasAsync(VariableMqttAliasDto mqttAliasDto)
|
||
{
|
||
try
|
||
{
|
||
_repoManager.BeginTranAsync();
|
||
var mqttAlias = _mapper.Map<VariableMqttAlias>(mqttAliasDto);
|
||
await _repoManager.VariableMqttAliases.AddAsync(mqttAlias);
|
||
await _repoManager.CommitAsync();
|
||
return mqttAlias.Id;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
await _repoManager.RollbackAsync();
|
||
throw new ApplicationException("创建MQTT别名时发生错误，操作已回滚。", ex);
|
||
}
|
||
}
|
||
|
||
public async Task UpdateMqttAliasAsync(VariableMqttAliasDto mqttAliasDto)
|
||
{
|
||
try
|
||
{
|
||
_repoManager.BeginTranAsync();
|
||
var mqttAlias = await _repoManager.VariableMqttAliases.GetByIdAsync(mqttAliasDto.Id);
|
||
if (mqttAlias == null)
|
||
{
|
||
throw new ApplicationException($"MQTT Alias with ID {mqttAliasDto.Id} not found.");
|
||
}
|
||
_mapper.Map(mqttAliasDto, mqttAlias);
|
||
await _repoManager.VariableMqttAliases.UpdateAsync(mqttAlias);
|
||
await _repoManager.CommitAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
await _repoManager.RollbackAsync();
|
||
throw new ApplicationException("更新MQTT别名时发生错误，操作已回滚。", ex);
|
||
}
|
||
}
|
||
|
||
public async Task DeleteMqttAliasAsync(int id)
|
||
{
|
||
try
|
||
{
|
||
_repoManager.BeginTranAsync();
|
||
await _repoManager.VariableMqttAliases.DeleteByIdAsync(id);
|
||
await _repoManager.CommitAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
await _repoManager.RollbackAsync();
|
||
throw new ApplicationException("删除MQTT别名时发生错误，操作已回滚。", ex);
|
||
}
|
||
}
|
||
} |