完成变量表的增删改

This commit is contained in:
2025-09-03 18:08:42 +08:00
parent 11956c26f3
commit c96390384d
4 changed files with 120 additions and 96 deletions

View File

@@ -299,6 +299,8 @@ public class DataCenterService : IDataCenterService
if (variableTableDto != null && Devices.TryGetValue(variableTableDto.DeviceId, out var device)) if (variableTableDto != null && Devices.TryGetValue(variableTableDto.DeviceId, out var device))
{ {
deviceDto = device; deviceDto = device;
device.VariableTables.Remove(variableTableDto);
} }
OnVariableTableChanged(new VariableTableChangedEventArgs( OnVariableTableChanged(new VariableTableChangedEventArgs(

View File

@@ -106,7 +106,7 @@ public partial class DataServices : ObservableObject
//更新当前界面 //更新当前界面
Devices.Add(_mapper.Map<DeviceItemViewModel>(addDto.Device)); Devices.Add(_mapper.Map<DeviceItemViewModel>(addDto.Device));
AddMenuItem(_mapper.Map<MenuItemViewModel>(addDto.DeviceMenu)); AddMenuItem(_mapper.Map<MenuItemViewModel>(addDto.DeviceMenu));
AddVariableTable(_mapper.Map<VariableTableItemViewModel>(addDto.VariableTable)); await AddVariableTable(addDto.VariableTable);
AddMenuItem(_mapper.Map<MenuItemViewModel>(addDto.VariableTableMenu)); AddMenuItem(_mapper.Map<MenuItemViewModel>(addDto.VariableTableMenu));
//更新数据中心 //更新数据中心
_dataCenterService.AddDeviceToMemory(addDto.Device); _dataCenterService.AddDeviceToMemory(addDto.Device);
@@ -135,16 +135,7 @@ public partial class DataServices : ObservableObject
foreach (var variableTable in device.VariableTables) foreach (var variableTable in device.VariableTables)
{ {
// 删除与当前变量表关联的所有变量 // 删除与当前变量表关联的所有变量
foreach (var variable in variableTable.Variables) DeleteVariableTable(variableTable);
{
Variables.Remove(variable);
}
var variableTableMenu
= Menus.FirstOrDefault(m => m.MenuType == MenuType.VariableTableMenu && m.TargetId == variableTable.Id);
DeleteMenuItem(variableTableMenu);
// 删除变量表
VariableTables.Remove(variableTable);
} }
// 2. 删除设备 // 2. 删除设备
@@ -167,11 +158,11 @@ public partial class DataServices : ObservableObject
} }
_mapper.Map(device, deviceDto); _mapper.Map(device, deviceDto);
if ( await _dataCenterService.UpdateDeviceAsync(deviceDto)> 0) if (await _dataCenterService.UpdateDeviceAsync(deviceDto) > 0)
{ {
var menu = Menus.FirstOrDefault(m => var menu = Menus.FirstOrDefault(m =>
m.MenuType == MenuType.DeviceMenu && m.MenuType == MenuType.DeviceMenu &&
m.TargetId == device.Id); m.TargetId == device.Id);
if (menu != null) if (menu != null)
{ {
menu.Header = device.Name; menu.Header = device.Name;
@@ -181,34 +172,95 @@ public partial class DataServices : ObservableObject
return true; return true;
} }
public void DeleteVariableTableById(int id)
public async Task<bool> AddVariableTable(VariableTableDto variableTableDto,
MenuBeanDto menuDto = null, bool isAddDb = false)
{ {
var variableTable = VariableTables.FirstOrDefault(vt => vt.Id == id); if (variableTableDto == null)
if (variableTable != null) return false;
if (isAddDb && menuDto != null)
{ {
// 删除与当前变量表关联的所有变量 CreateVariableTableWithMenuDto createDto = new CreateVariableTableWithMenuDto();
var variablesToDelete = Variables.Where(v => v.VariableTableId == variableTable.Id) createDto.VariableTable = variableTableDto;
.ToList(); createDto.DeviceId = variableTableDto.DeviceId;
foreach (var variable in variablesToDelete) createDto.Menu = menuDto;
var resDto = await _dataCenterService.CreateVariableTableAsync(createDto);
_mapper.Map(resDto.VariableTable, variableTableDto);
AddMenuItem(_mapper.Map<MenuItemViewModel>(resDto.Menu));
}
_dataCenterService.AddVariableTableToMemory(variableTableDto);
var device = Devices.FirstOrDefault(d => d.Id == variableTableDto.DeviceId);
if (device != null)
{
var variableTableItemViewModel = _mapper.Map<VariableTableItemViewModel>(variableTableDto);
variableTableItemViewModel.Device = device;
device.VariableTables.Add(variableTableItemViewModel);
VariableTables.Add(variableTableItemViewModel);
}
return true;
}
public async Task<bool> UpdateVariableTable(VariableTableItemViewModel variableTable)
{
if (variableTable==null)
{
return false;
}
var variableTableDto = _mapper.Map<VariableTableDto>(variableTable);
if (await _dataCenterService.UpdateVariableTableAsync(variableTableDto) > 0)
{
_dataCenterService.UpdateVariableTableInMemory(variableTableDto);
var menu = Menus.FirstOrDefault(m =>
m.MenuType == MenuType.VariableTableMenu &&
m.TargetId == variableTable.Id);
if (menu != null)
{ {
Variables.Remove(variable); menu.Header = variableTable.Name;
} }
return true;
}
var device = Devices.FirstOrDefault(d => d.Id == variableTable.DeviceId); return false;
if (device != null)
device.VariableTables.Remove(variableTable);
// 删除变量表
VariableTables.Remove(variableTable);
// 删除与变量表关联的菜单项 }
var variableTableMenu public async Task<bool> DeleteVariableTable(VariableTableItemViewModel variableTable, bool isDeleteDb = false)
= Menus.FirstOrDefault(m => m.MenuType == MenuType.VariableTableMenu && m.TargetId == variableTable.Id); {
if (variableTableMenu != null) if (variableTable == null)
{
return false;
}
if (isDeleteDb)
{
if (!await _dataCenterService.DeleteVariableTableAsync(variableTable.Id))
{ {
DeleteMenuItem(variableTableMenu); return false;
} }
} }
// 删除与当前变量表关联的所有变量
foreach (var variable in variableTable.Variables)
{
Variables.Remove(variable);
}
_dataCenterService.RemoveVariableTableFromMemory(variableTable.Id);
var variableTableMenu
= Menus.FirstOrDefault(m => m.MenuType == MenuType.VariableTableMenu && m.TargetId == variableTable.Id);
DeleteMenuItem(variableTableMenu);
// 删除变量表
VariableTables.Remove(variableTable);
variableTable.Device.VariableTables.Remove(variableTable);
return true;
} }
@@ -237,7 +289,6 @@ public partial class DataServices : ObservableObject
} }
public void AddMenuItem(MenuItemViewModel menuItemViewModel) public void AddMenuItem(MenuItemViewModel menuItemViewModel)
{ {
if (menuItemViewModel == null) if (menuItemViewModel == null)
@@ -253,19 +304,6 @@ public partial class DataServices : ObservableObject
} }
} }
public void AddVariableTable(VariableTableItemViewModel variableTableItemViewModel)
{
if (variableTableItemViewModel == null)
return;
var device = Devices.FirstOrDefault(d => d.Id == variableTableItemViewModel.DeviceId);
if (device != null)
{
device.VariableTables.Add(variableTableItemViewModel);
VariableTables.Add(variableTableItemViewModel);
}
}
public void AddVariable(VariableItemViewModel variableItem) public void AddVariable(VariableItemViewModel variableItem)
{ {
if (variableItem == null) if (variableItem == null)
@@ -281,7 +319,7 @@ public partial class DataServices : ObservableObject
} }
} }
public void DeleteMenuItem(MenuItemViewModel? menuItemViewModel) private void DeleteMenuItem(MenuItemViewModel? menuItemViewModel)
{ {
if (menuItemViewModel == null) if (menuItemViewModel == null)
{ {
@@ -306,7 +344,7 @@ public partial class DataServices : ObservableObject
} }
public void DeleteVariableById(int id) public void DeleteVariable(int id)
{ {
var variableItem = Variables.FirstOrDefault(v => v.Id == id); var variableItem = Variables.FirstOrDefault(v => v.Id == id);
if (variableItem == null) if (variableItem == null)

View File

@@ -1,6 +1,7 @@
using AutoMapper; using AutoMapper;
using CommunityToolkit.Mvvm.ComponentModel; using CommunityToolkit.Mvvm.ComponentModel;
using CommunityToolkit.Mvvm.Input; using CommunityToolkit.Mvvm.Input;
using Dm;
using DMS.Application.DTOs; using DMS.Application.DTOs;
using DMS.Application.Interfaces; using DMS.Application.Interfaces;
using DMS.Core.Enums; using DMS.Core.Enums;
@@ -18,8 +19,7 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
private readonly IMapper _mapper; private readonly IMapper _mapper;
private readonly IDialogService _dialogService; private readonly IDialogService _dialogService;
private readonly INavigationService _navigationService; private readonly INavigationService _navigationService;
private readonly IVariableTableAppService _variableTableAppService; public DataServices DataServices { get; }
public DataServices DataServices { get; set; }
[ObservableProperty] [ObservableProperty]
private DeviceItemViewModel _currentDevice; private DeviceItemViewModel _currentDevice;
@@ -28,12 +28,11 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
private VariableTableItemViewModel _selectedVariableTable; private VariableTableItemViewModel _selectedVariableTable;
public DeviceDetailViewModel(IMapper mapper, IDialogService dialogService, INavigationService navigationService, public DeviceDetailViewModel(IMapper mapper, IDialogService dialogService, INavigationService navigationService,
DataServices dataServices, IVariableTableAppService variableTableAppService) DataServices dataServices)
{ {
_mapper = mapper; _mapper = mapper;
_dialogService = dialogService; _dialogService = dialogService;
_navigationService = navigationService; _navigationService = navigationService;
_variableTableAppService = variableTableAppService;
DataServices = dataServices; DataServices = dataServices;
} }
@@ -54,18 +53,23 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
return; return;
} }
CreateVariableTableWithMenuDto createDto = new CreateVariableTableWithMenuDto(); variableTableItemViewModel.DeviceId = CurrentDevice.Id;
createDto.VariableTable = _mapper.Map<VariableTableDto>(variableTableItemViewModel); var tableMenu = new MenuBeanDto()
createDto.DeviceId = CurrentDevice.Id;
createDto.Menu = new MenuBeanDto()
{ {
Header = variableTableItemViewModel.Name, Header = variableTableItemViewModel.Name,
Icon = SegoeFluentIcons.DataSense.Glyph Icon = SegoeFluentIcons.DataSense.Glyph
}; };
CreateVariableTableWithMenuDto
resCreateDto = await _variableTableAppService.CreateVariableTableAsync(createDto); if (await DataServices.AddVariableTable(_mapper.Map<VariableTableDto>(variableTableItemViewModel),
DataServices.AddVariableTable(_mapper.Map<VariableTableItemViewModel>(resCreateDto.VariableTable)); tableMenu, true))
DataServices.AddMenuItem(_mapper.Map<MenuItemViewModel>(resCreateDto.Menu)); {
NotificationHelper.ShowSuccess($"添加变量表成功:{variableTableItemViewModel.Name}");
}
else
{
NotificationHelper.ShowError($"添加变量表失败:{variableTableItemViewModel.Name}");
}
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -96,16 +100,13 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
return; return;
} }
int res = await _variableTableAppService.UpdateVariableTableAsync(_mapper.Map<VariableTableDto>(variableTable)); if (await DataServices.UpdateVariableTable(variableTable))
if (res > 0)
{ {
var menu = DataServices.Menus.FirstOrDefault(m => NotificationHelper.ShowSuccess($"编辑变量表成功:{variableTable.Name}");
m.MenuType == MenuType.VariableTableMenu && }
m.TargetId == variableTable.Id); else
if (menu != null) {
{ NotificationHelper.ShowError($"编辑变量表失败:{variableTable.Name}");
menu.Header = variableTable.Name;
}
} }
} }
catch (Exception e) catch (Exception e)
@@ -127,17 +128,16 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
string message = $"确认要删除变量表名为:{SelectedVariableTable.Name} \n\n此操作将同时删除该变量表下的所有变量数据且无法恢复"; string message = $"确认要删除变量表名为:{SelectedVariableTable.Name} \n\n此操作将同时删除该变量表下的所有变量数据且无法恢复";
ConfirmDialogViewModel viewModel = new ConfirmDialogViewModel("删除变量表",message,"删除"); ConfirmDialogViewModel viewModel = new ConfirmDialogViewModel("删除变量表",message,"删除");
var res = await _dialogService.ShowDialogAsync(viewModel); if (await _dialogService.ShowDialogAsync(viewModel))
if (res)
{ {
var isDel = await _variableTableAppService.DeleteVariableTableAsync(SelectedVariableTable.Id); var tableName = SelectedVariableTable.Name;
if (isDel) if (await DataServices.DeleteVariableTable(SelectedVariableTable,true))
{ {
var delName = SelectedVariableTable.Name; NotificationHelper.ShowSuccess($"变量表:{tableName},删除成功。");
// 更新界面 }
DataServices.DeleteVariableTableById(SelectedVariableTable.Id); else
{
NotificationHelper.ShowSuccess($"删除变量表成功,变量表名:{delName}"); NotificationHelper.ShowError($"变量表{tableName},删除失败!!!");
} }
} }
} }
@@ -147,22 +147,6 @@ public partial class DeviceDetailViewModel : ViewModelBase, INavigatable
} }
} }
// Placeholder for EditDeviceCommand and DeleteDeviceCommand if they are needed here
[RelayCommand]
private async Task EditDevice()
{
// Implement device editing logic, similar to AddDeviceCommand but for existing device
//NotificationHelper.ShowInfo("编辑设备功能待实现。");
await Task.CompletedTask;
}
[RelayCommand]
private async Task DeleteDevice()
{
// Implement device deletion logic
//NotificationHelper.ShowInfo("删除设备功能待实现。");
await Task.CompletedTask;
}
public async Task OnNavigatedToAsync(MenuItemViewModel menu) public async Task OnNavigatedToAsync(MenuItemViewModel menu)

View File

@@ -432,7 +432,7 @@ partial class VariableTableViewModel : ViewModelBase, INavigatable
foreach (var variable in variablesToDelete) foreach (var variable in variablesToDelete)
{ {
_variableItemList.Remove(variable); _variableItemList.Remove(variable);
_dataServices.DeleteVariableById(variable.Id); _dataServices.DeleteVariable(variable.Id);
} }
// 显示成功通知 // 显示成功通知
NotificationHelper.ShowSuccess($"成功删除 {variablesToDelete.Count} 个变量"); NotificationHelper.ShowSuccess($"成功删除 {variablesToDelete.Count} 个变量");