using Microsoft.AspNetCore.Mvc;
using System.Net;
using System.Net.Http.Headers;
using Microsoft.Extensions.Hosting.Internal;
using Microsoft.AspNetCore.Http.Extensions;
using IStation.Untity;
using Furion.DynamicApiController;
using System.ComponentModel.DataAnnotations;
using Mapster;
using IStation.Calculation;
using IStation.Model;

namespace IStation.Application
{
    /// <summary>
    /// MonitorKpi
    /// </summary>
    [Route("Run/MonitorKpi")]
    [ApiDescriptionSettings("Run", Name = "监测KPI", Order = 700)]
    public class MonitorKpi_Controller : IDynamicApiController
    {
        /// <summary>
        /// 通过 StationID 获取泵站面板信息
        /// </summary>
        [Route("GetStationPanelInfoByCorpID@V1.0")]
        [HttpGet]
        public List<MonitorPanelKpiInfo> GetStationPanelInfoByCorpID
            (
                [Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
                long CorpID,
                int KpiCount = 4
            )
        {
            var station_list = new Service.Station().GetByCorpID(CorpID);
            if (station_list == null || station_list.Count < 1)
            {
                return default;
            }

            var service_record = new Service.MonitorRealRecord();
            var vm_list = new List<MonitorPanelKpiInfo>();
            foreach (var station in station_list)
            {
                var vm = new MonitorPanelKpiInfo();
                vm.CorpID = station.CorpID;
                vm.ObjectType = IStation.ObjectType.Station;
                vm.ObjectID = station.ID;
                vm.ObjectName = station.Name;
                vm.LastKpiRecordList = new List<MonitorKpiLastRecord>();
                vm.LastRunStatusRecordList = new List<MonitorObjectLastRunStatusRecord>();
                vm_list.Add(vm);

                //最后kpi记录列表
                var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID
                    (CorpID, IStation.ObjectType.Station, station.ID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
                var monitor_kpi_list = monitor_list?.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.KPI))
                    .OrderBy(x => x.ImportanceIndex == null ? int.MaxValue : x.ImportanceIndex.Value).ToList();
                if (monitor_kpi_list != null)
                {
                    var take_count = monitor_kpi_list.Count > KpiCount ? KpiCount : monitor_kpi_list.Count;
                    monitor_kpi_list = monitor_kpi_list.Take(take_count).ToList();

                    foreach (var monitor_kpi in monitor_kpi_list)
                    {
                        var vm_kpi_last_record = new MonitorKpiLastRecord();
                        vm_kpi_last_record.CorpID = monitor_kpi.CorpID;
                        vm_kpi_last_record.MonitorPointID = monitor_kpi.ID;
                        vm_kpi_last_record.SignalID = monitor_kpi.SignalList.First().ID;
                        vm_kpi_last_record.SignalType = monitor_kpi.SignalList.First().SignalType.Identifier;
                        vm_kpi_last_record.Name = monitor_kpi.Name;
                        vm_kpi_last_record.Unit = monitor_kpi.SignalList.First().SignalType.GetEnUnitName();
                        vm_kpi_last_record.DecimalPlaces = monitor_kpi.SignalList.First().DecimalPlaces;
                        var last_record = service_record.GetLastRecord(vm_kpi_last_record.CorpID, vm_kpi_last_record.MonitorPointID, vm_kpi_last_record.SignalID);
                        if (last_record != null)
                        {
                            vm_kpi_last_record.SrcTime = last_record.SrcTime.ToString("yyyy-MM-dd HH:mm:ss");
                            vm_kpi_last_record.SrcValue = last_record.SrcValue;
                            vm_kpi_last_record.DataTime = last_record.DataTime.ToString("yyyy-MM-dd HH:mm:ss");
                            vm_kpi_last_record.DataValue = last_record.DataValue;
                            vm_kpi_last_record.DataStatus = last_record.DataStatus;
                        }
                        vm.LastKpiRecordList.Add(vm_kpi_last_record);
                    }
                }

                //最后运行状态记录列表
                var monitor_group_list = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(CorpID, IStation.ObjectType.Station, station.ID);
                if (monitor_group_list != null && monitor_group_list.Count > 0)
                { 
                    var monitor_engine_pump_group_list = monitor_group_list.Where
                        (x => x.Flags != null && x.Flags.Contains(LogicFlags.机泵)).OrderBy(x => x.ParentIds == null ? 0 : x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
                    if (monitor_engine_pump_group_list != null && monitor_engine_pump_group_list.Count > 0)
                    {
                        foreach (var engine_pump_group in monitor_engine_pump_group_list)
                        {
                            var vm_run_status_last_record = new MonitorObjectLastRunStatusRecord();
                            vm_run_status_last_record.CorpID = engine_pump_group.CorpID;
                            vm_run_status_last_record.ObjectType = IStation.ObjectType.MonitorPointGroup;
                            vm_run_status_last_record.ObjectID = engine_pump_group.ID;
                            vm_run_status_last_record.ObjectName = engine_pump_group.Name;
                            vm_run_status_last_record.RunStatus = IStation.RunStatus.Shut;

                            var monitor_run_list = monitor_list?.Where(x =>x.GroupID== engine_pump_group.ID && x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
                            var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(LogicFlags.默认));
                            if (monitor_run_default == null)
                                monitor_run_default = monitor_run_list?.FirstOrDefault();
                            if (monitor_run_default != null)
                            {
                                var last_record = service_record.GetLastRecord(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID);
                                if (last_record != null)
                                {
                                    vm_run_status_last_record.DataTime = last_record.DataTime;
                                    if (double.TryParse(last_record.DataValue, out double data_value))
                                    {
                                        vm_run_status_last_record.RunStatus = data_value > 0 ? IStation.RunStatus.Run : IStation.RunStatus.Shut;
                                    }
                                }
                            }
                            vm.LastRunStatusRecordList.Add(vm_run_status_last_record);
                        }
                    }
                }
            }

            return vm_list;

        }
         
 

        /// <summary>
        /// 通过 StationID 获取面板信息
        /// </summary>
        [Route("GetPanelInfoByStationID@V1.0")]
        [HttpGet]
        public MonitorPanelKpiInfo GetPanelInfoByStationID
            (
                [Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
                long CorpID,
                [Required, Range(1, long.MaxValue, ErrorMessage = "StationID 必须大于0")]
                long StationID, 
                int KpiCount = 4
            )
        {
            var station = new Service.Station().GetByID(CorpID, StationID);
            if (station == null)
            {
                return default;
            }

            var service_record = new Service.MonitorRealRecord();

            var vm = new MonitorPanelKpiInfo();
            vm.CorpID = station.CorpID;
            vm.ObjectType = IStation.ObjectType.Station;
            vm.ObjectID = station.ID;
            vm.ObjectName = station.Name;
            vm.LastKpiRecordList = new List<MonitorKpiLastRecord>();
            vm.LastRunStatusRecordList = new List<MonitorObjectLastRunStatusRecord>();

            //最后kpi记录列表
            var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByBelongTypeAndBelongID
                (CorpID, IStation.ObjectType.Station, station.ID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
            var monitor_kpi_list = monitor_list?.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.KPI))
                .OrderBy(x => x.ImportanceIndex == null ? int.MaxValue : x.ImportanceIndex.Value).ToList();
            if (monitor_kpi_list != null)
            {
                var take_count = monitor_kpi_list.Count > KpiCount ? KpiCount : monitor_kpi_list.Count;
                monitor_kpi_list = monitor_kpi_list.Take(take_count).ToList();

                foreach (var monitor_kpi in monitor_kpi_list)
                {
                    var vm_kpi_last_record = new MonitorKpiLastRecord();
                    vm_kpi_last_record.CorpID = monitor_kpi.CorpID;
                    vm_kpi_last_record.MonitorPointID = monitor_kpi.ID;
                    vm_kpi_last_record.SignalID = monitor_kpi.SignalList.First().ID;
                    vm_kpi_last_record.SignalType = monitor_kpi.SignalList.First().SignalType.Identifier;
                    vm_kpi_last_record.Name = monitor_kpi.Name;
                    vm_kpi_last_record.Unit = monitor_kpi.SignalList.First().SignalType.GetEnUnitName();
                    vm_kpi_last_record.DecimalPlaces = monitor_kpi.SignalList.First().DecimalPlaces;
                    var last_record = service_record.GetLastRecord(vm_kpi_last_record.CorpID, vm_kpi_last_record.MonitorPointID, vm_kpi_last_record.SignalID);
                    if (last_record != null)
                    {
                        vm_kpi_last_record.SrcTime = last_record.SrcTime.ToString("yyyy-MM-dd HH:mm:ss");
                        vm_kpi_last_record.SrcValue = last_record.SrcValue;
                        vm_kpi_last_record.DataTime = last_record.DataTime.ToString("yyyy-MM-dd HH:mm:ss");
                        vm_kpi_last_record.DataValue = last_record.DataValue;
                        vm_kpi_last_record.DataStatus = last_record.DataStatus;
                    }
                    vm.LastKpiRecordList.Add(vm_kpi_last_record);
                }
            }

            //最后运行状态记录列表
            var monitor_group_list = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(CorpID, IStation.ObjectType.Station, station.ID);
            if (monitor_group_list != null && monitor_group_list.Count > 0)
            {
                var monitor_engine_pump_group_list = monitor_group_list.Where
                    (x => x.Flags != null && x.Flags.Contains(LogicFlags.机泵)).OrderBy(x => x.ParentIds == null ? 0 : x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
                if (monitor_engine_pump_group_list != null && monitor_engine_pump_group_list.Count > 0)
                {
                    foreach (var engine_pump_group in monitor_engine_pump_group_list)
                    {
                        var vm_run_status_last_record = new MonitorObjectLastRunStatusRecord();
                        vm_run_status_last_record.CorpID = engine_pump_group.CorpID;
                        vm_run_status_last_record.ObjectType = IStation.ObjectType.MonitorPointGroup;
                        vm_run_status_last_record.ObjectID = engine_pump_group.ID;
                        vm_run_status_last_record.ObjectName = engine_pump_group.Name;
                        vm_run_status_last_record.RunStatus = IStation.RunStatus.Shut;

                        var monitor_run_list = monitor_list?.Where(x =>x.GroupID== engine_pump_group.ID&& x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
                        var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(LogicFlags.默认));
                        if (monitor_run_default == null)
                            monitor_run_default = monitor_run_list?.FirstOrDefault();
                        if (monitor_run_default != null)
                        {
                            var last_record = service_record.GetLastRecord(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID);
                            if (last_record != null)
                            {
                                vm_run_status_last_record.DataTime = last_record.DataTime;
                                if (double.TryParse(last_record.DataValue, out double data_value))
                                {
                                    vm_run_status_last_record.RunStatus = data_value > 0 ? IStation.RunStatus.Run : IStation.RunStatus.Shut;
                                }
                            }
                        }
                        vm.LastRunStatusRecordList.Add(vm_run_status_last_record);
                    }
                }
            }

            return vm;
        }






    }
}