From 84720f1ac46a573853b81dbf6ff4abba62f3d137 Mon Sep 17 00:00:00 2001 From: "David P.G" Date: Sun, 7 Sep 2025 21:16:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=86=E5=88=86DataCenterService(=E6=9C=AA?= =?UTF-8?q?=E5=AE=8C=E6=88=90)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DMS.Application/Services/DataCenterService.cs | 295 +++++------------- .../Services/DeviceManagementService.cs | 134 ++++++++ .../Services/LogManagementService.cs | 105 +++++++ .../Services/MenuManagementService.cs | 174 +++++++++++ .../Services/MqttManagementService.cs | 113 +++++++ .../Services/VariableManagementService.cs | 149 +++++++++ .../VariableTableManagementService.cs | 143 +++++++++ 7 files changed, 893 insertions(+), 220 deletions(-) create mode 100644 DMS.Application/Services/DeviceManagementService.cs create mode 100644 DMS.Application/Services/LogManagementService.cs create mode 100644 DMS.Application/Services/MenuManagementService.cs create mode 100644 DMS.Application/Services/MqttManagementService.cs create mode 100644 DMS.Application/Services/VariableManagementService.cs create mode 100644 DMS.Application/Services/VariableTableManagementService.cs diff --git a/DMS.Application/Services/DataCenterService.cs b/DMS.Application/Services/DataCenterService.cs index 4fd66df..657c166 100644 --- a/DMS.Application/Services/DataCenterService.cs +++ b/DMS.Application/Services/DataCenterService.cs @@ -22,12 +22,14 @@ public class DataCenterService : IDataCenterService { private readonly IRepositoryManager _repositoryManager; private readonly IMapper _mapper; - private readonly IDeviceAppService _deviceAppService; - private readonly IVariableTableAppService _variableTableAppService; - private readonly IVariableAppService _variableAppService; - private readonly IMenuService _menuService; - private readonly IMqttAppService _mqttAppService; - private readonly INlogAppService _nlogAppService; + + // 管理服务 + private readonly DeviceManagementService _deviceManagementService; + private readonly VariableTableManagementService _variableTableManagementService; + private readonly VariableManagementService _variableManagementService; + private readonly MenuManagementService _menuManagementService; + private readonly MqttManagementService _mqttManagementService; + private readonly LogManagementService _logManagementService; /// /// 安全字典，用于存储所有设备数据 @@ -131,12 +133,14 @@ public class DataCenterService : IDataCenterService { _repositoryManager = repositoryManager; _mapper = mapper; - _deviceAppService = deviceAppService; - _variableTableAppService = variableTableAppService; - _variableAppService = variableAppService; - _menuService = menuService; - _mqttAppService = mqttAppService; - _nlogAppService = nlogAppService; + + // 初始化管理服务 + _deviceManagementService = new DeviceManagementService(deviceAppService, Devices); + _variableTableManagementService = new VariableTableManagementService(variableTableAppService, VariableTables); + _variableManagementService = new VariableManagementService(variableAppService, Variables); + _menuManagementService = new MenuManagementService(menuService, Menus, MenuTrees); + _mqttManagementService = new MqttManagementService(mqttAppService, MqttServers); + _logManagementService = new LogManagementService(nlogAppService, Nlogs); } #region 设备管理 @@ -146,7 +150,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetDeviceByIdAsync(int id) { - return await _deviceAppService.GetDeviceByIdAsync(id); + return await _deviceManagementService.GetDeviceByIdAsync(id); } /// @@ -154,7 +158,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllDevicesAsync() { - return await _deviceAppService.GetAllDevicesAsync(); + return await _deviceManagementService.GetAllDevicesAsync(); } /// @@ -162,7 +166,7 @@ public class DataCenterService : IDataCenterService /// public async Task CreateDeviceWithDetailsAsync(CreateDeviceWithDetailsDto dto) { - return await _deviceAppService.CreateDeviceWithDetailsAsync(dto); + return await _deviceManagementService.CreateDeviceWithDetailsAsync(dto); } /// @@ -170,7 +174,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateDeviceAsync(DeviceDto deviceDto) { - return await _deviceAppService.UpdateDeviceAsync(deviceDto); + return await _deviceManagementService.UpdateDeviceAsync(deviceDto); } /// @@ -178,7 +182,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteDeviceByIdAsync(int deviceId) { - return await _deviceAppService.DeleteDeviceByIdAsync(deviceId); + return await _deviceManagementService.DeleteDeviceByIdAsync(deviceId); } /// @@ -186,7 +190,7 @@ public class DataCenterService : IDataCenterService /// public async Task ToggleDeviceActiveStateAsync(int id) { - await _deviceAppService.ToggleDeviceActiveStateAsync(id); + await _deviceManagementService.ToggleDeviceActiveStateAsync(id); } /// @@ -194,10 +198,7 @@ public class DataCenterService : IDataCenterService /// public void AddDeviceToMemory(DeviceDto deviceDto) { - if (Devices.TryAdd(deviceDto.Id, deviceDto)) - { - OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Added, deviceDto)); - } + _deviceManagementService.AddDeviceToMemory(deviceDto, VariableTables, Variables); } /// @@ -205,8 +206,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateDeviceInMemory(DeviceDto deviceDto) { - Devices.AddOrUpdate(deviceDto.Id, deviceDto, (key, oldValue) => deviceDto); - OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Updated, deviceDto)); + _deviceManagementService.UpdateDeviceInMemory(deviceDto); } /// @@ -214,22 +214,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveDeviceFromMemory(int deviceId) { - if (Devices.TryGetValue(deviceId, out var deviceDto)) - { - foreach (var variableTable in deviceDto.VariableTables) - { - foreach (var variable in variableTable.Variables) - { - Variables.TryRemove(variable.Id, out _); - } - - VariableTables.TryRemove(variableTable.Id, out _); - } - - Devices.TryRemove(deviceId, out _); - - OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Deleted, deviceDto)); - } + _deviceManagementService.RemoveDeviceFromMemory(deviceId, VariableTables, Variables); } #endregion @@ -241,7 +226,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetVariableTableByIdAsync(int id) { - return await _variableTableAppService.GetVariableTableByIdAsync(id); + return await _variableTableManagementService.GetVariableTableByIdAsync(id); } /// @@ -249,7 +234,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllVariableTablesAsync() { - return await _variableTableAppService.GetAllVariableTablesAsync(); + return await _variableTableManagementService.GetAllVariableTablesAsync(); } /// @@ -257,7 +242,7 @@ public class DataCenterService : IDataCenterService /// public async Task CreateVariableTableAsync(CreateVariableTableWithMenuDto dto) { - return await _variableTableAppService.CreateVariableTableAsync(dto); + return await _variableTableManagementService.CreateVariableTableAsync(dto); } /// @@ -265,7 +250,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateVariableTableAsync(VariableTableDto variableTableDto) { - return await _variableTableAppService.UpdateVariableTableAsync(variableTableDto); + return await _variableTableManagementService.UpdateVariableTableAsync(variableTableDto); } /// @@ -273,7 +258,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteVariableTableAsync(int id) { - return await _variableTableAppService.DeleteVariableTableAsync(id); + return await _variableTableManagementService.DeleteVariableTableAsync(id); } /// @@ -281,21 +266,7 @@ public class DataCenterService : IDataCenterService /// public void AddVariableTableToMemory(VariableTableDto variableTableDto) { - DeviceDto deviceDto = null; - if (Devices.TryGetValue(variableTableDto.DeviceId, out var device)) - { - deviceDto = device; - device.VariableTables.Add(variableTableDto); - variableTableDto.Device = device; - } - - if (VariableTables.TryAdd(variableTableDto.Id, variableTableDto)) - { - OnVariableTableChanged(new VariableTableChangedEventArgs( - DataChangeType.Added, - variableTableDto, - deviceDto)); - } + _variableTableManagementService.AddVariableTableToMemory(variableTableDto, Devices); } /// @@ -303,17 +274,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateVariableTableInMemory(VariableTableDto variableTableDto) { - DeviceDto deviceDto = null; - if (Devices.TryGetValue(variableTableDto.DeviceId, out var device)) - { - deviceDto = device; - } - - VariableTables.AddOrUpdate(variableTableDto.Id, variableTableDto, (key, oldValue) => variableTableDto); - OnVariableTableChanged(new VariableTableChangedEventArgs( - DataChangeType.Updated, - variableTableDto, - deviceDto)); + _variableTableManagementService.UpdateVariableTableInMemory(variableTableDto, Devices); } /// @@ -321,20 +282,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveVariableTableFromMemory(int variableTableId) { - if (VariableTables.TryRemove(variableTableId, out var variableTableDto)) - { - DeviceDto deviceDto = null; - if (variableTableDto != null && Devices.TryGetValue(variableTableDto.DeviceId, out var device)) - { - deviceDto = device; - device.VariableTables.Remove(variableTableDto); - } - - OnVariableTableChanged(new VariableTableChangedEventArgs( - DataChangeType.Deleted, - variableTableDto, - deviceDto)); - } + _variableTableManagementService.RemoveVariableTableFromMemory(variableTableId, Devices); } #endregion @@ -346,7 +294,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllMenusAsync() { - return await _menuService.GetAllMenusAsync(); + return await _menuManagementService.GetAllMenusAsync(); } /// @@ -354,7 +302,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetMenuByIdAsync(int id) { - return await _menuService.GetMenuByIdAsync(id); + return await _menuManagementService.GetMenuByIdAsync(id); } /// @@ -362,7 +310,7 @@ public class DataCenterService : IDataCenterService /// public async Task CreateMenuAsync(MenuBeanDto menuDto) { - return await _menuService.CreateMenuAsync(menuDto); + return await _menuManagementService.CreateMenuAsync(menuDto); } /// @@ -370,7 +318,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateMenuAsync(MenuBeanDto menuDto) { - await _menuService.UpdateMenuAsync(menuDto); + await _menuManagementService.UpdateMenuAsync(menuDto); } /// @@ -378,7 +326,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteMenuAsync(int id) { - await _menuService.DeleteMenuAsync(id); + await _menuManagementService.DeleteMenuAsync(id); } /// @@ -386,17 +334,7 @@ public class DataCenterService : IDataCenterService /// public void AddMenuToMemory(MenuBeanDto menuDto) { - if (Menus.TryAdd(menuDto.Id, menuDto)) - { - MenuBeanDto parentMenu = null; - if (menuDto.ParentId > 0 && Menus.TryGetValue(menuDto.ParentId, out var parent)) - { - parentMenu = parent; - parent.Children.Add(menuDto); - } - - OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Added, menuDto, parentMenu)); - } + _menuManagementService.AddMenuToMemory(menuDto); } /// @@ -404,15 +342,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateMenuInMemory(MenuBeanDto menuDto) { - Menus.AddOrUpdate(menuDto.Id, menuDto, (key, oldValue) => menuDto); - - MenuBeanDto parentMenu = null; - if (menuDto.ParentId > 0 && Menus.TryGetValue(menuDto.ParentId, out var parent)) - { - parentMenu = parent; - } - - OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Updated, menuDto, parentMenu)); + _menuManagementService.UpdateMenuInMemory(menuDto); } /// @@ -420,16 +350,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveMenuFromMemory(int menuId) { - if (Menus.TryRemove(menuId, out var menuDto)) - { - MenuBeanDto parentMenu = null; - if (menuDto.ParentId > 0 && Menus.TryGetValue(menuDto.ParentId, out var parent)) - { - parentMenu = parent; - } - - OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Deleted, menuDto, parentMenu)); - } + _menuManagementService.RemoveMenuFromMemory(menuId); } /// @@ -437,8 +358,7 @@ public class DataCenterService : IDataCenterService /// public List GetRootMenus() { - return Menus.Values.Where(m => m.ParentId == 0) - .ToList(); + return _menuManagementService.GetRootMenus(); } /// @@ -448,8 +368,7 @@ public class DataCenterService : IDataCenterService /// 子菜单列表 public List GetChildMenus(int parentId) { - return Menus.Values.Where(m => m.ParentId == parentId) - .ToList(); + return _menuManagementService.GetChildMenus(parentId); } #endregion @@ -461,7 +380,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetVariableByIdAsync(int id) { - return await _variableAppService.GetVariableByIdAsync(id); + return await _variableManagementService.GetVariableByIdAsync(id); } /// @@ -469,7 +388,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllVariablesAsync() { - return await _variableAppService.GetAllVariablesAsync(); + return await _variableManagementService.GetAllVariablesAsync(); } /// @@ -477,7 +396,7 @@ public class DataCenterService : IDataCenterService /// public async Task CreateVariableAsync(VariableDto variableDto) { - return await _variableAppService.CreateVariableAsync(variableDto); + return await _variableManagementService.CreateVariableAsync(variableDto); } /// @@ -485,7 +404,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateVariableAsync(VariableDto variableDto) { - return await _variableAppService.UpdateVariableAsync(variableDto); + return await _variableManagementService.UpdateVariableAsync(variableDto); } /// @@ -493,7 +412,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateVariablesAsync(List variableDtos) { - return await _variableAppService.UpdateVariablesAsync(variableDtos); + return await _variableManagementService.UpdateVariablesAsync(variableDtos); } /// @@ -501,7 +420,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteVariableAsync(int id) { - return await _variableAppService.DeleteVariableAsync(id); + return await _variableManagementService.DeleteVariableAsync(id); } /// @@ -509,7 +428,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteVariablesAsync(List ids) { - return await _variableAppService.DeleteVariablesAsync(ids); + return await _variableManagementService.DeleteVariablesAsync(ids); } /// @@ -517,18 +436,7 @@ public class DataCenterService : IDataCenterService /// public void AddVariableToMemory(VariableDto variableDto) { - VariableTableDto variableTableDto = null; - if (VariableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) - { - variableTableDto = variableTable; - variableDto.VariableTable = variableTableDto; - variableTable.Variables.Add(variableDto); - } - - if (Variables.TryAdd(variableDto.Id, variableDto)) - { - OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Added, variableDto, variableTableDto)); - } + _variableManagementService.AddVariableToMemory(variableDto, VariableTables); } /// @@ -536,14 +444,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateVariableInMemory(VariableDto variableDto) { - VariableTableDto variableTableDto = null; - if (VariableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) - { - variableTableDto = variableTable; - } - - Variables.AddOrUpdate(variableDto.Id, variableDto, (key, oldValue) => variableDto); - OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Updated, variableDto, variableTableDto)); + _variableManagementService.UpdateVariableInMemory(variableDto, VariableTables); } /// @@ -551,17 +452,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveVariableFromMemory(int variableId) { - if (Variables.TryRemove(variableId, out var variableDto)) - { - VariableTableDto variableTableDto = null; - if (variableDto != null && VariableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) - { - variableTableDto = variableTable; - variableTable.Variables.Remove(variableDto); - } - - OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Deleted, variableDto, variableTableDto)); - } + _variableManagementService.RemoveVariableFromMemory(variableId, VariableTables); } #endregion @@ -573,7 +464,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetMqttServerByIdAsync(int id) { - return await _mqttAppService.GetMqttServerByIdAsync(id); + return await _mqttManagementService.GetMqttServerByIdAsync(id); } /// @@ -581,7 +472,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllMqttServersAsync() { - return await _mqttAppService.GetAllMqttServersAsync(); + return await _mqttManagementService.GetAllMqttServersAsync(); } /// @@ -589,7 +480,7 @@ public class DataCenterService : IDataCenterService /// public async Task CreateMqttServerAsync(MqttServerDto mqttServerDto) { - return await _mqttAppService.CreateMqttServerAsync(mqttServerDto); + return await _mqttManagementService.CreateMqttServerAsync(mqttServerDto); } /// @@ -597,7 +488,7 @@ public class DataCenterService : IDataCenterService /// public async Task UpdateMqttServerAsync(MqttServerDto mqttServerDto) { - await _mqttAppService.UpdateMqttServerAsync(mqttServerDto); + await _mqttManagementService.UpdateMqttServerAsync(mqttServerDto); } /// @@ -605,7 +496,7 @@ public class DataCenterService : IDataCenterService /// public async Task DeleteMqttServerAsync(int id) { - await _mqttAppService.DeleteMqttServerAsync(id); + await _mqttManagementService.DeleteMqttServerAsync(id); } /// @@ -613,10 +504,7 @@ public class DataCenterService : IDataCenterService /// public void AddMqttServerToMemory(MqttServerDto mqttServerDto) { - if (MqttServers.TryAdd(mqttServerDto.Id, mqttServerDto)) - { - OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Added, mqttServerDto)); - } + _mqttManagementService.AddMqttServerToMemory(mqttServerDto); } /// @@ -624,8 +512,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateMqttServerInMemory(MqttServerDto mqttServerDto) { - MqttServers.AddOrUpdate(mqttServerDto.Id, mqttServerDto, (key, oldValue) => mqttServerDto); - OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Updated, mqttServerDto)); + _mqttManagementService.UpdateMqttServerInMemory(mqttServerDto); } /// @@ -633,10 +520,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveMqttServerFromMemory(int mqttServerId) { - if (MqttServers.TryRemove(mqttServerId, out var mqttServerDto)) - { - OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Deleted, mqttServerDto)); - } + _mqttManagementService.RemoveMqttServerFromMemory(mqttServerId); } #endregion @@ -755,7 +639,7 @@ public class DataCenterService : IDataCenterService // 构建菜单树 - BuildMenuTree(); + _menuManagementService.BuildMenuTree(); // 触发数据加载完成事件 OnDataLoadCompleted(new DataLoadCompletedEventArgs(true, "数据加载完成")); @@ -772,7 +656,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllDevicesAsync() { - return await _deviceAppService.GetAllDevicesAsync(); + return await _deviceManagementService.GetAllDevicesAsync(); } /// @@ -780,7 +664,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllVariableTablesAsync() { - return await _variableTableAppService.GetAllVariableTablesAsync(); + return await _variableTableManagementService.GetAllVariableTablesAsync(); } /// @@ -788,7 +672,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllVariablesAsync() { - return await _variableAppService.GetAllVariablesAsync(); + return await _variableManagementService.GetAllVariablesAsync(); } /// @@ -796,7 +680,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllMenusAsync() { - return await _menuService.GetAllMenusAsync(); + return await _menuManagementService.GetAllMenusAsync(); } /// @@ -804,7 +688,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllMqttServersAsync() { - return await _mqttAppService.GetAllMqttServersAsync(); + return await _mqttManagementService.GetAllMqttServersAsync(); } /// @@ -812,7 +696,7 @@ public class DataCenterService : IDataCenterService /// public async Task> LoadAllNlogsAsync() { - return await _nlogAppService.GetAllLogsAsync(); + return await _logManagementService.GetAllNlogsAsync(); } #endregion @@ -886,28 +770,6 @@ public class DataCenterService : IDataCenterService #endregion - #region 私有辅助方法 - - /// - /// 构建菜单树结构 - /// - private void BuildMenuTree() - { - // 清空现有菜单树 - MenuTrees.Clear(); - - // 获取所有根菜单 - var rootMenus = GetRootMenus(); - - // 将根菜单添加到菜单树中 - foreach (var rootMenu in rootMenus) - { - MenuTrees.TryAdd(rootMenu.Id, rootMenu); - } - } - - #endregion - #region 日志管理 /// @@ -915,7 +777,7 @@ public class DataCenterService : IDataCenterService /// public async Task GetNlogByIdAsync(int id) { - return await _nlogAppService.GetLogByIdAsync(id); + return await _logManagementService.GetNlogByIdAsync(id); } /// @@ -923,7 +785,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetAllNlogsAsync() { - return await _nlogAppService.GetAllLogsAsync(); + return await _logManagementService.GetAllNlogsAsync(); } /// @@ -931,7 +793,7 @@ public class DataCenterService : IDataCenterService /// public async Task> GetLatestNlogsAsync(int count) { - return await _nlogAppService.GetLatestLogsAsync(count); + return await _logManagementService.GetLatestNlogsAsync(count); } /// @@ -939,7 +801,7 @@ public class DataCenterService : IDataCenterService /// public async Task ClearAllNlogsAsync() { - await _nlogAppService.ClearAllLogsAsync(); + await _logManagementService.ClearAllNlogsAsync(); } /// @@ -947,10 +809,7 @@ public class DataCenterService : IDataCenterService /// public void AddNlogToMemory(NlogDto nlogDto) { - if (Nlogs.TryAdd(nlogDto.Id, nlogDto)) - { - OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Added, nlogDto)); - } + _logManagementService.AddNlogToMemory(nlogDto); } /// @@ -958,8 +817,7 @@ public class DataCenterService : IDataCenterService /// public void UpdateNlogInMemory(NlogDto nlogDto) { - Nlogs.AddOrUpdate(nlogDto.Id, nlogDto, (key, oldValue) => nlogDto); - OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Updated, nlogDto)); + _logManagementService.UpdateNlogInMemory(nlogDto); } /// @@ -967,10 +825,7 @@ public class DataCenterService : IDataCenterService /// public void RemoveNlogFromMemory(int nlogId) { - if (Nlogs.TryRemove(nlogId, out var nlogDto)) - { - OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Deleted, nlogDto)); - } + _logManagementService.RemoveNlogFromMemory(nlogId); } #endregion diff --git a/DMS.Application/Services/DeviceManagementService.cs b/DMS.Application/Services/DeviceManagementService.cs new file mode 100644 index 0000000..c55a6b4 --- /dev/null +++ b/DMS.Application/Services/DeviceManagementService.cs @@ -0,0 +1,134 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// 设备管理服务，负责设备相关的业务逻辑。 +/// +public class DeviceManagementService +{ + private readonly IDeviceAppService _deviceAppService; + private readonly ConcurrentDictionary _devices; + + /// + /// 当设备数据发生变化时触发 + /// + public event EventHandler DeviceChanged; + + public DeviceManagementService(IDeviceAppService deviceAppService, ConcurrentDictionary devices) + { + _deviceAppService = deviceAppService; + _devices = devices; + } + + /// + /// 异步根据ID获取设备DTO。 + /// + public async Task GetDeviceByIdAsync(int id) + { + return await _deviceAppService.GetDeviceByIdAsync(id); + } + + /// + /// 异步获取所有设备DTO列表。 + /// + public async Task> GetAllDevicesAsync() + { + return await _deviceAppService.GetAllDevicesAsync(); + } + + /// + /// 异步创建一个新设备及其关联的变量表和菜单（事务性操作）。 + /// + public async Task CreateDeviceWithDetailsAsync(CreateDeviceWithDetailsDto dto) + { + return await _deviceAppService.CreateDeviceWithDetailsAsync(dto); + } + + /// + /// 异步更新一个已存在的设备。 + /// + public async Task UpdateDeviceAsync(DeviceDto deviceDto) + { + return await _deviceAppService.UpdateDeviceAsync(deviceDto); + } + + /// + /// 异步删除一个设备。 + /// + public async Task DeleteDeviceByIdAsync(int deviceId) + { + return await _deviceAppService.DeleteDeviceByIdAsync(deviceId); + } + + /// + /// 异步切换设备的激活状态。 + /// + public async Task ToggleDeviceActiveStateAsync(int id) + { + await _deviceAppService.ToggleDeviceActiveStateAsync(id); + } + + /// + /// 在内存中添加设备 + /// + public void AddDeviceToMemory(DeviceDto deviceDto, ConcurrentDictionary variableTables, + ConcurrentDictionary variables) + { + if (_devices.TryAdd(deviceDto.Id, deviceDto)) + { + OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Added, deviceDto)); + } + } + + /// + /// 在内存中更新设备 + /// + public void UpdateDeviceInMemory(DeviceDto deviceDto) + { + _devices.AddOrUpdate(deviceDto.Id, deviceDto, (key, oldValue) => deviceDto); + OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Updated, deviceDto)); + } + + /// + /// 在内存中删除设备 + /// + public void RemoveDeviceFromMemory(int deviceId, ConcurrentDictionary variableTables, + ConcurrentDictionary variables) + { + if (_devices.TryGetValue(deviceId, out var deviceDto)) + { + foreach (var variableTable in deviceDto.VariableTables) + { + foreach (var variable in variableTable.Variables) + { + variables.TryRemove(variable.Id, out _); + } + + variableTables.TryRemove(variableTable.Id, out _); + } + + _devices.TryRemove(deviceId, out _); + + OnDeviceChanged(new DeviceChangedEventArgs(DataChangeType.Deleted, deviceDto)); + } + } + + /// + /// 触发设备变更事件 + /// + protected virtual void OnDeviceChanged(DeviceChangedEventArgs e) + { + DeviceChanged?.Invoke(this, e); + } +} \ No newline at end of file diff --git a/DMS.Application/Services/LogManagementService.cs b/DMS.Application/Services/LogManagementService.cs new file mode 100644 index 0000000..0cec476 --- /dev/null +++ b/DMS.Application/Services/LogManagementService.cs @@ -0,0 +1,105 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// 日志管理服务，负责日志相关的业务逻辑。 +/// +public class LogManagementService +{ + private readonly INlogAppService _nlogAppService; + private readonly ConcurrentDictionary _nlogs; + + /// + /// 当日志数据发生变化时触发 + /// + public event EventHandler NlogChanged; + + public LogManagementService(INlogAppService nlogAppService, + ConcurrentDictionary nlogs) + { + _nlogAppService = nlogAppService; + _nlogs = nlogs; + } + + /// + /// 异步根据ID获取日志DTO。 + /// + public async Task GetNlogByIdAsync(int id) + { + return await _nlogAppService.GetLogByIdAsync(id); + } + + /// + /// 异步获取所有日志DTO列表。 + /// + public async Task> GetAllNlogsAsync() + { + return await _nlogAppService.GetAllLogsAsync(); + } + + /// + /// 异步获取指定数量的最新日志DTO列表。 + /// + public async Task> GetLatestNlogsAsync(int count) + { + return await _nlogAppService.GetLatestLogsAsync(count); + } + + /// + /// 异步清空所有日志。 + /// + public async Task ClearAllNlogsAsync() + { + await _nlogAppService.ClearAllLogsAsync(); + } + + /// + /// 在内存中添加日志 + /// + public void AddNlogToMemory(NlogDto nlogDto) + { + if (_nlogs.TryAdd(nlogDto.Id, nlogDto)) + { + OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Added, nlogDto)); + } + } + + /// + /// 在内存中更新日志 + /// + public void UpdateNlogInMemory(NlogDto nlogDto) + { + _nlogs.AddOrUpdate(nlogDto.Id, nlogDto, (key, oldValue) => nlogDto); + OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Updated, nlogDto)); + } + + /// + /// 在内存中删除日志 + /// + public void RemoveNlogFromMemory(int nlogId) + { + if (_nlogs.TryRemove(nlogId, out var nlogDto)) + { + OnNlogChanged(new NlogChangedEventArgs(DataChangeType.Deleted, nlogDto)); + } + } + + /// + /// 触发日志变更事件 + /// + protected virtual void OnNlogChanged(NlogChangedEventArgs e) + { + NlogChanged?.Invoke(this, e); + } +} \ No newline at end of file diff --git a/DMS.Application/Services/MenuManagementService.cs b/DMS.Application/Services/MenuManagementService.cs new file mode 100644 index 0000000..1ff4e9a --- /dev/null +++ b/DMS.Application/Services/MenuManagementService.cs @@ -0,0 +1,174 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// 菜单管理服务，负责菜单相关的业务逻辑。 +/// +public class MenuManagementService +{ + private readonly IMenuService _menuService; + private readonly ConcurrentDictionary _menus; + private readonly ConcurrentDictionary _menuTrees; + + /// + /// 当菜单数据发生变化时触发 + /// + public event EventHandler MenuChanged; + + public MenuManagementService(IMenuService menuService, + ConcurrentDictionary menus, + ConcurrentDictionary menuTrees) + { + _menuService = menuService; + _menus = menus; + _menuTrees = menuTrees; + } + + /// + /// 异步获取所有菜单DTO列表。 + /// + public async Task> GetAllMenusAsync() + { + return await _menuService.GetAllMenusAsync(); + } + + /// + /// 异步根据ID获取菜单DTO。 + /// + public async Task GetMenuByIdAsync(int id) + { + return await _menuService.GetMenuByIdAsync(id); + } + + /// + /// 异步创建一个新菜单。 + /// + public async Task CreateMenuAsync(MenuBeanDto menuDto) + { + return await _menuService.CreateMenuAsync(menuDto); + } + + /// + /// 异步更新一个已存在的菜单。 + /// + public async Task UpdateMenuAsync(MenuBeanDto menuDto) + { + await _menuService.UpdateMenuAsync(menuDto); + } + + /// + /// 异步删除一个菜单。 + /// + public async Task DeleteMenuAsync(int id) + { + await _menuService.DeleteMenuAsync(id); + } + + /// + /// 在内存中添加菜单 + /// + public void AddMenuToMemory(MenuBeanDto menuDto) + { + if (_menus.TryAdd(menuDto.Id, menuDto)) + { + MenuBeanDto parentMenu = null; + if (menuDto.ParentId > 0 && _menus.TryGetValue(menuDto.ParentId, out var parent)) + { + parentMenu = parent; + parent.Children.Add(menuDto); + } + + OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Added, menuDto, parentMenu)); + } + } + + /// + /// 在内存中更新菜单 + /// + public void UpdateMenuInMemory(MenuBeanDto menuDto) + { + _menus.AddOrUpdate(menuDto.Id, menuDto, (key, oldValue) => menuDto); + + MenuBeanDto parentMenu = null; + if (menuDto.ParentId > 0 && _menus.TryGetValue(menuDto.ParentId, out var parent)) + { + parentMenu = parent; + } + + OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Updated, menuDto, parentMenu)); + } + + /// + /// 在内存中删除菜单 + /// + public void RemoveMenuFromMemory(int menuId) + { + if (_menus.TryRemove(menuId, out var menuDto)) + { + MenuBeanDto parentMenu = null; + if (menuDto.ParentId > 0 && _menus.TryGetValue(menuDto.ParentId, out var parent)) + { + parentMenu = parent; + } + + OnMenuChanged(new MenuChangedEventArgs(DataChangeType.Deleted, menuDto, parentMenu)); + } + } + + /// + /// 获取根菜单列表 + /// + public List GetRootMenus() + { + return _menus.Values.Where(m => m.ParentId == 0) + .ToList(); + } + + /// + /// 根据父级ID获取子菜单列表 + /// + /// 父级菜单ID + /// 子菜单列表 + public List GetChildMenus(int parentId) + { + return _menus.Values.Where(m => m.ParentId == parentId) + .ToList(); + } + + /// + /// 构建菜单树结构 + /// + public void BuildMenuTree() + { + // 清空现有菜单树 + _menuTrees.Clear(); + + // 获取所有根菜单 + var rootMenus = GetRootMenus(); + + // 将根菜单添加到菜单树中 + foreach (var rootMenu in rootMenus) + { + _menuTrees.TryAdd(rootMenu.Id, rootMenu); + } + } + + /// + /// 触发菜单变更事件 + /// + protected virtual void OnMenuChanged(MenuChangedEventArgs e) + { + MenuChanged?.Invoke(this, e); + } +} \ No newline at end of file diff --git a/DMS.Application/Services/MqttManagementService.cs b/DMS.Application/Services/MqttManagementService.cs new file mode 100644 index 0000000..702ee46 --- /dev/null +++ b/DMS.Application/Services/MqttManagementService.cs @@ -0,0 +1,113 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// MQTT管理服务，负责MQTT相关的业务逻辑。 +/// +public class MqttManagementService +{ + private readonly IMqttAppService _mqttAppService; + private readonly ConcurrentDictionary _mqttServers; + + /// + /// 当MQTT服务器数据发生变化时触发 + /// + public event EventHandler MqttServerChanged; + + public MqttManagementService(IMqttAppService mqttAppService, + ConcurrentDictionary mqttServers) + { + _mqttAppService = mqttAppService; + _mqttServers = mqttServers; + } + + /// + /// 异步根据ID获取MQTT服务器DTO。 + /// + public async Task GetMqttServerByIdAsync(int id) + { + return await _mqttAppService.GetMqttServerByIdAsync(id); + } + + /// + /// 异步获取所有MQTT服务器DTO列表。 + /// + public async Task> GetAllMqttServersAsync() + { + return await _mqttAppService.GetAllMqttServersAsync(); + } + + /// + /// 异步创建一个新的MQTT服务器。 + /// + public async Task CreateMqttServerAsync(MqttServerDto mqttServerDto) + { + return await _mqttAppService.CreateMqttServerAsync(mqttServerDto); + } + + /// + /// 异步更新一个已存在的MQTT服务器。 + /// + public async Task UpdateMqttServerAsync(MqttServerDto mqttServerDto) + { + await _mqttAppService.UpdateMqttServerAsync(mqttServerDto); + } + + /// + /// 异步删除一个MQTT服务器。 + /// + public async Task DeleteMqttServerAsync(int id) + { + await _mqttAppService.DeleteMqttServerAsync(id); + } + + /// + /// 在内存中添加MQTT服务器 + /// + public void AddMqttServerToMemory(MqttServerDto mqttServerDto) + { + if (_mqttServers.TryAdd(mqttServerDto.Id, mqttServerDto)) + { + OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Added, mqttServerDto)); + } + } + + /// + /// 在内存中更新MQTT服务器 + /// + public void UpdateMqttServerInMemory(MqttServerDto mqttServerDto) + { + _mqttServers.AddOrUpdate(mqttServerDto.Id, mqttServerDto, (key, oldValue) => mqttServerDto); + OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Updated, mqttServerDto)); + } + + /// + /// 在内存中删除MQTT服务器 + /// + public void RemoveMqttServerFromMemory(int mqttServerId) + { + if (_mqttServers.TryRemove(mqttServerId, out var mqttServerDto)) + { + OnMqttServerChanged(new MqttServerChangedEventArgs(DataChangeType.Deleted, mqttServerDto)); + } + } + + /// + /// 触发MQTT服务器变更事件 + /// + protected virtual void OnMqttServerChanged(MqttServerChangedEventArgs e) + { + MqttServerChanged?.Invoke(this, e); + } +} \ No newline at end of file diff --git a/DMS.Application/Services/VariableManagementService.cs b/DMS.Application/Services/VariableManagementService.cs new file mode 100644 index 0000000..15d99cf --- /dev/null +++ b/DMS.Application/Services/VariableManagementService.cs @@ -0,0 +1,149 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// 变量管理服务，负责变量相关的业务逻辑。 +/// +public class VariableManagementService +{ + private readonly IVariableAppService _variableAppService; + private readonly ConcurrentDictionary _variables; + + /// + /// 当变量数据发生变化时触发 + /// + public event EventHandler VariableChanged; + + public VariableManagementService(IVariableAppService variableAppService, ConcurrentDictionary variables) + { + _variableAppService = variableAppService; + _variables = variables; + } + + /// + /// 异步根据ID获取变量DTO。 + /// + public async Task GetVariableByIdAsync(int id) + { + return await _variableAppService.GetVariableByIdAsync(id); + } + + /// + /// 异步获取所有变量DTO列表。 + /// + public async Task> GetAllVariablesAsync() + { + return await _variableAppService.GetAllVariablesAsync(); + } + + /// + /// 异步创建一个新变量。 + /// + public async Task CreateVariableAsync(VariableDto variableDto) + { + return await _variableAppService.CreateVariableAsync(variableDto); + } + + /// + /// 异步更新一个已存在的变量。 + /// + public async Task UpdateVariableAsync(VariableDto variableDto) + { + return await _variableAppService.UpdateVariableAsync(variableDto); + } + + /// + /// 异步批量更新变量。 + /// + public async Task UpdateVariablesAsync(List variableDtos) + { + return await _variableAppService.UpdateVariablesAsync(variableDtos); + } + + /// + /// 异步删除一个变量。 + /// + public async Task DeleteVariableAsync(int id) + { + return await _variableAppService.DeleteVariableAsync(id); + } + + /// + /// 异步批量删除变量。 + /// + public async Task DeleteVariablesAsync(List ids) + { + return await _variableAppService.DeleteVariablesAsync(ids); + } + + /// + /// 在内存中添加变量 + /// + public void AddVariableToMemory(VariableDto variableDto, ConcurrentDictionary variableTables) + { + VariableTableDto variableTableDto = null; + if (variableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) + { + variableTableDto = variableTable; + variableDto.VariableTable = variableTableDto; + variableTable.Variables.Add(variableDto); + } + + if (_variables.TryAdd(variableDto.Id, variableDto)) + { + OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Added, variableDto, variableTableDto)); + } + } + + /// + /// 在内存中更新变量 + /// + public void UpdateVariableInMemory(VariableDto variableDto, ConcurrentDictionary variableTables) + { + VariableTableDto variableTableDto = null; + if (variableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) + { + variableTableDto = variableTable; + } + + _variables.AddOrUpdate(variableDto.Id, variableDto, (key, oldValue) => variableDto); + OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Updated, variableDto, variableTableDto)); + } + + /// + /// 在内存中删除变量 + /// + public void RemoveVariableFromMemory(int variableId, ConcurrentDictionary variableTables) + { + if (_variables.TryRemove(variableId, out var variableDto)) + { + VariableTableDto variableTableDto = null; + if (variableDto != null && variableTables.TryGetValue(variableDto.VariableTableId, out var variableTable)) + { + variableTableDto = variableTable; + variableTable.Variables.Remove(variableDto); + } + + OnVariableChanged(new VariableChangedEventArgs(DataChangeType.Deleted, variableDto, variableTableDto)); + } + } + + /// + /// 触发变量变更事件 + /// + protected virtual void OnVariableChanged(VariableChangedEventArgs e) + { + VariableChanged?.Invoke(this, e); + } +} \ No newline at end of file diff --git a/DMS.Application/Services/VariableTableManagementService.cs b/DMS.Application/Services/VariableTableManagementService.cs new file mode 100644 index 0000000..382f498 --- /dev/null +++ b/DMS.Application/Services/VariableTableManagementService.cs @@ -0,0 +1,143 @@ +using AutoMapper; +using DMS.Application.DTOs; +using DMS.Application.DTOs.Events; +using DMS.Core.Models; +using DMS.Application.Interfaces; +using DMS.Core.Interfaces; +using DMS.Core.Enums; +using System.Collections.Concurrent; +using System.Collections.Generic; +using System.Threading.Tasks; +using System; + +namespace DMS.Application.Services; + +/// +/// 变量表管理服务，负责变量表相关的业务逻辑。 +/// +public class VariableTableManagementService +{ + private readonly IVariableTableAppService _variableTableAppService; + private readonly ConcurrentDictionary _variableTables; + + /// + /// 当变量表数据发生变化时触发 + /// + public event EventHandler VariableTableChanged; + + public VariableTableManagementService(IVariableTableAppService variableTableAppService, + ConcurrentDictionary variableTables) + { + _variableTableAppService = variableTableAppService; + _variableTables = variableTables; + } + + /// + /// 异步根据ID获取变量表DTO。 + /// + public async Task GetVariableTableByIdAsync(int id) + { + return await _variableTableAppService.GetVariableTableByIdAsync(id); + } + + /// + /// 异步获取所有变量表DTO列表。 + /// + public async Task> GetAllVariableTablesAsync() + { + return await _variableTableAppService.GetAllVariableTablesAsync(); + } + + /// + /// 异步创建一个新变量表及其关联菜单（事务性操作）。 + /// + public async Task CreateVariableTableAsync(CreateVariableTableWithMenuDto dto) + { + return await _variableTableAppService.CreateVariableTableAsync(dto); + } + + /// + /// 异步更新一个已存在的变量表。 + /// + public async Task UpdateVariableTableAsync(VariableTableDto variableTableDto) + { + return await _variableTableAppService.UpdateVariableTableAsync(variableTableDto); + } + + /// + /// 异步删除一个变量表。 + /// + public async Task DeleteVariableTableAsync(int id) + { + return await _variableTableAppService.DeleteVariableTableAsync(id); + } + + /// + /// 在内存中添加变量表 + /// + public void AddVariableTableToMemory(VariableTableDto variableTableDto, ConcurrentDictionary devices) + { + DeviceDto deviceDto = null; + if (devices.TryGetValue(variableTableDto.DeviceId, out var device)) + { + deviceDto = device; + device.VariableTables.Add(variableTableDto); + variableTableDto.Device = device; + } + + if (_variableTables.TryAdd(variableTableDto.Id, variableTableDto)) + { + OnVariableTableChanged(new VariableTableChangedEventArgs( + DataChangeType.Added, + variableTableDto, + deviceDto)); + } + } + + /// + /// 在内存中更新变量表 + /// + public void UpdateVariableTableInMemory(VariableTableDto variableTableDto, ConcurrentDictionary devices) + { + DeviceDto deviceDto = null; + if (devices.TryGetValue(variableTableDto.DeviceId, out var device)) + { + deviceDto = device; + } + + _variableTables.AddOrUpdate(variableTableDto.Id, variableTableDto, (key, oldValue) => variableTableDto); + OnVariableTableChanged(new VariableTableChangedEventArgs( + DataChangeType.Updated, + variableTableDto, + deviceDto)); + } + + /// + /// 在内存中删除变量表 + /// + public void RemoveVariableTableFromMemory(int variableTableId, ConcurrentDictionary devices) + { + if (_variableTables.TryRemove(variableTableId, out var variableTableDto)) + { + DeviceDto deviceDto = null; + if (variableTableDto != null && devices.TryGetValue(variableTableDto.DeviceId, out var device)) + { + deviceDto = device; + device.VariableTables.Remove(variableTableDto); + } + + OnVariableTableChanged(new VariableTableChangedEventArgs( + DataChangeType.Deleted, + variableTableDto, + deviceDto)); + } + } + + /// + /// 触发变量表变更事件 + /// + protected virtual void OnVariableTableChanged(VariableTableChangedEventArgs e) + { + VariableTableChanged?.Invoke(this, e); + } +} \ No newline at end of file