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;
}
}
}