修改了目录架构

DMS.Application/Services/Database/MqttAppService.cs

@@ -0,0 +1,121 @@
+using AutoMapper;
+using DMS.Application.DTOs;
+using DMS.Application.Interfaces;
+using DMS.Application.Interfaces.Database;
+using DMS.Core.Interfaces;
+using DMS.Core.Models;
+
+namespace DMS.Application.Services.Database;
+
+/// <summary>
+/// MQTT应用服务，负责处理MQTT服务器相关的业务逻辑。
+/// 实现 <see cref="IMqttAppService"/> 接口。
+/// </summary>
+public class MqttAppService : IMqttAppService
+{
+    private readonly IRepositoryManager _repoManager;
+    private readonly IMapper _mapper;
+
+    /// <summary>
+    /// 构造函数，通过依赖注入获取仓储管理器和AutoMapper实例。
+    /// </summary>
+    /// <param name="repoManager">仓储管理器实例。</param>
+    /// <param name="mapper">AutoMapper 实例。</param>
+    public MqttAppService(IRepositoryManager repoManager, IMapper mapper)
+    {
+        _repoManager = repoManager;
+        _mapper = mapper;
+    }
+
+    /// <summary>
+    /// 异步根据ID获取MQTT服务器数据传输对象。
+    /// </summary>
+    /// <param name="id">MQTT服务器ID。</param>
+    /// <returns>MQTT服务器数据传输对象。</returns>
+    public async Task<MqttServerDto> GetMqttServerByIdAsync(int id)
+    {
+        var mqttServer = await _repoManager.MqttServers.GetByIdAsync(id);
+        return _mapper.Map<MqttServerDto>(mqttServer);
+    }
+
+    /// <summary>
+    /// 异步获取所有MQTT服务器数据传输对象列表。
+    /// </summary>
+    /// <returns>MQTT服务器数据传输对象列表。</returns>
+    public async Task<List<MqttServerDto>> GetAllMqttServersAsync()
+    {
+        var mqttServers = await _repoManager.MqttServers.GetAllAsync();
+        return _mapper.Map<List<MqttServerDto>>(mqttServers);
+    }
+
+    /// <summary>
+    /// 异步创建一个新MQTT服务器（事务性操作）。
+    /// </summary>
+    /// <param name="mqttServerDto">要创建的MQTT服务器数据传输对象。</param>
+    /// <returns>新创建MQTT服务器的ID。</returns>
+    /// <exception cref="ApplicationException">如果创建MQTT服务器时发生错误。</exception>
+    public async Task<int> CreateMqttServerAsync(MqttServerDto mqttServerDto)
+    {
+        try
+        {
+            await _repoManager.BeginTranAsync();
+            var mqttServer = _mapper.Map<MqttServer>(mqttServerDto);
+            await _repoManager.MqttServers.AddAsync(mqttServer);
+            await _repoManager.CommitAsync();
+            return mqttServer.Id;
+        }
+        catch (Exception ex)
+        {
+            await _repoManager.RollbackAsync();
+            throw new ApplicationException("创建MQTT服务器时发生错误，操作已回滚。", ex);
+        }
+    }
+
+    /// <summary>
+    /// 异步更新一个已存在的MQTT服务器（事务性操作）。
+    /// </summary>
+    /// <param name="mqttServerDto">要更新的MQTT服务器数据传输对象。</param>
+    /// <returns>表示异步操作的任务。</returns>
+    /// <exception cref="ApplicationException">如果找不到MQTT服务器或更新MQTT服务器时发生错误。</exception>
+    public async Task UpdateMqttServerAsync(MqttServerDto mqttServerDto)
+    {
+        try
+        {
+            await _repoManager.BeginTranAsync();
+            var mqttServer = await _repoManager.MqttServers.GetByIdAsync(mqttServerDto.Id);
+            if (mqttServer == null)
+            {
+                throw new ApplicationException($"MQTT Server with ID {mqttServerDto.Id} not found.");
+            }
+            _mapper.Map(mqttServerDto, mqttServer);
+            await _repoManager.MqttServers.UpdateAsync(mqttServer);
+            await _repoManager.CommitAsync();
+        }
+        catch (Exception ex)
+        {
+            await _repoManager.RollbackAsync();
+            throw new ApplicationException("更新MQTT服务器时发生错误，操作已回滚。", ex);
+        }
+    }
+
+    /// <summary>
+    /// 异步删除一个MQTT服务器（事务性操作）。
+    /// </summary>
+    /// <param name="id">要删除MQTT服务器的ID。</param>
+    /// <returns>表示异步操作的任务。</returns>
+    /// <exception cref="ApplicationException">如果删除MQTT服务器时发生错误。</exception>
+    public async Task DeleteMqttServerAsync(int id)
+    {
+        try
+        {
+            await _repoManager.BeginTranAsync();
+            await _repoManager.MqttServers.DeleteByIdAsync(id);
+            await _repoManager.CommitAsync();
+        }
+        catch (Exception ex)
+        {
+            await _repoManager.RollbackAsync();
+            throw new ApplicationException("删除MQTT服务器时发生错误，操作已回滚。", ex);
+        }
+    }
+}