using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using IStation.Untity; namespace IStation.Calculation { /// /// 能效汇总多时辅助类 /// public class EtaSumMultiHourHelper { /// /// 汇总 /// /// public static List Sum ( long CorpID, string ObjectType, long ObjectID, DateTime Day, IEnumerable list ) { if (list == null || list.Count() < 1) return default; var run_list = list.Where(x =>x.RunningCount>0).ToList(); if (run_list.Count < 1) return default; var group_list = run_list.GroupBy(x => new { CorpID = x.CorpID, ObjectType = x.ObjectType, ObjectID = x.ObjectID, RunningCount = x.RunningCount, RunningFlag = IntListHelper.ToString(x.RunningFlag) }).ToList(); var result = new List(); foreach (var group in group_list) { for (int i = 0; i < 24; i++) { var run_hour_list = group.Where(t => t.DataTime >= Day.Date.AddHours(i) && t.DataTime < Day.Date.AddHours(i + 1)).ToList(); var run_normal_hour_list = run_hour_list.Where(t => t.AnalyStatus == Model.Eta.eAnalyStatus.Normal).ToList(); var model = new Model.EtaSumMultiHourRecord(); model.CorpID = CorpID; model.ObjectType = ObjectType; model.ObjectID = ObjectID; model.DataDay = Day.Date; model.DataHour = i + 1; model.DataTime = DateTime.Now; model.RunningCount = group.Key.RunningCount; model.RunningFlag = IntListHelper.ToList(group.Key.RunningFlag); model.Qt = run_hour_list.Sum(x => (x.Qa ?? 0) * x.Duration) / 3600f; model.Dt = run_hour_list.Sum(x => (x.Pa ?? 0) * x.Duration) / 3600f; model.RunTime = run_hour_list.Sum(x => x.Duration); model.PointCount = run_hour_list.Count; if (run_normal_hour_list.Count > 0) { model.Qmin = run_normal_hour_list.Min(x => x.Qa.Value); model.Qmax = run_normal_hour_list.Max(x => x.Qa.Value); model.Qavg = run_normal_hour_list.Average(x => x.Qa.Value); model.Hmin = run_normal_hour_list.Min(x => x.Ha.Value); model.Hmax = run_normal_hour_list.Max(x => x.Ha.Value); model.Havg = run_normal_hour_list.Average(x => x.Ha.Value); model.Emin = run_normal_hour_list.Min(x => x.Ea.Value); model.Emax = run_normal_hour_list.Max(x => x.Ea.Value); model.Eavg = run_normal_hour_list.Average(x => x.Ea.Value); model.Pmin = run_normal_hour_list.Min(x => x.Pa.Value); model.Pmax = run_normal_hour_list.Max(x => x.Pa.Value); model.Pavg = run_normal_hour_list.Average(x => x.Pa.Value); model.WPmin = run_normal_hour_list.Min(x => x.WPa.Value); model.WPmax = run_normal_hour_list.Max(x => x.WPa.Value); model.WPavg = run_normal_hour_list.Average(x => x.WPa.Value); model.UWPmin = run_normal_hour_list.Min(x => x.UWPa.Value); model.UWPmax = run_normal_hour_list.Max(x => x.UWPa.Value); model.UWPavg = run_normal_hour_list.Average(x => x.UWPa.Value); } result.Add(model); } } return result; } } }