PunkHPX8/PunkHPX8_MainPages/ViewModels/TemperatureControllerViewModel.cs

using Aitex.Core.Util;
using MECF.Framework.Common.CommonData.TemperatureControl;
using MECF.Framework.Common.DataCenter;
using MECF.Framework.Common.Device.TemperatureController;
using MECF.Framework.Common.Utilities;
using PunkHPX8_MainPages.Model;
using Prism.Mvvm;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Timers;
using System.Windows.Threading;
using MECF.Framework.Common.Persistent.Temperature;
using MECF.Framework.Common.Persistent.Prewet;
using MECF.Framework.Common.Persistent.Reservoirs;

namespace PunkHPX8_MainPages.ViewModels
{
    public class TemperatureControllerViewModel : BindableBase
    {
        #region 常量
        private const string TEMPERATURE_DEVICELIST = "TemperatureDeviceList";
        private const string TEMPERATURE_DATA = "TemperatureData";
        private const string IS_CONNECTED = "IsConnected";
        private const string PERSISTENT_VALUE = "PersistentValue";
        #endregion


        #region 内部变量
        /// <summary>
        /// Temperature设备配置
        /// </summary>
        private ObservableCollection<TemperatureUIData> _temperatureUIDatas;
        /// <summary>
        /// 持久化数据
        /// </summary>
        private TCPersistentValue _tCPersistent;
        /// <summary>
        /// 模块名称
        /// </summary>
        private string _moduleName;
        /// <summary>
        /// 查询后台数据集合
        /// </summary>
        private List<string> _rtDataKeys = new List<string>();
        /// <summary>
        /// 查询后台的数据
        /// </summary>
        private Dictionary<string, object> _rtDataValues;
        /// <summary>
        /// 定时器
        /// </summary>
        private DispatcherTimer _timer;
        /// <summary>
        ///当前模式是否可用
        /// </summary>
        private bool _isEnabled;
        /// <summary>
        /// Persistent
        /// </summary>
        private ReservoirsPersistentValue _reservoirsPersistent;
        #endregion

        #region 属性
        /// <summary>
        /// 模块名称
        /// </summary>
        public string ModuleName { get { return _moduleName; } set { SetProperty(ref _moduleName, value); } }
        /// <summary>
        /// Temperature设备数据集合
        /// </summary>
        public ObservableCollection<TemperatureUIData> TemperatureUIDatas { get { return _temperatureUIDatas; } set { SetProperty(ref _temperatureUIDatas, value); } }
        public TCPersistentValue TCPersistent
        {
            get { return _tCPersistent; }
            set { SetProperty(ref _tCPersistent, value); }
        }
        public bool IsEnabled
        {
            get { return _isEnabled; }
            set { SetProperty(ref _isEnabled, value); }
        }
        public ReservoirsPersistentValue ReservoirsPersistent
        {
            get { return _reservoirsPersistent; }
            set { SetProperty(ref _reservoirsPersistent, value); }
        }
        #endregion
        /// <summary>
        /// 构造函数
        /// </summary>
        public TemperatureControllerViewModel()
        {
        }

        /// <summary>
        /// 加载数据
        /// </summary>
        public void LoadData(string systemName)
        {
            ModuleName = systemName;
            List<string> lst = new List<string>();
            lst.Add($"{ModuleName}.{TEMPERATURE_DEVICELIST}");
            _rtDataValues = QueryDataClient.Instance.Service.PollData(lst);
            if (_rtDataValues != null)
            {
                TemperatureDeviceConfig config = CommonFunction.GetValue<TemperatureDeviceConfig>(_rtDataValues, $"{ModuleName}.{TEMPERATURE_DEVICELIST}");
                TemperatureUIDatas = new ObservableCollection<TemperatureUIData>();
                foreach(TemperatureDevice item in config.TemperatureDevices)
                {
                    TemperatureUIData temp = new TemperatureUIData();
                    temp.ReserviorName = item.ReserviorName;
                    temp.Name = item.Name;
                    TemperatureUIDatas.Add(temp);
                }
                InitialKeys(config);
            }
            if (_timer == null)
            {
                _timer = new DispatcherTimer();
                _timer.Interval = TimeSpan.FromMilliseconds(200);
                _timer.Tick += Timer_Tick;
            }
            _timer.Start();
        }
        /// <summary>
        /// 定时器执行
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Tick(object sender, EventArgs e)
        {
            if (_rtDataKeys.Count != 0)
            {
                _rtDataValues = QueryDataClient.Instance.Service.PollData(_rtDataKeys);
                if (_rtDataValues != null && _rtDataValues.Count != 0 && TemperatureUIDatas != null)
                {
                    foreach (TemperatureUIData item in TemperatureUIDatas)
                    {
                        TemperatureControllerData data = CommonFunction.GetValue<TemperatureControllerData>(_rtDataValues, $"{item.Name}.{TEMPERATURE_DATA}");
                        if (data != null)
                        {
                            data.IsConnected = CommonFunction.GetValue<bool>(_rtDataValues, $"{item.Name}.{IS_CONNECTED}");
                            TCPersistent = CommonFunction.GetValue<TCPersistentValue>(_rtDataValues, $"{item.Name}.{PERSISTENT_VALUE}");
                            ReservoirsPersistent = CommonFunction.GetValue<ReservoirsPersistentValue>(_rtDataValues, $"{item.ReserviorName}.{PERSISTENT_VALUE}");
                            data.AutoStatus = ReservoirsPersistent.OperatingMode;
                            data.SetPoint = TCPersistent.SetPoint;
                            data.SetPointMaxValue = TCPersistent.SetPointHighLimit;
                            data.SetPointMinValue = TCPersistent.SetPointLowLimit;
                            item.SetValue(data);
                            if ("Auto".Equals(item.AutoStatus) || (item.Alarm!=null && (item.Alarm.Substring(0, 10) + item.Alarm.Substring(13, 1) + item.Alarm.Substring(15)).Contains("1")))
                            {
                                item.IsEnable = false;
                            }
                            else
                            {
                                item.IsEnable = true;
                            }
                            if ("Auto".Equals(item.AutoStatus) || (item.Alarm != null && (item.Alarm.Substring(0, 10) + item.Alarm.Substring(13, 1) + item.Alarm.Substring(15)).Contains("1")) || "Disable".Equals(item.ControlOperationModel))
                            {
                                item.IsApplyEnable = false;
                            }
                            else
                            {
                                item.IsApplyEnable = true;
                            }
                        }
                    }
                }
            }
        }
        /// <summary>
        /// 隐藏
        /// </summary>
        public void Hide()
        {
            if (_timer != null)
            {
                _timer.Stop();
            }
        }
        /// <summary>
        /// 初始化Keys
        /// </summary>
        private void InitialKeys(TemperatureDeviceConfig config)
        {
            _rtDataKeys.Clear(); 
            foreach (TemperatureDevice item in config.TemperatureDevices)
            {
                _rtDataKeys.Add($"{item.Name}.{TEMPERATURE_DATA}");
                _rtDataKeys.Add($"{item.Name}.{IS_CONNECTED}");
                _rtDataKeys.Add($"{item.Name}.{PERSISTENT_VALUE}");
                _rtDataKeys.Add($"{item.ReserviorName}.{PERSISTENT_VALUE}");
            }
            

        }
    }
}