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>
    /// EtaAnalyRunSpan
    /// </summary>
    [Route("Eta/Analy/RunSpan")]
    [ApiDescriptionSettings("Eta", Name = "能效运行区间分析", Order = 860)]
    public class EtaAnalyRunSpan_Controller : IDynamicApiController
    {

        /// <summary>
        /// 通过日期获取泵站下运行区间信息
        /// </summary>
        [Route("GetInfoByStationIDOfDay@V1.0")]
        [HttpGet]
        public EtaRunSpanLogicInfo GetInfoByStationIDOfDay([FromQuery][Required] StationIDUnderCorpOfDayInput input)
        {
            var station = new Service.Station().GetByID(input.CorpID, input.StationID);
            if (station == null)
            {
                throw new Exception("未检索到泵站信息");
            }

            var vm = new EtaRunSpanLogicInfo();
            vm.CorpID = station.CorpID;
            vm.ObjectType = IStation.ObjectType.Station;
            vm.ObjectID = station.ID;
            vm.ObjectName = station.Name;

            var recordList = new Service.EtaMultiRealRecord().GetByObjectOfDay(input.CorpID, IStation.ObjectType.Station, input.StationID, input.Day);
            recordList = recordList?.OrderBy(x => x.DataTime).ToList();
            vm.Records = recordList?.Select(x => new EtaRunSpanRecord(x)).ToList();

            var pipeLineList = new Service.PipeLine().GetByBelongTypeAndBelongID(input.CorpID, IStation.ObjectType.Station, input.StationID);
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                return vm;
            }
            pipeLineList = pipeLineList.Where(x => x.Catalog == IStation.PipeLine.EnginePump && x.SerialNO != null).OrderBy(x => x.SerialNO.Value).ToList();
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                return vm;
            }

            vm.Items = new List<EtaRunSpanItem>();
            foreach (var pipe in pipeLineList)
            {
                var vm_item = new EtaRunSpanItem();
                vm_item.CorpID = pipe.CorpID;
                vm_item.ObjectType = IStation.ObjectType.PipeLine;
                vm_item.ObjectID = pipe.ID;
                vm_item.ObjectName = pipe.Name;
                vm_item.Spans = new List<EtaRunSpan>();
                vm.Items.Add(vm_item);
                if (recordList == null || recordList.Count < 1)
                {
                    var vm_span = new EtaRunSpan();
                    vm_span.RunStatus = IStation.RunStatus.Shut;
                    vm_span.StartTime = input.Day.Date;
                    var end_time = input.Day.Date.AddDays(1);
                    if (end_time > DateTime.Now)
                        end_time = DateTime.Now;
                    vm_span.EndTime = end_time;
                    vm_span.Duration = (end_time - input.Day.Date).TotalSeconds;
                    vm_item.Spans.Add(vm_span);
                    continue;
                }

                var index = pipeLineList.IndexOf(pipe);
                foreach (var record in recordList)
                {
                    var run_status = record.RunningFlag[index];
                    var vm_span = vm_item.Spans.LastOrDefault();
                    if (vm_span == null)
                    {
                        vm_span = new EtaRunSpan();
                        vm_span.RunStatus = run_status;
                        vm_span.StartTime = record.DataTime;
                        vm_item.Spans.Add(vm_span);
                    }
                    if (run_status == vm_span.RunStatus)
                    {
                        var end_time = record.DataTime.AddSeconds(record.Duration);
                        if (end_time > input.Day.Date.AddDays(1))
                            end_time = input.Day.Date.AddDays(1);
                        vm_span.EndTime = end_time;
                        vm_span.Duration += record.Duration;
                    }
                    else
                    {
                        vm_span.EndTime = record.DataTime;
                        var vm_span_next = new EtaRunSpan();
                        vm_span_next.RunStatus = run_status;
                        vm_span_next.StartTime = record.DataTime;
                        var end_time = record.DataTime.AddSeconds(record.Duration);
                        if (end_time > input.Day.Date.AddDays(1))
                            end_time = input.Day.Date.AddDays(1);
                        vm_span_next.EndTime = end_time;
                        vm_span_next.Duration += record.Duration;
                        vm_item.Spans.Add(vm_span_next);
                    }
                }
            }

            return vm;
        }

        /// <summary>
        /// 通过日期获取泵站下运行区间信息
        /// </summary>
        [Route("GetItemsByStationIDOfDay@V1.0")]
        [HttpGet]
        public List<EtaRunSpanItem> GetItemsByStationIDOfDay([FromQuery][Required] StationIDUnderCorpOfDayInput input)
        {
            var station = new Service.Station().GetByID(input.CorpID, input.StationID);
            if (station == null)
            {
                throw new Exception("未检索到泵站信息");
            }

            var recordList = new Service.EtaMultiRealRecord().GetByObjectOfDay(input.CorpID, IStation.ObjectType.Station, input.StationID, input.Day);
            recordList = recordList?.OrderBy(x => x.DataTime).ToList();

            var pipeLineList = new Service.PipeLine().GetByBelongTypeAndBelongID(input.CorpID, IStation.ObjectType.Station, input.StationID);
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                return default;
            }
            pipeLineList = pipeLineList.Where(x => x.Catalog == IStation.PipeLine.EnginePump && x.SerialNO != null).OrderBy(x => x.SerialNO.Value).ToList();
            if (pipeLineList == null || pipeLineList.Count < 1)
            {
                return default;
            }

            var vm_list = new List<EtaRunSpanItem>();
            foreach (var pipe in pipeLineList)
            {
                var vm_item = new EtaRunSpanItem();
                vm_item.CorpID = pipe.CorpID;
                vm_item.ObjectType = IStation.ObjectType.PipeLine;
                vm_item.ObjectID = pipe.ID;
                vm_item.ObjectName = pipe.Name;
                vm_item.Spans = new List<EtaRunSpan>();
                vm_list.Add(vm_item);
                if (recordList == null || recordList.Count < 1)
                {
                    var vm_span = new EtaRunSpan();
                    vm_span.RunStatus = IStation.RunStatus.Shut;
                    vm_span.StartTime = input.Day.Date;
                    var end_time = input.Day.Date.AddDays(1);
                    if (end_time > DateTime.Now)
                        end_time = DateTime.Now;
                    vm_span.EndTime = end_time;
                    vm_span.Duration = (end_time - input.Day.Date).TotalSeconds;
                    vm_item.Spans.Add(vm_span);
                    continue;
                }

                var index = pipeLineList.IndexOf(pipe);
                foreach (var record in recordList)
                {
                    var run_status = record.RunningFlag[index];
                    var vm_span = vm_item.Spans.LastOrDefault();
                    if (vm_span == null)
                    {
                        vm_span = new EtaRunSpan();
                        vm_span.RunStatus = run_status;
                        vm_span.StartTime = record.DataTime;
                        vm_item.Spans.Add(vm_span);
                    }
                    if (run_status == vm_span.RunStatus)
                    {
                        var end_time = record.DataTime.AddSeconds(record.Duration);
                        if (end_time > input.Day.Date.AddDays(1))
                            end_time = input.Day.Date.AddDays(1);
                        vm_span.EndTime = end_time;
                        vm_span.Duration += record.Duration;
                    }
                    else
                    {
                        vm_span.EndTime = record.DataTime;
                        var vm_span_next = new EtaRunSpan();
                        vm_span_next.RunStatus = run_status;
                        vm_span_next.StartTime = record.DataTime;
                        var end_time = record.DataTime.AddSeconds(record.Duration);
                        if (end_time > input.Day.Date.AddDays(1))
                            end_time = input.Day.Date.AddDays(1);
                        vm_span_next.EndTime = end_time;
                        vm_span_next.Duration += record.Duration;
                        vm_item.Spans.Add(vm_span_next);
                    }
                }
            }

            return vm_list;
        }



    }
}