using System.Globalization; using System.Collections.ObjectModel; using System.ComponentModel; using System.Runtime.CompilerServices; using System.Windows; using System.Windows.Controls; using System.Windows.Input; using System.Windows.Media; using System.Windows.Media.Animation; using NetworkTool.Client.Models; using NetworkTool.Client.Services; namespace NetworkTool.Client; public partial class DeviceDetailsWindow : Window { private const int ApplyConfirmationTimeoutSeconds = 20; private readonly ServerApiService _serverApiService = new(); private readonly ObservableCollection _interfaces = []; private readonly string _baseAddress; private readonly string _remoteHost; private readonly string _localIPv4; private readonly string _password; private bool _configValidated; private bool _configDirty; private bool _isBusy; private bool _suppressConfigChangeHandling; private CancellationTokenSource? _statusMessageCts; public DeviceDetailsWindow(string baseAddress, string localIPv4, string password) { InitializeComponent(); InterfacesItemsControl.ItemsSource = _interfaces; _baseAddress = baseAddress; _remoteHost = GetRemoteHost(baseAddress); _localIPv4 = localIPv4; _password = password; UpdateWindowTitle(); Loaded += DeviceDetailsWindow_OnLoaded; Closing += DeviceDetailsWindow_OnClosing; } private async void DeviceDetailsWindow_OnLoaded(object sender, RoutedEventArgs e) { try { await LoadRemoteDetailsAsync(); UpdateButtonStates(); } catch (Exception ex) { ShowStatusMessage($"读取设备信息失败:{ex.Message}"); SetBusyState(false); } } private async Task LoadRemoteDetailsAsync() { ClearDetails(); var device = await _serverApiService.GetDeviceInfoAsync(_baseAddress, _password, _localIPv4); if (device is not null) { UpdateWindowTitle(device.Hostname, device.ServerVersion); } var interfaces = await _serverApiService.GetInterfacesAsync(_baseAddress, _password, _localIPv4); if (interfaces is null) { ShowStatusMessage("设备已连接,但暂时无法读取 Linux 接口列表。"); return; } ShowStatusMessage($"当前管理接口:{interfaces.ManagementInterface}。正在读取全部接口配置。"); foreach (var info in interfaces.Interfaces) { var editor = new InterfaceEditor(info); _interfaces.Add(editor); await LoadRemoteInterfaceConfigAsync(editor); } _configValidated = false; _configDirty = false; ShowStatusMessage("已读取全部接口配置。"); } private void ClearDetails() { UpdateWindowTitle(); _interfaces.Clear(); _configValidated = false; _configDirty = false; } private void UpdateWindowTitle(string? hostname = null, string? serverVersion = null) { var hostPart = string.IsNullOrWhiteSpace(hostname) ? _remoteHost : $"{hostname} ({_remoteHost})"; var versionPart = string.IsNullOrWhiteSpace(serverVersion) ? string.Empty : $" - Server {serverVersion}"; Title = string.IsNullOrWhiteSpace(hostPart) ? $"设备信息与接口配置{versionPart}" : $"设备信息与接口配置 - {hostPart}{versionPart}"; } private static string GetRemoteHost(string baseAddress) { return Uri.TryCreate(baseAddress, UriKind.Absolute, out var uri) ? uri.Host : baseAddress; } private async Task LoadRemoteInterfaceConfigAsync(InterfaceEditor editor, bool useBusyState = false) { if (useBusyState) { SetBusyState(true, "正在读取 Linux 端 IP 配置..."); } try { var result = await _serverApiService.GetInterfaceConfigAsync(_baseAddress, _password, _localIPv4, editor.SystemName); if (!result.Success || result.Data is null) { ShowStatusMessage($"读取目标接口 {editor.SystemName} 配置失败:{result.Message}"); return; } var config = result.Data; _suppressConfigChangeHandling = true; editor.Dhcp4 = config.Dhcp4; editor.Addresses.Clear(); foreach (var address in config.EffectiveAddresses) { editor.Addresses.Add(new EditableAddress(editor) { IP = address.IP, Mask = PrefixToMask(address.Prefix) }); } editor.Routes.Clear(); editor.DefaultGatewayEnabled = false; editor.DefaultGateway = string.Empty; foreach (var route in config.EffectiveRoutes) { if (route.To.Equals("default", StringComparison.OrdinalIgnoreCase)) { editor.DefaultGatewayEnabled = true; editor.DefaultGateway = route.Via; } else { editor.Routes.Add(CreateEditableRoute(editor, route)); } } editor.CustomRoutesEnabled = editor.Routes.Count > 0; editor.Dns.Clear(); if (config.Dns is not null) { foreach (var dns in config.Dns) { editor.Dns.Add(new EditableDns(editor) { Address = dns }); } } _suppressConfigChangeHandling = false; UpdateButtonStates(); } finally { _suppressConfigChangeHandling = false; if (useBusyState) { SetBusyState(false); } } } private async void ReloadInterfaceConfigButton_OnClick(object sender, RoutedEventArgs e) { if (!ConfirmDiscardPendingChanges("当前配置已修改但尚未应用,刷新会丢失未应用内容。是否继续刷新?", "确认刷新配置")) { return; } SetBusyState(true, "正在刷新全部接口配置..."); try { foreach (var editor in _interfaces) { await LoadRemoteInterfaceConfigAsync(editor); } _configValidated = false; _configDirty = false; ShowStatusMessage("已刷新全部接口配置。"); } finally { SetBusyState(false); } } private void DeviceDetailsWindow_OnClosing(object? sender, CancelEventArgs e) { if (!ConfirmDiscardPendingChanges("当前配置已修改但尚未应用。是否关闭窗口?", "确认关闭窗口")) { e.Cancel = true; } } private bool ConfirmDiscardPendingChanges(string message, string title) { if (!_configDirty) { return true; } return MessageBox.Show(this, message, title, MessageBoxButton.OKCancel, MessageBoxImage.Warning) == MessageBoxResult.OK; } private async void ValidateConfigButton_OnClick(object sender, RoutedEventArgs e) { var request = BuildConfigRequests(); if (request is null) { return; } SetBusyState(true, "正在校验配置,请稍候..."); try { var result = await _serverApiService.ValidateInterfaceConfigsAsync(_baseAddress, _password, _localIPv4, request); _configValidated = result.Success && result.Data?.Valid == true; if (result.Data is not null) { var warnings = result.Data.Warnings.Count > 0 ? $" 警告:{string.Join(";", result.Data.Warnings)}" : string.Empty; var errors = result.Data.Errors.Count > 0 ? $" 错误:{string.Join(";", result.Data.Errors)}" : string.Empty; ShowStatusMessage(_configValidated ? $"全部接口校验通过,可应用配置。{warnings}" : $"校验失败。{errors}{warnings}"); } else { ShowStatusMessage($"校验失败:{result.Message}"); } UpdateButtonStates(); } finally { SetBusyState(false); } } private async void ApplyConfigButton_OnClick(object sender, RoutedEventArgs e) { var request = BuildConfigRequests(); if (request is null) { return; } var confirmMessage = "将要一次性应用以下接口配置:\n\n" + FormatConfigSummary(request) + "\n\n请确认是否继续。"; if (MessageBox.Show(this, confirmMessage, "确认应用配置", MessageBoxButton.OKCancel, MessageBoxImage.Question) != MessageBoxResult.OK) { return; } SetBusyState(true, "正在提交并应用配置,请稍候..."); try { var applyResult = await _serverApiService.ApplyInterfaceConfigsAsync(_baseAddress, _password, _localIPv4, request); if (!applyResult.Success || applyResult.Data is null) { ShowStatusMessage($"提交配置任务失败:{applyResult.Message}"); return; } ShowStatusMessage("配置任务已提交,正在应用并等待连通确认..."); await PollTaskAsync(applyResult.Data.TaskId); } finally { SetBusyState(false); } } private async Task PollTaskAsync(string taskId) { var transientFailureCount = 0; var confirmationRequested = false; for (var i = 0; i < 20; i++) { await Task.Delay(1000); var result = await _serverApiService.GetTaskAsync(_baseAddress, _password, _localIPv4, taskId); if (!result.Success || result.Data is null) { if (result.StatusCode is null) { transientFailureCount++; ShowStatusMessage($"设备连接短暂中断,正在重试({transientFailureCount})。"); continue; } ShowStatusMessage($"读取任务状态失败:{result.Message}"); return; } transientFailureCount = 0; var task = result.Data; ShowStatusMessage(FormatTaskStatusMessage(task)); if (task.Status == "running" && task.Step == "confirming" && !confirmationRequested) { confirmationRequested = true; var confirm = ShowApplyConfirmationDialog(ApplyConfirmationTimeoutSeconds); if (confirm) { var confirmResult = await _serverApiService.ConfirmApplyTaskAsync(_baseAddress, _password, _localIPv4, taskId); ShowStatusMessage(confirmResult.Success ? "已发送保留配置确认。" : $"发送确认失败:{confirmResult.Message}"); } else { var cancelResult = await _serverApiService.CancelApplyTaskAsync(_baseAddress, _password, _localIPv4, taskId); ShowStatusMessage(cancelResult.Success ? "已取消保留配置,正在回滚。" : $"发送取消失败:{cancelResult.Message}"); } } if (task.Status is "success" or "failed" or "rolled_back") { ShowTaskCompletionDialog(task); foreach (var editor in _interfaces) { await LoadRemoteInterfaceConfigAsync(editor); } return; } } ShowStatusMessage($"任务 {taskId} 轮询超时,请稍后手动刷新。"); } private bool ShowApplyConfirmationDialog(int timeoutSeconds) { var remaining = timeoutSeconds; var result = false; var messageTextBlock = new TextBlock { Width = 420, TextWrapping = TextWrapping.Wrap, FontSize = 13, Foreground = Brushes.Black, }; var confirmButton = new Button { MinWidth = 88, MinHeight = 32, Margin = new Thickness(0, 0, 10, 0), Content = "保留", IsDefault = true, }; confirmButton.Style = (Style)FindResource("PrimaryButtonStyle"); var cancelButton = new Button { MinWidth = 88, MinHeight = 32, Content = "回滚", IsCancel = true, }; var dialog = new Window { Title = "确认保留网络配置", Owner = this, WindowStartupLocation = WindowStartupLocation.CenterOwner, ResizeMode = ResizeMode.NoResize, SizeToContent = SizeToContent.WidthAndHeight, Content = new StackPanel { Margin = new Thickness(18), Children = { messageTextBlock, new StackPanel { Margin = new Thickness(0, 18, 0, 0), HorizontalAlignment = HorizontalAlignment.Right, Orientation = Orientation.Horizontal, Children = { confirmButton, cancelButton }, }, }, }, }; void UpdateMessage() { messageTextBlock.Text = $"当前客户端仍可连接到设备。是否确认保留这次网络配置?\n\n剩余 {remaining} 秒;超时或取消时,Linux 端会自动回滚。"; } var timer = new System.Windows.Threading.DispatcherTimer { Interval = TimeSpan.FromSeconds(1) }; timer.Tick += (_, _) => { remaining--; if (remaining <= 0) { timer.Stop(); dialog.DialogResult = false; dialog.Close(); return; } UpdateMessage(); }; confirmButton.Click += (_, _) => { result = true; dialog.DialogResult = true; dialog.Close(); }; cancelButton.Click += (_, _) => { dialog.DialogResult = false; dialog.Close(); }; dialog.Closed += (_, _) => timer.Stop(); UpdateMessage(); timer.Start(); dialog.ShowDialog(); return result; } private async void RebootButton_OnClick(object sender, RoutedEventArgs e) { await ExecuteSystemActionAsync( "重启设备", "设备将立即重启,当前窗口和连接可能马上中断。是否继续?", () => _serverApiService.RebootAsync(_baseAddress, _password, _localIPv4)); } private async void ShutdownButton_OnClick(object sender, RoutedEventArgs e) { await ExecuteSystemActionAsync( "关闭设备", "设备将立即关机,当前窗口和连接可能马上中断。是否继续?", () => _serverApiService.ShutdownAsync(_baseAddress, _password, _localIPv4)); } private async Task ExecuteSystemActionAsync(string title, string confirmMessage, Func>> action) { if (MessageBox.Show(this, confirmMessage, title, MessageBoxButton.OKCancel, MessageBoxImage.Warning) != MessageBoxResult.OK) { return; } var result = await action(); if (!result.Success || result.Data is null) { ShowStatusMessage($"{title}失败:{result.Message}"); return; } ShowStatusMessage($"{title}任务已提交:{result.Data.TaskId}。命令已发出,设备可能立即断开。"); } private RemoteInterfaceConfig[]? BuildConfigRequests() { CommitConfigEdits(); var result = new List(); foreach (var editor in _interfaces) { var request = BuildConfigRequest(editor); if (request is null) { return null; } result.Add(request); } if (result.Count == 0) { ShowStatusMessage("接口配置不能为空。"); return null; } return result.ToArray(); } private RemoteInterfaceConfig? BuildConfigRequest(InterfaceEditor editor) { var dhcp4 = editor.Dhcp4; var addresses = Array.Empty(); var routes = Array.Empty(); if (!dhcp4) { if (editor.Addresses.All(item => string.IsNullOrWhiteSpace(item.IP) && string.IsNullOrWhiteSpace(item.Mask))) { ShowStatusMessage($"{editor.SystemName}:IP 地址不能为空,至少需要填写一行地址。"); return null; } if (!TryBuildAddresses(editor, out addresses, out var addressError)) { ShowStatusMessage($"{editor.SystemName}:{addressError}"); return null; } if (!TryBuildRoutes(editor, out routes, out var routeError)) { ShowStatusMessage($"{editor.SystemName}:{routeError}"); return null; } } var dns = editor.Dns.Select(item => item.Address.Trim()).Where(item => item != string.Empty).ToArray(); return new RemoteInterfaceConfig { Interface = editor.SystemName, Dhcp4 = dhcp4, Addresses = dhcp4 ? Array.Empty() : addresses, Routes = dhcp4 ? Array.Empty() : routes, Dns = dns, }; } private void CommitConfigEdits() { CommitDataGridEdits(InterfacesItemsControl); } private static void CommitDataGridEdits(DependencyObject root) { for (var i = 0; i < VisualTreeHelper.GetChildrenCount(root); i++) { var child = VisualTreeHelper.GetChild(root, i); if (child is DataGrid dataGrid) { dataGrid.CommitEdit(DataGridEditingUnit.Cell, true); dataGrid.CommitEdit(DataGridEditingUnit.Row, true); } CommitDataGridEdits(child); } } private static string FormatCurrentIp(RemoteInterfaceConfig config) { if (config.EffectiveAddresses.Count == 0) { return config.Dhcp4 ? "DHCP 自动获取,暂无 IPv4" : "无"; } var text = FormatAddresses(config.EffectiveAddresses); return config.Dhcp4 ? $"{text} (DHCP)" : text; } private static string FormatAddresses(IReadOnlyList addresses) { return addresses.Count == 0 ? "无" : string.Join(Environment.NewLine, addresses.Select(item => $"{item.IP}/{item.Prefix}")); } private static string FormatRoutes(IReadOnlyList routes) { return routes.Count == 0 ? "无" : string.Join(Environment.NewLine, routes.Select(item => $"{item.To} via {item.Via}")); } private static string FormatConfigSummary(IReadOnlyList configs) { return string.Join(Environment.NewLine + Environment.NewLine, configs.Select(item => $"接口:{item.Interface}\n" + $"模式:{(item.Dhcp4 ? "DHCP 自动获取" : "静态 IPv4")}\n" + $"IP:{(item.Dhcp4 ? "自动获取" : FormatAddresses(item.Addresses))}\n" + $"路由:{(item.Dhcp4 ? "自动获取" : FormatRoutes(item.Routes))}\n" + $"DNS:{(item.Dns.Count == 0 ? "无" : string.Join(", ", item.Dns))}")); } private static EditableRoute CreateEditableRoute(InterfaceEditor owner, RemoteInterfaceRouteConfig route) { var to = route.To.Trim(); var mask = string.Empty; if (to.Contains('/')) { var parts = to.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length == 2 && int.TryParse(parts[1], out var prefix) && prefix >= 0 && prefix <= 32) { to = parts[0]; mask = PrefixToMask(prefix); } } return new EditableRoute(owner) { To = to, Mask = mask, Via = route.Via }; } private bool TryBuildAddresses(InterfaceEditor editor, out RemoteInterfaceAddressConfig[] addresses, out string error) { var result = new List(); foreach (var row in editor.Addresses) { var ip = row.IP.Trim(); var maskText = row.Mask.Trim(); if (ip == string.Empty && maskText == string.Empty) { continue; } if (ip.Contains('/')) { var parts = ip.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length != 2 || !int.TryParse(parts[1], out var cidrPrefix) || cidrPrefix < 0 || cidrPrefix > 32) { addresses = []; error = $"地址格式不正确:{ip}"; return false; } row.IP = parts[0]; row.Mask = PrefixToMask(cidrPrefix); result.Add(new RemoteInterfaceAddressConfig { IP = parts[0], Prefix = cidrPrefix }); continue; } if (ip == string.Empty || maskText == string.Empty) { addresses = []; error = "IP 地址和子网掩码都需要填写。"; return false; } if (!TryMaskOrPrefixToPrefix(maskText, out var prefix)) { addresses = []; error = $"子网掩码格式不正确:{ip} {maskText}"; return false; } row.Mask = PrefixToMask(prefix); result.Add(new RemoteInterfaceAddressConfig { IP = ip, Prefix = prefix }); } addresses = result.ToArray(); error = string.Empty; return addresses.Length > 0; } private bool TryBuildRoutes(InterfaceEditor editor, out RemoteInterfaceRouteConfig[] routes, out string error) { var result = new List(); if (editor.DefaultGatewayEnabled) { var gateway = editor.DefaultGateway.Trim(); if (gateway == string.Empty) { routes = []; error = "启用默认网关时,网关地址不能为空。"; return false; } result.Add(new RemoteInterfaceRouteConfig { To = "default", Via = gateway }); } if (editor.CustomRoutesEnabled) { foreach (var row in editor.Routes) { var to = row.To.Trim(); var maskText = row.Mask.Trim(); var via = row.Via.Trim(); if (to == string.Empty && maskText == string.Empty && via == string.Empty) { continue; } if (to.Contains('/')) { var parts = to.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length != 2 || !int.TryParse(parts[1], out var cidrPrefix) || cidrPrefix < 0 || cidrPrefix > 32) { routes = []; error = $"自定义路由目标网段格式不正确:{to}"; return false; } to = parts[0]; maskText = PrefixToMask(cidrPrefix); row.To = to; row.Mask = maskText; } if (to == string.Empty || maskText == string.Empty || via == string.Empty) { routes = []; error = "自定义路由的目标网段、子网掩码和网关地址都需要填写。"; return false; } if (!TryMaskOrPrefixToPrefix(maskText, out var prefix)) { routes = []; error = $"自定义路由子网掩码格式不正确:{to} {maskText}"; return false; } row.Mask = PrefixToMask(prefix); result.Add(new RemoteInterfaceRouteConfig { To = $"{to}/{prefix}", Via = via }); } } routes = result.ToArray(); error = string.Empty; return true; } private static bool TryParseAddresses(string text, out RemoteInterfaceAddressConfig[] addresses, out string error) { var result = new List(); foreach (var line in ParseListText(text)) { var parts = line.Split(' ', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length == 1 && line.Contains('/')) { var cidrParts = line.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (cidrParts.Length != 2 || !int.TryParse(cidrParts[1], out var prefix) || prefix < 0 || prefix > 32) { addresses = []; error = $"地址格式不正确:{line}"; return false; } result.Add(new RemoteInterfaceAddressConfig { IP = cidrParts[0], Prefix = prefix }); continue; } if (parts.Length != 2) { addresses = []; error = $"地址格式不正确:{line}"; return false; } if (!TryMaskOrPrefixToPrefix(parts[1], out var parsedPrefix)) { addresses = []; error = $"子网掩码或前缀格式不正确:{line}"; return false; } result.Add(new RemoteInterfaceAddressConfig { IP = parts[0], Prefix = parsedPrefix }); } addresses = result.ToArray(); error = string.Empty; return addresses.Length > 0; } private static bool TryParseRoutes(string text, out RemoteInterfaceRouteConfig[] routes, out string error) { var result = new List(); foreach (var line in ParseListText(text)) { var parts = line.Split(' ', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length == 1) { result.Add(new RemoteInterfaceRouteConfig { To = "default", Via = parts[0] }); continue; } if (parts.Length == 3 && parts[1].Equals("via", StringComparison.OrdinalIgnoreCase)) { result.Add(new RemoteInterfaceRouteConfig { To = parts[0], Via = parts[2] }); continue; } routes = []; error = $"路由格式不正确:{line}"; return false; } routes = result.ToArray(); error = string.Empty; return true; } private static string[] ParseListText(string text) { return text.Split(['\r', '\n', ',', ';'], StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); } private static bool TryMaskOrPrefixToPrefix(string text, out int prefix) { if (int.TryParse(text, out prefix) && prefix >= 0 && prefix <= 32) { return true; } return TryMaskToPrefix(text, out prefix); } private static string PrefixToMask(int prefix) { if (prefix < 0 || prefix > 32) { return string.Empty; } var mask = prefix == 0 ? 0u : uint.MaxValue << (32 - prefix); return string.Join('.', new[] { (mask >> 24) & 255, (mask >> 16) & 255, (mask >> 8) & 255, mask & 255 }); } private static bool TryMaskToPrefix(string maskText, out int prefix) { prefix = 0; if (string.IsNullOrWhiteSpace(maskText)) { return false; } var parts = maskText.Trim().Split('.'); if (parts.Length != 4) { return false; } uint mask = 0; foreach (var part in parts) { if (!byte.TryParse(part, out var octet)) { return false; } mask = (mask << 8) | octet; } var seenZero = false; for (var i = 31; i >= 0; i--) { var bit = (mask & (1u << i)) != 0; if (bit && seenZero) { return false; } if (bit) { prefix++; } else { seenZero = true; } } return true; } private void ConfigInputChanged_OnChanged(object sender, TextChangedEventArgs e) { if (_suppressConfigChangeHandling) { return; } _configValidated = false; ShowStatusMessage("配置内容已变更,请重新点击“2. 校验配置”。"); UpdateButtonStates(); } private void ConfigModeChanged_OnChanged(object sender, RoutedEventArgs e) { if (_suppressConfigChangeHandling) { UpdateButtonStates(); return; } _configValidated = false; _configDirty = true; ShowStatusMessage("配置模式已变更,请重新点击“2. 校验配置”。"); UpdateButtonStates(); } private void GatewayOrRouteModeChanged_OnChanged(object sender, RoutedEventArgs e) { if (_suppressConfigChangeHandling) { UpdateButtonStates(); return; } _configValidated = false; _configDirty = true; ShowStatusMessage("配置内容已变更,请重新点击“2. 校验配置”。"); UpdateButtonStates(); } private void ConfigGrid_OnCellEditEnding(object sender, DataGridCellEditEndingEventArgs e) { if (e.Row.Item is EditableAddress address) { NormalizeAddressRow(address); } else if (e.Row.Item is EditableRoute route) { NormalizeRouteRow(route); } MarkConfigChanged("配置内容已变更,请重新点击“2. 校验配置”。"); } private void DataGrid_OnPreviewMouseWheel(object sender, MouseWheelEventArgs e) { if (sender is not DataGrid dataGrid) { return; } e.Handled = true; var eventArg = new MouseWheelEventArgs(e.MouseDevice, e.Timestamp, e.Delta) { RoutedEvent = MouseWheelEvent, Source = dataGrid, }; ContentScrollViewer.RaiseEvent(eventArg); } private void AddAddressButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is not InterfaceEditor editor) { return; } editor.Addresses.Add(new EditableAddress(editor) { Mask = "255.255.255.0" }); MarkConfigChanged("已添加 IP 地址,请填写后重新校验配置。"); } private void AddRouteButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is not InterfaceEditor editor) { return; } editor.Routes.Add(new EditableRoute(editor)); MarkConfigChanged("已添加路由,请填写后重新校验配置。"); } private void AddDnsButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is not InterfaceEditor editor) { return; } editor.Dns.Add(new EditableDns(editor)); MarkConfigChanged("已添加 DNS,请填写后重新校验配置。"); } private void DeleteAddressButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is not EditableAddress address) { return; } address.Owner.Addresses.Remove(address); MarkConfigChanged("已删除 IP 地址,请重新校验配置。"); } private void DeleteRouteButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is EditableRoute route) { route.Owner.Routes.Remove(route); MarkConfigChanged("已删除路由,请重新校验配置。"); } } private void DeleteDnsButton_OnClick(object sender, RoutedEventArgs e) { if ((sender as FrameworkElement)?.DataContext is EditableDns dns) { dns.Owner.Dns.Remove(dns); MarkConfigChanged("已删除 DNS,请重新校验配置。"); } } private void MarkConfigChanged(string message) { if (_suppressConfigChangeHandling) { return; } _configValidated = false; _configDirty = true; ShowStatusMessage(message); UpdateButtonStates(); } private static void NormalizeAddressRow(EditableAddress row) { var ip = row.IP.Trim(); if (!ip.Contains('/')) { return; } var parts = ip.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length == 2 && int.TryParse(parts[1], out var prefix) && prefix >= 0 && prefix <= 32) { row.IP = parts[0]; row.Mask = PrefixToMask(prefix); } } private static void NormalizeRouteRow(EditableRoute row) { var to = row.To.Trim(); if (!to.Contains('/')) { return; } var parts = to.Split('/', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries); if (parts.Length == 2 && int.TryParse(parts[1], out var prefix) && prefix >= 0 && prefix <= 32) { row.To = parts[0]; row.Mask = PrefixToMask(prefix); } } private void ShowStatusMessage(string message) { ApplyStatusMessageStyle(message); StatusMessageTextBlock.Text = message; StatusMessageBorder.Opacity = 0; StatusMessageBorder.Visibility = Visibility.Visible; StatusMessageBorder.BeginAnimation(OpacityProperty, new DoubleAnimation(1, TimeSpan.FromMilliseconds(160))); _statusMessageCts?.Cancel(); _statusMessageCts = new CancellationTokenSource(); _ = HideStatusMessageAsync(_statusMessageCts.Token); } private async Task HideStatusMessageAsync(CancellationToken cancellationToken) { try { await Task.Delay(3000, cancellationToken); await Dispatcher.InvokeAsync(() => { var animation = new DoubleAnimation(0, TimeSpan.FromMilliseconds(200)); animation.Completed += (_, _) => { if (!cancellationToken.IsCancellationRequested) { StatusMessageBorder.Visibility = Visibility.Collapsed; } }; StatusMessageBorder.BeginAnimation(OpacityProperty, animation); }); } catch (TaskCanceledException) { } } private void ApplyStatusMessageStyle(string message) { var (background, foreground) = GetStatusMessageBrushes(message); StatusMessageBorder.Background = background; StatusMessageTextBlock.Foreground = foreground; } private static (Brush Background, Brush Foreground) GetStatusMessageBrushes(string message) { if (ContainsAny(message, "失败", "错误", "拒绝", "超时", "不能为空", "不正确", "无法")) { return (new SolidColorBrush((Color)ColorConverter.ConvertFromString("#B91C1C")), Brushes.White); } if (ContainsAny(message, "未发现", "请", "重试", "警告", "需要")) { return (new SolidColorBrush((Color)ColorConverter.ConvertFromString("#C2410C")), Brushes.White); } if (ContainsAny(message, "成功", "已切换", "已刷新", "已读取", "已加载", "已发现", "已提交", "已回填")) { return (new SolidColorBrush((Color)ColorConverter.ConvertFromString("#047857")), Brushes.White); } return (new SolidColorBrush((Color)ColorConverter.ConvertFromString("#111827")), Brushes.White); } private static bool ContainsAny(string message, params string[] markers) { return markers.Any(marker => message.Contains(marker, StringComparison.Ordinal)); } private static string FormatTaskStatusMessage(RemoteTaskResult task) { return task.Status switch { "success" => string.IsNullOrWhiteSpace(task.Detail) ? "配置已成功应用。" : task.Detail, "failed" => string.IsNullOrWhiteSpace(task.Detail) ? "配置应用失败。" : task.Detail, "rolled_back" => string.IsNullOrWhiteSpace(task.Detail) ? "配置应用失败,已自动回滚。" : task.Detail, _ => task.Step switch { "validating" => "正在校验配置...", "writing_netplan" => "正在写入 Linux 网络配置...", "applying" => "正在应用 Linux 网络配置...", "confirming" => string.IsNullOrWhiteSpace(task.Detail) ? "等待确认保留配置..." : task.Detail, "rolling_back" => "配置应用失败,正在自动回滚...", _ => string.IsNullOrWhiteSpace(task.Detail) ? "正在处理,请稍候..." : task.Detail, } }; } private void ShowTaskCompletionDialog(RemoteTaskResult task) { var message = FormatTaskStatusMessage(task); var title = task.Status == "success" ? "应用配置成功" : "应用配置失败"; var image = task.Status == "success" ? MessageBoxImage.Information : MessageBoxImage.Warning; MessageBox.Show(this, message, title, MessageBoxButton.OK, image); } private void UpdateButtonStates() { var hasInterfaces = _interfaces.Count > 0; InterfacesItemsControl.IsEnabled = !_isBusy && hasInterfaces; ReloadInterfaceConfigButton.IsEnabled = !_isBusy && hasInterfaces; ValidateConfigButton.IsEnabled = !_isBusy && hasInterfaces; ApplyConfigButton.IsEnabled = !_isBusy && _configValidated && hasInterfaces; RebootButton.IsEnabled = !_isBusy; ShutdownButton.IsEnabled = !_isBusy; } private void SetBusyState(bool isBusy, string? message = null) { _isBusy = isBusy; BusyOverlay.Visibility = isBusy ? Visibility.Visible : Visibility.Collapsed; BusyMessageTextBlock.Text = string.IsNullOrWhiteSpace(message) ? "正在处理,请稍候..." : message; UpdateButtonStates(); } private sealed class InterfaceEditor : INotifyPropertyChanged { private bool _dhcp4; private bool _defaultGatewayEnabled; private bool _customRoutesEnabled; private string _defaultGateway = string.Empty; public InterfaceEditor(RemoteInterfaceInfo info) { SystemName = info.SystemName; StatusSummary = info.StatusSummary; LinkUp = info.LinkUp; } public string SystemName { get; } public string StatusSummary { get; } public bool LinkUp { get; } public ObservableCollection Addresses { get; } = []; public ObservableCollection Routes { get; } = []; public ObservableCollection Dns { get; } = []; public bool Dhcp4 { get => _dhcp4; set => SetField(ref _dhcp4, value); } public bool DefaultGatewayEnabled { get => _defaultGatewayEnabled; set => SetField(ref _defaultGatewayEnabled, value); } public bool CustomRoutesEnabled { get => _customRoutesEnabled; set => SetField(ref _customRoutesEnabled, value); } public string DefaultGateway { get => _defaultGateway; set => SetField(ref _defaultGateway, value); } public event PropertyChangedEventHandler? PropertyChanged; private void SetField(ref T field, T value, [CallerMemberName] string propertyName = "") { if (EqualityComparer.Default.Equals(field, value)) { return; } field = value; PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName)); } } private sealed class EditableAddress : INotifyPropertyChanged { private string _ip = string.Empty; private string _mask = string.Empty; public EditableAddress(InterfaceEditor owner) { Owner = owner; } public InterfaceEditor Owner { get; } public string IP { get => _ip; set => SetField(ref _ip, value); } public string Mask { get => _mask; set => SetField(ref _mask, value); } public event PropertyChangedEventHandler? PropertyChanged; private void SetField(ref T field, T value, [CallerMemberName] string propertyName = "") { if (EqualityComparer.Default.Equals(field, value)) { return; } field = value; PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName)); } } private sealed class EditableRoute { public EditableRoute(InterfaceEditor owner) { Owner = owner; } public InterfaceEditor Owner { get; } public string To { get; set; } = string.Empty; public string Mask { get; set; } = string.Empty; public string Via { get; set; } = string.Empty; } private sealed class EditableDns { public EditableDns(InterfaceEditor owner) { Owner = owner; } public InterfaceEditor Owner { get; } public string Address { get; set; } = string.Empty; } }