//******************************************************************************************************//  RealTimeData.cs - Gbtc////  Copyright © 2010, Grid Protection Alliance.  All Rights Reserved.////  Licensed to the Grid Protection Alliance (GPA) under one or more contributor license agreements. See//  the NOTICE file distributed with this work for additional information regarding copyright ownership.//  The GPA licenses this file to you under the MIT License (MIT), the "License"; you may//  not use this file except in compliance with the License. You may obtain a copy of the License at:////      http://www.opensource.org/licenses/MIT////  Unless agreed to in writing, the subject software distributed under the License is distributed on an//  "AS-IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. Refer to the//  License for the specific language governing permissions and limitations.////  Code Modification History://  ----------------------------------------------------------------------------------------------------//  07/21/2011 - Mehulbhai P Thakkar//       Generated original version of source code.//  03/06/2012 - J. Ritchie Carroll//       Added virtual device for subscribed measurements when two nodes share a single database.////****************************************************************************************************** using System;using System.Collections.Generic;using System.Collections.ObjectModel;using System.Data;using System.Globalization;using System.Linq;using System.Windows;using System.Windows.Media;using GSF.Data;using GSF.TimeSeries.UI; namespace GSF.PhasorProtocols.UI.DataModels{    /// <summary>    /// Represents a real-time stream of subscribed data.    /// </summary>    public class RealTimeStream : DataModelBase    {        #region [ Members ]         // Fields        private int m_id;        private string m_acronym;        private string m_name;        private string m_companyName;        private bool m_enabled;        private bool m_expanded;        private string m_statusColor;        private ObservableCollection<RealTimeDevice> m_deviceList;         #endregion         #region [ Constructors ]         /// <summary>        /// Creates a new instance of the <see cref="RealTimeStream"/> class.        /// </summary>        public RealTimeStream()            : base(false, false)        {        }         #endregion         #region [ Properties ]         /// <summary>        /// Gets or sets the ID of the <see cref="RealTimeStream"/>.        /// </summary>        public int ID        {            get            {                return m_id;            }            set            {                m_id = value;                OnPropertyChanged(nameof(ID));            }        }         /// <summary>        /// Gets or sets the acronym of the current <see cref="RealTimeStream"/>.        /// </summary>        public string Acronym        {            get            {                return m_acronym;            }            set            {                m_acronym = value;                OnPropertyChanged(nameof(Acronym));            }        }         /// <summary>        /// Gets or sets the name of the current <see cref="RealTimeStream"/>.        /// </summary>        public string Name        {            get            {                return m_name;            }            set            {                m_name = value;                OnPropertyChanged(nameof(Name));            }        }         /// <summary>        /// Gets or sets the company name of the current <see cref="RealTimeStream"/>.        /// </summary>        public string CompanyName        {            get            {                return m_companyName;            }            set            {                m_companyName = value;                OnPropertyChanged(nameof(CompanyName));            }        }         /// <summary>        /// Gets or sets the Expanded flag for the current <see cref="RealTimeStream"/>.        /// </summary>        public bool Expanded        {            get            {                return m_expanded;            }            set            {                m_expanded = value;                OnPropertyChanged(nameof(Expanded));            }        }         /// <summary>        /// Gets or sets the status color of the current <see cref="RealTimeStream"/>.        /// </summary>        public string StatusColor        {            get            {                return m_statusColor;            }            set            {                m_statusColor = value;                OnPropertyChanged(nameof(StatusColor));            }        }         /// <summary>        /// Gets or sets whether the current <see cref="RealTimeStream"/> is enabled.        /// </summary>        public bool Enabled        {            get            {                return m_enabled;            }            set            {                m_enabled = value;                OnPropertyChanged(nameof(Enabled));            }        }         /// <summary>        /// Gets or sets collection of <see cref="RealTimeDevice"/>s for the current <see cref="RealTimeStream"/>.        /// </summary>        public ObservableCollection<RealTimeDevice> DeviceList        {            get            {                return m_deviceList;            }            set            {                m_deviceList = value;                OnPropertyChanged(nameof(DeviceList));            }        }         #endregion         #region [ Static ]         private const int GroupAccessID = -99999;         // Static Methods         /// <summary>        /// Loads <see cref="RealTimeStream"/> information as an <see cref="ObservableCollection{T}"/> style list.        /// </summary>        /// <param name="database"><see cref="AdoDataConnection"/> to connection to database.</param>        /// <returns>Collection of <see cref="RealTimeStream"/>.</returns>        public static ObservableCollection<RealTimeStream> Load(AdoDataConnection database)        {            bool createdConnection = false;             try            {                ObservableCollection<RealTimeStream> realTimeStreamList = null;                createdConnection = CreateConnection(ref database);                 DataSet resultSet = new();                resultSet.EnforceConstraints = false;                 // Get PDCs list.                resultSet.Tables.Add(database.Connection.RetrieveData(database.AdapterType, database.ParameterizedQueryString("SELECT ID, Acronym, Name, ConnectionString, CompanyName, Enabled FROM DeviceDetail " +                    "WHERE NodeID = {0} AND IsConcentrator = {1} AND Enabled = {2} ORDER BY Acronym", "nodeID", "isConcentrator", "enabled"), DefaultTimeout, database.CurrentNodeID(), database.Bool(true), database.Bool(true)).Copy());                 resultSet.Tables[0].TableName = "PdcTable";                 // Add a dummy device row in PDC table to associate PMUs which are not PDC and connected directly.                DataRow row = resultSet.Tables["PdcTable"].NewRow();                row["ID"] = 0;                row["Acronym"] = string.Empty;                row["Name"] = "Devices Connected Directly";                row["CompanyName"] = string.Empty;                row["Enabled"] = false;                resultSet.Tables["PdcTable"].Rows.Add(row);                 // Get Non-PDC device list.                resultSet.Tables.Add(database.Connection.RetrieveData(database.AdapterType, database.ParameterizedQueryString("SELECT ID, Acronym, Name, AccessID, CompanyName, ProtocolName, VendorDeviceName, " +                    "ParentAcronym, Enabled FROM DeviceDetail WHERE NodeID = {0} AND IsConcentrator = {1} AND Enabled = {2} ORDER BY Acronym", "nodeID", "isConcentrator", "enabled"),                    DefaultTimeout, database.CurrentNodeID(), database.Bool(false), database.Bool(true)).Copy());                 resultSet.Tables[1].TableName = "DeviceTable";                 // Get non-statistical measurement list                resultSet.Tables.Add(database.Connection.RetrieveData(database.AdapterType, database.ParameterizedQueryString("SELECT ID, DeviceID, SignalID, PointID, PointTag, SignalReference, " +                    "SignalAcronym, Description, SignalName, EngineeringUnits, HistorianAcronym, Subscribed, Internal FROM MeasurementDetail WHERE NodeID = {0} AND " +                    "SignalAcronym <> {1} ORDER BY SignalReference", "nodeID", "signalAcronym"), DefaultTimeout, database.CurrentNodeID(), "STAT").Copy());                 resultSet.Tables[2].TableName = "MeasurementTable";                 // Query for any non-statistical measurements that are subscribed via GEP, but are a part of another node in the same database                // IMPORTANT: Make sure columns in this external node query exactly match those of the previous primary measurement query                DataTable otherMeasurements = database.Connection.RetrieveData(database.AdapterType, database.ParameterizedQueryString("SELECT ID, 0 AS DeviceID, SignalID, PointID, PointTag, SignalReference, " +                    "SignalAcronym, Description, SignalName, EngineeringUnits, HistorianAcronym, Subscribed, Internal FROM MeasurementDetail WHERE NodeID <> {0} AND " +                    "SignalAcronym <> {1} AND Subscribed <> 0 ORDER BY SignalReference", "nodeID", "signalAcronym"), DefaultTimeout, database.CurrentNodeID(), "STAT");                 realTimeStreamList = new ObservableCollection<RealTimeStream>(                        from pdc in resultSet.Tables["PdcTable"].AsEnumerable()                        let settings = pdc.Field<string>("ConnectionString").ToNonNullString().ParseKeyValuePairs()                        select new RealTimeStream                            {                                ID = pdc.ConvertField<int>("ID"),                                Acronym = string.IsNullOrEmpty(pdc.Field<string>("Acronym")) ? "DIRECT CONNECTED" : pdc.Field<string>("Acronym"),                                Name = pdc.Field<string>("Name"),                                CompanyName = pdc.Field<string>("CompanyName"),                                StatusColor = string.IsNullOrEmpty(pdc.Field<string>("Acronym")) ? "Transparent" : "Gray",                                Enabled = Convert.ToBoolean(pdc.Field<object>("Enabled")),                                Expanded = false,                                DeviceList = new ObservableCollection<RealTimeDevice>(                                        from device in resultSet.Tables["DeviceTable"].AsEnumerable()                                        where device.Field<string>("ParentAcronym").ToNonNullString() == pdc.Field<string>("Acronym") && device.ConvertField<int>("AccessID") != GroupAccessID                                        select new RealTimeDevice                                            {                                                ID = device.ConvertNullableField<int>("ID"),                                                Acronym = device.Field<string>("Acronym"),                                                Name = device.Field<string>("Name"),                                                ProtocolName = device.Field<string>("ProtocolName"),                                                VendorDeviceName = device.Field<string>("VendorDeviceName"),                                                ParentAcronym = string.IsNullOrEmpty(device.Field<string>("ParentAcronym")) ? "DIRECT CONNECTED" : device.Field<string>("ParentAcronym"),                                                Expanded = false,                                                StatusColor = device.ConvertNullableField<int>("ID") == null ? "Transparent" : "Gray",                                                Enabled = Convert.ToBoolean(device.Field<object>("Enabled")),                                                MeasurementList = new ObservableCollection<RealTimeMeasurement>(                                                        from measurement in resultSet.Tables["MeasurementTable"].AsEnumerable()                                                        where measurement.ConvertNullableField<int>("DeviceID") == device.ConvertNullableField<int>("ID") && (measurement.ConvertField<bool>("Subscribed") || measurement.ConvertField<bool>("Internal") || (settings.ContainsKey("securityMode") && settings["securityMode"].Equals("None", StringComparison.OrdinalIgnoreCase)))   //We will only display measurements which are internal or subscribed to avoid confusion.                                                        select new RealTimeMeasurement                                                            {                                                                ID = measurement.Field<string>("ID"),                                                                DeviceID = measurement.ConvertNullableField<int>("DeviceID"),                                                                SignalID = Guid.Parse(measurement.Field<object>("SignalID").ToString()),                                                                PointID = measurement.ConvertField<int>("PointID"),                                                                PointTag = measurement.Field<string>("PointTag"),                                                                SignalReference = measurement.Field<string>("SignalReference"),                                                                Description = measurement.Field<string>("description"),                                                                SignalName = measurement.Field<string>("SignalName"),                                                                SignalAcronym = measurement.Field<string>("SignalAcronym"),                                                                EngineeringUnit = measurement.Field<string>("SignalAcronym") == "FLAG" ? "Hex" : measurement.Field<string>("EngineeringUnits"),                                                                Expanded = false,                                                                Selected = false,                                                                Selectable = measurement.Field<string>("SignalAcronym") == "IPHM" || measurement.Field<string>("SignalAcronym") == "IPHA" || measurement.Field<string>("SignalAcronym") == "VPHM" || measurement.Field<string>("SignalAcronym") == "VPHA" || measurement.Field<string>("SignalAcronym") == "FREQ",                                                                LongTimeTag = "N/A",                                                                TimeTag = "N/A",                                                                Value = "--",                                                                Quality = "N/A",                                                                Foreground = new SolidColorBrush(Color.FromArgb(255, 0, 0, 0))                                                            }                                                    )                                            }                                    )                            }                    );                 if (otherMeasurements.Rows.Count > 0)                {                    // Add subscribed measurements from other nodes                    realTimeStreamList.Add(new RealTimeStream                        {                            ID = 0,                            Acronym = "SUBSCRIBED",                            Name = "Subscribed Measurements",                            CompanyName = string.Empty,                            StatusColor = "Transparent",                            Enabled = false,                            Expanded = false,                            DeviceList = new ObservableCollection<RealTimeDevice>(                                otherMeasurements.Rows                                .Cast<DataRow>()                                .Where(measurement => measurement.ConvertNullableField<int>("DeviceID") == null)                                .Select(measurement => measurement.Field<string>("SignalReference"))                                .Select(GetSourceName)                                .Distinct()                                .Select(source => new RealTimeDevice                                    {                                        ID = 0,                                        Acronym = source,                                        Name = source,                                        ProtocolName = string.Empty,                                        VendorDeviceName = string.Empty,                                        ParentAcronym = "SUBSCRIBED",                                        Expanded = false,                                        StatusColor = "Gray",                                        Enabled = false,                                        MeasurementList = new ObservableCollection<RealTimeMeasurement>(                                            otherMeasurements.Rows                                            .Cast<DataRow>()                                            .Where(measurement => measurement.ConvertNullableField<int>("DeviceID") == null && measurement.Field<string>("SignalReference").StartsWith(source))                                            .Select(measurement => new RealTimeMeasurement                                                {                                                    ID = measurement.Field<string>("ID"),                                                    DeviceID = measurement.ConvertNullableField<int>("DeviceID"),                                                    SignalID = Guid.Parse(measurement.Field<object>("SignalID").ToString()),                                                    PointID = measurement.ConvertField<int>("PointID"),                                                    PointTag = measurement.Field<string>("PointTag"),                                                    SignalReference = measurement.Field<string>("SignalReference"),                                                    Description = measurement.Field<string>("description"),                                                    SignalName = measurement.Field<string>("SignalName"),                                                    SignalAcronym = measurement.Field<string>("SignalAcronym"),                                                    EngineeringUnit = measurement.Field<string>("SignalAcronym") == "FLAG" ? "Hex" : measurement.Field<string>("EngineeringUnits"),                                                    Expanded = false,                                                    Selected = false,                                                    Selectable = measurement.Field<string>("SignalAcronym") == "IPHM" || measurement.Field<string>("SignalAcronym") == "IPHA" || measurement.Field<string>("SignalAcronym") == "VPHM" || measurement.Field<string>("SignalAcronym") == "VPHA" || measurement.Field<string>("SignalAcronym") == "FREQ",                                                    LongTimeTag = "N/A",                                                    TimeTag = "N/A",                                                    Value = "--",                                                    Quality = "N/A",                                                    Foreground = new SolidColorBrush(Color.FromArgb(255, 0, 0, 0))                                                })                                        )                                    })                            )                        });                }                 if (resultSet.Tables["MeasurementTable"].Select("DeviceID IS NULL").Length > 0)                {                    // Add direct connected measurements with no associated device (DeviceID IS NULL)                    realTimeStreamList.Add(new RealTimeStream                        {                            ID = 0,                            Acronym = "CALCULATED",                            Name = "Calculated Measurements",                            CompanyName = string.Empty,                            StatusColor = "Transparent",                            Enabled = false,                            Expanded = false,                            DeviceList = new ObservableCollection<RealTimeDevice>(                                resultSet.Tables["MeasurementTable"].Rows                                .Cast<DataRow>()                                .Where(measurement => measurement.ConvertNullableField<int>("DeviceID") == null)                                .Select(measurement => measurement.Field<string>("SignalReference"))                                .Select(GetSourceName)                                .Distinct()                                .Select(source => new RealTimeDevice                                    {                                        ID = 0,                                        Acronym = source,                                        Name = source,                                        ProtocolName = string.Empty,                                        VendorDeviceName = string.Empty,                                        ParentAcronym = "CALCULATED",                                        Expanded = false,                                        StatusColor = "Gray",                                        Enabled = false,                                        MeasurementList = new ObservableCollection<RealTimeMeasurement>(                                            resultSet.Tables["MeasurementTable"].Rows                                            .Cast<DataRow>()                                            .Where(measurement => measurement.ConvertNullableField<int>("DeviceID") == null && measurement.Field<string>("SignalReference").StartsWith(source))                                            .Select(measurement => new RealTimeMeasurement                                                {                                                    ID = measurement.Field<string>("ID"),                                                    DeviceID = measurement.ConvertNullableField<int>("DeviceID"),                                                    SignalID = Guid.Parse(measurement.Field<object>("SignalID").ToString()),                                                    PointID = measurement.ConvertField<int>("PointID"),                                                    PointTag = measurement.Field<string>("PointTag"),                                                    SignalReference = measurement.Field<string>("SignalReference"),                                                    Description = measurement.Field<string>("description"),                                                    SignalName = measurement.Field<string>("SignalName"),                                                    SignalAcronym = measurement.Field<string>("SignalAcronym"),                                                    EngineeringUnit = measurement.Field<string>("SignalAcronym") == "FLAG" ? "Hex" : measurement.Field<string>("EngineeringUnits"),                                                    Expanded = false,                                                    Selected = false,                                                    Selectable = measurement.Field<string>("SignalAcronym") == "IPHM" || measurement.Field<string>("SignalAcronym") == "IPHA" || measurement.Field<string>("SignalAcronym") == "VPHM" || measurement.Field<string>("SignalAcronym") == "VPHA" || measurement.Field<string>("SignalAcronym") == "FREQ",                                                    LongTimeTag = "N/A",                                                    TimeTag = "N/A",                                                    Value = "--",                                                    Quality = "N/A",                                                    Foreground = new SolidColorBrush(Color.FromArgb(255, 0, 0, 0))                                                })                                        )                                    })                            )                        });                }                 // Assign parent references for real-time measurements                foreach (RealTimeStream stream in realTimeStreamList)                {                    foreach (RealTimeDevice device in stream.DeviceList)                    {                        device.Parent = stream;                         foreach (RealTimeMeasurement measurement in device.MeasurementList)                        {                            measurement.Parent = device;                        }                    }                }                 return realTimeStreamList;            }            finally            {                if (createdConnection && database != null)                    database.Dispose();            }        }         // Calculate text width        internal static double GetTextWidth(string text)        {            // Just making some assumptions about font and size here for rough assertion on size - would be more accurate to pass in actual font info            Typeface tf = new(new FontFamily("Segoe UI"), FontStyles.Normal, FontWeights.Normal, FontStretches.Normal);            FormattedText ft = new(text, CultureInfo.InvariantCulture, FlowDirection.LeftToRight, tf, 14.0D, Brushes.Black, null, TextFormattingMode.Display);            return ft.WidthIncludingTrailingWhitespace;             // Try this for Silverlight if prior doesn't work:            //TextBlock txtMeasure = new TextBlock();            //txtMeasure.FontSize = fontSize;            //txtMeasure.Text = text ?? "";            //return txtMeasure.ActualWidth;        }         /// <summary>        /// Retrieves <see cref="Dictionary{T1,T2}"/> type collection.        /// </summary>        /// <param name="database"><see cref="AdoDataConnection"/> to connection to database.</param>        /// <param name="isOptional">Indicates if selection on UI is optional for this collection.</param>        /// <returns><see cref="Dictionary{T1,T2}"/> type collection.</returns>        /// <remarks>This is only a place holder method with no implementation.</remarks>        public static Dictionary<int, string> GetLookupList(AdoDataConnection database, bool isOptional = false)        {            return null;        }         /// <summary>        /// Saves <see cref="RealTimeStream"/> information into the database.        /// </summary>        /// <param name="database"><see cref="AdoDataConnection"/> to connection to database.</param>        /// <param name="stream">Information about <see cref="RealTimeStream"/></param>        /// <returns>String, for display use, indicating success.</returns>        /// <remarks>This is only a place holder method with no implementation.</remarks>        public static string Save(AdoDataConnection database, RealTimeStream stream)        {            return string.Empty;        }         /// <summary>

Lines 1–500 of 1251. Load more