ACP/DeviceEditModule/ViewModels/DG1000ZViewModel.cs

using DeviceCommand.Devices;
using Prism.Commands;
using Prism.Ioc;
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Input;
using UIShare.GlobalVariable;
using UIShare.ViewModelBase;

namespace DeviceEditModule.ViewModels
{
    /// <summary>
    /// DG1000Z 信号发生器一拖三 控制面板 ViewModel
    /// </summary>
    public class DG1000ZViewModel : NavigateViewModelBase, IDisposable
    {
        private readonly DeviceManager _dm;
        private DG1000Z? _dev;
        private CancellationTokenSource? _cts;

        private string _deviceName = "DG1000Z";
        public string DeviceName { get => _deviceName; set => SetProperty(ref _deviceName, value); }
        private bool _isConnected;
        public bool IsConnected { get => _isConnected; set => SetProperty(ref _isConnected, value); }
        private bool _isBusy;
        public bool IsBusy { get => _isBusy; set => SetProperty(ref _isBusy, value); }

        #region 输入参数
        private int _channel = 1; public int Channel { get => _channel; set => SetProperty(ref _channel, value); }
        private double _frequency = 1000; public double Frequency { get => _frequency; set => SetProperty(ref _frequency, value); }
        private double _amplitude = 5; public double Amplitude { get => _amplitude; set => SetProperty(ref _amplitude, value); }
        private double _offsetVoltage; public double OffsetVoltage { get => _offsetVoltage; set => SetProperty(ref _offsetVoltage, value); }
        private double _dutyCycle = 50; public double DutyCycle { get => _dutyCycle; set => SetProperty(ref _dutyCycle, value); }
        #endregion

        #region 测量结果
        private double _measuredFrequency;
        public double MeasuredFrequency { get => _measuredFrequency; set => SetProperty(ref _measuredFrequency, value); }
        private double _measuredAmplitude;
        public double MeasuredAmplitude { get => _measuredAmplitude; set => SetProperty(ref _measuredAmplitude, value); }
        private string _responseLog = "";
        public string ResponseLog { get => _responseLog; set => SetProperty(ref _responseLog, value); }
        #endregion

        #region 命令
        public ICommand QueryIdn { get; } public ICommand Reset { get; }
        public ICommand OutOn { get; } public ICommand OutOff { get; }
        public ICommand SetFreq { get; } public ICommand SetAmp { get; } public ICommand SetOffset { get; }
        public ICommand SetDuty { get; } public ICommand QueryFreq { get; } public ICommand QueryAmp { get; }
        public ICommand QueryCounter { get; } public ICommand QueryError { get; }
        #endregion

        public DG1000ZViewModel(IContainerProvider cp) : base(cp)
        {
            _dm = cp.Resolve<DeviceManager>();
            QueryIdn = new DelegateCommand(async () => await Exec(async () => Log("IDN:" + await _dev!.查询设备标识(Ct()))));
            Reset = new DelegateCommand(async () => await Exec(async () => { await _dev!.重置设备(Ct()); Log("设备已重置"); }));
            OutOn = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置通道输出状态(Channel, true, Ct()); Log($"CH{Channel}输出开"); }));
            OutOff = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置通道输出状态(Channel, false, Ct()); Log($"CH{Channel}输出关"); }));
            SetFreq = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置频率(Channel, Frequency, Ct()); Log($"CH{Channel}频率={Frequency}Hz"); }));
            SetAmp = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置幅度(Channel, Amplitude, Ct()); Log($"CH{Channel}幅度={Amplitude}Vpp"); }));
            SetOffset = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置偏移电压(Channel, OffsetVoltage, Ct()); Log($"CH{Channel}偏移={OffsetVoltage}Vdc"); }));
            SetDuty = new DelegateCommand(async () => await Exec(async () => { await _dev!.设置方波占空比(Channel, DutyCycle, Ct()); Log($"CH{Channel}占空比={DutyCycle}%"); }));
            QueryFreq = new DelegateCommand(async () => await Exec(async () => { MeasuredFrequency = await _dev!.查询频率(Channel, Ct()); Log($"CH{Channel}频率={MeasuredFrequency}Hz"); }));
            QueryAmp = new DelegateCommand(async () => await Exec(async () => { MeasuredAmplitude = await _dev!.查询幅度(Channel, Ct()); Log($"CH{Channel}幅度={MeasuredAmplitude}Vpp"); }));
            QueryCounter = new DelegateCommand(async () => await Exec(async () => { MeasuredFrequency = await _dev!.查询频率计测量值(Ct()); Log($"频率计={MeasuredFrequency}Hz"); }));
            QueryError = new DelegateCommand(async () => await Exec(async () => Log("错误:" + await _dev!.查询错误信息(Ct()))));
            Initialize();
        }

        #region 初始化 / Navigation

        public void Initialize(string? deviceName = null)
        {
            DG1000Z? found = null; string? fn = null;
            if (deviceName != null && _dm.DeviceMap.TryGetValue(deviceName, out var d) && d is DG1000Z e)
            { found = e; fn = deviceName; }
            else
            {
                foreach (var kv in _dm.DeviceMap)
                    if (kv.Value is DG1000Z it) { found = it; fn = kv.Key; break; }
            }
            _dev = found;
            DeviceName = fn ?? "DG1000Z (未找到)";
            IsConnected = _dev?.IsConnected ?? false;
            Log(found != null
                ? $"已关联设备 [{DeviceName}]，连接:{(IsConnected ? "已连接" : "未连接")}"
                : "未在 DeviceManager 中找到 DG1000Z 设备");
        }

        public override void OnNavigatedTo(NavigationContext context)
        {
            var pName = context.Parameters.GetValue<string?>("DeviceName");
            Initialize(pName);
        }

        #endregion

        #region 辅助

        private CancellationToken Ct() => (_cts = new CancellationTokenSource(TimeSpan.FromSeconds(10))).Token;

        private async Task Exec(Func<Task> action)
        {
            if (_dev == null) { Log("错误：未关联到设备实例，请检查设备配置。"); return; }
            if (IsBusy) return;
            IsBusy = true;
            try
            {
                await action();
                IsConnected = _dev.IsConnected;
            }
            catch (OperationCanceledException) { Log("命令超时或已取消。"); }
            catch (Exception ex) { Log($"错误：{ex.Message}"); }
            finally { IsBusy = false; }
        }

        private void Log(string message)
        {
            var line = $"[{DateTime.Now:HH:mm:ss}] {message}";
            ResponseLog = ResponseLog.Length > 4000
                ? line + "\n" + ResponseLog[..3000]
                : line + "\n" + ResponseLog;
        }

        #endregion

        public void Dispose()
        {
            _cts?.Cancel();
            _cts?.Dispose();
        }
    }
}