using PBS.Model;
using System.Data;
using System.IO;
using Yw;
using Yw.WinFrmUI;

namespace IBox.WinFrmUI
{
    public partial class IBoxFormControll : DocumentPage
    {

        private string startCode = "[&start&]";
        private string endCode = "[&end&]";
        private string paramCode = "[&param&]";
        private string datadownloadCode = "datadownload";

        private void EboxFormControll_Load(object sender, EventArgs e)
        {
            //BluetoothHelper.GetInstance().SMR -= null;
            //BluetoothHelper.GetInstance().SMR += new BluetoothHelper.ShowMessReturn(GetReceive);
            //BluetoothHelper.GetInstance().ListenerData();
        }

        public void GetReceive(string msg)
        {
            if (!this.IsHandleCreated || this.IsDisposed || string.IsNullOrEmpty(msg)) return;
            if (msg.StartsWith("error:") && msg.Contains("目标主机坏了"))
            {
                MessageBoxHelper.ShowWarning(" c蓝牙设备连接失败，请重试!"); return;
            }
            if (!string.IsNullOrEmpty(msg) && msg.Contains(startCode))
            {
                var order = msg.Replace(endCode, "").Replace(startCode, "").Trim();
                SetOrder(order);
            }
            else MessageBoxHelper.ShowWarning(" c蓝牙设备连接失败");
        }
        public event EventHandler<string> SendData;
        private void SendText(string content)
        {
            //BluetoothHelper.GetInstance().SendData(content);
            SendData?.Invoke(null, content);
        }

        private void SetOrder(string order)
        {
            var smsg = order.Split(new string[] { paramCode }, StringSplitOptions.RemoveEmptyEntries);
            if (smsg.Length < 2)
            {
                return;
            }

            switch (smsg[0].Trim())
            {
                case "datadownload":
                    //WaitFrmHelper.HideWaitForm();
                    break;
            }
        }
        private Model.Facilities _facilities = null;
        private BLL.EquipmentEChartMapping _bll = new BLL.EquipmentEChartMapping();
        private BLL.EChart _bllEChart = new BLL.EChart();
        private BLL.Equipment _bllEquipment = new BLL.Equipment();
        private Model.Kit _kit = null;
        private BLL.EquipmentTypeEChartMapping _equipmentTypeEChartMappingBLL = new BLL.EquipmentTypeEChartMapping();
        public IBoxFormControll(Facility facilities)
        {
            this.PageTitle.Caption = "智能控制";
            _facilities = facilities;
            InitializeComponent();
            this.treeListCtrl1.FocusedChangedEvent += EquipmentTreeListCtrl1_FocusedChangedEvent;
            InitDataSource();
        }
        private string filePath = "Data\\AnalyData_{0}.json";
        private void InitDataSource()
        {
            var f = new BLL.Facilities().GetByID(this._facilities.ID);
            if (f != null)
            {
                var kid = long.Parse(f.CompletePlant);
                var kit = new BLL.Kit().GetByID(kid);
                _kit = kit;
                this.treeListCtrl1.SetBindingData(kid);
            }
            this._SelectedBuild = new Basic.Build()
            {
                factoryName = f.Name,
                系统最大流量 = f.WaterHeight,
                Type = 二供分区Type.加压供水,
                ID = f.ID.ToString(),
                用户压力需求 = int.Parse(f.WaterPressure.ToString()),
                层数 = double.Parse(f.Floor.ToString()),
                层高 = double.Parse(f.FloorHeight.ToString()),
                每层户数 = double.Parse(f.FloorHouseHolds.ToString())
            };
            ShowChart();
        }

        private void ShowChart()
        {
            var file = string.Format(filePath, _facilities.ID.ToString());
            var path = Path.Combine(Directory.GetCurrentDirectory(), file);
            if (!File.Exists(path))
            {
                MessageBoxHelper.ShowInfo("请先进行系统曲线操作!");
                return;
            }
            else
            {
                SetResult(path);
            }
        }

        private void SetResult(string path)
        {
            var content = new Eventech.Common.FileHelper().ReadFile(path);
            var result = JsonHelper.Json2Object<List<Result>>(content);
            AddPoints(result);
            ShowPressPoints();
        }
        private List<Result> _res;
        private Build _SelectedBuild;
        public void AddPoints(List<Result> res)
        {
            _res = res;
            List<PointF> nums = res.Select(o => new PointF((float)o.Demand, (float)o.ObjFunctionValue)).ToList();
            var chartDatas = nums.Select(p => new PointF(p.X, p.Y + _SelectedBuild.用户压力需求 + (float)_facilities.MaxHeight)).ToList();
            if (chartDatas == null || chartDatas.Count == 0) return;

            // 计算多项式在点 x 处的取值
            // 计算拟合曲线上的点
            var curve = new CurveFitHelper(chartDatas, 2);
            //List<PointF> fitPoints = curve.GetFitCurve(100);
            List<List<PointF>> confidencePoints = curve.GetConfidenceCurve(100);

            //_SelectedPump.流量压降平均.Data = fitPoints;
            //_SelectedBuild.流量压降曲线.Data = chartDatas;
            _SelectedBuild.Datasets.Clear();
            _SelectedBuild.流量压降曲线.Data = chartDatas;
            _SelectedBuild.流量压降下限.Data = confidencePoints[0];
            _SelectedBuild.流量压降上限.Data = confidencePoints[1];
        }
        public void ShowPressPoints()
        {
            this.chart1.ChartAreas.Clear();
            this.chart1.ChartAreas.Add(new ChartArea());
            chart1.Series.Clear();
            chart1.Series.Add("数据");
            chart1.Series.Add("平均");
            chart1.Series["平均"].ChartType = SeriesChartType.Line;
            chart1.Series["平均"].BorderWidth = 2;
            chart1.Series.Add("上限");
            chart1.Series["上限"].ChartType = SeriesChartType.Line;
            chart1.Series["上限"].BorderWidth = 2;
            chart1.Series.Add("下限");
            chart1.Series["下限"].ChartType = SeriesChartType.Line;
            chart1.Series["下限"].BorderWidth = 2;
            chart1.Series.Add("泵出口静压线");
            chart1.Series["泵出口静压线"].ChartType = SeriesChartType.Line;
            chart1.Series["泵出口静压线"].BorderWidth = 2;
            chart1.Series["泵出口静压线"].Color = Color.Green;

            chart1.Series.Add("最高楼层标高");
            chart1.Series["最高楼层标高"].ChartType = SeriesChartType.Line;
            chart1.Series["最高楼层标高"].BorderWidth = 2;
            chart1.Series["最高楼层标高"].Color = Color.Yellow;
            if (chart1.ChartAreas.Count > 0)
            {
                chart1.ChartAreas[0].AxisY.Enabled = AxisEnabled.True;
                //chart1.ChartAreas[0].AxisY2.Enabled = AxisEnabled.True;
                chart1.ChartAreas[0].AxisX.Enabled = AxisEnabled.True;
                chart1.ChartAreas[0].AxisX.LabelStyle.Format = "0";
                chart1.ChartAreas[0].AxisY.LabelStyle.Format = "0";
                chart1.ChartAreas[0].AxisX.Title = "系统流量(m³/h)";
                chart1.ChartAreas[0].AxisY.Title = "泵后压力(m)";
                chart1.ChartAreas[0].AxisY2.Enabled = AxisEnabled.False;
            }
            //chart1.ChartAreas[0].AxisX.Minimum = double.NaN;

            //chart1.ChartAreas[0].AxisY.Minimum = double.NaN;
            var nums = _SelectedBuild.流量压降曲线.Data;
            if (nums.Count == 0) return;
            _SelectedBuild.流量压降曲线.CurveFit();
            var fitPoints = _SelectedBuild.流量压降曲线.FittedCurve;
            _SelectedBuild.流量压降下限.CurveFit();
            _SelectedBuild.流量压降上限.CurveFit();
            List<List<PointF>> confidencePoints = new List<List<PointF>>() { _SelectedBuild.流量压降下限.FittedCurve, _SelectedBuild.流量压降上限.FittedCurve };
            var chartDatas = nums.ToList();
            double yMin = double.MaxValue;
            double yMax = double.MinValue;
            float xMin = float.MaxValue;
            float xMax = float.MinValue;
            if (nums == null || nums.Count == 0) return;
            this.chart1.Series[0].ChartType = SeriesChartType.Point;
            //double x = double.Parse(textBox_current_TotalDemand.Text);
            float x_Avg = 0;
            float x_Sum = 0;
            nums.ForEach(y =>
            {
                this.chart1.Series["数据"].Points.AddXY(y.X, y.Y);
                x_Sum += (y.X);
                if (yMin > y.Y) yMin = y.Y;
                if (yMax < y.Y) yMax = y.Y;
                if (xMin > y.X) xMin = y.X;
                if (xMax < y.X) xMax = y.X;
            });
            x_Avg = x_Sum / nums.Count;

            var dataPoints = this.chart1.Series[0].Points;

            // 计算多项式在点 x 处的取值
            // 计算拟合曲线上的点
            var waterpress = _SelectedBuild.流量压降下限.FittedCurve.Select((d) => { return new PointF(d.X, (float)_facilities.MaxHeight + _SelectedBuild.用户压力需求); }).ToList();

            var maxheight = _SelectedBuild.流量压降下限.FittedCurve.Select((d) => { return new PointF(d.X, (float)_facilities.MaxHeight); }).ToList();
            AddSeries(chart1.Series["平均"], fitPoints);
            AddSeries(chart1.Series["下限"], confidencePoints[0]);
            AddSeries(chart1.Series["上限"], confidencePoints[1]);
            AddSeries(chart1.Series["泵出口静压线"], waterpress);
            AddSeries(chart1.Series["最高楼层标高"], maxheight);
            if (yMin > 0 && yMin < 10)
            {
                this.chart1.ChartAreas[0].AxisY.Minimum = 0;
                this.chart1.ChartAreas[0].AxisY.Maximum = Math.Ceiling((yMax * 1.2) / 10) * 10;
                this.chart1.ChartAreas[0].AxisY.Interval = (chart1.ChartAreas[0].AxisY.Maximum - chart1.ChartAreas[0].AxisY.Minimum) / 4;
            }
            else
            {
                this.chart1.ChartAreas[0].AxisY.Minimum = Math.Floor((yMin * 0.8) / 10) * 10;
                this.chart1.ChartAreas[0].AxisY.Maximum = Math.Ceiling((yMax * 1.2) / 10) * 10;
                chart1.ChartAreas[0].AxisX.IsLabelAutoFit = true;
                //this.chart1.ChartAreas[0].AxisX.Minimum = double.NaN;
                //this.chart1.ChartAreas[0].AxisX.Maximum = double.NaN;
                this.chart1.ChartAreas[0].AxisY.Interval = (chart1.ChartAreas[0].AxisY.Maximum - chart1.ChartAreas[0].AxisY.Minimum) / 4;
            }
            if (xMin > 0 && xMin < 10)
            {
                this.chart1.ChartAreas[0].AxisX.Minimum = 0;
                this.chart1.ChartAreas[0].AxisX.Maximum = Math.Ceiling(xMax);
            }
            else
            {
                this.chart1.ChartAreas[0].AxisX.Minimum = Math.Floor((xMin * 0.8) / 10) * 10;
                this.chart1.ChartAreas[0].AxisX.Maximum = Math.Ceiling(xMax * 1.2);
            }
        }

        private void AddSeries(System.Windows.Forms.DataVisualization.Charting.Series serie, List<PointF> points)
        {
            if (points == null) return;
            serie.Points.Clear();
            foreach (var point in points)
            {
                serie.Points.AddXY(point.X, point.Y);
            }
        }
        private void EquipmentTreeListCtrl1_FocusedChangedEvent(string objType, object obj)
        {
            this.curveExpressChart1.InitialChartData();
            if (obj != null && objType == ISupply.ObjectType.Kit)
            {
                _kit = obj as Model.Kit;
                var equipmentList = _bllEquipment.GetByKitIDAndCatalog(_kit.ID, ISupply.Equipment.Pump);
                if (equipmentList != null && equipmentList.Any())
                {
                    var mappings = new List<Model.EquipmentEChartMapping>();
                    foreach (var equipment in equipmentList)
                    {
                        var mapping = _bll.GetWorkingByEquipmentID(equipment.ID);
                        if (mapping != null)
                        {
                            mappings.Add(mapping);
                        }
                    }
                    if (mappings.Any())
                    {
                        var curveInfoList = new List<Model.PumpCurveInfo>();
                        foreach (var mapping in mappings)
                        {
                            var chart = _bllEChart.GetPumpCurveInfoByID(mapping.EChartID);
                            if (chart != null && chart.CurveInfoModel != null)
                            {
                                curveInfoList.Add(chart.CurveInfoModel);
                            }
                        }

                        if (curveInfoList != null && curveInfoList.Any())
                        {
                            var theConnectCurve = new Curve.ParallelConnectionHelper();
                            for (int i = 0; i < curveInfoList.Count; i++)
                            {
                                var chart = curveInfoList[i];
                                var QH = chart.CurveQH;
                                var QP = chart.CurveQP;
                                var QE = Curve.PumpCalculateHelper.CalculateE(QH, QP);
                                theConnectCurve.AddCurve(QH, QP);
                            }
                            var bol = theConnectCurve.CalculateParallel(out List<ISupply.Curve.CurvePoint> ConnectCurveQH,
                                                                     out List<ISupply.Curve.CurvePoint> ConnectCurveQE,
                                                                     out List<ISupply.Curve.CurvePoint> ConnectCurveQP);
                            if (bol)
                            {
                                var curveExpressQH = ISupply.Curve.FitHelper.BuildCurveExpress(ConnectCurveQH);
                                var curveExpressQE = ISupply.Curve.FitHelper.BuildCurveExpress(ConnectCurveQE);
                                var curveExpressQP = ISupply.Curve.FitHelper.BuildCurveExpress(ConnectCurveQP);
                                this.curveExpressChart1.SetBindingData(curveExpressQH,
                                                              curveExpressQE,
                                                             curveExpressQP);
                            }
                        }
                    }
                }
            }
            else if (obj != null && objType == ISupply.ObjectType.Equipment)
            {
                var equ = obj as Model.Equipment;
                var _equipmentChartMappingEx = _equipmentTypeEChartMappingBLL.GetExByEquipmentTypeID(equ.TypeID);

                SetBindingData(_equipmentChartMappingEx);
            }
        }

        private void SendDownloadData()
        {
            var model = new IBoxControllViewModel();
            model.facilities = _facilities;
            model.kit = _kit;
            model.流量压降下限 = _SelectedBuild.流量压降下限.FittedCurve;
            model.流量压降上限 = _SelectedBuild.流量压降上限.FittedCurve;
            model.流量压降曲线 = _SelectedBuild.流量压降曲线.FittedCurve;

            if (!_SelectedBuild.流量压降曲线.IsFitted)
                 _SelectedBuild.流量压降曲线.CurveFit();
            model.coefficients = _SelectedBuild.流量压降上限.coefficients;
            //model.IsControll = checkEdit1.Checked;
            var equipmentList = _bllEquipment.GetByKitIDAndCatalog(_kit.ID, ISupply.Equipment.Pump);
            if (equipmentList != null && equipmentList.Any())
            {
                foreach (var item in equipmentList)
                {
                    var _equipmentChartMappingEx = _equipmentTypeEChartMappingBLL.GetExByEquipmentTypeID(item.TypeID);
                    _equipmentChartMappingEx.EquipmentId = item.ID;
                    _equipmentChartMappingEx.EquipmentOtherName = item.Name;
                    _equipmentChartMappingEx.RatedParas = item.RatedParas;
                    model.equations.Add(_equipmentChartMappingEx);
                }
            }
            //FileHelper.Write("d:\\EboxData.txt", JsonHelper.Object2Json(model));
            Thread.Sleep(500);
            SendText(startCode + datadownloadCode + paramCode + JsonHelper.Object2Json(model) + endCode);
        }

        private void simpleButton1_Click(object sender, EventArgs e)
        {
            //WaitFrmHelper.ShowWaitForm();
            SendDownloadData();
            MessageBoxHelper.ShowInfo("数据下发成功!");
            //MessageBoxHelper.ShowInfo("数据下发成功!");
        }



        private void SetBindingData(Model.EquipmentTypeEChartMappingEx model)
        {
            this.curveExpressChart1.InitialChartData();
            var curveInfo = model?.CurveInfo;
            var coordParas = model?.CoordParas;
            if (curveInfo != null)
            {
                var coordinateParas = ISupply.Curve.CurveCoordinate.ToModel(coordParas);
                this.curveExpressChart1.SetBindingData(curveInfo.CurveQH,
                                                            curveInfo.CurveQE,
                                                            curveInfo.CurveQP,
                                                            coordinateParas);
            }
        }
    }
}