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

namespace IStation.WinFrmUI.Basic
{
    /// <summary>
    /// 
    /// </summary>
    public class ConvertHelper
    {
        public static bool ConvertTProduct(FullPacking packing)
        {
            if (packing == null)
                return false;
            if (packing.Stations == null || !packing.Stations.Any())
                return false;

            var testItemGroup = packing.TestItems?.GroupBy(x => x.PartID);

            var stations = new List<Model.Station>();
            var products = new List<Model.Equipment>();
            var curves = new List<Model.PumpCurve>();
            var curveMappings = new List<Model.PumpCurveMapping>();

            foreach (var itemStaton in packing.Stations)
            {
                var station = new Model.Station();
                station.ID = itemStaton.ID;
                station.Name = itemStaton.Name;
                station.TagName = itemStaton.Tag;
                station.SortCode = itemStaton.SortCode;
                station.Description = itemStaton.Note;
                stations.Add(station);
                if (itemStaton.Pumps == null || !itemStaton.Pumps.Any())
                    continue;

                foreach (var itemPump in itemStaton.Pumps)
                {
                    Model.Equipment enginePump, pump, motor;

                    //添加机泵组
                    enginePump = new Model.Equipment()
                    {
                        ID = SnowflakeIdHelper.NextId(),
                        BelongType = IStation.ObjectType.Station,
                        BelongID = station.ID,
                        Catalog = IStation.Equipment.EnginePump,
                        Supplier = itemPump.ManufacturerName,
                        NO = itemPump.PartCode,
                        Name = itemPump.PartName + "-机组",
                        ModelType = itemPump.Code,
                        Specification = itemPump.SeriesName,
                        TagName = itemPump.Tag,
                        UseStatus = Model.eProductStatus.Enable,
                        SortCode = itemPump.SortCode,
                        Description = itemPump.ProductParas
                    };
                    {
                        var ratedParas = new Model.EnginePump();
                        enginePump.RatedParas = ratedParas.ToJson();
                    }
                    products.Add(enginePump);

                    //添加泵
                    pump = new Model.Equipment()
                    {
                        ID = itemPump.PartID,
                        BelongType = IStation.ObjectType.Station,
                        BelongID = station.ID,
                        Catalog = IStation.Equipment.Pump,
                        Supplier = itemPump.ManufacturerName,
                        ParentIds = new List<long>() { enginePump.ID },
                        NO = itemPump.PartCode,
                        Name = itemPump.PartName,
                        ModelType = itemPump.Code,
                        Specification = itemPump.SeriesName,
                        TagName = itemPump.Tag,
                        UseStatus = Model.eProductStatus.Enable,
                        SortCode = 0,
                        Description = itemPump.ProductParas
                    };
                    if (itemPump.RatedParas != null)
                    {
                        var itemRatedParas = itemPump.RatedParas;
                        var ratedParas = new Model.Pump();
                        ratedParas.Qr = itemRatedParas.Q;
                        ratedParas.Hr = itemRatedParas.H;
                        ratedParas.Pr = itemRatedParas.P;
                        ratedParas.Er = itemRatedParas.E;
                        if (itemPump.Ratedn.HasValue)
                            ratedParas.Nr = itemPump.Ratedn.Value;
                        if (itemRatedParas.NPSHr.HasValue)
                            ratedParas.NPSHr = itemRatedParas.NPSHr.Value;
                        ratedParas.Oc = itemRatedParas.OutletDia;
                        ratedParas.Ic = itemRatedParas.InletDia;
                        //ratedParas.IOd
                        ratedParas.StNumr = itemRatedParas.StageNumber;
                        ratedParas.IsBp = itemRatedParas.IsFrequency;
                        ratedParas.IsSxp = itemRatedParas.IsSxp;
                        pump.RatedParas = ratedParas.ToJson();
                    }
                    products.Add(pump);

                    //添加电机
                    if (itemPump.Motor != null)
                    {
                        var itemMotor = itemPump.Motor;
                        motor = new Model.Equipment()
                        {
                            ID = itemMotor.PartID,
                            BelongType = IStation.ObjectType.Station,
                            BelongID = station.ID,
                            Catalog = IStation.Equipment.Motor,
                            Supplier = itemMotor.ManufacturerName,
                            ParentIds = new List<long>() { enginePump.ID },
                            NO = itemMotor.PartCode,
                            Name = itemMotor.PartName,
                            ModelType = itemMotor.Code,
                            Specification = itemMotor.SeriesName,
                            TagName = itemMotor.Tag,
                            UseStatus = Model.eProductStatus.Enable,
                            SortCode = 0,
                            Description = itemMotor.ProductParas
                        };
                        products.Add(motor);

                        var ratedParas = new Model.Motor();
                        if (itemMotor.RatedPower.HasValue)
                            ratedParas.Pr = itemMotor.RatedPower.Value;

                        if (itemMotor.Ratedn.HasValue)
                            ratedParas.Nr = itemMotor.Ratedn.Value;

                        if (itemMotor.RatedI.HasValue)
                            ratedParas.Ir = itemMotor.RatedI.Value;
                        ratedParas.Er = itemMotor.E_Self;
                        motor.RatedParas = ratedParas.ToJson();
                    }

                    //添加测试曲线
                    if (testItemGroup == null || !testItemGroup.Any())
                        continue;
                    var testItems = testItemGroup.Where(x => x.Key == pump.ID).FirstOrDefault().ToList();
                    testItems = testItems?.Where(x => x.Records != null && x.Records.Any()).ToList();
                    if (testItems == null || !testItems.Any())
                        continue;
                    foreach (var testItem in testItems)
                    {
                        List<Model.CurvePoint> qhPoints = new List<Model.CurvePoint>(),
                            qePoints = new List<Model.CurvePoint>(),
                            qpPoints = new List<Model.CurvePoint>();

                        testItem.Records.ForEach(record =>
                        {
                            var qhPoint = new Model.CurvePoint()
                            {
                                X = record.CorrectPtQ,
                                Y = record.CorrectPtH
                            };
                            qhPoints.Add(qhPoint);
                            if (record.CorrectPtE.HasValue)
                            {
                                var qePoint = new Model.CurvePoint()
                                {
                                    X = record.CorrectPtQ,
                                    Y = record.CorrectPtE.Value
                                };
                                qePoints.Add(qePoint);
                            }
                            if (record.CorrectPtP.HasValue)
                            {
                                var qpPoint = new Model.CurvePoint()
                                {
                                    X = record.CorrectPtQ,
                                    Y = record.CorrectPtP.Value
                                };
                                qpPoints.Add(qpPoint);
                            }
                        });

                        var curve = new Model.PumpCurve();
                        curve.ID = SnowflakeIdHelper.NextId();
                        curve.CurveCode = $"[现场测试]{testItem.ItemName}";
                        curve.SourceFrom = Model.eCurveSourceFrom.现场测试;
                        curve.CreateMethod = Model.eCurveCreateMethod.中间格式导入;
                        //curve.PointInfo = new Model.FeatCurvePointGroup(qhPoints, qePoints, qpPoints);
                        curve.CurveInfo = new Model.FeatCurveExpressGroup();

                        var qhFitType = (Model.eCurveFitType)(int)itemPump.CurveFitTypeQH;
                        curve.CurveInfo.CurveQH = new Model.CurveExpress(qhPoints, qhFitType, true);
                        if (qePoints.Any())
                        {
                            var qeFitType = (Model.eCurveFitType)(int)itemPump.CurveFitTypeQE;
                            curve.CurveInfo.CurveQE = new Model.CurveExpress(qePoints, qeFitType, true);
                        }
                        if (qpPoints.Any())
                        {
                            var qpFitType = (Model.eCurveFitType)(int)itemPump.CurveFitTypeQP;
                            curve.CurveInfo.CurveQP = new Model.CurveExpress(qpPoints, qpFitType, true);
                        }
                        curve.ReliabilityStatus = Model.PumpCurve.eReliabilityStatus.Normal;
                        curve.CreateTime = testItem.ItemCreateTime;
                        curve.Description = testItem.ProjectUseStatus;
                        curves.Add(curve);

                        var curveMpping = new Model.PumpCurveMapping();
                        curveMpping.PumpID = pump.ID;
                        curveMpping.CurveID = curve.ID;
                        curveMpping.OtherName = $"[测试]{testItem.ItemName}";
                        curveMpping.IsWorking = false;
                        curveMpping.SortCode = 1;
                        curveMappings.Add(curveMpping);
                    }
                };
            }

            var result_Station = new BLL.Station().Covers(stations);
            var result_product = new BLL.Equipment().Covers(products);
            var result_pumpCurve = new BLL.PumpCurve().Covers(curves);
            var result_pumpMapping = new BLL.PumpCurveMapping().Covers(curveMappings);
            return true;
        }

    }
}