using IStation.IEtaCalculation;
|
using IStation.Model;
|
|
namespace IStation.EtaCalculation
|
{
|
/// <summary>
|
/// 分析计算器(上海城投)
|
/// </summary>
|
public class AnalyCalculatorSMI : AnalyCalculatorBase, IStation.IEtaCalculation.IAnalyCalculator
|
{
|
private long _corpID = 0;
|
/// <summary>
|
/// 计算
|
/// </summary>
|
/// <param name="context">分析上下文</param>
|
/// <param name="handler">EtaMultiRealRecordPure 为基类 EtaLogicRealRecordPure、EtaMultiRealRecordPure、EtaSingleRealRecordPure都集成自此基类</param>
|
/// <returns></returns>
|
/// <exception cref="NotImplementedException"></exception>
|
public override bool Calculate(EtaCorpAnalyContext context,
|
Action<
|
List<Model.EtaSingleRealRecordPure>,
|
List<Model.EtaMultiRealRecordPure>,
|
List<Model.EtaLogicRealRecordPure>,
|
string> handler)
|
{
|
List<Model.EtaSingleRealRecordPure> all_Single = new List<EtaSingleRealRecordPure>();
|
List<Model.EtaMultiRealRecordPure> all_Multi = new List<EtaMultiRealRecordPure>();
|
List<Model.EtaLogicRealRecordPure> all_Logic = null;
|
this._corpID = context.ID;
|
var dateTime = context.DataTime;
|
var duration = context.Duration;
|
|
if(this._corpID == 4)
|
{
|
|
}
|
|
try
|
{
|
#region 泵站分析
|
//16时原水泵站数量
|
InitialStationList(context, 9);
|
|
if (_allStationContextList == null || _allStationContextList.Count() == 0)
|
{
|
return false;
|
}
|
|
List<IStation.Calculation.Eta.Model.StationAnaInfoBundle> allStationBundles = new List<Calculation.Eta.Model.StationAnaInfoBundle>(_allStationContextList.Count());
|
foreach (var station_context in _allStationContextList)
|
{
|
var calalcor = CreateCalculater4Station(station_context.ID);
|
if (calalcor == null)
|
continue;
|
|
string error_info = null;
|
if (!calalcor.Calculate(station_context, out error_info))
|
{
|
LogHelper.Info($"能效分析任务中，客户标识：(上海城投), 泵站信息:{station_context.ID}({station_context.Name},错误信息:{error_info}");
|
continue;
|
}
|
|
|
|
var results_machines = calalcor.GetAllSingleAnaRecord();
|
if (results_machines != null)
|
{
|
foreach (var machine in results_machines)
|
{
|
machine.CorpID = _corpID;
|
machine.DataTime = dateTime;
|
machine.Duration = duration;
|
if (machine.AnalyStatus == Model.Eta.eAnalyStatus.Unkonw)
|
{
|
LogHelper.Info($"能效分析任务中,AnalyStatus(machine) 值为 Model.Eta.eAnalyStatus.Unkonw，客户标识：(上海城投), 泵站信息:{station_context.ID}({station_context.Name} ");
|
}
|
|
all_Single.Add(machine);
|
}
|
}
|
|
var result_station = calalcor.GetStationAnaRecord();
|
if (result_station != null)
|
{
|
result_station.CorpID = _corpID;
|
result_station.DataTime = dateTime;
|
result_station.Duration = duration;
|
if (result_station.AnalyStatus == Model.Eta.eAnalyStatus.Unkonw)
|
{
|
LogHelper.Info($"能效分析任务中,AnalyStatus( station) 值为 Model.Eta.eAnalyStatus.Unkonw，客户标识：(上海城投), 泵站信息:{station_context.ID}({station_context.Name} ");
|
}
|
if (result_station.HZa == null)
|
result_station.HZa = new List<double>();
|
if (result_station.RunningFlag == null)
|
result_station.RunningFlag = new List<int>();
|
|
all_Multi.Add(result_station);
|
}
|
|
var results_pipes = calalcor.GetAllPipeAnaRecord();
|
if (results_pipes != null)
|
{
|
foreach (var pipe in results_pipes)
|
{
|
pipe.CorpID = _corpID;
|
pipe.DataTime = dateTime;
|
pipe.Duration = duration;
|
if (pipe.AnalyStatus == Model.Eta.eAnalyStatus.Unkonw)
|
{
|
LogHelper.Info($"能效分析任务中,AnalyStatus( pipe) 值为 Model.Eta.eAnalyStatus.Unkonw，客户标识：(上海城投), 泵站信息:{station_context.ID}({station_context.Name} ");
|
}
|
if (pipe.HZa == null)
|
pipe.HZa = new List<double>();
|
if (pipe.RunningFlag == null)
|
pipe.RunningFlag = new List<int>();
|
all_Multi.Add(pipe);
|
}
|
}
|
|
|
var station_bundle = calalcor.GetAnaBundle();
|
if(station_bundle != null)
|
allStationBundles.Add(station_bundle);
|
|
}
|
|
if (all_Single.Count() == 0 || all_Multi.Count() == 0)
|
return false;
|
|
|
|
#endregion
|
|
|
//业务区域分析
|
var logicCalc = new IStation.EtaCalculation.SHYS.EtaAnalyCalculator4Logic();
|
logicCalc.AnaContext(context, allStationBundles);
|
all_Logic = logicCalc.GetAllLogicAnaRecord();
|
if (all_Logic != null)
|
{
|
foreach (var logic in all_Logic)
|
{
|
logic.CorpID = _corpID;
|
logic.DataTime = dateTime;
|
logic.Duration = duration;
|
if (logic.AnalyStatus == Model.Eta.eAnalyStatus.Unkonw)
|
{
|
LogHelper.Info($"能效分析任务中,AnalyStatus(logic) 值为 Model.Eta.eAnalyStatus.Unkonw，客户标识：(上海城投), logic id信息:{logic.ObjectID} ");
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
IStation.LogHelper.Error(String.Format("corpID:{0},能效分析出错,原因是:{1}", this. _corpID, ex.Message ));
|
return false;
|
}
|
if (handler != null)
|
{
|
handler.Invoke(all_Single, all_Multi, all_Logic, null);
|
}
|
return true;
|
}
|
|
|
|
private IEtaStationAnalyCalculator CreateCalculater4Station(long StationID)
|
{
|
if (StationID == 24)
|
{
|
return new IStation.EtaCalculation.SMI.Station.EtaAnalyCalculator4松花江();
|
}
|
|
if (StationID == 25)
|
{
|
return new IStation.EtaCalculation.SMI.Station.EtaAnalyCalculator4南大路();
|
}
|
|
if (StationID == 1564533764212789248)
|
{
|
return new IStation.EtaCalculation.SMI.Station.EtaAnalyCalculator4南市水厂();
|
}
|
|
return null;
|
}
|
|
}
|
}
|
