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;

namespace IStation.Application
{
    /// <summary>
    /// EtaAnalyRunStatus
    /// </summary>
    [Route("Eta/Analy/RunStatus")]
    [ApiDescriptionSettings("Eta", Name = "能效运行状态分析", Order = 870)]
    public class EtaAnalyRunStatus_Controller : IDynamicApiController
    {
        /// <summary>
        /// 通过 PipeLineID 获取当前运行状态信息
        /// </summary>
        [Route("GetCurrentInfoByPipeLineID@V1.0")]
        [HttpGet]
        public EtaPipeLineRunCurrentInfo GetCurrentInfoByPipeLineID([FromQuery][Required] PipeLineIDUnderCorpInput input)
        {
            var pipeLine = new Service.PipeLine().GetByID(input.CorpID,input.PipeLineID);
            if (pipeLine == null)
            {
                throw new Exception("未检索到管路信息");
            }
            var vm = new EtaPipeLineRunCurrentInfo();
            vm.CorpID = pipeLine.CorpID;
            vm.PipeLineID = pipeLine.ID;
            vm.PipeLineName = pipeLine.Name;
            vm.CurrentRunStatus = IStation.RunStatus.Shut;

            var record = new Service.EtaSingleRealRecord().GetLastNormalRecord(input.CorpID, IStation.ObjectType.PipeLine, input.PipeLineID);
            if (record != null)
            {
                vm.CurrentRunStatus = record.RSa;
                vm.HZ = record.HZa;
            }

            return vm;
        }

        /// <summary>
        /// 通过 PipeLineIds 获取当前运行状态信息
        /// </summary>
        [Route("GetCurrentInfoByPipeLineIds@V1.0")]
        [HttpGet]
        public List<EtaPipeLineRunCurrentInfo> GetCurrentInfoByPipeLineIds([FromQuery][Required] PipeLineIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.PipeLineIds);

            var pipeLineList = new Service.PipeLine().GetByIds(input.CorpID, ids);
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                throw new Exception("未检索到管路信息");
            }
            pipeLineList = pipeLineList.OrderBy(x => x.SerialNO).ToList();

            var service_record = new Service.EtaSingleRealRecord();
            var vm_list = new List<EtaPipeLineRunCurrentInfo>();
            foreach (var pipeLine in pipeLineList)
            {
                var vm = new EtaPipeLineRunCurrentInfo();
                vm.CorpID = pipeLine.CorpID;
                vm.PipeLineID = pipeLine.ID;
                vm.PipeLineName = pipeLine.Name;
                vm.CurrentRunStatus = IStation.RunStatus.Shut;
                //   var record = service_record.GetLastNormalRecord(pipeLine.CorpID, IStation.ObjectType.PipeLine, pipeLine.ID);
                var record = service_record.GetLastRecord(pipeLine.CorpID, IStation.ObjectType.PipeLine, pipeLine.ID);
                if (record != null)
                {
                    vm.CurrentRunStatus = record.RSa;
                    vm.HZ = record.HZa;
                }
                vm_list.Add(vm);
            }
            return vm_list;
        }

        /// <summary>
        /// 通过 StationID 获取当前运行状态信息
        /// </summary>
        [Route("GetCurrentInfoByStationID@V1.0")]
        [HttpGet]
        public List<EtaPipeLineRunCurrentInfo> GetCurrentInfoByStationID([FromQuery][Required] StationIDUnderCorpInput input)
        {
            var pipeLineList = new Service.PipeLine().GetByBelongTypeAndBelongID(input.CorpID, IStation.ObjectType.Station, input.StationID);
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                throw new Exception("未检索到管路信息");
            }
            pipeLineList = pipeLineList.Where(x => x.Catalog == IStation.PipeLine.EnginePump).OrderBy(x => x.SerialNO).ToList();
            if(pipeLineList.Count<1)
            {
                throw new Exception("未检索到机泵管路信息");
            }

            var service_record = new Service.EtaSingleRealRecord();
            var vm_list = new List<EtaPipeLineRunCurrentInfo>();
            foreach (var pipeLine in pipeLineList)
            {
                var vm = new EtaPipeLineRunCurrentInfo();
                vm.CorpID = pipeLine.CorpID;
                vm.PipeLineID = pipeLine.ID;
                vm.PipeLineName = pipeLine.Name;
                vm.CurrentRunStatus = IStation.RunStatus.Shut;
                var record = service_record.GetLastNormalRecord(pipeLine.CorpID, IStation.ObjectType.PipeLine, pipeLine.ID);
                if (record != null)
                {
                    vm.CurrentRunStatus = record.RSa;
                    vm.HZ = record.HZa;
                }
                vm_list.Add(vm);
            }
            return vm_list;
        }

        /// <summary>
        /// 通过 PipeLineID 获取日运行状态信息
        /// </summary>
        [Route("GetDayInfoByPipeLineID@V1.0")]
        [HttpGet]
        public EtaPipeLineRunDayInfo GetDayInfoByPipeLineID([FromQuery][Required] PipeLineIDUnderCorpOfDayInput input)
        {
            var pipeLine = new Service.PipeLine().GetByID(input.CorpID, input.PipeLineID);
            if (pipeLine == null)
            {
                throw new Exception("未监测到管路信息");
            }

            var vm = new EtaPipeLineRunDayInfo();
            vm.CorpID = pipeLine.CorpID;
            vm.PipeLineID = pipeLine.ID;
            vm.PipeLineName = pipeLine.Name;
            vm.LastRunStatus = IStation.RunStatus.Shut;

            if (input.Day < DateTime.Today)
            {
                var summary = new Service.EtaSumSingleRecord().GetDayByObjectOfDay(input.CorpID, IStation.ObjectType.PipeLine, input.PipeLineID, input.Day);
                if (summary != null)
                {
                    vm.TotalRunTime = summary.RunTime;
                };
            }
            else
            {
                var last_record = new Service.EtaSingleRealRecord().GetLastNormalRecord(input.CorpID, IStation.ObjectType.PipeLine, input.PipeLineID);
                {
                    if (last_record != null)
                    {
                        vm.LastRunStatus = last_record.RSa;
                    }
                }
            }

            return vm;
        }

        /// <summary>
        /// 通过 PipeLineIds 获取日运行状态信息
        /// </summary>
        [Route("GetDayInfoByPipeLineIds@V1.0")]
        [HttpGet]
        public List<EtaPipeLineRunDayInfo> GetDayInfoByPipeLineIds([FromQuery][Required] PipeLineIdsUnderCorpOfDayInput input)
        {
            var pipeLineIds = LongListHelper.ToList(input.PipeLineIds);
            var piepLineList = new Service.PipeLine().GetByIds(input.CorpID, pipeLineIds);
            if (piepLineList == null || piepLineList.Count < 1)
            {
                throw new Exception("未检索到管路信息");
            }
            piepLineList = piepLineList.Where(x => x.Catalog == IStation.PipeLine.EnginePump).OrderBy(x => x.SerialNO == null ? 0 : x.SerialNO.Value).ToList();
            if (piepLineList == null || piepLineList.Count < 1)
            {
                throw new Exception("未检索到机泵管路信息");
            }

            var vm_list = piepLineList.Select(x => new EtaPipeLineRunDayInfo()
            {
                CorpID = x.CorpID,
                PipeLineID = x.ID,
                PipeLineName = x.Name,
                LastRunStatus = IStation.RunStatus.Shut
            }).ToList();
            if (input.Day < DateTime.Today)
            {
                vm_list.ForEach(x => {
                    var summary = new Service.EtaSumSingleRecord().GetDayByObjectOfDay(x.CorpID, IStation.ObjectType.PipeLine, x.PipeLineID, input.Day);
                    if (summary != null)
                    {
                        x.TotalRunTime = summary.RunTime;
                    }
                });
            }
            else
            {
                vm_list.ForEach(x => {
                    var last_record = new Service.EtaSingleRealRecord().GetLastNormalRecord(x.CorpID, IStation.ObjectType.PipeLine, x.PipeLineID);
                    if (last_record != null)
                    {
                        x.LastRunStatus = last_record.RSa;
                    }
                });
            }

            return vm_list;
        }

        /// <summary>
        /// 通过 StationID 获取日运行状态信息
        /// </summary>
        [Route("GetDayInfoByStationID@V1.0")]
        [HttpGet]
        public List<EtaPipeLineRunDayInfo> GetDayInfoByStationID([FromQuery][Required] StationIDUnderCorpOfDayInput input)
        {
            var pipeLineList = new Service.PipeLine().GetByBelongTypeAndBelongID(input.CorpID, IStation.ObjectType.Station, input.StationID);
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                throw new Exception("未检索到管路信息");
            }
            pipeLineList = pipeLineList.Where(x => x.Catalog == IStation.PipeLine.EnginePump).OrderBy(x => x.SerialNO).ToList();
            if (pipeLineList.Count < 1)
            {
                throw new Exception("未检索到机泵管路信息");
            }

            var vm_list = pipeLineList.Select(x => new EtaPipeLineRunDayInfo()
            {
                CorpID = x.CorpID,
                PipeLineID = x.ID,
                PipeLineName = x.Name,
                LastRunStatus = IStation.RunStatus.Shut
            }).ToList();
            if (input.Day < DateTime.Today)
            {
                vm_list.ForEach(x => {
                    var summary = new Service.EtaSumSingleRecord().GetDayByObjectOfDay(x.CorpID, IStation.ObjectType.PipeLine, x.PipeLineID, input.Day);
                    if (summary != null)
                    {
                        x.TotalRunTime = summary.RunTime;
                    }
                });
            }
            else
            {
                vm_list.ForEach(x => {
                    var last_record = new Service.EtaSingleRealRecord().GetLastNormalRecord(x.CorpID, IStation.ObjectType.PipeLine, x.PipeLineID);
                    if (last_record != null)
                    {
                        x.LastRunStatus = last_record.RSa;
                    }
                });
            }

            return vm_list;

        }






    }
}