ShanXi_SmartControl/IntelligentControlForsx/MyControls/MatrixPopupLine.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Drawing;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Windows.Forms.DataVisualization.Charting;
using System.Threading;
using WisdomClient;
using IntelligentControlForsx.Service;
using WisdomClient.data;
using log4net;
using IntelligentControlForsx.Model;
using IntelligentControlForsx.Common;

namespace IntelligentControlForsx.MyControls
{
    public partial class MatrixPopupLine : UserControl
    {
        private ILog logger = LogManager.GetLogger("AppInfoLog");

        public MatrixPopupLine()
        {
            InitializeComponent();
        }

        private void MatrixPopupLine_Load(object sender, EventArgs e)
        {
            //定义图表大小尺寸
            //chart1.Width = Width - 100;
            //chart1.Height = Height - 100;

            //X轴设置
            //chart1.ChartAreas[0].AxisX.Title = "时间";
            chart1.ChartAreas[0].AxisX.TitleAlignment = StringAlignment.Near;
            chart1.ChartAreas[0].AxisX.MajorGrid.Enabled = true;//不显示竖着的分割线

            /************************************************************************/
            /* 本文重点讲解时间格式的设置
             * 如果想显示原点第一个时间坐标,需要设置最小时间,时间间隔类型，时间间隔值等三个参数*/
            /************************************************************************/
            chart1.ChartAreas[0].AxisX.LabelStyle.Format = "HH:mm"; //X轴显示的时间格式，HH为大写时是24小时制，hh小写时是12小时制
            chart1.ChartAreas[0].AxisX.Minimum = DateTime.Parse("00:00:00").ToOADate();
            chart1.ChartAreas[0].AxisX.Maximum = DateTime.Parse("23:45:00").ToOADate();
            chart1.ChartAreas[0].AxisX.IntervalType = DateTimeIntervalType.Seconds;//如果是时间类型的数据，间隔方式可以是秒、分、时
            chart1.ChartAreas[0].AxisX.Interval = DateTime.Parse("01:00:00").Second;//间隔为15分钟

            //Y轴设置
            //chart1.ChartAreas[0].AxisY.Title = "功率";
            //chart1.ChartAreas[0].AxisY.TitleAlignment = StringAlignment.Center;
            chart1.ChartAreas[0].AxisY.MajorGrid.Enabled = true;//显示横着的分割线
            //chart1.ChartAreas[0].AxisY.Minimum = 0;
            //chart1.ChartAreas[0].AxisY.Maximum = 600;
            //chart1.ChartAreas[0].AxisY.Interval = 5;

            //Series绘制
            chart1.Series[0].LegendText = "预测功率";
            chart1.Series[0].ChartType = SeriesChartType.Spline;
            chart1.Series[0].XValueType = ChartValueType.DateTime;
            //chart1.Series[0].IsValueShownAsLabel = true;//显示数据点的值
            chart1.Series[0].MarkerStyle = MarkerStyle.None;

            chart1.Series[1].LegendText = "AGC有功设定";
            chart1.Series[1].ChartType = SeriesChartType.Line;
            chart1.Series[1].XValueType = ChartValueType.DateTime;
            //chart1.Series[1].IsValueShownAsLabel = true;//显示数据点的值
            chart1.Series[1].MarkerStyle = MarkerStyle.None;

            chart1.Series[2].LegendText = "实时功率";
            chart1.Series[2].ChartType = SeriesChartType.Line;
            chart1.Series[2].XValueType = ChartValueType.DateTime;
            //chart1.Series[2].IsValueShownAsLabel = true;//显示数据点的值
            chart1.Series[2].MarkerStyle = MarkerStyle.None;

            chart1.Series[3].LegendText = "理论功率";
            chart1.Series[3].ChartType = SeriesChartType.Line;
            chart1.Series[3].XValueType = ChartValueType.DateTime;
            //chart1.Series[3].IsValueShownAsLabel = true;//显示数据点的值
            chart1.Series[3].MarkerStyle = MarkerStyle.None;
        }

        private string stationId;

        public string StationId
        {
            get
            {
                return stationId;
            }

            set
            {
                stationId = value;
                Thread ayscThread = new Thread(LoadData);
                ayscThread.IsBackground = true;
                ayscThread.Start();
            }
        }

        // private DateTime lastUpdateTime = DateTime.Parse
        public void BuildChart(DateTime[] dts, Double[] speeds, Double[] powers)
        {
            chart1.Series[0].Points.Clear();
            chart1.Series[1].Points.Clear();
            if (dts.Length == speeds.Length && dts.Length == powers.Length)
            {
                for (int i = 0; i < dts.Length; i++)
                {
                    this.chart1.Series[0].Points.AddXY(dts[i], speeds[i]);
                    this.chart1.Series[1].Points.AddXY(dts[i], powers[i]);
                }
            }
            chart1.Invalidate();

        }

        private void chart1_GetToolTipText(object sender, System.Windows.Forms.DataVisualization.Charting.ToolTipEventArgs e)
        {
            //if (e.HitTestResult.ChartElementType == ChartElementType.DataPoint)
            //{
            //    int i = e.HitTestResult.PointIndex;
            //    //DataPoint dp = e.HitTestResult.Series.Points[i];
            //    DataPoint dp1 = this.chart1.Series[0].Points[i];
            //    DataPoint dp2 = this.chart1.Series[1].Points[i];

            //    //分别显示x轴和y轴的数值，其中{1:F3},表示显示的是float类型，精确到小数点后3位。  
            //    e.Text = string.Format("时间：{0}；\n风速：{1:F2}；\n功率：{2:F2}；", dp1.XValue, dp1.YValues[0], dp2.YValues[0]);
            //}  
        }

        public void DeActive()
        {
            timer1.Stop();
        }

        public void Active()
        {
            Thread ayscThread = new Thread(LoadData);
            ayscThread.IsBackground = true;
            ayscThread.Start();
            timer1.Start();

        }

        #region 异步加载数据

        private void timer1_Tick(object sender, EventArgs e)
        {
            if (isLoadding) return;

            Thread ayscThread = new Thread(LoadData);
            ayscThread.IsBackground = true;
            ayscThread.Start();
            //LoadData();
        }

        private bool isLoadding = false;

        private void LoadData()
        {
            if (isLoadding)
                return;

            isLoadding = true;
            try
            {
                UpdateCurve();
            }
            catch (Exception ex)
            {
                logger.Info("读取实时数据失败！ex=" + ex.Message);
            }
            finally
            {
                isLoadding = false;
            }
        }

        private void UpdateCurve()
        {
            var dict = CacheService.Instance.DictPowerCurveModel;
            if (dict == null)
                return;

            var pcm = dict[StationId];
            Console.WriteLine("==================当前曲线刷新场站为" + StationId);
            if (pcm == null)
                return;

            if (pcm.LastUpdateTime < DateTime.Today)
            {
                //跨天清空缓存数据
                pcm.LastUpdateTime = DateTime.Today;
                pcm.FactPowerData.Clear();
                pcm.PredictPowerData.Clear();
                //pcm.CDQPredictPowerData;
                pcm.TheoryPowerData.Clear();
                pcm.AgcPowerData.Clear();
                pcm.WindSpeedData.Clear();
            }

            DateTime now = DateTime.Now;
            long startTs = CommonMethod.ConvertDateTimeInt(pcm.LastUpdateTime);
            long endTs = CommonMethod.ConvertDateTimeInt(now);
            var lstFactPowerData = RestfulClient.findHistorySnapByTagName(pcm.FactPowerPoint, startTs, endTs, 20);
            pcm.FactPowerData.AddRange(lstFactPowerData);

            if (StationId != "SBQ_FDC")
            {
                var lstAgcPowerData = RestfulClient.findHistorySnapByTagName(pcm.AgcPowerPoint, startTs, endTs, 20);
                pcm.AgcPowerData.AddRange(lstAgcPowerData);
            }
            else
            {
                var lstAgcPowerData1 = RestfulClient.findHistorySnapByTagName("SBQDQ.NX_GD_SBQF_DQ_P1_L1_001_AI0818", startTs, endTs, 20);
                var lstAgcPowerData2 = RestfulClient.findHistorySnapByTagName("SBQDQ.NX_GD_SBQF_DQ_P1_L1_001_AI0827", startTs, endTs, 20);

                List<TsData> list = new List<TsData>();
                for (int i = 0; i < lstAgcPowerData1.Count; i++)
                {
                    if (lstAgcPowerData1.Count == lstAgcPowerData2.Count)
                    {
                        TsData t = new TsData();
                        t.ts = lstAgcPowerData1[i].ts;
                        t.doubleValue = lstAgcPowerData1[i].doubleValue + lstAgcPowerData2[i].doubleValue;

                        list.Add(t);
                    }
                  
                }
                pcm.AgcPowerData.AddRange(list);
            }


            var lstTheoryPowerData = RestfulClient.findHistorySnapByTagName(pcm.TheoryPowerPoint, startTs, endTs, 20);
            pcm.TheoryPowerData.AddRange(lstTheoryPowerData);
            var lstPredictPowerData = RestfulClient.findHistorySnapByTagName(pcm.PredictPowerPoint, startTs, endTs, 20);
            pcm.PredictPowerData.AddRange(lstPredictPowerData);

            pcm.LastUpdateTime = now;


            var dict2 = CacheService.Instance.MatrixCDQPredictPointMap;
            if (dict2 != null)
            {
                var pmms = dict2.Values.Where(q => q.ThingType == PointType.Station && q.ThingId == StationId).ToArray();
                var points = pmms.Select(q => q.PointId).ToArray();

                Dictionary<string, TsData> dictResult = RestfulClient.findLatestByTagNames(points);
                if (dictResult != null && dictResult.Count > 0)
                {
                    for (int i = 0; i < pcm.CDQPredictPowerData.Length; i++)
                    {
                        TsData td = new TsData();
                        td.ts = CommonMethod.ConvertDateTimeInt(pcm.LastUpdateTime.AddMinutes(15 * i));
                        td.doubleValue = 0;
                        pcm.CDQPredictPowerData[i] = td;
                    }


                    foreach (string pid in dictResult.Keys)
                    {
                        string id = pid.Substring(pid.Length - 2, 2);
                        int index = Convert.ToInt32(id);
                        pcm.CDQPredictPowerData[index - 1].doubleValue = dictResult[pid].doubleValue == null ? 0 : dictResult[pid].doubleValue.Value;
                    }

                }
            }
            DateTime endTime = DateTime.Now;

            TimeSpan sp = endTime - now;

            Console.WriteLine("==============================曲线数据访问时间：" + sp.TotalMilliseconds);

            lock (this)
            {
                this.BeginInvoke(
                (Action)delegate
                {
                    try
                    {
                        DateTime sTime = DateTime.Now;

                        this.chart1.Series[0].Points.Clear();
                        foreach (var td in pcm.PredictPowerData)
                        {
                            DateTime dt = CommonMethod.ConvertIntDateTime(td.ts);
                            this.chart1.Series[0].Points.AddXY(dt, td.doubleValue.Value);
                        }

                        foreach (var td in pcm.CDQPredictPowerData)
                        {
                            DateTime dt = CommonMethod.ConvertIntDateTime(td.ts);
                            this.chart1.Series[0].Points.AddXY(dt, td.doubleValue.Value);
                        }

                        this.chart1.Series[1].Points.Clear();
                        foreach (var td in pcm.AgcPowerData)
                        {
                            DateTime dt = CommonMethod.ConvertIntDateTime(td.ts);
                            this.chart1.Series[1].Points.AddXY(dt, td.doubleValue.Value);
                        }

                        this.chart1.Series[2].Points.Clear();
                        foreach (var td in pcm.FactPowerData)
                        {
                            DateTime dt = CommonMethod.ConvertIntDateTime(td.ts);
                            this.chart1.Series[2].Points.AddXY(dt, td.doubleValue.Value);
                        }

                        this.chart1.Series[3].Points.Clear();
                        foreach (var td in pcm.TheoryPowerData)
                        {
                            DateTime dt = CommonMethod.ConvertIntDateTime(td.ts);
                            this.chart1.Series[3].Points.AddXY(dt, td.doubleValue.Value / 1000);
                        }
                        DateTime eTime = DateTime.Now;
                        TimeSpan sp1 = eTime - sTime;
                        Console.WriteLine("==============================曲线数据绑定时间：" + sp1.TotalMilliseconds);

                    }
                    catch (Exception ex)
                    {
                        logger.Error(ex);
                    }

                });
            }
        }



        #endregion





    }
}