VacuumPressureMembranePoreSizeAnalyzer/ViewModels/MainViewModel.cs

using MembranePoreTester.Communication;
using System.Collections.ObjectModel;
using System.ComponentModel;  // 用于 PropertyChanged
using System.Net;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Input;
using System.Windows.Threading;
using static OfficeOpenXml.ExcelErrorValue;

namespace MembranePoreTester.ViewModels
{
    public class MainViewModel : ViewModelBase
    {
        public ObservableCollection<StationItem> Stations { get; } = new();



        // 报警信息集合（用于显示多条）
        private ObservableCollection<string> _alarmMessages;
        public ObservableCollection<string> AlarmMessages
        {
            get => _alarmMessages;
            set => SetProperty(ref _alarmMessages, value);
        }

        private bool _hasAlarm;
        public bool HasAlarm
        {
            get => _hasAlarm;
            set => SetProperty(ref _hasAlarm, value);
        }

        private string _alarmText;
        public string AlarmText
        {
            get => _alarmText;
            set => SetProperty(ref _alarmText, value);
        }

        private DispatcherTimer _alarmTimer;









        public class PressureModeItem
        {
            public string Text { get; set; }
            public int Value { get; set; }


            public override string ToString()
            {
                return Text;  // 直接返回要显示的文本
            }
        }
        public class StationItem : ViewModelBase
        {
            private PressureModeItem _selectedPressureMode;
            private List<PressureModeItem> _pressureModeList;

            public List<PressureModeItem> PressureModeList => _pressureModeList ??= new List<PressureModeItem>
    {
        new PressureModeItem { Text = "低压", Value = 1 },
        new PressureModeItem { Text = "高压", Value = 0 }
    };

            public PressureModeItem SelectedPressureMode
            {
                get => _selectedPressureMode;
                set
                {
                    if (SetProperty(ref _selectedPressureMode, value))
                    {
                        Task.Run(async () => await WritePressureModeAsync(value?.Text ?? "低压"));
                    }
                }
            }



            private PressureModeItem _selectedInTakeMode;
            private List<PressureModeItem> _inTakeModeList;

            public List<PressureModeItem> InTakeModeList => _inTakeModeList ??= new List<PressureModeItem>
    {
        new PressureModeItem { Text = "底部进气", Value = 0 },
        //new PressureModeItem { Text = "顶部进气", Value = 1 }
    };

            public PressureModeItem SelecteInTakeMode
            {
                get => _selectedInTakeMode;
                set
                {
                    if (SetProperty(ref _selectedInTakeMode, value))
                    {
                        Task.Run(async () => await WriteInTakeModeAsync(value?.Text ?? "底部进气"));
                    }
                }
            }






            private readonly IPlcService _plcService;
            private readonly PlcConfiguration _plcConfig;
            private bool _isPressing;
            private string _pressButtonText = "加压";
            private string _highLowPressure = "低压";
            private bool _enableStatus;  // M21 状态

            public string Name { get; set; }
            public BubblePointViewModel BubblePointVM { get; set; }
            public PoreDistributionViewModel PoreDistributionVM { get; set; }
            public int StationId { get; set; }

            public string HighLowPressure
            {
                get => _selectedPressureMode?.Text ?? "低压";
                set
                {
                    var mode = PressureModeList.FirstOrDefault(m => m.Text == value);
                    if (mode != null)
                    {
                        SelectedPressureMode = mode;
                    }
                }
            }

            public string UpAndDown
            {
                get => _selectedInTakeMode?.Text ?? "底部";
                set
                {
                    var mode = InTakeModeList.FirstOrDefault(m => m.Text == value);
                    if (mode != null)
                    {
                        SelecteInTakeMode = mode;
                    }
                }
            }

            public string PressButtonText
            {
                get => _pressButtonText;
                set => SetProperty(ref _pressButtonText, value);
            }


            public bool EnableStatus
            {
                get => _enableStatus;
                private set
                {
                    if (SetProperty(ref _enableStatus, value))
                    {
                        // 当设备停止运行时，停止孔分布自动采集
                        if (!value)
                        {
                            PoreDistributionVM?.StopCollecting();
                        }
                        OnPropertyChanged(nameof(EnableStatusText));
                        OnPropertyChanged(nameof(EnableStatusColor));
                    }
                }
            }

            // 使能状态显示文本
            public string EnableStatusText => EnableStatus ? "运行中" : "未启动";

            // 使能状态显示颜色（绿色表示运行中，灰色表示未启动）
            // 使能状态显示颜色（更亮的颜色）
            public string EnableStatusColor => EnableStatus ? "#00FF00" : "#FF3333";

            // 定时器，用于轮询 M21 状态
            private System.Windows.Threading.DispatcherTimer _timer;

            public ICommand PressCommand { get; }
            //public ICommand BurstCommand { get; }
            public ICommand StartCommand { get; }
            public ICommand StopCommand { get; }
            public ICommand EnableCommand { get; } // 备用，但可以使用复选框直接绑定





            private double _pressureUpperLimit;
            private double _pressureRate;
            // 防止从PLC读取时触发校验弹窗
            private bool _suppressPressureValidation = false;

            public double PressureUpperLimit
            {
                get => _pressureUpperLimit;
                set
                {
                    // 如果不是从PLC读取（即用户交互或程序主动设置），先校验再设置
                    if (!_suppressPressureValidation && HighLowPressure.Contains("低压") && value > 200)
                    {
                        MessageBox.Show("低压模式,加压上限不能超过200!");
                        return;
                    }
                    if (!_suppressPressureValidation && HighLowPressure.Contains("高压") && value > 1000)
                    {
                        MessageBox.Show("高压模式,加压上限不能超过1000!");
                        return;
                    }

                    bool changed = SetProperty(ref _pressureUpperLimit, value);
                    // 仅在非抑制模式下将改变写回PLC，避免把PLC读回的值再次写入造成循环
                    if (changed && !_suppressPressureValidation)
                    {
                        ushort address = StationId == 1 ? _plcConfig.PressureUpperLimit
               : StationId == 2 ? _plcConfig.PressureUpperLimit2
               : _plcConfig.PressureUpperLimit3;
                        _ = _plcService.WriteMultipleRegistersAsync(address, (float)value);
                    }
                }
            }

            public double PressureRate
            {
                get => _pressureRate;
                set
                {
                    if (SetProperty(ref _pressureRate, value))
                    {
                        // 值改变时写入PLC
                        _ = _plcService.WriteMultipleRegistersAsync(StationId == 1 ? _plcConfig.PressureRate : StationId == 2 ? _plcConfig.PressureRate2 : _plcConfig.PressureRate3, (float)value);
                    }
                }
            }

            // 添加读取这两个参数的方法
            private async Task ReadPressureParametersAsync()
            {
                try
                {
                    // 根据工位选择加压上限的PLC地址
                    ushort upperLimitAddress = StationId == 1 ? _plcConfig.PressureUpperLimit
                                             : StationId == 2 ? _plcConfig.PressureUpperLimit2
                                             : _plcConfig.PressureUpperLimit3;

                    float upperLimit = await _plcService.ReadFloatAsync(upperLimitAddress);
                    float rate = await _plcService.ReadFloatAsync(StationId == 1 ? _plcConfig.PressureRate : StationId == 2 ? _plcConfig.PressureRate2 : _plcConfig.PressureRate3);




                    Application.Current.Dispatcher.Invoke(() =>
                    {
                        // 在将PLC读取的值赋回到属性时，抑制用户校验提示和避免回写PLC
                        _suppressPressureValidation = true;
                        PressureUpperLimit = upperLimit;
                        PressureRate = rate;
                        _suppressPressureValidation = false;
                    });
                }
                catch (Exception ex)
                {
                    System.Diagnostics.Debug.WriteLine($"读取压力参数失败: {ex.Message}");
                }
            }


            public StationItem()
            {

                if (IsInDesignMode())
                {
                    return; // 设计时跳过PLC初始化
                }





                _plcService = App.PlcService;
                _plcConfig = App.PlcConfig;

                PressCommand = new RelayCommand(async () => await TogglePressAsync());


                // 在 StationItem 构造函数中
                StartCommand = new RelayCommand(async () =>
                {
                    // 启动PLC
                    await WriteCoilAsync(StationId == 1 ? _plcConfig.StartCoil : StationId == 2 ? _plcConfig.StartCoil2 : _plcConfig.StartCoil3, true);

                    // 启动孔分布自动采集
                    PoreDistributionVM.StartCollecting();

                });

                StopCommand = new RelayCommand(async () =>
                {
                    // 停止自动采集
                    PoreDistributionVM.StopCollecting();
                    // 停止PLC
                    await WriteCoilAsync(StationId == 1 ? _plcConfig.StopCoil : StationId == 2 ? _plcConfig.StopCoil2 : _plcConfig.StopCoil3, true);
                });




                // 启动定时器，每秒读取一次 M21 状态
                _timer = new System.Windows.Threading.DispatcherTimer();
                _timer.Interval = TimeSpan.FromSeconds(1);
                _timer.Tick += async (s, e) =>
                {
                    await ReadEnableStatusAsync();
                    await ReadPressureParametersAsync(); // 新增：读取压力参数
                };
                _timer.Start();

                // 延迟2秒后读取，确保连接稳定
                Task.Delay(2000).ContinueWith(async _ =>
                {
                    await ReadPressureModeAsync();
                    await ReadPressureParametersAsync(); // 新增：读取压力参数
                    await ReadInTakeModeAsync();

                }, TaskScheduler.Default);

            }
            private async Task ReadPressureModeAsync()
            {
                await SafeExecuteAsync($"ReadPressureModeAsync{StationId}", async () =>
                {
                    try
                    {
                        ushort[] values = await _plcService.ReadHoldingRegistersAsync(StationId == 1 ? _plcConfig.PressureModeRegister : StationId == 2 ? _plcConfig.PressureModeRegister2 : _plcConfig.PressureModeRegister3, 1);
                        ushort val = values[0];
                        string newValue = val == 0 ? "高压" : "低压";

                        Application.Current.Dispatcher.Invoke(() =>
                        {
                            // 更新选中项
                            HighLowPressure = newValue;
                        });
                    }
                    catch (Exception ex)
                    {
                        System.Diagnostics.Debug.WriteLine($"读取压力模式失败: {ex.Message}");
                    }
                });
            }

            private async Task ReadInTakeModeAsync()
            {
                await SafeExecuteAsync($"ReadInTakeModeAsync{StationId}", async () =>
                {
                    try
                    {
                        ushort address = 0;

                        if (StationId == 1)
                        {
                            address = _plcConfig.UpAndDown1;
                        }
                        else if (StationId == 2)
                        {
                            address = _plcConfig.UpAndDown2;
                        }
                        else if (StationId == 3)
                        {
                            address = _plcConfig.UpAndDown3;
                        }

                        ushort[] values = await _plcService.ReadHoldingRegistersAsync(address, 1);
                        ushort val = values[0];
                        string newValue = val == 0 ? "底部进气" : "顶部进气";

                        Application.Current.Dispatcher.Invoke(() =>
                        {
                            // 更新选中项
                            UpAndDown = newValue;
                        });
                    }
                    catch (Exception ex)
                    {
                        System.Diagnostics.Debug.WriteLine($"读取出口模式失败: {ex.Message}");
                    }
                });
            }

            private async Task TogglePressAsync()
            {
                try
                {
                    ushort coilAddress = _plcConfig.PressCoil; // 根据工位选择不同的线圈地址
                    switch (StationId)
                    {
                        case 1:
                            coilAddress = _plcConfig.PressCoil;
                            break;
                        case 2:
                            coilAddress = _plcConfig.PressCoil2;
                            break;
                        case 3:
                            coilAddress = _plcConfig.PressCoil3;
                            break;
                    }


                    // 先读取PLC当前的加压状态
                    bool currentStatus = await _plcService.ReadCoilAsync(coilAddress);

                    // 切换状态
                    _isPressing = !currentStatus;

                    // 写入新状态到PLC
                    await WriteCoilAsync(coilAddress, _isPressing);

                    // 更新按钮文字
                    PressButtonText = _isPressing ? "停止加压" : "加压";
                }
                catch (Exception ex)
                {
                    MessageBox.Show($"读取加压状态失败: {ex.Message}", "错误", MessageBoxButton.OK, MessageBoxImage.Error);
                }
            }
            // 在 StationItem 类中添加字段
            private bool _lastEnableReadFailed = false;
            private DateTime _lastEnableErrorTime = DateTime.MinValue;
            private async Task ReadEnableStatusAsync()
            {
                await SafeExecuteAsync($"ReadEnableStatus_Station{StationId}", async () =>
                {
                    try
                    {
                        bool status = await _plcService.ReadCoilAsync(StationId == 1 ? _plcConfig.EnableCoil : StationId == 2 ? _plcConfig.EnableCoil2 : _plcConfig.EnableCoil3);  // 读取 M21
                        EnableStatus = status;


                        bool pressStatus = await _plcService.ReadCoilAsync(StationId == 1 ? _plcConfig.PressCoil : StationId == 2 ? _plcConfig.PressCoil2 : _plcConfig.PressCoil3);//这里也要更新加压的按钮状态

                        _isPressing = pressStatus;

                        // 在UI线程更新按钮文字
                        Application.Current.Dispatcher.Invoke(() =>
                        {
                            PressButtonText = pressStatus ? "停止加压" : "加压";
                        });



                    }
                    catch (Exception ex)
                    {
                        // 读取出错时保持原状态或显示错误
                        System.Diagnostics.Debug.WriteLine($"读取使能状态失败: {ex.Message}");
                    }
                });
            }

            private async Task WriteCoilAsync(ushort coil, bool value)
            {
                try
                {
                    await _plcService.WriteCoilAsync(coil, value);
                }
                catch (Exception ex)
                {
                    MessageBox.Show($"写线圈失败: {ex.Message}");
                }
            }

            private async Task WritePressureModeAsync(string mode)
            {
                if (IsDisposed) return;

                ushort val = mode.ToString().Contains("高压") ? (ushort)0 : (ushort)1;
                try
                {
                    if (StationId == 1)
                    {
                        await _plcService.WriteSingleRegisterAsync(_plcConfig.PressureModeRegister, val);
                    }
                    else if (StationId == 2)
                    {
                        await _plcService.WriteSingleRegisterAsync(_plcConfig.PressureModeRegister2, val);
                    }
                    else if (StationId == 3)
                    {
                        await _plcService.WriteSingleRegisterAsync(_plcConfig.PressureModeRegister3, val);
                    }
                }
                catch (Exception ex)
                {
                    MessageBox.Show($"写压力模式失败: {ex.Message}");
                }

            }


            private async Task WriteInTakeModeAsync(string mode)
            {
                if (IsDisposed) return;

                ushort val = mode.ToString().Contains("底部") ? (ushort)0 : (ushort)1;
                try
                {
                    ushort address = 0;

                    if (StationId == 1)
                    {
                        address = _plcConfig.UpAndDown1;
                    }
                    else if (StationId == 2)
                    {
                        address = _plcConfig.UpAndDown2;
                    }
                    else if (StationId == 3)
                    {
                        address = _plcConfig.UpAndDown3;
                    }

                    await _plcService.WriteSingleRegisterAsync(address, val);
                }
                catch (Exception ex)
                {
                    MessageBox.Show($"写出口模式失败: {ex.Message}");
                }

            }

            private bool _isPoreDistributionActive;
            public bool IsPoreDistributionActive
            {
                get => _isPoreDistributionActive;
                set => SetProperty(ref _isPoreDistributionActive, value);
            }




        }







        public MainViewModel()
        {
            for (int i = 1; i <= 3; i++)
            {
                var station = new StationItem
                {
                    Name = $"工位 {i}",
                    BubblePointVM = new BubblePointViewModel(),
                    PoreDistributionVM = new PoreDistributionViewModel(),
                    StationId = i
                };
                // 在构造完成后显式传入 StationId 以初始化 VM
                station.BubblePointVM.Initialize(i);
                station.PoreDistributionVM.Initialize(i);
                Stations.Add(station);
            }


            AlarmMessages = new ObservableCollection<string>();

            _alarmTimer = new DispatcherTimer { Interval = TimeSpan.FromSeconds(1) };
            _alarmTimer.Tick += async (s, e) => await RefreshAlarms();
            _alarmTimer.Start();
        }



        private async Task RefreshAlarms()
        {
            try
            {
                var plc = App.PlcService;
                var config = App.PlcConfig;

                // 读取4个报警线圈状态
                bool smallFlowAlarm = await plc.ReadCoilAsync(config.SmallFlowAlarm);
                bool bigFlowAlarm = await plc.ReadCoilAsync(config.BigFlowAlarm);
                bool highPressAlarm = await plc.ReadCoilAsync(config.HighPressAlarm);
                bool lowPressAlarm = await plc.ReadCoilAsync(config.LowPressAlarm);


                bool Midnight1 = await plc.ReadCoilAsync(config.Midnight1);
                bool Midnight2 = await plc.ReadCoilAsync(config.Midnight2);
                bool Midnight3 = await plc.ReadCoilAsync(config.Midnight3);

                // 收集当前报警信息
                var newAlarms = new List<string>();
                if (smallFlowAlarm) newAlarms.Add("小流量计报警");
                if (bigFlowAlarm) newAlarms.Add("大流量报警");
                if (highPressAlarm) newAlarms.Add("高压超限");
                if (lowPressAlarm) newAlarms.Add("低压超限");

                if (Midnight1) newAlarms.Add("1工位漏液");
                if (Midnight2) newAlarms.Add("2工位漏液");
                if (Midnight3) newAlarms.Add("3工位漏液");

                // 更新UI（避免频繁刷新集合导致界面闪烁，直接替换内容）
                Application.Current.Dispatcher.Invoke(() =>
                {
                    AlarmMessages.Clear();
                    foreach (var msg in newAlarms)
                        AlarmMessages.Add(msg);

                    HasAlarm = newAlarms.Any();
                    AlarmText = HasAlarm ? string.Join("；", newAlarms) : "";
                });
            }
            catch (Exception ex)
            {
                System.Diagnostics.Debug.WriteLine($"读取报警状态失败: {ex.Message}");
            }
        }
    }
}