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

using Aitex.Core.RT.DataCenter;
using Aitex.Core.RT.Log;
using Aitex.Core.UI.ControlDataContext;
using ControlzEx.Standard;
using LiveCharts.Wpf;
using MECF.Framework.Common.CommonData;
using MECF.Framework.Common.ControlDataContext;
using MECF.Framework.Common.DataCenter;
using Newtonsoft.Json;
using OpenSEMI.ClientBase;
using Prism.Commands;
using Prism.Mvvm;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Forms;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Threading;
using System.Xml;
using Venus_MainPages.Unity;
using Venus_MainPages.Views;
using WPF.Themes.UserControls;
using Xceed.Wpf.DataGrid;

namespace Venus_MainPages.ViewModels
{
    public class DataHistoryViewModel : BindableBase
    {
        #region 私有字段
        private DataHistoryView DataHistoryView;
        private ObservableCollection<ParameterNode> _ParameterNodes;
        RealtimeProvider _provider = new RealtimeProvider();
        private object _lockSelection = new object();
        ConcurrentBag<QueryIndexer> _lstTokenTimeData = new ConcurrentBag<QueryIndexer>();
        ObservableCollection<string> m_Keys=new ObservableCollection<string> ();
        ObservableCollection<KeyData> m_KeyDataObservableCollection = new ObservableCollection<KeyData>();
        DispatcherTimer timer = new DispatcherTimer();
        public List<SolidColorBrush> solidColorBrushes = new List<SolidColorBrush> ();
        DateTime currentTime;
        private bool firstFlag = true;
        #endregion

        #region 属性
        public ObservableCollection<KeyData> OldKeyDataCollection { get; set; }
        public ObservableCollection<ParameterNode> ParameterNodes
        {
            get { return _ParameterNodes; }
            set { SetProperty(ref _ParameterNodes, value); }
        }
        public ObservableCollection<string> Keys
        {
            get { return m_Keys; }
            set { SetProperty(ref m_Keys, value); }
        }
        public ObservableCollection<KeyData> KeyDataObservableCollection
        {
            get { return m_KeyDataObservableCollection; }
            set { SetProperty(ref m_KeyDataObservableCollection, value); }
        }
        #endregion

        #region 命令
        private DelegateCommand<object> _LoadCommand;
        public DelegateCommand<object> LoadCommand =>
            _LoadCommand ?? (_LoadCommand = new DelegateCommand<object>(OnLoad));

        private DelegateCommand _UnLoadCommand;
        public DelegateCommand UnLoadCommand =>
            _UnLoadCommand ?? (_UnLoadCommand = new DelegateCommand(OnUnLoad));

        private DelegateCommand<object> _ParameterCheckCommand;
        public DelegateCommand<object> ParameterCheckCommand =>
            _ParameterCheckCommand ?? (_ParameterCheckCommand = new DelegateCommand<object>(OnParameterCheck));

        private DelegateCommand _StartCommand;
        public DelegateCommand StartCommand =>
            _StartCommand ?? (_StartCommand = new DelegateCommand(OnStart));

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

        private DelegateCommand<object> _StartRealTimeCommand;
        public DelegateCommand<object> StartRealTimeCommand =>
            _StartRealTimeCommand ?? (_StartRealTimeCommand = new DelegateCommand<object>(OnStartRealTime));

        private DelegateCommand _StopRealTimeCommand;
        public DelegateCommand StopRealTimeCommand =>
            _StopRealTimeCommand ?? (_StopRealTimeCommand = new DelegateCommand(OnStopRealTime));
        #endregion

        #region 构造函数
        public DataHistoryViewModel() 
        {
            OldKeyDataCollection = new ObservableCollection<KeyData>();
            ParameterNodes = _provider.GetParameters();
            timer.Interval = TimeSpan.FromSeconds(0.5);
            timer.Tick += Timer_Tick;
            solidColorBrushes.Add(new SolidColorBrush (Colors.Green));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Red));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Blue));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Orange));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Yellow));
            solidColorBrushes.Add(new SolidColorBrush(Colors.YellowGreen));
            solidColorBrushes.Add(new SolidColorBrush(Colors.AliceBlue));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Chocolate));
            solidColorBrushes.Add(new SolidColorBrush(Colors.Cyan));
            solidColorBrushes.Add(new SolidColorBrush(Colors.DarkGreen));


        }


        #endregion

        #region 命令方法
        private void OnLoad(Object eventView)
        {
            if (firstFlag)
            {
                this.DataHistoryView = (DataHistoryView)eventView;
                this.DataHistoryView.wfTimeFrom.Value = DateTime.Today;
                this.DataHistoryView.wfTimeTo.Value = new DateTime(DateTime.Today.Year, DateTime.Today.Month, DateTime.Today.Day, 23, 59, 59, 999);
                //this.DataHistoryView.MyDrawGraphicsControl.PointCollections=new PointCollection(new Point[] {})
            }
        }
        private void OnUnLoad()
        {
            GC.Collect(); // This should pick up the control removed at a previous MouseDown
            GC.WaitForPendingFinalizers(); // Doesn't help either
            GC.Collect();
            GC.WaitForPendingFinalizers(); // Doesn't help either
        }
        private void OnParameterCheck(object obj)
        {      
            ParameterNode node = obj as ParameterNode;
            if (!RefreshTreeStatusToChild(node))
            {
                node.Selected = !node.Selected;
            }
            else
            {
                RefreshTreeStatusToParent(node);
            }

            Keys.Clear();
            for (int i = 0; i < ParameterNodes.Count; i++)
            {
                CalKeys(ParameterNodes[i]);
            }
            OldKeyDataCollection.Clear();
            OldKeyDataCollection = DeepCopyJson(KeyDataObservableCollection);
            KeyDataObservableCollection.Clear();
            for (int i = 0; i < Keys.Count; i++)
            {
                if (i == 10)
                {
                    break;
                }
                KeyDataObservableCollection.Add(new KeyData() { Key = Keys[i], Color = solidColorBrushes[i],UniqueId=i });
            }
            Compare(OldKeyDataCollection, KeyDataObservableCollection);
            KeyDataObservableCollection = DeepCopyJson(OldKeyDataCollection);
        }
        public void Compare(ObservableCollection<KeyData> olddata, ObservableCollection<KeyData> newdata)
        {
            if (newdata != null)
            {
                for (int i = 0; i < newdata.Count; i++)
                {
                    var lists = olddata.ToList().Find(t => t.Key == newdata[i].Key);
                    if (lists == null)
                    {
                        olddata.Add(new KeyData() { Key = newdata[i].Key, Color = solidColorBrushes[i], UniqueId = olddata.Count + 1 });
                    }
                }
                for (int i = 0; i < olddata.Count; i++)
                {
                    var lists = newdata.ToList().Find(t => t.Key == olddata[i].Key);
                    if (lists == null)
                    {
                        olddata.Remove(olddata[i]);
                    }
                }

            }
        }
        public static T DeepCopyJson<T>(T obj)
        {
            // 序列化
            string json = JsonConvert.SerializeObject(obj);
            // 反序列化
            return JsonConvert.DeserializeObject<T>(json);
        }
        private void OnStartRealTime(object obj)
        {
            
            if (Keys.Count > 10)
            {
                ((System.Windows.Controls.CheckBox)obj).IsChecked= false;
                timer.Stop();
                WPFMessageBox.ShowWarning("最多显示10个数据");
                return;
            }

            currentTime = DateTime.Now;
            timer.Start();
        }
        private void OnStopRealTime()
        {
            timer.Stop();
        }
      
        private void OnStart()
        {
           
            if (Keys.Count > 10)
            {
                WPFMessageBox.ShowWarning("最多显示10个数据");
                return;
            }
            this.DataHistoryView.MyDrawGraphicsControl.ClearPlotPoints();
            var result = GetData(Keys.Distinct().ToList(), this.DataHistoryView.wfTimeFrom.Value, this.DataHistoryView.wfTimeTo.Value);
            if (result == null)
            {
                return;
            }
            List<PointCollection> cls = new List<PointCollection>(); 
            for (int i = 0; i < Keys.Count; i++)
            {
                PointCollection points = new PointCollection();
                int k = 1;
                result[Keys[i]].ForEach(point => 
                {
                    points.Add(new Point() { X = point.dateTime.ToOADate(), Y = point.value });
                    k += 1;
                });
                cls.Add(points);
            }
            this.DataHistoryView.MyDrawGraphicsControl.PointCollections = cls;
            this.DataHistoryView.MyDrawGraphicsControl.FitControl();
        }
        private void CloseAll(ObservableCollection<ParameterNode> parameterNodes)
        {
            foreach (var item in parameterNodes)
            {
                item.Selected = false;
                if (item.ChildNodes.Count > 0)
                {
                    CloseAll(item.ChildNodes);
                }
            }
        }
        private void OnClear()
        {
            this.DataHistoryView.MyDrawGraphicsControl.ClearPlotPoints();
            KeyDataObservableCollection.Clear();
            CloseAll(ParameterNodes);
        }
        #endregion

        #region 私有方法
        private bool RefreshTreeStatusToChild(ParameterNode node)
        {
            if (node.ChildNodes.Count > 0)
            {
                for (int i = 0; i < node.ChildNodes.Count; i++)
                {
                    ParameterNode n = node.ChildNodes[i];
                    n.Selected = node.Selected;

                    if (!RefreshTreeStatusToChild(n))
                    {
                        //uncheck left node
                        for (int j = i; j < node.ChildNodes.Count; j++)
                        {
                            node.ChildNodes[j].Selected = !node.Selected;
                        }
                        //node.Selected = !node.Selected;
                        return false;
                    }
                }
            }
            //else
            //{
            //    if (node.Selected == true)
            //    {
            //        keys.Add(node.Name);
            //    }
            //    else
            //    { 
            //    keys.Remove(node.Name);
            //    }
            //}     
            return true;
        }
        private void RefreshTreeStatusToParent(ParameterNode node)
        {
            if (node.ParentNode != null)
            {
                if (node.Selected)
                {
                    bool flag = true;
                    for (int i = 0; i < node.ParentNode.ChildNodes.Count; i++)
                    {
                        if (!node.ParentNode.ChildNodes[i].Selected)
                        {
                            flag = false;  //as least one child is unselected
                            break;
                        }
                    }
                    if (flag)
                        node.ParentNode.Selected = true;
                }
                else
                {
                    node.ParentNode.Selected = false;
                }
                RefreshTreeStatusToParent(node.ParentNode);
                
            }
        }

        private Dictionary<string, List<HistoryDataItem>> GetData(List<string> keys, DateTime from, DateTime to)
        {
            string sql = "select time AS InternalTimeStamp";
            foreach (var dataId in keys)
            {
                sql += "," + string.Format("\"{0}\"", dataId);
            }
            sql += string.Format(" from \"{0}\" where time > {1} and time <= {2} order by time asc",
                from.ToString("yyyyMMdd") + "." + "Data", from.Ticks, to.Ticks);

            DataTable dataTable = QueryDataClient.Instance.Service.QueryData(sql);

            Dictionary<string, List<HistoryDataItem>> historyData = new Dictionary<string, List<HistoryDataItem>>();
            if (dataTable == null || dataTable.Rows.Count == 0)
                return null;

            DateTime dt = new DateTime();
            Dictionary<int, string> colName = new Dictionary<int, string>();
            for (int colNo = 0; colNo < dataTable.Columns.Count; colNo++)
            {
                colName.Add(colNo, dataTable.Columns[colNo].ColumnName);
                historyData[dataTable.Columns[colNo].ColumnName] = new List<HistoryDataItem>();
            }
            for (int rowNo = 0; rowNo < dataTable.Rows.Count; rowNo++)
            {
                PointCollection points = new PointCollection();

                var row = dataTable.Rows[rowNo];

                for (int i = 0; i < dataTable.Columns.Count; i++)
                {
                    HistoryDataItem data = new HistoryDataItem();
                    if (i == 0)
                    {
                        long ticks = (long)row[i];
                        dt = new DateTime(ticks);
                        continue;
                    }
                    else
                    {
                        string dataId = colName[i];
                        if (row[i] is DBNull || row[i] == null)
                        {
                            data.dateTime = dt;
                            data.dbName = colName[i];
                            data.value = 0;
                        }
                        else if (row[i] is bool)
                        {
                            data.dateTime = dt;
                            data.dbName = colName[i];
                            data.value = (bool)row[i] ? 1 : 0;
                        }
                        else
                        {
                            data.dateTime = dt;
                            data.dbName = colName[i];
                            data.value = float.Parse(row[i].ToString());
                        }
                    }
                    historyData[data.dbName].Add(data);
                }

            }

            foreach (var item in historyData)
            {
                item.Value.Sort((x, y) => DateTime.Compare(x.dateTime, y.dateTime));
            }
            return historyData;

        }
        private void CalKeys(ParameterNode parameterNode)
        {           
            if (parameterNode.ChildNodes.Count > 0)
            {
                foreach (var item in parameterNode.ChildNodes)
                {
                    CalKeys(item);
                }
            }
            else
            {
                if (parameterNode.Selected == true)
                {
                    Keys.Add(parameterNode.Name);
                }
            }
            

        }

        private void Timer_Tick(object sender, EventArgs e)
        {
           
            if (Keys.Count > 10)
            {
                WPFMessageBox.ShowWarning("最多显示10个数据");
                timer.Stop();
                return;
            }
            this.DataHistoryView.MyDrawGraphicsControl.ClearPlotPoints();
            var result = GetData(Keys.Distinct().ToList(), currentTime.AddMinutes(-1), DateTime.Now);
            if (result == null)
            {
                return;
            }
            List<PointCollection> cls = new List<PointCollection>();
            for (int i = 0; i < Keys.Count; i++)
            {
                PointCollection points = new PointCollection();
                int k = 1;
                result[Keys[i]].ForEach(point =>
                {
                    points.Add(new Point() { X = point.dateTime.ToOADate(), Y = point.value });
                    k += 1;
                });
                cls.Add(points);
            }
            
            this.DataHistoryView.MyDrawGraphicsControl.PointCollections = cls;
            if (this.DataHistoryView.MyDrawGraphicsControl.IsHorizontalNavigationEnabled == false && this.DataHistoryView.MyDrawGraphicsControl.IsVerticalNavigationEnabled == false)
            {
                this.DataHistoryView.MyDrawGraphicsControl.FitControlWithoutDrawing();

            }

        }
        #endregion

    }

    public class QueryIndexer
    {
        public DateTime TimeToken { get; set; }
        public List<string> DataList { get; set; }
        public string Module { get; set; }
    }
    public class KeyData:BindableBase
    {
        public string Key { get; set; }
        public SolidColorBrush _Color;
        public SolidColorBrush Color
        {
            get { return _Color; }
            set { SetProperty(ref _Color, value); }
        }
        public int UniqueId { get; set; }
    }
}