Kepler-Release/Venus/Venus_MainPages/ViewModels/TopViewModel.cs

using Aitex.Core.Common.DeviceData;
using Aitex.Core.RT.Event;
using Aitex.Core.RT.Log;
using Aitex.Core.Util;
using Aitex.Core.WCF;
using MECF.Framework.Common.DataCenter;
using MECF.Framework.Common.Equipment;
using MECF.Framework.Common.OperationCenter;
using Prism.Commands;
using Prism.Mvvm;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Threading;
using Venus_Core;
using Venus_MainPages.Unity;
using Venus_Themes.UserControls;

namespace Venus_MainPages.ViewModels
{
    internal class TopViewModel : BindableBase
    {
        #region 私有字段
        private string m_Title;
        private string m_SoftwareVersion;
        //private DateTime m_DateTimeNow;

        private List<string> m_RtDataKeys = new List<string>();
        private Dictionary<string, object> m_RtDataValues;

        //private string ModuleName;

        private ObservableCollection<EventItem> m_EventLogList = new ObservableCollection<EventItem>();
        private EventItem m_CurrentEventItem = new EventItem();
        private string m_CurrentEventItemValue;
        //private object _lockObj = new object();
        private int m_EventLogListSelectedIndex;
        private Queue<EventItem> alarmQuery = new Queue<EventItem>();//控制alarm log 在 top UI显示

        private int logMaxCount = 50;//log在ui最多显示数量
        private AITSignalTowerData m_SignalTowerData;
        private string m_HostCommunicationStatus;
        private string m_TimeTick;

        //private JetChamber m_SelectedJetChamber = JetChamber.None;

        private bool m_PMAIsInstalled;
        private bool m_PMBIsInstalled;
        private bool m_PMCIsInstalled;
        private bool m_PMDIsInstalled;
        private bool m_LLAIsInstalled;
        private bool m_LLBIsInstalled;
        private bool m_TMIsInstalled;
        private bool m_EFEMIsInstalled;

        private List<eEvent> stopEntityId = new List<eEvent>() 
        {
            eEvent.ERR_MATCH,
            eEvent.ERR_RF,
            eEvent.ERR_PENDULUM_VALVE,
            eEvent.ERR_DEVICE_INFO
        };
        private PressureType m_PressureType;

        #endregion

        #region  属性

        //public DateTime DateTimeNow
        //{
        //    get { return m_DateTimeNow; }
        //    set { SetProperty(ref m_DateTimeNow, value); }
        //}
        public string Title
        {
            get { return m_Title; }
            set { SetProperty(ref m_Title, value); }
        }
        public string SoftwareVersion
        {
            get { return m_SoftwareVersion; }
            set { SetProperty(ref m_SoftwareVersion, value); }
        }

        public string TimeTick
        {
            get { return m_TimeTick; }
            set { SetProperty(ref m_TimeTick, value); }
        }

        public Dictionary<string, object> RtDataValues
        {
            get { return m_RtDataValues; }
            set { SetProperty(ref m_RtDataValues, value); }
        }

        public ObservableCollection<EventItem> EventLogList
        {
            get { return m_EventLogList; }
            set { SetProperty(ref m_EventLogList, value); }
        }

        public EventItem CurrentEventItem
        {
            get { return m_CurrentEventItem; }
            set { SetProperty(ref m_CurrentEventItem, value); }
        }
        public int EventLogListSelectedIndex
        {
            get { return m_EventLogListSelectedIndex; }
            set { SetProperty(ref m_EventLogListSelectedIndex, value); }
        }

        public string CurrentEventItemValue
        {
            get { return m_CurrentEventItemValue; }
            set { SetProperty(ref m_CurrentEventItemValue, value); }
        }

        public AITSignalTowerData SignalTowerData
        {
            get { return m_SignalTowerData; }
            set { SetProperty(ref m_SignalTowerData, value); }
        }
        public string HostCommunicationStatusBackground
        {
            get
            {
                switch (HostCommunicationStatus)
                {
                    case "Disabled":
                        return "#D79C11";
                    case "Enabled":
                    case "EnabledNotCommunicating":
                    case "WaitCRA":
                    case "WaitDelay":
                    case "WaitCRFromHost":
                        return "Transparent";
                    case "EnabledCommunicating":
                        return "LawnGreen";
                    default:
                        return "#D79C11";
                }
            }
        }
        public string m_HostBack;
        public string HostBack
        {
            get { return m_HostBack; }
            set { SetProperty(ref m_HostBack, value); }
        }

        [Subscription("System.CommunicationStatus")]
        public string HostCommunicationStatus
        {
            get { return m_HostCommunicationStatus; }
            set 
            { 
                SetProperty(ref m_HostCommunicationStatus, value);
            }
        }
        public bool IsEnableFAEnable
        {
            get
            {
                return HostCommunicationStatus == "Disabled";
            }

        }
        public bool _IsEnableEnable;
        public bool IsEnableEnable
        {
            get { return _IsEnableEnable; }
            set { SetProperty(ref _IsEnableEnable, value); }
        }
        public bool _IsEnableDisable;
        public bool IsEnableDisable
        {
            get { return _IsEnableDisable; }
            set { SetProperty(ref _IsEnableDisable, value); }
        }
        public FACommunicationState FACommunicationState
        {
            get
            {
                return string.IsNullOrEmpty(HostCommunicationStatus) ? FACommunicationState.Disabled
                    : (FACommunicationState)Enum.Parse(typeof(FACommunicationState), HostCommunicationStatus);
            }
        }

        public bool PMAIsInstalled
        {
            get { return m_PMAIsInstalled; }
            set { SetProperty(ref m_PMAIsInstalled, value); }
        }
        public bool PMBIsInstalled
        {
            get { return m_PMBIsInstalled; }
            set { SetProperty(ref m_PMBIsInstalled, value); }
        }
        public bool PMCIsInstalled
        {
            get { return m_PMCIsInstalled; }
            set { SetProperty(ref m_PMCIsInstalled, value); }
        }
        public bool PMDIsInstalled
        {
            get { return m_PMDIsInstalled; }
            set { SetProperty(ref m_PMDIsInstalled, value); }
        }
        public bool LLAIsInstalled
        {
            get { return m_LLAIsInstalled; }
            set { SetProperty(ref m_LLAIsInstalled, value); }
        }
        public bool LLBIsInstalled
        {
            get { return m_LLBIsInstalled; }
            set { SetProperty(ref m_LLBIsInstalled, value); }
        }
        public bool TMIsInstalled
        {
            get { return m_TMIsInstalled; }
            set { SetProperty(ref m_TMIsInstalled, value); }
        }
        public bool EFEMIsInstalled
        {
            get { return m_EFEMIsInstalled; }
            set { SetProperty(ref m_EFEMIsInstalled, value); }
        }
        private bool m_SETMIsInstalled;
        private bool m_VCE1IsInstalled;
        public bool SETMIsInstalled
        {
            get { return m_SETMIsInstalled; }
            set { SetProperty(ref m_SETMIsInstalled, value); }
        }
        public bool VCE1IsInstalled
        {
            get { return m_VCE1IsInstalled; }
            set { SetProperty(ref m_VCE1IsInstalled, value); }
        }

        #endregion

        #region 命令
        private DelegateCommand _SwichLanguageCommand;
        public DelegateCommand SwichLanguageCommand =>
                 _SwichLanguageCommand ?? (_SwichLanguageCommand = new DelegateCommand(OnSwitchLanguage));

        private DelegateCommand _ResetCommand;
        public DelegateCommand ResetCommand =>
                 _ResetCommand ?? (_ResetCommand = new DelegateCommand(OnReset));

        private DelegateCommand _ClearCommand;
        public DelegateCommand ClearCommand =>
                 _ClearCommand ?? (_ClearCommand = new DelegateCommand(OnClear));

        private DelegateCommand _SkipCommand;
        public DelegateCommand SkipCommand =>
                 _SkipCommand ?? (_SkipCommand = new DelegateCommand(OnSkip));

        //private DelegateCommand _BuzzerOffCommand;
        //public DelegateCommand BuzzerOffCommand =>
        //         _BuzzerOffCommand ?? (_BuzzerOffCommand = new DelegateCommand(OnBuzzerOff));

        private DelegateCommand _FADisableCommand;
        public DelegateCommand FADisableCommand =>
                 _FADisableCommand ?? (_FADisableCommand = new DelegateCommand(FaDisable));
        private DelegateCommand _FAEnableCommand;
        public DelegateCommand FAEnableCommand =>
                 _FAEnableCommand ?? (_FAEnableCommand = new DelegateCommand(FaEnable));

        #endregion

        #region 构造函数
        public TopViewModel()
        {
            m_SoftwareVersion = System.Reflection.Assembly.GetExecutingAssembly().GetName().Version.ToString();

            string allModules = QueryDataClient.Instance.Service.GetConfig($"System.InstalledModules").ToString();

            PMAIsInstalled = allModules.Contains("PMA");
            PMBIsInstalled = allModules.Contains("PMB");
            PMCIsInstalled = allModules.Contains("PMC");
            PMDIsInstalled = allModules.Contains("PMD");
            LLAIsInstalled = allModules.Contains("LLA");
            LLBIsInstalled = allModules.Contains("LLB");
            TMIsInstalled = allModules.Contains("TM");
            EFEMIsInstalled = allModules.Contains("EFEM");
            SETMIsInstalled = allModules.Contains("SETM");
            VCE1IsInstalled = allModules.Contains("VCE1");

            //ModuleName = "PMA";
            addDataKeys();

            DispatcherTimer timer = new DispatcherTimer();
            timer.Interval = TimeSpan.FromSeconds(0.5);
            timer.Tick += timer_Tick;
            timer.Start();

            EventClient.Instance.OnEvent += Instance_OnEvent;
            EventClient.Instance.Start();
            Title = QueryDataClient.Instance.Service.GetConfig($"System.Name").ToString();

            object obj = QueryDataClient.Instance.Service.GetData("System.PressureUnitType");
            m_PressureType = (PressureType)Convert.ToInt32(obj);

        }
        #endregion

        #region 方法

        void timer_Tick(object sender, EventArgs e)
        {
            TimeTick = DateTime.Now.ToString();
            RtDataValues = QueryDataClient.Instance.Service.PollData(m_RtDataKeys);

            SignalTowerData = CommonFunction.GetValue<AITSignalTowerData>(RtDataValues, $"System.SignalTower.DeviceData");
            HostCommunicationStatus = CommonFunction.GetValue<String>(RtDataValues, "System.CommunicationStatus");
            //IsEnableEnable = FACommunicationState == CommunicationState.Disabled;
            //IsEnableDisable = FACommunicationState != CommunicationState.Disabled;
            HostBack = HostCommunicationStatusBackground;
            IsEnableEnable = (HostCommunicationStatus == FACommunicationState.Disabled.ToString());
            IsEnableDisable = (HostCommunicationStatus != FACommunicationState.Disabled.ToString());
        }

        private void OnSwitchLanguage()
        {
            List<ResourceDictionary> dictionaryList = new List<ResourceDictionary>();
            foreach (ResourceDictionary dictionary in Application.Current.Resources.MergedDictionaries)
            {
                if (dictionary.Source != null)
                {
                    dictionaryList.Add(dictionary);
                }
            }
            string requestedCulture1 = @"/Venus_Themes;component/Languages/StringResources.en-US.xaml";
            string requestedCulture2 = @"/Venus_Themes;component/Languages/StringResources.zh-CN.xaml";
            ResourceDictionary resourceDictionary1 = dictionaryList.FirstOrDefault(d => d.Source.OriginalString.Equals(requestedCulture1));
            ResourceDictionary resourceDictionary2 = dictionaryList.FirstOrDefault(d => d.Source.OriginalString.Equals(requestedCulture2));
            if (dictionaryList.IndexOf(resourceDictionary1) < dictionaryList.IndexOf(resourceDictionary2))
            {
                Application.Current.Resources.MergedDictionaries.Remove(resourceDictionary1);
                Application.Current.Resources.MergedDictionaries.Add(resourceDictionary1);
            }
            else
            {
                Application.Current.Resources.MergedDictionaries.Remove(resourceDictionary2);
                Application.Current.Resources.MergedDictionaries.Add(resourceDictionary2);
            }
        }
        private void OnReset()
        {
            InvokeClient.Instance.Service.DoOperation("System.Reset");
        }
        private void addDataKeys()
        {
            if (PMAIsInstalled == true)
            {
                m_RtDataKeys.Add("PMA.FsmState");
                m_RtDataKeys.Add("PMA.IsOnline");
                m_RtDataKeys.Add("PMA.IsInclude");


            }
            if (PMBIsInstalled == true)
            {
                m_RtDataKeys.Add("PMB.FsmState");
                m_RtDataKeys.Add("PMB.IsOnline");
                m_RtDataKeys.Add("PMB.IsInclude");


            }
            if (PMCIsInstalled == true)
            {
                m_RtDataKeys.Add("PMC.FsmState");
                m_RtDataKeys.Add("PMC.IsOnline");
                m_RtDataKeys.Add("PMC.IsInclude");
            }
            if (PMDIsInstalled == true)
            {
                m_RtDataKeys.Add("PMD.FsmState");
                m_RtDataKeys.Add("PMD.IsOnline");
                m_RtDataKeys.Add("PMD.IsInclude");
            }
            if (TMIsInstalled == true)
            {
                m_RtDataKeys.Add("TM.FsmState");
                m_RtDataKeys.Add("TM.IsOnline");
            }
            if (LLAIsInstalled == true)
            {
                m_RtDataKeys.Add("LLA.FsmState");
                m_RtDataKeys.Add("LLA.IsOnline");
                m_RtDataKeys.Add("LLA.IsInclude");

            }
            if (LLBIsInstalled == true)
            {
                m_RtDataKeys.Add("LLB.FsmState");
                m_RtDataKeys.Add("LLB.IsOnline");
                m_RtDataKeys.Add("LLB.IsInclude");
            }
            if (EFEMIsInstalled == true)
            {
                m_RtDataKeys.Add("EFEM.FsmState");
                m_RtDataKeys.Add("EFEM.IsOnline");
            }
            if (SETMIsInstalled)
            {
                m_RtDataKeys.Add("SETM.FsmState");
                //m_RtDataKeys.Add("SETM.IsOnline");
            }
            if (VCE1IsInstalled)
            {
                m_RtDataKeys.Add("VCE1.FsmState");
                //m_RtDataKeys.Add("VCE1.IsOnline");
            }

            m_RtDataKeys.Add("SYSTEM.FsmState");
            m_RtDataKeys.Add("System.IsAutoMode");


            m_RtDataKeys.Add($"System.SignalTower.DeviceData");
            m_RtDataKeys.Add("System.CommunicationStatus");
        }

        private void Instance_OnEvent(EventItem eventItem)
        {
            GlobalEvents.Instance.OnEventItemRaiseChanged(eventItem);
            switch (eventItem.Type)
            {
                case EventType.EventUI_Notify:
                    Application.Current.Dispatcher.Invoke(delegate
                    {
                        EventLogList.Insert(0, eventItem);
                        if (EventLogList.Count > logMaxCount)
                        {
                            EventLogList.RemoveAt(EventLogList.Count - 1);
                        }

                        if (eventItem.Level == EventLevel.Alarm)
                        {
                            alarmQuery.Enqueue(eventItem);
                            if (m_PressureType == PressureType.Pa)
                            {
                                if (stopEntityId.Contains((eEvent)eventItem.Id) && eventItem.Source.Contains("PM"))
                                {
                                    InvokeClient.Instance.Service.DoOperation($"{eventItem.Source}.PmError");
                                }
                            }

                        }
                        if (alarmQuery.Count > 0)
                        {
                            CurrentEventItem = alarmQuery.First();
                        }
                        else
                        {
                            CurrentEventItem = eventItem;
                        }
                        EventLogListSelectedIndex = 0;
                    });
                    break;
                case EventType.Dialog_Nofity:
                    //PopDialog(obj);
                    break;
                case EventType.KickOut_Notify:
                    break;
                case EventType.Sound_Notify:
                    break;
                case EventType.UIMessage_Notify:
                    //PopUIMessage(obj);
                    break;
            }



        }

        private void OnClear()
        {
            CurrentEventItem = null;
            alarmQuery.Clear();
            EventLogList.Clear();

        }
        private void OnSkip()
        {
            if (alarmQuery.Count > 0)
            {
                alarmQuery.Dequeue();
                if (alarmQuery.Count > 0)
                {
                    CurrentEventItem = alarmQuery.First();
                }
                else
                {
                    CurrentEventItem = null;
                }
            }
        }
        //private void OnBuzzerOff()
        //{
        //    InvokeClient.Instance.Service.DoOperation($"{ModuleName}.SignalTower.SwitchOffBuzzer");
        //}
        public void FaDisable()
        {
            InvokeClient.Instance.Service.DoOperation($"FACommand", "FADisable");
        }
        public void FaEnable()
        {
            InvokeClient.Instance.Service.DoOperation($"FACommand", "FAEnable");
        }
        #endregion

    }
}