using IStation.Model;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.Common
|
{
|
public class PumpHistoryDataFileHelper
|
{
|
|
public class RunParasData
|
{
|
/// <summary>
|
/// 泵运行状态
|
/// </summary>
|
public List<(DateTime,DateTime,int )> TimeRunParas { get; set; }
|
/// <summary>
|
/// 取水量
|
/// </summary>
|
public List<double> Water { get; set; }
|
/// <summary>
|
/// 用电量
|
/// </summary>
|
public List<double> Electric { get; set; }
|
}
|
|
/// <summary>
|
/// 初始方法获取所有数据
|
/// </summary>
|
/// <param name="day"></param>
|
/// <returns></returns>
|
public static List<RunParasData> GetHistoryData(DateTime day)
|
{
|
List<double> doublesWater = new List<double>();
|
List<double> doublesEle = new List<double>();
|
var PumpIsOpen = getPumpIsOpen(day);
|
foreach (var item in PumpIsOpen)
|
{
|
doublesWater.Add(GetWaterdata(item.Item1, item.Item2));
|
}
|
foreach (var item in PumpIsOpen)
|
{
|
doublesEle.Add(GetElectrityData(item.Item1, item.Item2));
|
}
|
List<RunParasData> runParasDatas = new List<RunParasData>();
|
runParasDatas.Add(new RunParasData
|
{
|
TimeRunParas = PumpIsOpen,
|
Water = doublesWater,
|
Electric = doublesEle
|
});
|
return runParasDatas;
|
}
|
|
/// <summary>
|
/// 获取总取水量
|
/// </summary>
|
/// <returns></returns>
|
public static List<Model.PumpWater> GetWaterData()
|
{
|
string path = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(),
|
"PumpRunParas", "二取水机泵累计流量.csv");
|
if (!File.Exists(path))
|
return null;
|
int totalLines = File.ReadLines(path, Encoding.GetEncoding("gb2312")).Count();//总行数
|
System.IO.FileStream fs = new System.IO.FileStream(path, System.IO.FileMode.Open);
|
System.IO.StreamReader sr = new System.IO.StreamReader(fs, Encoding.GetEncoding("gb2312"));
|
string tempText;
|
List<Model.PumpWater> pumpISopenlist = new List<Model.PumpWater>();
|
for (int i = 0; i < totalLines-1; i++)
|
{
|
tempText = sr.ReadLine();
|
string[] arr = tempText.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
try
|
{
|
var pumpISopen = new Model.PumpWater
|
{
|
Tag = arr[1],
|
Values = new List<Model.Water>
|
{
|
new Model.Water
|
{
|
DateTime = Convert.ToDateTime(arr[0]),
|
SingleWater =Convert.ToDouble( arr[2])
|
}
|
}
|
|
|
};
|
pumpISopenlist.Add(pumpISopen);
|
}
|
catch
|
{
|
var a = i;
|
}
|
}
|
fs.Close();
|
return pumpISopenlist;
|
}
|
|
|
|
/// <summary>
|
/// 获取有功电能
|
/// </summary>
|
/// <returns></returns>
|
public static List<Model.electricity> GetEleData()
|
{
|
string path = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(),
|
"PumpRunParas", "二取水机泵有功电能.csv");
|
if (!File.Exists(path))
|
return null;
|
int totalLines = File.ReadLines(path, Encoding.GetEncoding("gb2312")).Count();//总行数
|
System.IO.FileStream fs = new System.IO.FileStream(path, System.IO.FileMode.Open);
|
System.IO.StreamReader sr = new System.IO.StreamReader(fs, Encoding.GetEncoding("gb2312"));
|
string tempText;
|
List<Model.electricity> pumpISopenlist = new List<Model.electricity>();
|
for (int i = 0; i < totalLines; i++)
|
{
|
tempText = sr.ReadLine();
|
string[] arr = tempText.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
var pumpISopen = new Model.electricity
|
{
|
Tag = arr[1],
|
TotalEle = new List<Model.Ele>
|
{
|
new Model.Ele
|
{
|
DateTime = Convert.ToDateTime(arr[0]),
|
Value =Convert.ToDouble( arr[2])
|
}
|
}
|
};
|
pumpISopenlist.Add(pumpISopen);
|
}
|
fs.Close();
|
return pumpISopenlist;
|
}
|
|
|
|
/// <summary>
|
/// 获取具体时间段的开泵台数
|
/// </summary>
|
public static List<(DateTime, DateTime, int)> getPumpIsOpen(DateTime datetime)
|
{
|
List<IsOpen> isOpenpump1 = new List<IsOpen>();
|
List<IsOpen> isOpenpump2 = new List<IsOpen>();
|
List<IsOpen> isOpenpump3 = new List<IsOpen>();
|
List<IsOpen> isOpenpump4 = new List<IsOpen>();
|
List<IsOpen> isOpenpump5 = new List<IsOpen>();
|
var TestIsOpen = GetPumpRunParas();
|
if (TestIsOpen == null)
|
return null;
|
var Pump1 = TestIsOpen.Where(x => x.Tag == "_0402010204012101001").ToList();
|
foreach (var item in Pump1)
|
{
|
isOpenpump1.AddRange(item.Values.Where(x => x.DateTime >= datetime && x.DateTime <= datetime.AddHours(23).AddMinutes(59)).ToList());
|
}
|
var Pump2 = TestIsOpen.Where(x => x.Tag == "_0402010204012201001").ToList();
|
foreach (var item in Pump2)
|
{
|
isOpenpump2.AddRange(item.Values.Where(x => x.DateTime >= datetime && x.DateTime <= datetime.AddHours(23).AddMinutes(59)).ToList());
|
}
|
var Pump3 = TestIsOpen.Where(x => x.Tag == "_0402010204012301001").ToList();
|
foreach (var item in Pump3)
|
{
|
isOpenpump3.AddRange(item.Values.Where(x => x.DateTime >= datetime && x.DateTime <= datetime.AddHours(23).AddMinutes(59)).ToList());
|
}
|
var Pump4 = TestIsOpen.Where(x => x.Tag == "_0402010204012401001").ToList();
|
foreach (var item in Pump4)
|
{
|
isOpenpump4.AddRange(item.Values.Where(x => x.DateTime >= datetime && x.DateTime <= datetime.AddHours(23).AddMinutes(59)).ToList());
|
}
|
var Pump5 = TestIsOpen.Where(x => x.Tag == "_0402010204012501001").ToList();
|
foreach (var item in Pump5)
|
{
|
isOpenpump5.AddRange(item.Values.Where(x => x.DateTime >= datetime && x.DateTime <= datetime.AddHours(23).AddMinutes(59)).ToList());
|
}
|
List<string> startTime = new List<string>();
|
List<string> endtime = new List<string>();
|
var Run1 = GetData(isOpenpump1);
|
var Run2 = GetData(isOpenpump2);
|
var Run3 = GetData(isOpenpump3);
|
var Run4 = GetData(isOpenpump4);
|
var Run5 = GetData(isOpenpump5);
|
List<(DateTime, DateTime)> mergedList = MergeList(Run1, Run2, Run3, Run4, Run5);
|
return MergeTimeSlots(mergedList);
|
}
|
|
/// <summary>
|
/// 获取泵的开机参数
|
/// </summary>
|
/// <returns></returns>
|
public static List<Model.PumpIsopen> GetPumpRunParas()
|
{
|
string path = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(),
|
"PumpRunParas", "二取水机泵开停状态.csv");
|
if (!File.Exists(path))
|
return null;
|
int totalLines = File.ReadLines(path, Encoding.GetEncoding("gb2312")).Count();//总行数
|
System.IO.FileStream fs = new System.IO.FileStream(path, System.IO.FileMode.Open);
|
System.IO.StreamReader sr = new System.IO.StreamReader(fs, Encoding.GetEncoding("gb2312"));
|
string tempText;
|
List<Model.PumpIsopen> pumpISopenlist = new List<Model.PumpIsopen>();
|
for (int i = 0; i < totalLines; i++)
|
{
|
tempText = sr.ReadLine();
|
string[] arr = tempText.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
|
var pumpISopen = new Model.PumpIsopen
|
{
|
Tag = arr[1],
|
Values = new List<Model.IsOpen>
|
{
|
new Model.IsOpen
|
{
|
DateTime = Convert.ToDateTime(arr[0]),
|
Isopen = arr[2]
|
}
|
}
|
};
|
pumpISopenlist.Add(pumpISopen);
|
}
|
fs.Close();
|
return pumpISopenlist;
|
}
|
|
|
//泵开机参数的辅助方法
|
private static List<(DateTime, DateTime)> GetData(List<IsOpen> PumpList)
|
{
|
List<(DateTime, DateTime)> values = new List<(DateTime, DateTime)>();
|
values.Clear();
|
// List<DateTime> Endvalues = new List<DateTime>();
|
DateTime startTime;
|
DateTime EndTime;
|
for (int time = 0; time < PumpList.Count; time++)
|
{
|
if (PumpList[time].Isopen == "1")
|
{
|
startTime = PumpList[time].DateTime;
|
EndTime = PumpList[time].DateTime;
|
for (int k = time + 1; k < PumpList.Count; k++) //k为从开机后比较的变量下标
|
{
|
if (PumpList[k].Isopen == "1")
|
{
|
EndTime = PumpList[k].DateTime;
|
time = k;
|
}
|
else break;
|
}
|
values.Add((startTime, EndTime));
|
}
|
|
}
|
return values;
|
}
|
|
|
|
|
/// <summary>
|
/// 模糊合并时间段
|
/// </summary>
|
/// <param name="Date"></param>
|
/// <returns></returns>
|
static List<(DateTime, DateTime, int)> MergeTimeSlots(List<(DateTime, DateTime)> Date)
|
{
|
List<(DateTime, DateTime, int)> mergedSlots = new List<(DateTime, DateTime, int)>();
|
Date.Sort((x, y) => x.Item1.CompareTo(y.Item1)); // 按照起始时间排序
|
|
DateTime mergedStart = Date[0].Item1;
|
DateTime mergedEnd = Date[0].Item2;
|
int mergeCount = 1;
|
|
// 从第二个时间段开始迭代
|
for (int i = 1; i < Date.Count; i++)
|
{
|
DateTime start = Date[i].Item1;
|
DateTime end = Date[i].Item2;
|
|
// 如果当前时间段的起始时间在模糊时间范围内，则合并
|
if (start <= mergedEnd.AddMinutes(40)) // 假设模糊时间范围为15分钟
|
{
|
mergedEnd = DateTime.Compare(mergedEnd, end) < 0 ? end : mergedEnd;
|
mergeCount++;
|
}
|
else
|
{
|
mergedSlots.Add((mergedStart, mergedEnd, mergeCount));
|
mergedStart = start;
|
mergedEnd = end;
|
mergeCount = 1;
|
}
|
}
|
|
// 添加最后一个时间段
|
mergedSlots.Add((mergedStart, mergedEnd, mergeCount));
|
|
return mergedSlots;
|
}
|
|
|
/// <summary>
|
/// 合并五台泵的运行时间
|
/// </summary>
|
/// <param name="lists"></param>
|
/// <returns></returns>
|
static List<(DateTime, DateTime)> MergeList(params List<(DateTime, DateTime)>[] lists)
|
{
|
List<(DateTime, DateTime)> mergedList = new List<(DateTime, DateTime)>();
|
foreach (var list in lists)
|
{
|
mergedList.AddRange(list);
|
}
|
return mergedList;
|
}
|
|
|
|
|
private static double GetWaterdata(DateTime Str, DateTime end)
|
{
|
List<Model.Water> water1 = new List<Model.Water>();
|
List<Model.Water> water2 = new List<Model.Water>();
|
List<Model.Water> water3 = new List<Model.Water>();
|
List<Model.Water> water4 = new List<Model.Water>();
|
List<Model.Water> water5 = new List<Model.Water>();
|
var waterData = GetWaterData();
|
var pump1 = waterData.Where(x => x.Tag == "二取水1号主水泵.日累计").ToList();
|
foreach (var item in pump1)
|
{
|
water1.AddRange(item.Values.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump2 = waterData.Where(x => x.Tag == "二取水2号主水泵.日累计").ToList();
|
foreach (var item in pump2)
|
{
|
water2.AddRange(item.Values.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump3 = waterData.Where(x => x.Tag == "二取水3号主水泵.日累计").ToList();
|
foreach (var item in pump3)
|
{
|
water3.AddRange(item.Values.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump4 = waterData.Where(x => x.Tag == "二取水4号主水泵.日累计").ToList();
|
foreach (var item in pump4)
|
{
|
water4.AddRange(item.Values.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump5 = waterData.Where(x => x.Tag == "二取水5号主水泵.日累计").ToList();
|
foreach (var item in pump5)
|
{
|
water5.AddRange(item.Values.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var Result1 = water1.Last().SingleWater - water1.First().SingleWater;
|
var Result2 = water2.Last().SingleWater - water2.First().SingleWater;
|
var Result3 = water3.Last().SingleWater - water3.First().SingleWater;
|
var Result4 = water4.Last().SingleWater - water4.First().SingleWater;
|
var Result5 = water5.Last().SingleWater - water5.First().SingleWater;
|
return Result1 + Result2 + Result3 + Result4 + Result5;
|
}
|
|
|
|
private static double GetElectrityData(DateTime Str, DateTime end)
|
{
|
var Ele = GetEleData();
|
List<Model.Ele> Ele1 = new List<Model.Ele>();
|
List<Model.Ele> Ele2 = new List<Model.Ele>();
|
List<Model.Ele> Ele3 = new List<Model.Ele>();
|
List<Model.Ele> Ele4 = new List<Model.Ele>();
|
List<Model.Ele> Ele5 = new List<Model.Ele>();
|
var pump1 = Ele.Where(x => x.Tag == "_0402010204040193046").ToList();
|
foreach (var item in pump1)
|
{
|
Ele1.AddRange(item.TotalEle.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump2 = Ele.Where(x => x.Tag == "_0402010204040193047").ToList();
|
foreach (var item in pump2)
|
{
|
Ele2.AddRange(item.TotalEle.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump3 = Ele.Where(x => x.Tag == "_0402010204012308007").ToList();
|
foreach (var item in pump3)
|
{
|
Ele3.AddRange(item.TotalEle.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump4 = Ele.Where(x => x.Tag == "_0402010204012408007").ToList();
|
foreach (var item in pump4)
|
{
|
Ele4.AddRange(item.TotalEle.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var pump5 = Ele.Where(x => x.Tag == "_0402010204012508007").ToList();
|
foreach (var item in pump5)
|
{
|
Ele5.AddRange(item.TotalEle.Where(x => x.DateTime >= Str && x.DateTime <= end));
|
}
|
var Result1 = Ele1.Last().Value - Ele1.First().Value;
|
var Result2 = Ele2.Last().Value - Ele2.First().Value;
|
var Result3 = Ele3.Last().Value - Ele3.First().Value;
|
var Result4 = Ele4.Last().Value - Ele4.First().Value;
|
var Result5 = Ele5.Last().Value - Ele5.First().Value;
|
return Result1 + Result2 + Result3 + Result4 + Result5;
|
}
|
}
|
}
|
