using DevExpress.XtraEditors;
|
using DevExpress.XtraGrid.Views.Grid.ViewInfo;
|
using MathNet.Numerics;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel.DataAnnotations;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using System.Windows.Forms;
|
|
namespace IStation.WinFrmUI.Monitor
|
{
|
public partial class MonitorDataIntegrationPage : DocumentPage
|
{
|
public MonitorDataIntegrationPage()
|
{
|
InitializeComponent();
|
this.PageTitle.Caption = "数据整合";
|
this.stationListCtrl1.FocusedChangedEvent += StationListCtrl1_FocusedChangedEvent;
|
this.monitorDataSourcesTreeList1.FocusedChangedEvent += MonitorDataSourcesListCtrl1_FocusedChangedEvent;
|
this.gridView1.SetNormalView();
|
this.colTime.DisplayFormat.FormatType = DevExpress.Utils.FormatType.DateTime;
|
this.colTime.DisplayFormat.FormatString = "G";
|
}
|
|
public class CurrentViewModel
|
{
|
[Display(Name = "年月")]
|
public string YearMonth { get; set; }
|
|
[Display(Name = "时间")]
|
public DateTime Time { get; set; }
|
|
[Display(Name = "运行工况")]
|
public string RunFlags { get; set; }
|
|
[Display(Name = "转速列表")]
|
public string RpmList { get; set; }
|
|
[Display(Name = "扬程列表")]
|
public string HeadList { get; set; }
|
|
[Display(Name = "总流量")]
|
public double TotalFlow { get; set; }
|
|
[Display(Name = "总功率")]
|
public double TotalPower { get; set; }
|
}
|
|
private BLL.StationSignalRecordPacket _bll = new BLL.StationSignalRecordPacket();
|
private Model.Station _station = null;
|
private Model.MonitorDataSources _monitorDataSources = null;
|
private List<CurrentViewModel> _allBindingList = null;
|
private Dictionary<string, Dictionary<string, Tuple<int, Dictionary<string, Dictionary<string, Tuple<double, double>>>>>> _statistical_dict = null;
|
|
/// <summary>
|
/// 清空数据
|
/// </summary>
|
public void Clear()
|
{
|
_allBindingList = new List<CurrentViewModel>();
|
this.currentViewModelBindingSource.DataSource = _allBindingList;
|
}
|
|
/// <summary>
|
/// 初始化数据
|
/// </summary>
|
public override void InitialDataSource()
|
{
|
this.stationListCtrl1.SetBindingData();
|
this.monitorDataSourcesTreeList1.SetBindingData();
|
}
|
|
//泵站变换
|
private void StationListCtrl1_FocusedChangedEvent(Model.Station obj)
|
{
|
_station = obj;
|
SetBindingData(_monitorDataSources, _station);
|
}
|
|
//来源变换
|
private void MonitorDataSourcesListCtrl1_FocusedChangedEvent(Model.MonitorDataSources obj)
|
{
|
_monitorDataSources = obj;
|
SetBindingData(_monitorDataSources, _station);
|
}
|
|
/// <summary>
|
/// 绑定数据
|
/// </summary>
|
public void SetBindingData(Model.MonitorDataSources monitorDataSources, Model.Station station)
|
{
|
_allBindingList = new List<CurrentViewModel>();
|
this.currentViewModelBindingSource.DataSource = _allBindingList;
|
if (monitorDataSources == null || station == null)
|
{
|
return;
|
}
|
if (this.barCekLoad.Checked)
|
{
|
return;
|
}
|
var packets = _bll.Get(_monitorDataSources.ID, _station.ID);
|
SetBindingData(packets);
|
}
|
|
/// <summary>
|
/// 绑定数据
|
/// </summary>
|
public void SetBindingData(List<Model.StationSignalRecordPacket> packets)
|
{
|
WaitFrmHelper.ShowWaitForm();
|
_allBindingList = new List<CurrentViewModel>();
|
_statistical_dict = new Dictionary<string, Dictionary<string, Tuple<int, Dictionary<string, Dictionary<string, Tuple<double, double>>>>>>();
|
if (packets != null && packets.Any())
|
{
|
var enginePumps = new BLL.Equipment().GetEnginePumpListByBelongTypeAndBelongID(IStation.ObjectType.Station, _station.ID);
|
foreach (var packet in packets)
|
{
|
var station_signal_records = packet.StationSignalRecords;
|
if (station_signal_records == null || !station_signal_records.Any())
|
continue;
|
var year_month = $"{packet.Year}-{packet.Month}";
|
foreach (var record in station_signal_records)
|
{
|
var pump_signal_records = record.PumpSignalRecords;
|
if (pump_signal_records == null || !pump_signal_records.Any())
|
continue;
|
pump_signal_records = pump_signal_records.OrderBy(x => x.Flag).ToList();
|
|
var total_power = pump_signal_records.Sum(x => x.InstantaneousPower);
|
var run_flags = pump_signal_records.Select(x => x.Flag).ToList();
|
var rpm_list = pump_signal_records.Select(x =>
|
{
|
if (x.Rpm == 0 && (x.Flag == 15 || x.Flag == 16))
|
{
|
return 590;
|
}
|
return x.Rpm;
|
}).ToList();
|
var head_list = pump_signal_records.Select(x =>
|
{
|
return Math.Round(x.Head, 2);
|
}).ToList();
|
|
|
var vm = new CurrentViewModel();
|
vm.YearMonth = year_month;
|
vm.Time = record.Time;
|
vm.RunFlags = IStation.Untity.IntListHelper.ToString(run_flags);
|
vm.RpmList = IStation.Untity.DoubleListHelper.ToString(rpm_list);
|
vm.HeadList = IStation.Untity.DoubleListHelper.ToString(head_list);
|
vm.TotalFlow = Math.Round(record.TotalFlow, 1);
|
vm.TotalPower = Math.Round(total_power, 1);
|
_allBindingList.Add(vm);
|
}
|
}
|
}
|
if (_allBindingList.Any())
|
{
|
var list = _allBindingList;
|
var group_ym = list.GroupBy(x => x.YearMonth);
|
var max_flow_diff = 0d;
|
var vm_list = new List<CurrentViewModel>();
|
foreach (var item_ym in group_ym)
|
{
|
_statistical_dict.Add(item_ym.Key, new Dictionary<string, Tuple<int, Dictionary<string, Dictionary<string, Tuple<double, double>>>>>());
|
var group_run_flag = item_ym.GroupBy(x => x.RunFlags);
|
foreach (var item_run_flag in group_run_flag)
|
{
|
var count = item_run_flag.Count();
|
var group_rpm = item_run_flag.GroupBy(x => x.RpmList);
|
var dict = new Dictionary<string, Dictionary<string, Tuple<double, double>>>();
|
foreach (var item_rpm in group_rpm)
|
{
|
dict.Add(item_rpm.Key, new Dictionary<string, Tuple<double, double>>());
|
var group_head = item_rpm.GroupBy(x => x.HeadList);
|
foreach (var item_head in group_head)
|
{
|
var flow_diff = item_head.Max(x => x.TotalFlow) - item_head.Min(x => x.TotalFlow);
|
var power_diff = item_head.Max(x => x.TotalPower) - item_head.Min(x => x.TotalPower);
|
dict[item_rpm.Key][item_head.Key] = new Tuple<double, double>(flow_diff, power_diff);
|
if (item_head.Count() > 1)
|
{
|
vm_list.AddRange(item_head);
|
}
|
if (flow_diff > max_flow_diff)
|
{
|
max_flow_diff = flow_diff;
|
}
|
}
|
}
|
_statistical_dict[item_ym.Key].Add(item_run_flag.Key, new Tuple<int, Dictionary<string, Dictionary<string, Tuple<double, double>>>>(count, dict));
|
}
|
}
|
|
// this.currentViewModelBindingSource.DataSource = vm_list;
|
// XtraMessageBox.Show($"{max_Info} / {max_flow_diff}");
|
}
|
|
|
this.currentViewModelBindingSource.DataSource = _allBindingList;
|
WaitFrmHelper.HideWaitForm();
|
}
|
|
//整合
|
private void barBtnIntegration_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
if (_monitorDataSources == null || _station == null)
|
return;
|
var dlg = new SetTimeStepDlg();
|
dlg.ReloadDataEvent += (timeStep) =>
|
{
|
Task.Run(() =>
|
{
|
this.Invoke(new Action(() =>
|
{
|
AlertTool.ShowInfo(Application.OpenForms[0], "提示", "开始整合！");
|
}));
|
var packets = _bll.AnalysisAndSave(_monitorDataSources.ID, _station.ID, timeStep);
|
this.Invoke(new Action(() =>
|
{
|
SetBindingData(packets);
|
AlertTool.ShowInfo(Application.OpenForms[0], "提示", "整合完成！");
|
}));
|
|
});
|
|
};
|
dlg.ShowDialog();
|
}
|
|
//
|
private void barCekLoad_CheckedChanged(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
SetBindingData(_monitorDataSources, _station);
|
}
|
|
//自定义组名
|
private void gridView1_CustomDrawGroupRow(object sender, DevExpress.XtraGrid.Views.Base.RowObjectCustomDrawEventArgs e)
|
{
|
if (_statistical_dict == null && !_statistical_dict.Any())
|
{
|
return;
|
}
|
var vm = this.gridView1.GetRow(e.RowHandle) as CurrentViewModel;
|
var grid = e.Info as GridGroupRowInfo;
|
if (grid.Level == 0)
|
{
|
// var name = $"{vm.RunFlags} (时间点：{_statistical_dict[vm.YearMonth][vm.RunFlags].Item1}) ";
|
var max_flow_diff = _statistical_dict[vm.YearMonth][vm.RunFlags].Item2.Max(x => x.Value.Max(y => y.Value.Item1));
|
// var name = $"{vm.RunFlags} (数量：{_statistical_dict[vm.YearMonth][vm.RunFlags].Item1} 最大流量差:{max_flow_diff:N1}) ";
|
var name = $"{vm.RunFlags} (流量差:{max_flow_diff:N1}) ";
|
grid.GroupText = name;
|
}
|
else if (grid.Level == 1)
|
{
|
var tuple = _statistical_dict[vm.YearMonth][vm.RunFlags].Item2[vm.RpmList];
|
var max_flow_diff = tuple.Max(x => x.Value.Item1);
|
var name = $"{vm.RpmList} (流量差:{max_flow_diff:N1})";
|
grid.GroupText = name;
|
}
|
else if (grid.Level == 2)
|
{
|
var tuple = _statistical_dict[vm.YearMonth][vm.RunFlags].Item2[vm.RpmList][vm.HeadList];
|
var name = $"{vm.HeadList} (流量差：{tuple.Item1:N1},功率差：{tuple.Item2})";
|
grid.GroupText = name;
|
}
|
}
|
|
#region 菜单
|
|
//全部展开
|
private void barBtnExpandAll_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
this.gridView1.ExpandAllGroups();
|
}
|
|
//全部折叠
|
private void barBtnCollapseAll_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
this.gridView1.CollapseAllGroups();
|
}
|
|
//检索
|
private void barCekSearch_CheckedChanged(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
if (this.barCekSearch.Checked)
|
this.gridView1.ShowFindPanel();
|
else
|
this.gridView1.HideFindPanel();
|
}
|
|
// 刷新数据
|
private void barBtnRefresh_ItemClick(object sender, DevExpress.XtraBars.ItemClickEventArgs e)
|
{
|
InitialDataSource();
|
}
|
|
#endregion
|
|
|
|
|
}
|
}
|
