using IStation.Untity;
using System;
using System.Collections.Generic;
using System.Linq;

namespace IStation.WinFrmUI.Monitor
{
    public class EtaExportHelper
    {

        public static void Export(long monitor_data_sources_id)
        {
            var duration = 300;
            var station_list = new BLL.Station().GetAll();
            foreach (var station in station_list)
            {
                var station_id = station.ID;
                var station_index = station.SortCode;
                var packet_list = new BLL.StationSignalRecordPacket().Get(monitor_data_sources_id, station_id);
                if (packet_list == null && !packet_list.Any())
                {
                    return;
                }

                var flag_nr_dict = new Dictionary<int, double>();
                var pumps = new BLL.Equipment().GetPumpListByBelongTypeAndBelongID(IStation.ObjectType.Station, station_id);
                foreach (var pump in pumps)
                {
                    flag_nr_dict.Add(pump.SortCode, pump.RatedParas.Nr);
                }

                var eta_list = new List<Model.EtaMultiRealRecord>();
                foreach (var packet in packet_list)
                {
                    var year = packet.Year;
                    var month = packet.Month;
                    var station_record_list = packet.StationSignalRecords;
                    foreach (var station_record in station_record_list)
                    {
                        var total_flow = station_record.TotalFlow;
                        var total_pressure = station_record.TotalPressure;
                        var pump_total_flow = station_record.PumpSignalRecords.Sum(x => x.FlowRate);
                        var diff_flow = station_record.DiffFlow;
                        if (total_pressure < 0)
                            continue;
                        if (total_flow <= 0 && pump_total_flow <= 0)
                            continue;
                        if (pump_total_flow > 0 && Math.Abs(diff_flow) > 3000)
                            continue;
                        total_flow = Math.Round(total_flow, 1);
                        pump_total_flow = Math.Round(pump_total_flow, 1);
                        diff_flow = Math.Round(diff_flow, 1);
                        total_pressure = Math.Round(total_pressure, 2);

                        var pump_record_list = station_record.PumpSignalRecords;
                        pump_record_list = pump_record_list.OrderBy(x => x.Flag).ToList();
                        if (pump_record_list.Exists(x => x.Rpm < 0))
                            continue;

                        var run_flag_list = pump_record_list.Select(x => x.Flag).ToList();
                        var hz_list = new List<double>();
                        var time = station_record.Time;
                        var flow = pump_total_flow;
                        if (flow <=0)
                            flow = total_flow;
                        var head = pump_record_list.Average(x => x.Head);
                        var power = pump_record_list.Sum(x => x.InstantaneousPower);
                        var wp = Model.CurveCalcuHelper.CalculateWP(power, flow);

                        var eff = 0d;
                        var uwp = 0d;

                        foreach (var pump_record in pump_record_list)
                        {
                            var pump_flow = pump_record.FlowRate;
                            var pump_head = pump_record.Head;
                            var pump_power = pump_record.InstantaneousPower;
                            var pump_rpm = pump_record.Rpm;
                            var pump_eff = Model.CurveCalcuHelper.CalculateE(pump_flow, pump_head, pump_power);
                            var pump_uwp = Model.CurveCalcuHelper.CalculateUWP(pump_power, pump_flow, pump_head);

                            eff += pump_eff * pump_flow / flow;
                            uwp += pump_uwp * pump_flow / flow;



                            var flag = pump_record.Flag;
                            var nr = flag_nr_dict[flag];
                            var hz = pump_rpm / nr * 50;
                            if (flag == 15 || flag == 16)
                                hz = 50;

                            hz = Math.Round(hz, 1);
                            hz_list.Add(hz);
                        }

                        if (eff <= 0 && uwp <= 0)
                        {
                            eff = Model.CurveCalcuHelper.CalculateE(flow, head, power);
                            uwp = Model.CurveCalcuHelper.CalculateUWP(power, flow, head);
                        }

                        if (eff>85)
                            continue;

                        var eta = new IStation.Model.EtaMultiRealRecord();
                        eta.Station = station_index;
                        eta.DataTime = time;
                        eta.Duration = duration;
                        eta.Qa = Math.Round(flow, 1);
                        eta.Ha = Math.Round(head, 2);
                        eta.Pa = Math.Round(power, 1);
                        eta.Ea = Math.Round(eff, 1);
                        eta.WPa = Math.Round(wp, 3); ;
                        eta.UWPa = Math.Round(uwp, 3);
                        eta.RunningCount = pump_record_list.Count();
                        eta.RunningFlag = IntListHelper.ToString(run_flag_list);
                        eta.HZa = DoubleListHelper.ToString(hz_list);

                        eta_list.Add(eta);
                    }
                }

                var bol = new DAL.EtaMultiRealRecord().BulkInserts(eta_list);
                if (!bol)
                {
                    throw new System.Exception("插入失败!");
                }

            }


        }



    }
}