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;
using Microsoft.AspNetCore.Authorization;

namespace IStation.Application
{
    /// <summary>
    /// MonitorRecord
    /// </summary>
    [Route("Run/MonitorRecord")]
    [ApiDescriptionSettings("Run", Name = "监测记录", Order = 1000)]
    public class MonitorRecord_Controller:IDynamicApiController 
    {
        //服务
        private readonly Service.MonitorRecord _service = new Service.MonitorRecord();

        #region 获取最近记录

        #region 通过 MonitorPointID 获取最近记录

        /// <summary>
        /// 通过 MonitorPointID 获取最近一条数据(未进行单位转换，使用的是系统单位)
        /// </summary>
        [Route("GetLastRecordByMonitorPointID@V1.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointID_V1_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
        {
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointID 获取最近一条数据(不需要验证Token)(未进行单位转换，使用的是系统单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordByMonitorPointID@V1.1")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointID_V1_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
        {
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointID 获取最近一条数据(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [Route("GetLastRecordByMonitorPointID@V2.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointID_V2_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
        {
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
            if (list == null || list.Count < 1)
                return default;
            var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
            var vmList = list.Select(x =>
            {
                var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
                var vm = new MonitorRecordDto(x, signal);
                return vm;
            }).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointID 获取最近一条数据(不需要验证Token)(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordByMonitorPointID@V2.1")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointID_V2_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
        {
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID); 
            if (list == null || list.Count < 1)
                return default;
            var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
            var vmList = list.Select(x =>
            {
                var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
                var vm = new MonitorRecordDto(x, signal);
                return vm;
            }).ToList();
            return vmList;
        }

        #endregion

        #region 通过 MonitorPointIds 获取最近记录

        /// <summary>
        /// 通过 MonitorPointIds  获取最近一条数据(未进行单位转换，使用的是系统单位)
        /// </summary>
        [Route("GetLastRecordByMonitorPointIds@V1.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointIds_V1_0([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.MonitorPointIds);
            var list = _service.GetLastRecord(input.CorpID, ids);
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointIds  获取最近一条数据(不需要验证Token)(未进行单位转换，使用的是系统单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordByMonitorPointIds@V1.1")] 
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointIds_V1_1([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.MonitorPointIds);
            var list = _service.GetLastRecord(input.CorpID, ids);
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointIds  获取最近一条数据(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [Route("GetLastRecordByMonitorPointIds@V2.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointIds_V2_0([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.MonitorPointIds);
            var list = _service.GetLastRecord(input.CorpID, ids);
            if (list == null || list.Count < 1)
                return default;
            var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(input.CorpID, ids);
            var vmList = list.Select(x =>
            {
                var monitor = monitorList.Find(t => t.ID == x.MonitorPointID);
                var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
                var vm = new MonitorRecordDto(x, signal);
                return vm;
            }).ToList();

            return vmList;
        }

        /// <summary>
        /// 通过 MonitorPointIds  获取最近一条数据(不需要验证Token)(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordByMonitorPointIds@V2.1")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordByMonitorPointIds_V2_1([FromQuery][Required] MonitorPointIdsUnderCorpInput input) 
        {
            var ids = LongListHelper.ToList(input.MonitorPointIds);
            var list = _service.GetLastRecord(input.CorpID, ids);
            if (list == null || list.Count < 1)
                return default;
            var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(input.CorpID, ids);
            var vmList = list.Select(x =>
            {
                var monitor = monitorList.Find(t => t.ID == x.MonitorPointID);
                var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
                var vm = new MonitorRecordDto(x, signal);
                return vm;
            }).ToList();

            return vmList;
        }

        #endregion

        #region 通过 SignalID 获取最近数据

        /// <summary>
        /// 通过 SignalID  获取最近一条数据(未进行单位转换，使用的是系统单位)
        /// </summary>
        [Route("GetLastRecordBySignalID@V1.0")]
        [HttpGet]
        public MonitorRecordDto GetLastRecordBySignalID_V1_0([FromQuery][Required] SignalIDUnderCorpInput input)
        {
            var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
            if (model == null)
                return default;
            var vm = new MonitorRecordDto(model);
            return vm;
        }

        /// <summary>
        /// 通过 SignalID  获取最近一条数据(不需要验证Token)(未进行单位转换，使用的是系统单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordBySignalID@V1.1")]
        [HttpGet]
        public MonitorRecordDto GetLastRecordBySignalID_V1_1([FromQuery][Required] SignalIDUnderCorpInput input)
        {
            var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
            if (model == null)
                return default;
            var vm = new MonitorRecordDto(model);
            return vm;
        }

        /// <summary>
        /// 通过 SignalID  获取最近一条数据(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [Route("GetLastRecordBySignalID@V2.0")]
        [HttpGet]
        public MonitorRecordDto GetLastRecordBySignalID_V2_0([FromQuery][Required] SignalIDUnderCorpInput input)
        {
            var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID); 
            if (model == null)
                return default;
            var signal = new Service.Signal().GetExSignalTypeByID(input.CorpID,input.SignalID);
            var vm = new MonitorRecordDto(model, signal);
            return vm;
        }

        /// <summary>
        /// 通过 SignalID  获取最近一条数据(不需要验证Token)(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordBySignalID@V2.1")] 
        [HttpGet]
        public MonitorRecordDto GetLastRecordBySignalID_V2_1([FromQuery][Required] SignalIDUnderCorpInput input)
        {
            var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
            if (model == null)
                return default;
            var signal = new Service.Signal().GetExSignalTypeByID(input.CorpID, input.SignalID);
            var vm = new MonitorRecordDto(model, signal);
            return vm;
        }

        #endregion

        #region 通过 SignalIds  获取最近数据

        /// <summary>
        /// 通过 SignalIds  获取最近一条数据(未进行单位转换，使用的是系统单位)
        /// </summary>
        [Route("GetLastRecordBySignalIds@V1.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordBySignalIds_V1_0([FromQuery][Required] SignalIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.SignalIds);
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 SignalIds  获取最近一条数据(不需要验证Token)(未进行单位转换，使用的是系统单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordBySignalIds@V1.1")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordBySignalIds_V1_1([FromQuery][Required] SignalIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.SignalIds);
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids); 
            var vmList = list?.Select(x => new MonitorRecordDto(x)).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 SignalIds 获取最近一条数据(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [Route("GetLastRecordBySignalIds@V2.0")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordBySignalIds_V2_0([FromQuery][Required] SignalIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.SignalIds);
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
            if (list == null || list.Count < 1)
                return default;
            var signalList = new Service.Signal().GetExSignalTypeBySignalIds(input.CorpID, ids);
            var vmList = list.Select(x => new MonitorRecordDto(x, signalList?.Find(t => t.ID == x.SignalID))).ToList();
            return vmList;
        }

        /// <summary>
        /// 通过 SignalIds 获取最近一条数据(不需要验证Token)(已进行单位转换，使用的是信号显示单位)
        /// </summary>
        [AllowAnonymous]
        [Route("GetLastRecordBySignalIds@V2.1")]
        [HttpGet]
        public List<MonitorRecordDto> GetLastRecordBySignalIds_V2_1([FromQuery][Required] SignalIdsUnderCorpInput input)
        {
            var ids = LongListHelper.ToList(input.SignalIds);
            var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids); 
            if (list == null || list.Count < 1)
                return default;
            var signalList = new Service.Signal().GetExSignalTypeBySignalIds(input.CorpID, ids);
            var vmList = list.Select(x => new MonitorRecordDto(x, signalList?.Find(t => t.ID == x.SignalID))).ToList();
            return vmList;
        }

        #endregion

        #endregion

        #region 插入最近记录

        /// <summary>
        /// 插入最近一条记录
        /// </summary>
        [Route("InsertLastRecord@V1.0")]
        [HttpPost]
        public bool InsertLastRecord([Required] AddMonitorRecordInput input)
        {
            var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
            var data_time = DateTime.Now;
            var last_record_list = new Service.MonitorRecord().GetLastRecord(input.CorpID, input.MonitorPointID);
            var bol = false;
            switch (monitor.MonitorType)
            {
                case Model.eMonitorType.General:
                    {
                        var signal = monitor.SignalList?.FirstOrDefault();
                        if (signal != null)
                        {
                            var data_status = new List<string>();
                            var data_value = MonitorHandleHelper.Handle(monitor, signal, last_record_list?.FirstOrDefault(), input.SrcTime, input.SrcValue, data_status);
                            if (!string.IsNullOrEmpty(data_value))
                            {
                                var record = MonitorHandleHelper.BuildMonitorRecord(monitor, signal, input.SrcTime, input.SrcValue, data_time, data_value, data_status);
                                if (record != null)
                                {
                                    bol = _service.InsertLastRecord(record);
                                }
                            }
                        }
                    }
                    break;
                case Model.eMonitorType.Vibration:
                    {
                        var sub_record_list = AddMonitorSubRecordInput.ToList(input.SrcValue);
                        if (sub_record_list != null && sub_record_list.Count > 0)
                        {
                            var record_list = new List<Model.MonitorBasicRecord>();
                            foreach (var sub_record in sub_record_list)
                            {
                                var signal = monitor.SignalList?.FirstOrDefault(x => x.ID == sub_record.SignalID);
                                if (signal == null)
                                    continue;
                                var last_record = last_record_list?.FirstOrDefault(x => x.SignalID == sub_record.SignalID);
                                var data_status = new List<string>();
                                var data_value = MonitorHandleHelper.Handle(monitor, signal, last_record, input.SrcTime, sub_record.SrcValue, data_status);
                                if (string.IsNullOrEmpty(data_value))
                                    continue;
                                var record = MonitorHandleHelper.BuildMonitorRecord(monitor, signal, input.SrcTime, sub_record.SrcValue, data_time, data_value, data_status);
                                if (record == null)
                                    continue;
                                record_list.Add(record);
                            }
                            if (record_list.Count > 0)
                            {
                                bol = _service.InsertsLastRecord(monitor.CronType, record_list);
                            }
                        }
                    }
                    break;
                default: break;
            }

            return bol;
        }

        /// <summary>
        /// 插入最近多条记录（暂时只支持同一计划类型）
        /// </summary>
        [Route("InsertsLastRecord@V1.0")]
        [HttpPost]
        public bool InsertsLastRecord([Required] List<AddMonitorRecordInput> list)
        {
            var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
            if (corpIds.Count > 1)
            {
                return false;
            }
            var monitor_id_list = list.Select(x => x.MonitorPointID).Distinct().ToList();
            var monitor_list = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(corpIds[0], monitor_id_list);
            if (monitor_list == null || monitor_list.Count < 1)
            {
                return false;
            }
            var cron_type_list = monitor_list.Select(x => x.CronType).Distinct().ToList();
            if (cron_type_list.Count > 1)
            {
                return false;
            }
            var last_record_total_list = _service.GetLastRecord(corpIds[0], monitor_id_list);
            var data_time = DateTime.Now;
            var record_list = new List<Model.MonitorBasicRecord>();
            foreach (var item in list)
            {
                var monitor = monitor_list.Find(x => x.ID == item.MonitorPointID);
                if (monitor == null)
                    continue;
                var last_record_list = last_record_total_list?.Where(x => x.MonitorPointID == item.MonitorPointID).ToList();
                switch (monitor.MonitorType)
                {
                    case Model.eMonitorType.General:
                        {
                            var signal = monitor.SignalList?.FirstOrDefault();
                            if (signal != null)
                            {
                                var data_status = new List<string>();
                                var data_value = MonitorHandleHelper.Handle(monitor, signal, last_record_list?.FirstOrDefault(), item.SrcTime, item.SrcValue, data_status);
                                if (!string.IsNullOrEmpty(data_value))
                                {
                                    var record = MonitorHandleHelper.BuildMonitorRecord(monitor, signal, item.SrcTime, item.SrcValue, data_time, data_value, data_status);
                                    if (record != null)
                                    {
                                        record_list.Add(record);
                                    }
                                }
                            }
                        }
                        break;
                    case Model.eMonitorType.Vibration:
                        {
                            var sub_record_list = AddMonitorSubRecordInput.ToList(item.SrcValue);
                            if (sub_record_list != null && sub_record_list.Count > 0)
                            {
                                foreach (var sub_record in sub_record_list)
                                {
                                    var signal = monitor.SignalList?.FirstOrDefault(x => x.ID == sub_record.SignalID);
                                    if (signal == null)
                                        continue;
                                    var last_record = last_record_list?.FirstOrDefault(x => x.SignalID == sub_record.SignalID);
                                    var data_status = new List<string>();
                                    var data_value = MonitorHandleHelper.Handle(monitor, signal, last_record, item.SrcTime, sub_record.SrcValue, data_status);
                                    if (string.IsNullOrEmpty(data_value))
                                        continue;
                                    var record = MonitorHandleHelper.BuildMonitorRecord(monitor, signal, item.SrcTime, sub_record.SrcValue, data_time, data_value, data_status);
                                    if (record == null)
                                        continue;
                                    record_list.Add(record);
                                }
                            }
                        }
                        break;
                    default: break;
                }
            }
            if (record_list.Count < 1)
            {
                return false;
            }
            var bol = _service.InsertsLastRecord(cron_type_list[0], record_list);
            return bol;
        } 

        #endregion

    }
}