using IStation.Model;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.Calculation
|
{
|
/// <summary>
|
/// 监测公式历史计算辅助类
|
/// </summary>
|
public class MonitorFormulaHistoryCalcuHelper
|
{
|
#region 常规实时
|
|
#region 映射
|
|
/// <summary>
|
/// 计算单一映射(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuSingleMapping
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.SingleMappingCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = "关联测点不存在监测记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <=duration; i+=realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null|| relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus =lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
if (formulaModel.Calculate(dataValue, out double toValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toValue = signal.ConvertParas.Convert(toValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toValue = signal.CorrectParas.Correct(toValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toValue = Math.Round(toValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算比较映射(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuCompareMapping
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.CompareMappingCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = "关联测点不存在监测记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
if (formulaModel.Calculate(dataValue, out double toValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toValue = signal.ConvertParas.Convert(toValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toValue = signal.CorrectParas.Correct(toValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toValue = Math.Round(toValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
|
/// <summary>
|
/// 计算区间映射(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuRangeMapping
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.RangeMappingCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = "关联测点不存在监测记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
if (formulaModel.Calculate(dataValue, out double toValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toValue = signal.ConvertParas.Convert(toValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toValue = signal.CorrectParas.Correct(toValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toValue = Math.Round(toValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
|
#endregion
|
|
#region 系数
|
|
/// <summary>
|
/// 计算一元系数(实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuOnceRatio
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.OnceRatioCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = "关联测点不存在监测记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
if (formulaModel.Calculate(dataValue, out double toValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toValue = signal.ConvertParas.Convert(toValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toValue = signal.CorrectParas.Correct(toValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toValue = Math.Round(toValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算二元系数(实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuTwiceRatio
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.TwiceRatioCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = "关联测点不存在监测记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
if (formulaModel.Calculate(dataValue, out double toValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toValue = signal.ConvertParas.Convert(toValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toValue = signal.CorrectParas.Correct(toValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toValue = Math.Round(toValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
#endregion
|
|
#region 其他
|
|
/// <summary>
|
/// 计算-和值(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuSum
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.SumValueCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
if (formulaModel.ObjectIds == null || formulaModel.ObjectIds.Count < 1)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
//关联测点列表
|
var relatedMonitorList = new List<Model.MonitorPoint_Signal_SignalType>();
|
foreach (var objectid in formulaModel.ObjectIds)
|
{
|
var relatedMonitor = getMonitorPoint(objectid);
|
if (relatedMonitor == null)
|
{
|
Msg = $"关联测点:{objectid}，不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = $"关联测点:{objectid},不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = $"关联测点:{objectid},关联测点不是实时测点";
|
return default;
|
}
|
relatedMonitorList.Add(relatedMonitor);
|
}
|
var relatedRecordListDict = new Dictionary<Model.MonitorPoint_Signal_SignalType, List<Model.MonitorBasicRecord>>();//关联测点记录
|
var relatedRealSlotDict = new Dictionary<Model.MonitorPoint_Signal_SignalType, Model.Monitor.RealSlot>();
|
var relatedRecordReadIndexDict = new Dictionary<Model.MonitorPoint_Signal_SignalType, int>();//已读角标
|
foreach (var relatedMonitor in relatedMonitorList)
|
{
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = $"关联测点:{relatedMonitor.ID}，不存在记录";
|
return default;
|
}
|
relatedRecordListDict.Add(relatedMonitor, relatedRecordList);
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(relatedMonitor, relatedRealSlot);
|
relatedRecordReadIndexDict.Add(relatedMonitor, -1);
|
}
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
var relatedRecordDict = new Dictionary<Model.MonitorPoint_Signal_SignalType, Model.MonitorBasicRecord>();
|
foreach (var relatedMonitor in relatedMonitorList)
|
{
|
var relatedRecordList = relatedRecordListDict[relatedMonitor];
|
var relatedRecordReadIndex = relatedRecordReadIndexDict[relatedMonitor];
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecord = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordDict.Add(relatedMonitor, relatedRecordList[index]);
|
relatedRecordReadIndexDict[relatedMonitor] = index + 1;
|
break;
|
}
|
}
|
}
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
if (relatedRecordDict.Count != relatedMonitorList.Count || relatedRecordDict.ToList().Exists(x => x.Value.DataTime < relatedRealSlotDict[x.Key].GetStartTime(dataTime)))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = string.Join(',', relatedRecordDict.Values.Select(x => x.DataValue));
|
pure.DataTime = dataTime;
|
pure.DataValue = string.Empty;
|
pure.DataStatus = new List<string>();
|
|
var dataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordDict.Values)
|
{
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValueTemp))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
break;
|
}
|
dataValueList.Add(dataValueTemp);
|
if (relatedRecord.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecord.DataStatus);
|
}
|
}
|
var dataValue = formulaModel.Calculate(dataValueList);
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算-差值(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuDiff
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.DiffValueCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
#region 第一个参数
|
|
var relatedMonitor1 = getMonitorPoint(formulaModel.First);
|
if (relatedMonitor1 == null)
|
{
|
Msg = $"关联测点:{formulaModel.First},不存在";
|
return default;
|
}
|
if (relatedMonitor1.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = $"关联测点:{formulaModel.First},不是常规测点";
|
return default;
|
}
|
if (relatedMonitor1.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = $"关联测点:{formulaModel.First},不是实时测点";
|
return default;
|
}
|
var relatedRecordList1 = getRecordList(relatedMonitor1.ID, relatedMonitor1.SignalList.First().ID);
|
if (relatedRecordList1 == null || relatedRecordList1.Count < 1)
|
{
|
Msg = $"关联测点:{formulaModel.First},不存在记录";
|
return default;
|
}
|
var relatedRealSlot1 = Model.Monitor.RealSlot.ToModel(relatedMonitor1.CronParas);
|
if (relatedRealSlot1 == null)
|
{
|
relatedRealSlot1 = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex1 = -1;
|
|
#endregion
|
|
#region 第二个参数
|
|
var relatedMonitor2 = getMonitorPoint(formulaModel.Second);
|
if (relatedMonitor2 == null)
|
{
|
Msg = $"关联测点:{formulaModel.Second},不存在";
|
return default;
|
}
|
if (relatedMonitor2.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = $"关联测点:{formulaModel.Second},不是常规测点";
|
return default;
|
}
|
if (relatedMonitor2.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = $"关联测点:{formulaModel.Second},不是实时测点";
|
return default;
|
}
|
var relatedRecordList2 = getRecordList(relatedMonitor2.ID,relatedMonitor2.SignalList.First().ID);
|
if (relatedRecordList2 == null || relatedRecordList2.Count < 1)
|
{
|
Msg = $"关联测点:{formulaModel.Second},不存在记录";
|
return default;
|
}
|
var relatedRealSlot2 = Model.Monitor.RealSlot.ToModel(relatedMonitor2.CronParas);
|
if (relatedRealSlot2 == null)
|
{
|
relatedRealSlot2 = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex2 = -1;
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecord1 = null;
|
for (int j = relatedRecordReadIndex1 + 1; j < relatedRecordList1.Count; j++)
|
{
|
var relatedRecord = relatedRecordList1[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord1 = relatedRecordList1[index];
|
relatedRecordReadIndex1 = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecord2 = null;
|
for (int j = relatedRecordReadIndex2 + 1; j < relatedRecordList2.Count; j++)
|
{
|
var relatedRecord = relatedRecordList2[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord2 = relatedRecordList2[index];
|
relatedRecordReadIndex2 = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord1 == null || relatedRecord1.DataTime < relatedRealSlot1.GetStartTime(dataTime)
|
|| relatedRecord2 == null || relatedRecord2.DataTime < relatedRealSlot2.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = $"{relatedRecord1.DataValue},{relatedRecord2.DataValue}";
|
pure.DataTime = dataTime;
|
pure.DataValue = string.Empty;
|
pure.DataStatus = new List<string>();
|
|
if (!double.TryParse(relatedRecord1.DataValue, out double dataValue1))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecord1.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecord1.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecord2.DataValue, out double dataValue2))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecord2.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecord2.DataStatus);
|
}
|
|
var dataValue = formulaModel.Calculate(dataValue2, dataValue1);
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算数值累积(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuNumberAccumulate
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.NumberAccumulateCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不存在记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var accumulateModel = Model.Monitor.AccumulateParameters.ToModel(signal.DataParas);
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex+ 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecordTemp.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
dataValue = formulaModel.Calculate(dataValue, realSlot.TimeStep);
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double lastDataValue))
|
{
|
dataValue += lastDataValue;
|
}
|
}
|
else
|
{
|
if (accumulateModel != null)
|
{
|
if (accumulateModel.InitialValue.HasValue)
|
{
|
dataValue += accumulateModel.InitialValue.Value;
|
}
|
}
|
}
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算枚举累积(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuEnumAccumulate
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.EnumAccumulateCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不是实时测点";
|
return default;
|
}
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
Msg = $"关联测点:{formulaModel.ObjectID},不存在记录";
|
return default;
|
}
|
var relatedRealSlot = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (relatedRealSlot == null)
|
{
|
relatedRealSlot = new Model.Monitor.RealSlot();
|
}
|
var relatedRecordReadIndex = -1;
|
|
var signal = monitor.SignalList.First();
|
var accumulateModel = Model.Monitor.AccumulateParameters.ToModel(signal.DataParas);
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndex + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecordTemp.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndex = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecord == null || relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = relatedRecord.SrcTime;
|
pure.SrcValue = relatedRecord.DataValue;
|
pure.DataTime = dataTime;
|
pure.DataValue = relatedRecord.DataValue;
|
pure.DataStatus = relatedRecord.DataStatus;
|
if (pure.DataStatus == null)
|
{
|
pure.DataStatus = new List<string>();
|
}
|
|
if (double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
dataValue = formulaModel.Calculate(dataValue, realSlot.TimeStep);
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double lastDataValue))
|
{
|
dataValue += lastDataValue;
|
}
|
}
|
else
|
{
|
if (accumulateModel != null)
|
{
|
if (accumulateModel.InitialValue.HasValue)
|
{
|
dataValue += accumulateModel.InitialValue.Value;
|
}
|
}
|
}
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
return recordList;
|
}
|
|
|
/// <summary>
|
/// 计算效率(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuE
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.ECalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
#region 流量参数
|
|
var relatedMonitorQ = getMonitorPoint(formulaModel.Q);
|
if (relatedMonitorQ == null)
|
{
|
Msg = "关联测点：{formulaModel.Q},不存在";
|
return default;
|
}
|
if (relatedMonitorQ.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorQ.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是实时测点";
|
return default;
|
}
|
var relatedSignalQ = relatedMonitorQ.SignalList.First();
|
if (relatedSignalQ.SignalType.Identifier != SignalType.瞬时流量)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是瞬时流量测点";
|
return default;
|
}
|
var relatedRecordListQ = getRecordList(relatedMonitorQ.ID, relatedSignalQ.ID);
|
if (relatedRecordListQ == null || relatedRecordListQ.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.Q},记录不存在";
|
return default;
|
}
|
var relatedRealSlotQ = Model.Monitor.RealSlot.ToModel(relatedMonitorQ.CronParas);
|
if (relatedRealSlotQ == null)
|
{
|
relatedRealSlotQ = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexQ = -1;
|
|
#endregion
|
|
#region 扬程参数
|
|
var relatedMonitorH = getMonitorPoint(formulaModel.H);
|
if (relatedMonitorH == null)
|
{
|
Msg = "关联测点：{formulaModel.H},不存在";
|
return default;
|
}
|
if (relatedMonitorH.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.H},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorH.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.H},不是实时测点";
|
return default;
|
}
|
var relatedSignalH = relatedMonitorH.SignalList.First();
|
if (relatedSignalH.SignalType.Identifier != SignalType.扬程)
|
{
|
Msg = "关联测点：{formulaModel.H},不是扬程测点";
|
return default;
|
}
|
var relatedRecordListH = getRecordList(relatedMonitorH.ID, relatedSignalH.ID);
|
if (relatedRecordListH == null || relatedRecordListH.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.H},记录不存在";
|
return default;
|
}
|
var relatedRealSlotH = Model.Monitor.RealSlot.ToModel(relatedMonitorH.CronParas);
|
if (relatedRealSlotH == null)
|
{
|
relatedRealSlotH = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexH = -1;
|
|
#endregion
|
|
#region 功率参数
|
|
var relatedMonitorP = getMonitorPoint(formulaModel.P);
|
if (relatedMonitorP == null)
|
{
|
Msg = "关联测点：{formulaModel.P},不存在";
|
return default;
|
}
|
if (relatedMonitorP.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.P},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorP.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.P},不是实时测点";
|
return default;
|
}
|
var relatedSignalP = relatedMonitorP.SignalList.First();
|
if (relatedSignalP.SignalType.Identifier != SignalType.有功功率)
|
{
|
Msg = "关联测点：{formulaModel.P},不是扬程测点";
|
return default;
|
}
|
var relatedRecordListP = getRecordList(relatedMonitorP.ID, relatedSignalP.ID);
|
if (relatedRecordListP == null || relatedRecordListP.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.P},记录不存在";
|
return default;
|
}
|
var relatedRealSlotP = Model.Monitor.RealSlot.ToModel(relatedMonitorP.CronParas);
|
if (relatedRealSlotP == null)
|
{
|
relatedRealSlotP = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexP = -1;
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecordQ = null;
|
for (int j = relatedRecordReadIndexQ + 1; j < relatedRecordListQ.Count; j++)
|
{
|
var relatedRecord = relatedRecordListQ[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordQ = relatedRecordListQ[index];
|
relatedRecordReadIndexQ = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecordH = null;
|
for (int j = relatedRecordReadIndexH + 1; j < relatedRecordListH.Count; j++)
|
{
|
var relatedRecord = relatedRecordListH[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordH = relatedRecordListH[index];
|
relatedRecordReadIndexH = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecordP = null;
|
for (int j = relatedRecordReadIndexP + 1; j < relatedRecordListP.Count; j++)
|
{
|
var relatedRecord = relatedRecordListP[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordP = relatedRecordListP[index];
|
relatedRecordReadIndexP = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecordQ == null || relatedRecordQ.DataTime < relatedRealSlotQ.GetStartTime(dataTime)
|
|| relatedRecordH == null || relatedRecordH.DataTime < relatedRealSlotH.GetStartTime(dataTime)
|
|| relatedRecordP == null || relatedRecordP.DataTime < relatedRealSlotP.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = $"{relatedRecordQ.DataValue},{relatedRecordH.DataValue},{relatedRecordP.DataValue}";
|
pure.DataTime = dataTime;
|
pure.DataValue = string.Empty;
|
pure.DataStatus = new List<string>();
|
|
|
if (!double.TryParse(relatedRecordQ.DataValue, out double dataValueQ))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordQ.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordQ.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecordH.DataValue, out double dataValueH))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordH.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordH.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecordP.DataValue, out double dataValueP))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordP.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordP.DataStatus);
|
}
|
|
if (formulaModel.Calculate(dataValueQ, dataValueH, dataValueP, out double dataValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算千吨能耗(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuWP
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.WPCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
|
#region 流量参数
|
|
var relatedMonitorQ = getMonitorPoint(formulaModel.Q);
|
if (relatedMonitorQ == null)
|
{
|
Msg = "关联测点：{formulaModel.Q},不存在";
|
return default;
|
}
|
if (relatedMonitorQ.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorQ.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是实时测点";
|
return default;
|
}
|
var relatedSignalQ = relatedMonitorQ.SignalList.First();
|
if (relatedSignalQ.SignalType.Identifier != SignalType.瞬时流量)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是瞬时流量测点";
|
return default;
|
}
|
var relatedRecordListQ = getRecordList(relatedMonitorQ.ID, relatedSignalQ.ID);
|
if (relatedRecordListQ == null || relatedRecordListQ.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.Q},记录不存在";
|
return default;
|
}
|
var relatedRealSlotQ = Model.Monitor.RealSlot.ToModel(relatedMonitorQ.CronParas);
|
if (relatedRealSlotQ == null)
|
{
|
relatedRealSlotQ = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexQ = -1;
|
|
#endregion
|
|
#region 功率参数
|
|
var relatedMonitorP = getMonitorPoint(formulaModel.P);
|
if (relatedMonitorP == null)
|
{
|
Msg = "关联测点：{formulaModel.P},不存在";
|
return default;
|
}
|
if (relatedMonitorP.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.P},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorP.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.P},不是实时测点";
|
return default;
|
}
|
var relatedSignalP = relatedMonitorP.SignalList.First();
|
if (relatedSignalP.SignalType.Identifier != SignalType.有功功率)
|
{
|
Msg = "关联测点：{formulaModel.P},不是扬程测点";
|
return default;
|
}
|
var relatedRecordListP = getRecordList(relatedMonitorP.ID, relatedSignalP.ID);
|
if (relatedRecordListP == null || relatedRecordListP.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.P},记录不存在";
|
return default;
|
}
|
var relatedRealSlotP = Model.Monitor.RealSlot.ToModel(relatedMonitorP.CronParas);
|
if (relatedRealSlotP == null)
|
{
|
relatedRealSlotP = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexP = -1;
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecordQ = null;
|
for (int j = relatedRecordReadIndexQ + 1; j < relatedRecordListQ.Count; j++)
|
{
|
var relatedRecord = relatedRecordListQ[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordQ = relatedRecordListQ[index];
|
relatedRecordReadIndexQ = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecordP = null;
|
for (int j = relatedRecordReadIndexP + 1; j < relatedRecordListP.Count; j++)
|
{
|
var relatedRecord = relatedRecordListP[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordP = relatedRecordListP[index];
|
relatedRecordReadIndexP = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecordQ == null || relatedRecordQ.DataTime < relatedRealSlotQ.GetStartTime(dataTime)
|
|| relatedRecordP == null || relatedRecordP.DataTime < relatedRealSlotP.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = $"{relatedRecordQ.DataValue},{relatedRecordP.DataValue}";
|
pure.DataTime = dataTime;
|
pure.DataValue = string.Empty;
|
pure.DataStatus = new List<string>();
|
|
if (!double.TryParse(relatedRecordQ.DataValue, out double dataValueQ))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordQ.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordQ.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecordP.DataValue, out double dataValueP))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordP.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordP.DataStatus);
|
}
|
|
if (formulaModel.Calculate(dataValueP, dataValueQ, out double dataValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 计算效率(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuUWP
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.UWPCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
#region 流量参数
|
|
var relatedMonitorQ = getMonitorPoint(formulaModel.Q);
|
if (relatedMonitorQ == null)
|
{
|
Msg = "关联测点：{formulaModel.Q},不存在";
|
return default;
|
}
|
if (relatedMonitorQ.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorQ.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是实时测点";
|
return default;
|
}
|
var relatedSignalQ = relatedMonitorQ.SignalList.First();
|
if (relatedSignalQ.SignalType.Identifier != SignalType.瞬时流量)
|
{
|
Msg = "关联测点：{formulaModel.Q},不是瞬时流量测点";
|
return default;
|
}
|
var relatedRecordListQ = getRecordList(relatedMonitorQ.ID, relatedSignalQ.ID);
|
if (relatedRecordListQ == null || relatedRecordListQ.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.Q},记录不存在";
|
return default;
|
}
|
var relatedRealSlotQ = Model.Monitor.RealSlot.ToModel(relatedMonitorQ.CronParas);
|
if (relatedRealSlotQ == null)
|
{
|
relatedRealSlotQ = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexQ = -1;
|
|
#endregion
|
|
#region 扬程参数
|
|
var relatedMonitorH = getMonitorPoint(formulaModel.H);
|
if (relatedMonitorH == null)
|
{
|
Msg = "关联测点：{formulaModel.H},不存在";
|
return default;
|
}
|
if (relatedMonitorH.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.H},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorH.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.H},不是实时测点";
|
return default;
|
}
|
var relatedSignalH = relatedMonitorH.SignalList.First();
|
if (relatedSignalH.SignalType.Identifier != SignalType.扬程)
|
{
|
Msg = "关联测点：{formulaModel.H},不是扬程测点";
|
return default;
|
}
|
var relatedRecordListH = getRecordList(relatedMonitorH.ID, relatedSignalH.ID);
|
if (relatedRecordListH == null || relatedRecordListH.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.H},记录不存在";
|
return default;
|
}
|
var relatedRealSlotH = Model.Monitor.RealSlot.ToModel(relatedMonitorH.CronParas);
|
if (relatedRealSlotH == null)
|
{
|
relatedRealSlotH = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexH = -1;
|
|
#endregion
|
|
#region 功率参数
|
|
var relatedMonitorP = getMonitorPoint(formulaModel.P);
|
if (relatedMonitorP == null)
|
{
|
Msg = "关联测点：{formulaModel.P},不存在";
|
return default;
|
}
|
if (relatedMonitorP.MonitorType != eMonitorType.General)
|
{
|
Msg = "关联测点：{formulaModel.P},不是常规测点";
|
return default;
|
}
|
if (relatedMonitorP.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点：{formulaModel.P},不是实时测点";
|
return default;
|
}
|
var relatedSignalP = relatedMonitorP.SignalList.First();
|
if (relatedSignalP.SignalType.Identifier != SignalType.有功功率)
|
{
|
Msg = "关联测点：{formulaModel.P},不是扬程测点";
|
return default;
|
}
|
var relatedRecordListP = getRecordList(relatedMonitorP.ID, relatedSignalP.ID);
|
if (relatedRecordListP == null || relatedRecordListP.Count < 1)
|
{
|
Msg = "关联测点：{formulaModel.P},记录不存在";
|
return default;
|
}
|
var relatedRealSlotP = Model.Monitor.RealSlot.ToModel(relatedMonitorP.CronParas);
|
if (relatedRealSlotP == null)
|
{
|
relatedRealSlotP = new Model.Monitor.RealSlot();
|
}
|
int relatedRecordReadIndexP = -1;
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
|
Model.MonitorBasicRecord relatedRecordQ = null;
|
for (int j = relatedRecordReadIndexQ + 1; j < relatedRecordListQ.Count; j++)
|
{
|
var relatedRecord = relatedRecordListQ[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordQ = relatedRecordListQ[index];
|
relatedRecordReadIndexQ = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecordH = null;
|
for (int j = relatedRecordReadIndexH + 1; j < relatedRecordListH.Count; j++)
|
{
|
var relatedRecord = relatedRecordListH[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordH = relatedRecordListH[index];
|
relatedRecordReadIndexH = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord relatedRecordP = null;
|
for (int j = relatedRecordReadIndexP + 1; j < relatedRecordListP.Count; j++)
|
{
|
var relatedRecord = relatedRecordListP[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordP = relatedRecordListP[index];
|
relatedRecordReadIndexP = index + 1;
|
break;
|
}
|
}
|
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (relatedRecordQ == null || relatedRecordQ.DataTime < relatedRealSlotQ.GetStartTime(dataTime)
|
|| relatedRecordH == null || relatedRecordH.DataTime < relatedRealSlotH.GetStartTime(dataTime)
|
|| relatedRecordP == null || relatedRecordP.DataTime < relatedRealSlotP.GetStartTime(dataTime))
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = string.Empty;
|
pure.DataTime = dataTime;
|
pure.DataValue = string.Empty;
|
pure.DataStatus = new List<string>();
|
|
if (!double.TryParse(relatedRecordQ.DataValue, out double dataValueQ))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordQ.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordQ.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecordH.DataValue, out double dataValueH))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordH.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordH.DataStatus);
|
}
|
|
if (!double.TryParse(relatedRecordP.DataValue, out double dataValueP))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_DataFormatError);
|
}
|
if (relatedRecordP.DataStatus != null)
|
{
|
pure.DataStatus.AddRange(relatedRecordP.DataStatus);
|
}
|
|
if (formulaModel.Calculate(dataValueP, dataValueQ, dataValueH, out double dataValue))
|
{
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
}
|
else
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_CalculateFailed);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
|
/// <summary>
|
/// 计算运行状态(常规实时)
|
/// </summary>
|
public static List<Model.MonitorRealRecordPure> CalcuRunStatus
|
(
|
DateTime startTime,//开始时间
|
DateTime endTime,//结束时间
|
Model.MonitorPoint_Signal_SignalType monitor,//当前测点
|
string formulaParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long, Model.MonitorBasicRecord> getLastRecord,//获取最后一条记录
|
out string Msg//错误信息
|
)
|
{
|
Msg = string.Empty;
|
var formulaModel = Model.Monitor.RunStatusCalculationFormulaParas.ToModel(formulaParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
if (formulaModel.JudgeItems == null || formulaModel.JudgeItems.Count < 1)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
|
//关联测点字典
|
var relatedMonitorDict = new Dictionary<long, Model.MonitorPoint_Signal_SignalType>();
|
//关联RealSlot字典
|
var relatedRealSlotDict = new Dictionary<long, Model.Monitor.RealSlot>();
|
//判断项Model字典
|
var judgeItemModelDict = new Dictionary<Model.Monitor.RunStatusCalculationFormulaParas.JudgeItem, object>();
|
//关联记录列表字典
|
var relatedRecordListDict = new Dictionary<long, List<Model.MonitorBasicRecord>>();
|
//关联记录读取索引字典
|
var relatedRecordReadIndexDict = new Dictionary<long, int>();
|
|
var signal = monitor.SignalList.First();
|
var realSlot = Model.Monitor.RealSlot.ToModel(monitor.CronParas);
|
if (realSlot == null)
|
{
|
realSlot = new Model.Monitor.RealSlot();
|
}
|
var duration = (int)(endTime - startTime).TotalSeconds;
|
var recordList = new List<Model.MonitorRealRecordPure>();
|
|
//时间循环
|
for (int i = 0; i <= duration; i += realSlot.TimeStep)
|
{
|
var dataTime = startTime.AddSeconds(i);
|
int runStatus = RunStatus.UnKnown;
|
|
//且列表（必须满足的条件）
|
var judgeAndItemList = formulaModel.JudgeItems.Where(x => x.OperateType == Model.Monitor.RunStatusCalculationFormulaParas.eOperateType.And).ToList();
|
foreach (var judgeAndItem in judgeAndItemList)
|
{
|
switch (judgeAndItem.JudgeType)
|
{
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.RS:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.RunStatusJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem,judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据运行状态项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.RunStatusJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID,relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.运行状态)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是运行状态测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.运行状态)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID,relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID,-1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID,realSlotTemp);
|
}
|
var relatedRealSlot=relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
runStatus = dataValue > 0 ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.P:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据功率项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.有功功率)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是有功功率测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.有功功率)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
runStatus = dataValue >= judgeModel.ThresholdValue ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.Pr:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.PressureDiffThresholdJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据压差项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.PressureDiffThresholdJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
|
#region 进口压力
|
|
if (!relatedMonitorDict.ContainsKey(judgeModel.Pr1))
|
{
|
var relatedMonitorPr1Temp = getMonitorPoint(judgeModel.Pr1);
|
relatedMonitorDict.Add(judgeModel.Pr1, relatedMonitorPr1Temp);
|
if (relatedMonitorPr1Temp == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不存在";
|
}
|
else
|
{
|
if (relatedMonitorPr1Temp.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不是压力测点";
|
}
|
}
|
}
|
var relatedMonitorPr1 = relatedMonitorDict[judgeModel.Pr1];
|
if (relatedMonitorPr1 == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitorPr1.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.Pr1))
|
{
|
var relatedRecordListPr1Temp = getRecordList(relatedMonitorPr1.ID, relatedMonitorPr1.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.Pr1, relatedRecordListPr1Temp);
|
if (relatedRecordListPr1Temp == null || relatedRecordListPr1Temp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不存在记录";
|
}
|
}
|
var relatedRecordListPr1 = relatedRecordListDict[judgeModel.Pr1];
|
if (relatedRecordListPr1 == null || relatedRecordListPr1.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.Pr1))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.Pr1, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.Pr1))
|
{
|
var realSlotPr1Temp = Model.Monitor.RealSlot.ToModel(relatedMonitorPr1.CronParas);
|
if (realSlotPr1Temp == null)
|
{
|
realSlotPr1Temp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.Pr1, realSlotPr1Temp);
|
}
|
var relatedRealSlotPr1 = relatedRealSlotDict[judgeModel.Pr1];
|
|
Model.MonitorBasicRecord relatedRecordPr1 = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.Pr1] + 1; j < relatedRecordListPr1.Count; j++)
|
{
|
var relatedRecordPr1Temp = relatedRecordListPr1[j];
|
if (relatedRecordPr1.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordPr1 = relatedRecordListPr1[index];
|
relatedRecordReadIndexDict[judgeModel.Pr1] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecordPr1 == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecordPr1.DataTime < relatedRealSlotPr1.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecordPr1.DataValue, out double dataValuePr1))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
#endregion
|
|
#region 出口压力
|
|
if (!relatedMonitorDict.ContainsKey(judgeModel.Pr2))
|
{
|
var relatedMonitorPr2Temp = getMonitorPoint(judgeModel.Pr2);
|
relatedMonitorDict.Add(judgeModel.Pr2, relatedMonitorPr2Temp);
|
if (relatedMonitorPr2Temp == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不存在";
|
}
|
else
|
{
|
if (relatedMonitorPr2Temp.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不是压力测点";
|
}
|
}
|
}
|
var relatedMonitorPr2 = relatedMonitorDict[judgeModel.Pr2];
|
if (relatedMonitorPr2 == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitorPr2.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.Pr2))
|
{
|
var relatedRecordListPr2Temp = getRecordList(relatedMonitorPr2.ID, relatedMonitorPr2.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.Pr2, relatedRecordListPr2Temp);
|
if (relatedRecordListPr2Temp == null || relatedRecordListPr2Temp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不存在记录";
|
}
|
}
|
var relatedRecordListPr2 = relatedRecordListDict[judgeModel.Pr2];
|
if (relatedRecordListPr2 == null || relatedRecordListPr2.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.Pr2))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.Pr2, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.Pr2))
|
{
|
var realSlotPr2Temp = Model.Monitor.RealSlot.ToModel(relatedMonitorPr2.CronParas);
|
if (realSlotPr2Temp == null)
|
{
|
realSlotPr2Temp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.Pr2, realSlotPr2Temp);
|
}
|
var relatedRealSlotPr2 = relatedRealSlotDict[judgeModel.Pr2];
|
|
Model.MonitorBasicRecord relatedRecordPr2 = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.Pr2] + 1; j < relatedRecordListPr2.Count; j++)
|
{
|
var relatedRecordPr2Temp = relatedRecordListPr2[j];
|
if (relatedRecordPr2.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordPr2 = relatedRecordListPr2[index];
|
relatedRecordReadIndexDict[judgeModel.Pr2] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecordPr2 == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecordPr2.DataTime < relatedRealSlotPr2.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecordPr2.DataValue, out double dataValuePr2))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
#endregion
|
|
runStatus = dataValuePr2 - dataValuePr1 >= judgeModel.ThresholdValue ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.Q:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据流量项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.瞬时流量)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是瞬时流量测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.瞬时流量)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
runStatus = dataValue >= judgeModel.ThresholdValue ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.I:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据电流项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.电流)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是电流测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.电流)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
runStatus = dataValue >= judgeModel.ThresholdValue ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.HZ:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeAndItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeAndItem.JudgeParas);
|
judgeItemModelDict.Add(judgeAndItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据频率项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeAndItem];
|
if (judgeModel == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.频率)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是频率测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.频率)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
runStatus = RunStatus.Shut;
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
runStatus = RunStatus.Shut;
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
runStatus = dataValue >= judgeModel.ThresholdValue ? RunStatus.Run : RunStatus.Shut;
|
}
|
break;
|
default: break;
|
}
|
if (runStatus == RunStatus.Shut)
|
{
|
break;
|
}
|
}
|
|
//或列表（仅需满足一项的条件）
|
if (runStatus == RunStatus.UnKnown)
|
{
|
var judgeOrItemList = formulaModel.JudgeItems.Where(x => x.OperateType == Model.Monitor.RunStatusCalculationFormulaParas.eOperateType.Or).ToList();
|
foreach (var judgeOrItem in judgeOrItemList)
|
{
|
switch (judgeOrItem.JudgeType)
|
{
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.RS:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.RunStatusJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据运行状态项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.RunStatusJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.运行状态)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是运行状态测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.运行状态)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
if (dataValue > 0)
|
{
|
runStatus = RunStatus.Run;
|
}
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.P:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据功率项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.有功功率)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是有功功率测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.有功功率)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
if (dataValue >= judgeModel.ThresholdValue)
|
{
|
runStatus = RunStatus.Run;
|
}
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.Pr:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.PressureDiffThresholdJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据压差项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.PressureDiffThresholdJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
|
#region 进口压力
|
|
if (!relatedMonitorDict.ContainsKey(judgeModel.Pr1))
|
{
|
var relatedMonitorPr1Temp = getMonitorPoint(judgeModel.Pr1);
|
relatedMonitorDict.Add(judgeModel.Pr1, relatedMonitorPr1Temp);
|
if (relatedMonitorPr1Temp == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不存在";
|
}
|
else
|
{
|
if (relatedMonitorPr1Temp.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不是压力测点";
|
}
|
}
|
}
|
var relatedMonitorPr1 = relatedMonitorDict[judgeModel.Pr1];
|
if (relatedMonitorPr1 == null)
|
{
|
break;
|
}
|
if (relatedMonitorPr1.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.Pr1))
|
{
|
var relatedRecordListPr1Temp = getRecordList(relatedMonitorPr1.ID, relatedMonitorPr1.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.Pr1, relatedRecordListPr1Temp);
|
if (relatedRecordListPr1Temp == null || relatedRecordListPr1Temp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},不存在记录";
|
}
|
}
|
var relatedRecordListPr1 = relatedRecordListDict[judgeModel.Pr1];
|
if (relatedRecordListPr1 == null || relatedRecordListPr1.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.Pr1))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.Pr1, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.Pr1))
|
{
|
var realSlotPr1Temp = Model.Monitor.RealSlot.ToModel(relatedMonitorPr1.CronParas);
|
if (realSlotPr1Temp == null)
|
{
|
realSlotPr1Temp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.Pr1, realSlotPr1Temp);
|
}
|
var relatedRealSlotPr1 = relatedRealSlotDict[judgeModel.Pr1];
|
|
Model.MonitorBasicRecord relatedRecordPr1 = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.Pr1] + 1; j < relatedRecordListPr1.Count; j++)
|
{
|
var relatedRecordPr1Temp = relatedRecordListPr1[j];
|
if (relatedRecordPr1.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordPr1 = relatedRecordListPr1[index];
|
relatedRecordReadIndexDict[judgeModel.Pr1] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecordPr1 == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecordPr1.DataTime < relatedRealSlotPr1.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecordPr1.DataValue, out double dataValuePr1))
|
{
|
Msg += $"关联测点：{judgeModel.Pr1},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
#endregion
|
|
#region 出口压力
|
|
if (!relatedMonitorDict.ContainsKey(judgeModel.Pr2))
|
{
|
var relatedMonitorPr2Temp = getMonitorPoint(judgeModel.Pr2);
|
relatedMonitorDict.Add(judgeModel.Pr2, relatedMonitorPr2Temp);
|
if (relatedMonitorPr2Temp == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不存在";
|
}
|
else
|
{
|
if (relatedMonitorPr2Temp.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不是压力测点";
|
}
|
}
|
}
|
var relatedMonitorPr2 = relatedMonitorDict[judgeModel.Pr2];
|
if (relatedMonitorPr2 == null)
|
{
|
break;
|
}
|
if (relatedMonitorPr2.SignalList.First().SignalType.Identifier != SignalType.压力)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.Pr2))
|
{
|
var relatedRecordListPr2Temp = getRecordList(relatedMonitorPr2.ID, relatedMonitorPr2.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.Pr2, relatedRecordListPr2Temp);
|
if (relatedRecordListPr2Temp == null || relatedRecordListPr2Temp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},不存在记录";
|
}
|
}
|
var relatedRecordListPr2 = relatedRecordListDict[judgeModel.Pr2];
|
if (relatedRecordListPr2 == null || relatedRecordListPr2.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.Pr2))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.Pr2, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.Pr2))
|
{
|
var realSlotPr2Temp = Model.Monitor.RealSlot.ToModel(relatedMonitorPr2.CronParas);
|
if (realSlotPr2Temp == null)
|
{
|
realSlotPr2Temp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.Pr2, realSlotPr2Temp);
|
}
|
var relatedRealSlotPr2 = relatedRealSlotDict[judgeModel.Pr2];
|
|
Model.MonitorBasicRecord relatedRecordPr2 = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.Pr2] + 1; j < relatedRecordListPr2.Count; j++)
|
{
|
var relatedRecordPr2Temp = relatedRecordListPr2[j];
|
if (relatedRecordPr2.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecordPr2 = relatedRecordListPr2[index];
|
relatedRecordReadIndexDict[judgeModel.Pr2] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecordPr2 == null)
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecordPr2.DataTime < relatedRealSlotPr2.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecordPr2.DataValue, out double dataValuePr2))
|
{
|
Msg += $"关联测点：{judgeModel.Pr2},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
#endregion
|
|
if (dataValuePr2 - dataValuePr1 >= judgeModel.ThresholdValue)
|
{
|
runStatus = RunStatus.Run;
|
}
|
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.Q:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据流量项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.瞬时流量)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是瞬时流量测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.瞬时流量)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
if (dataValue >= judgeModel.ThresholdValue)
|
{
|
runStatus = RunStatus.Run;
|
}
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.I:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据电流项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.电流)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是电流测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.电流)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
if (dataValue >= judgeModel.ThresholdValue)
|
{
|
runStatus = RunStatus.Run;
|
}
|
}
|
break;
|
case Model.Monitor.RunStatusCalculationFormulaParas.eJudgeType.HZ:
|
{
|
if (!judgeItemModelDict.ContainsKey(judgeOrItem))
|
{
|
var judgeModelTemp = Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas.ToModel(judgeOrItem.JudgeParas);
|
judgeItemModelDict.Add(judgeOrItem, judgeModelTemp);
|
if (judgeModelTemp == null)
|
{
|
Msg += "公式参数配置错误（根据频率项）";
|
}
|
}
|
var judgeModel = (Model.Monitor.RunStatusCalculationFormulaParas.ThresholdJudgeParas)judgeItemModelDict[judgeOrItem];
|
if (judgeModel == null)
|
{
|
break;
|
}
|
if (!relatedMonitorDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedMonitorTemp = getMonitorPoint(judgeModel.ObjectID);
|
relatedMonitorDict.Add(judgeModel.ObjectID, relatedMonitorTemp);
|
if (relatedMonitorTemp == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在";
|
}
|
else
|
{
|
if (relatedMonitorTemp.SignalList.First().SignalType.Identifier != SignalType.频率)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不是频率测点";
|
}
|
}
|
}
|
var relatedMonitor = relatedMonitorDict[judgeModel.ObjectID];
|
if (relatedMonitor == null)
|
{
|
break;
|
}
|
if (relatedMonitor.SignalList.First().SignalType.Identifier != SignalType.频率)
|
{
|
break;
|
}
|
if (!relatedRecordListDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var relatedRecordListTemp = getRecordList(relatedMonitor.ID, relatedMonitor.SignalList.First().ID);
|
relatedRecordListDict.Add(judgeModel.ObjectID, relatedRecordListTemp);
|
if (relatedRecordListTemp == null || relatedRecordListTemp.Count < 1)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},不存在记录";
|
}
|
}
|
var relatedRecordList = relatedRecordListDict[judgeModel.ObjectID];
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
{
|
break;
|
}
|
if (!relatedRecordReadIndexDict.ContainsKey(judgeModel.ObjectID))
|
{
|
relatedRecordReadIndexDict.Add(judgeModel.ObjectID, -1);
|
}
|
if (!relatedRealSlotDict.ContainsKey(judgeModel.ObjectID))
|
{
|
var realSlotTemp = Model.Monitor.RealSlot.ToModel(relatedMonitor.CronParas);
|
if (realSlotTemp == null)
|
{
|
realSlotTemp = new Model.Monitor.RealSlot();
|
}
|
relatedRealSlotDict.Add(judgeModel.ObjectID, realSlotTemp);
|
}
|
var relatedRealSlot = relatedRealSlotDict[judgeModel.ObjectID];
|
|
Model.MonitorBasicRecord relatedRecord = null;
|
for (int j = relatedRecordReadIndexDict[judgeModel.ObjectID] + 1; j < relatedRecordList.Count; j++)
|
{
|
var relatedRecordTemp = relatedRecordList[j];
|
if (relatedRecord.DataTime > dataTime)
|
{
|
var index = j - 1;
|
if (index < 0)
|
index = 0;
|
relatedRecord = relatedRecordList[index];
|
relatedRecordReadIndexDict[judgeModel.ObjectID] = index + 1;
|
break;
|
}
|
}
|
if (relatedRecord == null)
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 不存在记录";
|
break;
|
}
|
if (relatedRecord.DataTime < relatedRealSlot.GetStartTime(dataTime))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据已失效";
|
break;
|
}
|
if (!double.TryParse(relatedRecord.DataValue, out double dataValue))
|
{
|
Msg += $"关联测点：{judgeModel.ObjectID},时间：{dataTime:yyyy-MM-dd HH:mm:ss}, 数据格式错误";
|
break;
|
}
|
|
if (dataValue >= judgeModel.ThresholdValue)
|
{
|
runStatus = RunStatus.Run;
|
}
|
}
|
break;
|
default: break;
|
}
|
if (runStatus == RunStatus.Run)
|
{
|
break;
|
}
|
}
|
}
|
|
//判断是否生成记录
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
|
if (runStatus == RunStatus.UnKnown)
|
{
|
if (realSlot.UpdateWhenChanged)
|
{
|
if (lastRecord != null)
|
{
|
var spure = new Model.MonitorRealRecordPure();
|
spure.CorpID = monitor.CorpID;
|
spure.MonitorPointID = monitor.ID;
|
spure.SignalID = signal.ID;
|
spure.RecordType = eMonitorType.General;
|
spure.SrcTime = lastRecord.SrcTime;
|
spure.SrcValue = lastRecord.DataValue;
|
spure.DataTime = dataTime;
|
spure.DataValue = lastRecord.DataValue;
|
spure.DataStatus = lastRecord.DataStatus;
|
if (spure.DataStatus == null)
|
{
|
spure.DataStatus = new List<string>();
|
}
|
spure.DataStatus.Add(MonitorRecord.Status_Supplement);
|
spure.DataStatus = spure.DataStatus.Distinct().ToList();
|
recordList.Add(spure);
|
}
|
}
|
continue;
|
}
|
|
var pure = new Model.MonitorRealRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.SrcTime = dataTime;
|
pure.SrcValue = runStatus.ToString();
|
pure.DataTime = dataTime;
|
pure.DataValue = runStatus.ToString();
|
pure.DataStatus = new List<string>();
|
|
var toDataValue = (double)runStatus;
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
toDataValue = signal.ConvertParas.Convert(toDataValue, out bool succed);
|
if (!succed)
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_ConvertFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
toDataValue = signal.CorrectParas.Correct(toDataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(toDataValue, lastDataValue))
|
{
|
if (!pure.DataStatus.Contains(MonitorRecord.Status_FilterFailed))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
toDataValue = Math.Round(toDataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = toDataValue.ToString();
|
pure.DataStatus = pure.DataStatus.Distinct().ToList();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
|
#endregion
|
|
#endregion
|
|
#region 常规时
|
|
/// <summary>
|
/// 统计时最大值
|
/// </summary>
|
public static List<Model.MonitorHourRecordPure> StatisticalHourMaxValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long,Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long,long,DateTime,DateTime,List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long,long,Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MaxValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var hourSlot = Model.Monitor.HourSlot.ToModel(monitor.CronParas);
|
if (hourSlot == null)
|
{
|
hourSlot = new Model.Monitor.HourSlot();
|
}
|
var recordList = new List<Model.MonitorHourRecordPure>();
|
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
for (int h = 0; h < 24; h++)
|
{
|
var dt = day.AddHours(h+1);
|
var startTime = hourSlot.GetStartTime(dt);
|
var endTime = hourSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID,relatedSignal.ID,startTime,endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorHourRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.DataHour = h + 1;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID,signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计时最小值
|
/// </summary>
|
public static List<Model.MonitorHourRecordPure> StatisticalHourMinValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MinValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var hourSlot = Model.Monitor.HourSlot.ToModel(monitor.CronParas);
|
if (hourSlot == null)
|
{
|
hourSlot = new Model.Monitor.HourSlot();
|
}
|
var recordList = new List<Model.MonitorHourRecordPure>();
|
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
for (int h = 0; h < 24; h++)
|
{
|
var dt = day.AddHours(h + 1);
|
var startTime = hourSlot.GetStartTime(dt);
|
var endTime = hourSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorHourRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.DataHour = h + 1;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计时平均值
|
/// </summary>
|
public static List<Model.MonitorHourRecordPure> StatisticalHourAvgValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.AvgValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var hourSlot = Model.Monitor.HourSlot.ToModel(monitor.CronParas);
|
if (hourSlot == null)
|
{
|
hourSlot = new Model.Monitor.HourSlot();
|
}
|
var recordList = new List<Model.MonitorHourRecordPure>();
|
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
for (int h = 0; h < 24; h++)
|
{
|
var dt = day.AddHours(h + 1);
|
var startTime = hourSlot.GetStartTime(dt);
|
var endTime = hourSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorHourRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.DataHour = h + 1;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计时差值
|
/// </summary>
|
public static List<Model.MonitorHourRecordPure> StatisticalHourDiffValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.DiffValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var hourSlot = Model.Monitor.HourSlot.ToModel(monitor.CronParas);
|
if (hourSlot == null)
|
{
|
hourSlot = new Model.Monitor.HourSlot();
|
}
|
var recordList = new List<Model.MonitorHourRecordPure>();
|
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
for (int h = 0; h < 24; h++)
|
{
|
var dt = day.AddHours(h + 1);
|
var startTime = hourSlot.GetStartTime(dt);
|
var endTime = hourSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorHourRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.DataHour = h + 1;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计时和值
|
/// </summary>
|
public static List<Model.MonitorHourRecordPure> StatisticalHourSumValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.SumValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real)
|
{
|
Msg = "关联测点不是实时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var hourSlot = Model.Monitor.HourSlot.ToModel(monitor.CronParas);
|
if (hourSlot == null)
|
{
|
hourSlot = new Model.Monitor.HourSlot();
|
}
|
var recordList = new List<Model.MonitorHourRecordPure>();
|
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
for (int h = 0; h < 24; h++)
|
{
|
var dt = day.AddHours(h + 1);
|
var startTime = hourSlot.GetStartTime(dt);
|
var endTime = hourSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorHourRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.DataHour = h + 1;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
}
|
|
return recordList;
|
}
|
|
#endregion
|
|
#region 常规日
|
|
/// <summary>
|
/// 统计日最大值
|
/// </summary>
|
public static List<Model.MonitorDayRecordPure> StatisticalDayMaxValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long,Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MaxValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real&&relatedMonitor.CronType!=Model.Monitor.eCronType.EachHour)
|
{
|
Msg = "关联测点不是实时或时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var daySlot = Model.Monitor.DaySlot.ToModel(monitor.CronParas);
|
if (daySlot == null)
|
{
|
daySlot = new Model.Monitor.DaySlot();
|
}
|
var recordList = new List<Model.MonitorDayRecordPure>();
|
|
//日期循环
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
var dt = day.AddDays(1);
|
var startTime = daySlot.GetStartTime(dt);
|
var endTime = daySlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID,relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorDayRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计日最小值
|
/// </summary>
|
public static List<Model.MonitorDayRecordPure> StatisticalDayMinValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MinValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachHour)
|
{
|
Msg = "关联测点不是实时或时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var daySlot = Model.Monitor.DaySlot.ToModel(monitor.CronParas);
|
if (daySlot == null)
|
{
|
daySlot = new Model.Monitor.DaySlot();
|
}
|
var recordList = new List<Model.MonitorDayRecordPure>();
|
|
//日期循环
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
var dt = day.AddDays(1);
|
var startTime = daySlot.GetStartTime(dt);
|
var endTime = daySlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorDayRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计日平均值
|
/// </summary>
|
public static List<Model.MonitorDayRecordPure> StatisticalDayAvgValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.AvgValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachHour)
|
{
|
Msg = "关联测点不是实时或时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var daySlot = Model.Monitor.DaySlot.ToModel(monitor.CronParas);
|
if (daySlot == null)
|
{
|
daySlot = new Model.Monitor.DaySlot();
|
}
|
var recordList = new List<Model.MonitorDayRecordPure>();
|
|
//日期循环
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
var dt = day.AddDays(1);
|
var startTime = daySlot.GetStartTime(dt);
|
var endTime = daySlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorDayRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计日差值
|
/// </summary>
|
public static List<Model.MonitorDayRecordPure> StatisticalDayDiffValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.DiffValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachHour)
|
{
|
Msg = "关联测点不是实时或时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var daySlot = Model.Monitor.DaySlot.ToModel(monitor.CronParas);
|
if (daySlot == null)
|
{
|
daySlot = new Model.Monitor.DaySlot();
|
}
|
var recordList = new List<Model.MonitorDayRecordPure>();
|
|
//日期循环
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
var dt = day.AddDays(1);
|
var startTime = daySlot.GetStartTime(dt);
|
var endTime = daySlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorDayRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计日和值
|
/// </summary>
|
public static List<Model.MonitorDayRecordPure> StatisticalDaySumValue
|
(
|
DateTime startDay,//开始日期
|
DateTime endDay,//结束日期
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.SumValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachHour)
|
{
|
Msg = "关联测点不是实时或时测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var daySlot = Model.Monitor.DaySlot.ToModel(monitor.CronParas);
|
if (daySlot == null)
|
{
|
daySlot = new Model.Monitor.DaySlot();
|
}
|
var recordList = new List<Model.MonitorDayRecordPure>();
|
|
//日期循环
|
for (DateTime day = startDay.Date; day <= endDay.Date; day = day.AddDays(1))
|
{
|
var dt = day.AddDays(1);
|
var startTime = daySlot.GetStartTime(dt);
|
var endTime = daySlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorDayRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataDay = day;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
#endregion
|
|
#region 常规月
|
|
/// <summary>
|
/// 统计月最大值
|
/// </summary>
|
public static List<Model.MonitorMonthRecordPure> StatisticalMonthMaxValue
|
(
|
int startYear,//开始年份
|
int startMonth,//开始月份
|
int endYear,//结束年份
|
int endMonth,//结束月份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MaxValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachDay)
|
{
|
Msg = "关联测点不是实时或日测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var monthSlot = Model.Monitor.MonthSlot.ToModel(monitor.CronParas);
|
if (monthSlot == null)
|
{
|
monthSlot = new Model.Monitor.MonthSlot();
|
}
|
var recordList = new List<Model.MonitorMonthRecordPure>();
|
|
//日期循环
|
for (DateTime day = new DateTime(startYear,startMonth,1); day <=new DateTime(endYear,endMonth,1); day = day.AddMonths(1))
|
{
|
var dt = day.AddMonths(1);
|
var startTime = monthSlot.GetStartTime(dt);
|
var endTime = monthSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorMonthRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = day.Year;
|
pure.DataMonth = day.Month;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计月最小值
|
/// </summary>
|
public static List<Model.MonitorMonthRecordPure> StatisticalMonthMinValue
|
(
|
int startYear,//开始年份
|
int startMonth,//开始月份
|
int endYear,//结束年份
|
int endMonth,//结束月份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MinValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachDay)
|
{
|
Msg = "关联测点不是实时或日测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var monthSlot = Model.Monitor.MonthSlot.ToModel(monitor.CronParas);
|
if (monthSlot == null)
|
{
|
monthSlot = new Model.Monitor.MonthSlot();
|
}
|
var recordList = new List<Model.MonitorMonthRecordPure>();
|
|
//日期循环
|
for (DateTime day = new DateTime(startYear, startMonth, 1); day <= new DateTime(endYear, endMonth, 1); day = day.AddMonths(1))
|
{
|
var dt = day.AddMonths(1);
|
var startTime = monthSlot.GetStartTime(dt);
|
var endTime = monthSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorMonthRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = day.Year;
|
pure.DataMonth = day.Month;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计月平均值
|
/// </summary>
|
public static List<Model.MonitorMonthRecordPure> StatisticalMonthAvgValue
|
(
|
int startYear,//开始年份
|
int startMonth,//开始月份
|
int endYear,//结束年份
|
int endMonth,//结束月份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.AvgValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachDay)
|
{
|
Msg = "关联测点不是实时或日测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var monthSlot = Model.Monitor.MonthSlot.ToModel(monitor.CronParas);
|
if (monthSlot == null)
|
{
|
monthSlot = new Model.Monitor.MonthSlot();
|
}
|
var recordList = new List<Model.MonitorMonthRecordPure>();
|
|
//日期循环
|
for (DateTime day = new DateTime(startYear, startMonth, 1); day <= new DateTime(endYear, endMonth, 1); day = day.AddMonths(1))
|
{
|
var dt = day.AddMonths(1);
|
var startTime = monthSlot.GetStartTime(dt);
|
var endTime = monthSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorMonthRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = day.Year;
|
pure.DataMonth = day.Month;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计月差值
|
/// </summary>
|
public static List<Model.MonitorMonthRecordPure> StatisticalMonthDiffValue
|
(
|
int startYear,//开始年份
|
int startMonth,//开始月份
|
int endYear,//结束年份
|
int endMonth,//结束月份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.DiffValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachDay)
|
{
|
Msg = "关联测点不是实时或日测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var monthSlot = Model.Monitor.MonthSlot.ToModel(monitor.CronParas);
|
if (monthSlot == null)
|
{
|
monthSlot = new Model.Monitor.MonthSlot();
|
}
|
var recordList = new List<Model.MonitorMonthRecordPure>();
|
|
//日期循环
|
for (DateTime day = new DateTime(startYear, startMonth, 1); day <= new DateTime(endYear, endMonth, 1); day = day.AddMonths(1))
|
{
|
var dt = day.AddMonths(1);
|
var startTime = monthSlot.GetStartTime(dt);
|
var endTime = monthSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorMonthRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = day.Year;
|
pure.DataMonth = day.Month;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计月和值
|
/// </summary>
|
public static List<Model.MonitorMonthRecordPure> StatisticalMonthSumValue
|
(
|
int startYear,//开始年份
|
int startMonth,//开始月份
|
int endYear,//结束年份
|
int endMonth,//结束月份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.SumValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real && relatedMonitor.CronType != Model.Monitor.eCronType.EachDay)
|
{
|
Msg = "关联测点不是实时或日测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var monthSlot = Model.Monitor.MonthSlot.ToModel(monitor.CronParas);
|
if (monthSlot == null)
|
{
|
monthSlot = new Model.Monitor.MonthSlot();
|
}
|
var recordList = new List<Model.MonitorMonthRecordPure>();
|
|
//日期循环
|
for (DateTime day = new DateTime(startYear, startMonth, 1); day <= new DateTime(endYear, endMonth, 1); day = day.AddMonths(1))
|
{
|
var dt = day.AddMonths(1);
|
var startTime = monthSlot.GetStartTime(dt);
|
var endTime = monthSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorMonthRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = day.Year;
|
pure.DataMonth = day.Month;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
return recordList;
|
}
|
|
#endregion
|
|
#region 常规年
|
|
/// <summary>
|
/// 统计年最大值
|
/// </summary>
|
public static List<Model.MonitorYearRecordPure> StatisticalYearMaxValue
|
(
|
int startYear,//开始年份
|
int endYear,//结束年份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MaxValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachDay
|
&&relatedMonitor.CronType!=Model.Monitor.eCronType.EachMonth)
|
{
|
Msg = "关联测点不是实时、日或月测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var yearSlot = Model.Monitor.YearSlot.ToModel(monitor.CronParas);
|
if (yearSlot == null)
|
{
|
yearSlot = new Model.Monitor.YearSlot();
|
}
|
var recordList = new List<Model.MonitorYearRecordPure>();
|
|
//年份循环
|
for (int year = startYear; year <= endYear; year++)
|
{
|
var dt =new DateTime(year,1,1);
|
dt = dt.AddYears(1);
|
var startTime = yearSlot.GetStartTime(dt);
|
var endTime = yearSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorYearRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = year;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计年最小值
|
/// </summary>
|
public static List<Model.MonitorYearRecordPure> StatisticalYearMinValue
|
(
|
int startYear,//开始年份
|
int endYear,//结束年份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.MinValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachDay
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
Msg = "关联测点不是实时、日或月测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var yearSlot = Model.Monitor.YearSlot.ToModel(monitor.CronParas);
|
if (yearSlot == null)
|
{
|
yearSlot = new Model.Monitor.YearSlot();
|
}
|
var recordList = new List<Model.MonitorYearRecordPure>();
|
|
//年份循环
|
for (int year = startYear; year <= endYear; year++)
|
{
|
var dt = new DateTime(year, 1, 1);
|
dt = dt.AddYears(1);
|
var startTime = yearSlot.GetStartTime(dt);
|
var endTime = yearSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorYearRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = year;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计年平均值
|
/// </summary>
|
public static List<Model.MonitorYearRecordPure> StatisticalYearAvgValue
|
(
|
int startYear,//开始年份
|
int endYear,//结束年份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.AvgValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachDay
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
Msg = "关联测点不是实时、日或月测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var yearSlot = Model.Monitor.YearSlot.ToModel(monitor.CronParas);
|
if (yearSlot == null)
|
{
|
yearSlot = new Model.Monitor.YearSlot();
|
}
|
var recordList = new List<Model.MonitorYearRecordPure>();
|
|
//年份循环
|
for (int year = startYear; year <= endYear; year++)
|
{
|
var dt = new DateTime(year, 1, 1);
|
dt = dt.AddYears(1);
|
var startTime = yearSlot.GetStartTime(dt);
|
var endTime = yearSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorYearRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = year;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计年差值
|
/// </summary>
|
public static List<Model.MonitorYearRecordPure> StatisticalYearDiffValue
|
(
|
int startYear,//开始年份
|
int endYear,//结束年份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.DiffValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachDay
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
Msg = "关联测点不是实时、日或月测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var yearSlot = Model.Monitor.YearSlot.ToModel(monitor.CronParas);
|
if (yearSlot == null)
|
{
|
yearSlot = new Model.Monitor.YearSlot();
|
}
|
var recordList = new List<Model.MonitorYearRecordPure>();
|
|
//年份循环
|
for (int year = startYear; year <= endYear; year++)
|
{
|
var dt = new DateTime(year, 1, 1);
|
dt = dt.AddYears(1);
|
var startTime = yearSlot.GetStartTime(dt);
|
var endTime = yearSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorYearRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = year;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
|
return recordList;
|
}
|
|
/// <summary>
|
/// 统计年和值
|
/// </summary>
|
public static List<Model.MonitorYearRecordPure> StatisticalYearSumValue
|
(
|
int startYear,//开始年份
|
int endYear,//结束年份
|
Model.MonitorPoint_Signal_SignalType monitor,//监测点
|
string formularParas,//公式参数
|
Func<long, Model.MonitorPoint_Signal_SignalType> getMonitorPoint,//获取测点
|
Func<long, long, Model.Monitor.eCronType, DateTime, DateTime, List<Model.MonitorBasicRecord>> getRecordList,//获取记录列表
|
Func<long, long, Model.MonitorBasicRecord> getLastRecord,//获取最近一条记录
|
out string Msg
|
)
|
{
|
Msg = string.Empty;
|
|
#region 数据验证
|
|
var formulaModel = Model.Monitor.SumValueStatisticsFormulaParas.ToModel(formularParas);
|
if (formulaModel == null)
|
{
|
Msg = "公式参数配置错误";
|
return default;
|
}
|
var relatedMonitor = getMonitorPoint(formulaModel.ObjectID);
|
if (relatedMonitor == null)
|
{
|
Msg = "关联测点不存在";
|
return default;
|
}
|
if (relatedMonitor.MonitorType != Model.eMonitorType.General)
|
{
|
Msg = "关联测点不是常规测点";
|
return default;
|
}
|
if (relatedMonitor.CronType != Model.Monitor.eCronType.Real
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachDay
|
&& relatedMonitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
Msg = "关联测点不是实时、日或月测点";
|
return default;
|
}
|
var relatedSignal = relatedMonitor.SignalList.First();
|
|
#endregion
|
|
var signal = monitor.SignalList.First();
|
var yearSlot = Model.Monitor.YearSlot.ToModel(monitor.CronParas);
|
if (yearSlot == null)
|
{
|
yearSlot = new Model.Monitor.YearSlot();
|
}
|
var recordList = new List<Model.MonitorYearRecordPure>();
|
|
//年份循环
|
for (int year = startYear; year <= endYear; year++)
|
{
|
var dt = new DateTime(year, 1, 1);
|
dt = dt.AddYears(1);
|
var startTime = yearSlot.GetStartTime(dt);
|
var endTime = yearSlot.GetEndTime(dt);
|
var relatedRecordList = getRecordList(relatedMonitor.ID, relatedSignal.ID, relatedMonitor.CronType, startTime, endTime);
|
if (relatedRecordList == null || relatedRecordList.Count < 1)
|
continue;
|
var relatedDataValueList = new List<double>();
|
foreach (var relatedRecord in relatedRecordList)
|
{
|
if (double.TryParse(relatedRecord.DataValue, out double relatedDataValue))
|
{
|
relatedDataValueList.Add(relatedDataValue);
|
}
|
}
|
if (relatedDataValueList.Count < 1)
|
continue;
|
var dataValue = formulaModel.Statistic(relatedDataValueList);
|
|
var pure = new Model.MonitorYearRecordPure();
|
pure.CorpID = monitor.CorpID;
|
pure.MonitorPointID = monitor.ID;
|
pure.SignalID = signal.ID;
|
pure.RecordType = eMonitorType.General;
|
pure.DataYear = year;
|
pure.SrcTime = dt;
|
pure.SrcValue = dataValue.ToString();
|
pure.DataTime = dt;
|
pure.DataValue = dataValue.ToString();
|
pure.DataStatus = new List<string>();
|
|
//数据转换
|
if (signal.ConvertParas != null)
|
{
|
dataValue = signal.ConvertParas.Convert(dataValue, out bool succed);
|
if (!succed)
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_ConvertFailed);
|
}
|
}
|
|
//数据修正
|
if (signal.CorrectParas != null)
|
{
|
dataValue = signal.CorrectParas.Correct(dataValue);
|
}
|
|
//数据过滤
|
if (signal.FilterParas != null)
|
{
|
double? lastDataValue = null;
|
Model.MonitorBasicRecord lastRecord = recordList.LastOrDefault();
|
if (lastRecord == null)
|
{
|
lastRecord = getLastRecord(monitor.ID, signal.ID);
|
}
|
if (lastRecord != null)
|
{
|
if (double.TryParse(lastRecord.DataValue, out double dataValueTemp))
|
{
|
lastDataValue = dataValueTemp;
|
}
|
}
|
if (!signal.FilterParas.Filter(dataValue, lastDataValue))
|
{
|
pure.DataStatus.Add(MonitorRecord.Status_FilterFailed);
|
}
|
}
|
|
//保留小数位数
|
if (signal.SignalType.DecimalPlaces != null)
|
{
|
dataValue = Math.Round(dataValue, signal.SignalType.DecimalPlaces.Value);
|
}
|
|
pure.DataValue = dataValue.ToString();
|
recordList.Add(pure);
|
}
|
|
|
return recordList;
|
}
|
|
#endregion
|
|
|
}
|
}
|
