using IStation.IEtaCalculation;
using IStation.Model;

namespace IStation.EtaCalculation
{
    /// <summary>
    /// 分析计算器(上海原水)
    /// </summary>
    public class AnalyCalculator4SHYS : 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;

            try
            {
                #region 泵站分析
                //16时原水泵站数量
                InitialStationList(context, 22);

                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 == 1)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4青草沙取水泵房();
            }

            if (StationID == 2)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4长兴岛输水泵房();
            }

            if (StationID == 3)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4五号沟严桥方向1号泵房();
            }
            if (StationID == 4)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4严桥泵站();
            }
            if (StationID == 5)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4五号沟严桥方向2号泵房();
            }
            if (StationID == 6)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4临江一号泵房_老();
            }
            if (StationID == 7)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4临江二号泵房_新();
            }
            if (StationID == 8)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4徐泾泵站();
            }
            if (StationID == 9)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4五号沟金海方向();
            }
            if (StationID == 10)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4金海泵站();
            }
            if (StationID == 11)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4南汇北泵站();
            }
            if (StationID == 12)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4五号沟凌桥方向();
            }
            if (StationID == 13)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4成行一取();
            }


            if (StationID == 14)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4成行二取();
            }
            if (StationID == 15)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4陈行一输();
            }
            ////if (StationID == 16)
            ////{//运行状态 不是数据格式 
            ////    return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4陈行二输();
            ////}
            ////if (StationID == 17)
            ////{ //数据还不全 
            ////    return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4泰和泵站();
            ////}

            if (StationID == 18)
            {//金泽取水
                return null;
            }

            if (StationID == 19)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4金泽泵站();
            }
            if (StationID == 20)
            {
                return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4松江泵站();
            }
            ////if (StationID == 21)
            ////{// 由于没有出口压力, 暂时不能分析
            ////    return new IStation.EtaCalculation.SHYS.Station.EtaAnalyCalculator4松浦大桥泵站();
            ////}

            return null;
        }

    }
}