using DMS.Application.Interfaces.Database; using DMS.Core.Interfaces; using DMS.Core.Models; namespace DMS.Application.Services.Database; /// /// MQTT应用服务,负责处理MQTT服务器相关的业务逻辑。 /// 实现 接口。 /// public class MqttAppService : IMqttAppService { private readonly IRepositoryManager _repoManager; /// /// 构造函数,通过依赖注入获取仓储管理器实例。 /// /// 仓储管理器实例。 public MqttAppService(IRepositoryManager repoManager) { _repoManager = repoManager; } /// /// 异步根据ID获取MQTT服务器。 /// /// MQTT服务器ID。 /// MQTT服务器。 public async Task GetMqttServerByIdAsync(int id) { return await _repoManager.MqttServers.GetByIdAsync(id); } /// /// 异步获取所有MQTT服务器列表。 /// /// MQTT服务器列表。 public async Task> GetAllMqttServersAsync() { var mqttServers = await _repoManager.MqttServers.GetAllAsync(); return mqttServers.ToList(); } /// /// 异步创建一个新MQTT服务器(事务性操作)。 /// /// 要创建的MQTT服务器。 /// 新创建MQTT服务器的ID。 /// 如果创建MQTT服务器时发生错误。 public async Task CreateMqttServerAsync(MqttServer mqttServer) { try { await _repoManager.BeginTranAsync(); await _repoManager.MqttServers.AddAsync(mqttServer); await _repoManager.CommitAsync(); return mqttServer.Id; } catch (Exception ex) { await _repoManager.RollbackAsync(); throw new ApplicationException("创建MQTT服务器时发生错误,操作已回滚。", ex); } } /// /// 异步更新一个已存在的MQTT服务器(事务性操作)。 /// /// 要更新的MQTT服务器。 /// 表示异步操作的任务。 /// 如果找不到MQTT服务器或更新MQTT服务器时发生错误。 public async Task UpdateMqttServerAsync(MqttServer mqttServer) { try { await _repoManager.BeginTranAsync(); var existingMqttServer = await _repoManager.MqttServers.GetByIdAsync(mqttServer.Id); if (existingMqttServer == null) { throw new ApplicationException($"MQTT Server with ID {mqttServer.Id} not found."); } existingMqttServer.ServerName = mqttServer.ServerName; existingMqttServer.ServerUrl = mqttServer.ServerUrl; existingMqttServer.Port = mqttServer.Port; existingMqttServer.Username = mqttServer.Username; existingMqttServer.Password = mqttServer.Password; existingMqttServer.IsActive = mqttServer.IsActive; existingMqttServer.IsConnect = mqttServer.IsConnect; existingMqttServer.SubscribeTopic = mqttServer.SubscribeTopic; existingMqttServer.PublishTopic = mqttServer.PublishTopic; existingMqttServer.ClientId = mqttServer.ClientId; existingMqttServer.MessageFormat = mqttServer.MessageFormat; existingMqttServer.MessageHeader = mqttServer.MessageHeader; existingMqttServer.MessageContent = mqttServer.MessageContent; existingMqttServer.MessageFooter = mqttServer.MessageFooter; await _repoManager.MqttServers.UpdateAsync(existingMqttServer); await _repoManager.CommitAsync(); } catch (Exception ex) { await _repoManager.RollbackAsync(); throw new ApplicationException("更新MQTT服务器时发生错误,操作已回滚。", ex); } } /// /// 异步根据ID删除一个MQTT服务器(事务性操作)。 /// /// 要删除MQTT服务器的ID。 /// 如果删除成功则为 true,否则为 false。 /// 如果删除MQTT服务器时发生错误。 public async Task DeleteMqttServerAsync(int id) { try { var mqttServer = await _repoManager.MqttServers.GetByIdAsync(id); if (mqttServer == null) { return 0; } return await _repoManager.MqttServers.DeleteAsync(mqttServer); } catch (Exception ex) { await _repoManager.RollbackAsync(); throw new ApplicationException($"删除MQTT服务器时发生错误,操作已回滚,错误信息:{ex.Message}", ex); } } /// /// 异步批量更新MQTT服务器(事务性操作)。 /// /// 要更新的MQTT服务器列表。 /// 成功更新的MQTT服务器数量。 /// 如果批量更新MQTT服务器时发生错误。 public async Task UpdateMqttServersAsync(List mqttServers) { try { await _repoManager.BeginTranAsync(); var count = 0; foreach (var mqttServer in mqttServers) { var existingMqttServer = await _repoManager.MqttServers.GetByIdAsync(mqttServer.Id); if (existingMqttServer != null) { existingMqttServer.ServerName = mqttServer.ServerName; existingMqttServer.ServerUrl = mqttServer.ServerUrl; existingMqttServer.Port = mqttServer.Port; existingMqttServer.Username = mqttServer.Username; existingMqttServer.Password = mqttServer.Password; existingMqttServer.IsActive = mqttServer.IsActive; existingMqttServer.IsConnect = mqttServer.IsConnect; existingMqttServer.SubscribeTopic = mqttServer.SubscribeTopic; existingMqttServer.PublishTopic = mqttServer.PublishTopic; existingMqttServer.ClientId = mqttServer.ClientId; existingMqttServer.MessageFormat = mqttServer.MessageFormat; existingMqttServer.MessageHeader = mqttServer.MessageHeader; existingMqttServer.MessageContent = mqttServer.MessageContent; existingMqttServer.MessageFooter = mqttServer.MessageFooter; await _repoManager.MqttServers.UpdateAsync(existingMqttServer); count++; } } await _repoManager.CommitAsync(); return count; } catch (Exception ex) { await _repoManager.RollbackAsync(); throw new ApplicationException("批量更新MQTT服务器时发生错误,操作已回滚。", ex); } } // /// // /// 异步批量删除MQTT服务器(事务性操作)。 // /// // /// 要删除的MQTT服务器ID列表。 // /// 如果删除成功则为 true,否则为 false。 // /// 如果批量删除MQTT服务器时发生错误。 // public async Task DeleteMqttServersAsync(List ids) // { // try // { // if (ids == null || !ids.Any()) return true; // // await _repoManager.BeginTranAsync(); // var result = await _repoManager.MqttServers.DeleteByIdsAsync(ids); // await _repoManager.CommitAsync(); // return result > 0; // } // catch (Exception ex) // { // await _repoManager.RollbackAsync(); // throw new ApplicationException($"批量删除MQTT服务器时发生错误,操作已回滚,错误信息:{ex.Message}", ex); // } // } }