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 Microsoft.AspNetCore.Http;
using Furion.DependencyInjection;
using Microsoft.AspNetCore.Authorization;
using Furion.DataEncryption;
using AutoMapper;
using System.Text;

namespace IStation.Application
{
    /// <summary>
    /// 波形存储接口(城投的恩普特 市南泵站专用)
    /// </summary>
    [AllowAnonymous]
    [Route("smi/vibration/zept")]
    [ApiDescriptionSettings("Vibration", Name = "城投恩普特振动", Order = 1100)]
    public class Smi_Zept_VibrationController : IDynamicApiController
    {


        /// <summary>
        /// 单个添加 
        /// </summary>
        [Route("SingleInsert")]
        public bool SingleInsert([Required]AddSmiExpertVibrationRecordInput input)
        {
            //转化为内部使用对象
            var model = input.Adapt<AddSmiExpertVibrationRecordInput, Model.SmiExpertVibrationRecord>();

            //写redis缓存
            var redisHelper = new RedisCache.SmiExpertVibrationRecord();
            redisHelper.SetLastRecord(model);

            if (ConfigHelper.Smi_Expert_IsWriteLog)
            {
                LogHelper.Info($"恩普特写入Redis一条振动数据，ObjectId:{model.ObjectId}");
            }

            //获取配置
            var configure = new Service.DataDockingConfigure().GetByID(ConfigHelper.Smi_Expert_CorpID, ConfigHelper.Smi_Expert_ConfigureID);
            if (configure != null)
            {
                if (configure.Mappers != null && configure.Mappers.Count > 0)
                {
                    var mapper = configure.Mappers.Find(t => t.SignId == model.ObjectId);
                    if (mapper != null)
                    {
                        var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(configure.CorpID, mapper.SysId);
                        if (monitor != null)
                        {
                            if (monitor.MonitorType == Model.eMonitorType.Vibration)
                            {
                                var receive = new Model.MonitorDataDockingReceiveRecord();
                                receive.SysId = monitor.ID;
                                receive.RecordType = monitor.MonitorType;
                                receive.SrcTime = model.SrcTime;
                                receive.DataStatus = model.DataStatus;

                                //子项列表
                                var receiveSubList = new List<Model.MonitorDataDockingReceiveSubRecord>();

                                //配置
                                var signal_config = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.配置));
                                if (signal_config != null)
                                {
                                    var config = model.Adapt<Model.SmiExpertVibrationRecord, Model.SmiExpertVibrationConfig>();
                                    var config_json = JsonHelper.Object2Json(config);
                                    var config_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                    config_sub.SysId = signal_config.ID;
                                    config_sub.SrcValue = config_json;
                                    receiveSubList.Add(config_sub);
                                }

                                //转速
                                var signal_rpm = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.转速));
                                if (signal_rpm != null)
                                {
                                    var rpm_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                    rpm_sub.SysId = signal_rpm.ID;
                                    rpm_sub.SrcValue = model.Rpm.ToString();
                                    receiveSubList.Add(rpm_sub);
                                }

                                //直流量
                                var signal_ic = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.直流量));
                                if (signal_ic != null)
                                {
                                    var ic_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                    ic_sub.SysId = signal_ic.ID;
                                    ic_sub.SrcValue = model.DcValue.ToString();
                                    receiveSubList.Add(ic_sub);
                                }

                                //频率
                                var signal_hz = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.频率));
                                if (signal_hz != null)
                                {
                                    var hz_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                    hz_sub.SysId = signal_hz.ID;
                                    hz_sub.SrcValue = model.Frequency.ToString();
                                    receiveSubList.Add(hz_sub);
                                }

                                //波形
                                var signal_wave = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.波形));
                                if (signal_wave != null)
                                {
                                    var wave_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                    wave_sub.SysId = signal_wave.ID;
                                    wave_sub.SrcValue = model.Wave;
                                    receiveSubList.Add(wave_sub);
                                }

                                receive.SrcValue = Model.MonitorDataDockingReceiveSubRecord.ToJson(receiveSubList);

                                var queueHelper = new RabbitMqQueueHelper();
                                var bol = queueHelper.Push(ConfigHelper.DataDockingQueueName, new Model.MonitorDataDockingCorpRecord()
                                {
                                    CorpID = configure.CorpID,
                                    ConfigureID = configure.ID,
                                    Records = new List<Model.MonitorDataDockingReceiveRecord>() { receive }
                                });
                                if (bol)
                                {
                                    if (ConfigHelper.Smi_Expert_IsWriteLog)
                                    {
                                        LogHelper.Info($"恩普特推入通道一条振动数据，ObjectId:{model.ObjectId},SysId:{monitor.ID}");
                                    }
                                    return true;
                                }
                            }
                        }
                    }
                }
            }
            return false;
        }

        /// <summary>
        /// 批量添加
        /// </summary>
        [Route("BulkInsert")]
        public bool BulkInsert([Required]List<AddSmiExpertVibrationRecordInput> inputList)
        {
            if (inputList == null || inputList.Count < 1)
                return false;
            //转化为内部使用对象
            var modelList = inputList.Select(x => x.Adapt<AddSmiExpertVibrationRecordInput, Model.SmiExpertVibrationRecord>()).ToList();

            //写redis缓存
            var redisHelper = new RedisCache.SmiExpertVibrationRecord();
            redisHelper.SetLastRecord(modelList);

            if (ConfigHelper.Smi_HangTian_IsWriteLog)
            {
                LogHelper.Info($"恩普特写入Redis {modelList.Count} 条振动数据");
            }

            //获取配置
            var configure = new Service.DataDockingConfigure().GetByID(ConfigHelper.Smi_Expert_CorpID, ConfigHelper.Smi_Expert_ConfigureID);
            if (configure != null)
            {
                if (configure.Mappers != null && configure.Mappers.Count > 0)
                {
                    var receiveList = new List<Model.MonitorDataDockingReceiveRecord>();
                    foreach (var model in modelList)
                    {
                        var mapper = configure.Mappers.Find(t => t.SignId == model.ObjectId);
                        if (mapper != null)
                        {
                            var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(configure.CorpID, mapper.SysId);
                            if (monitor != null)
                            {
                                if (monitor.MonitorType == Model.eMonitorType.Vibration)
                                {
                                    var receive = new Model.MonitorDataDockingReceiveRecord();
                                    receive.SysId = monitor.ID;
                                    receive.RecordType = monitor.MonitorType;
                                    receive.SrcTime = model.SrcTime;
                                    receive.DataStatus = model.DataStatus;

                                    //子项列表
                                    var receiveSubList = new List<Model.MonitorDataDockingReceiveSubRecord>();

                                    //配置
                                    var signal_config = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.配置));
                                    if (signal_config != null)
                                    {
                                        var config = model.Adapt<Model.SmiExpertVibrationRecord, Model.SmiExpertVibrationConfig>();
                                        var config_json = JsonHelper.Object2Json(config);
                                        var config_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                        config_sub.SysId = signal_config.ID;
                                        config_sub.SrcValue = config_json;
                                        receiveSubList.Add(config_sub);
                                    }

                                    //转速
                                    var signal_rpm = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.转速));
                                    if (signal_rpm != null)
                                    {
                                        var rpm_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                        rpm_sub.SysId = signal_rpm.ID;
                                        rpm_sub.SrcValue = model.Rpm.ToString();
                                        receiveSubList.Add(rpm_sub);
                                    }

                                    //直流量
                                    var signal_ic = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.直流量));
                                    if (signal_ic != null)
                                    {
                                        var ic_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                        ic_sub.SysId = signal_ic.ID;
                                        ic_sub.SrcValue = model.DcValue.ToString();
                                        receiveSubList.Add(ic_sub);
                                    }

                                    //频率
                                    var signal_hz = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.频率));
                                    if (signal_hz != null)
                                    {
                                        var hz_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                        hz_sub.SysId = signal_hz.ID;
                                        hz_sub.SrcValue = model.Frequency.ToString();
                                        receiveSubList.Add(hz_sub);
                                    }

                                    //波形
                                    var signal_wave = monitor.SignalList.Find(t => t.Flags != null && t.Flags.Contains(LogicFlags.波形));
                                    if (signal_wave != null)
                                    {
                                        var wave_sub = new Model.MonitorDataDockingReceiveSubRecord();
                                        wave_sub.SysId = signal_wave.ID;
                                        wave_sub.SrcValue = model.Wave;
                                        receiveSubList.Add(wave_sub);
                                    }

                                    receive.SrcValue = Model.MonitorDataDockingReceiveSubRecord.ToJson(receiveSubList);
                                    receiveList.Add(receive);
                                }
                            }
                        }
                    }
                    if (receiveList.Count > 0)
                    {
                        var queueHelper = new RabbitMqQueueHelper();
                        var bol = queueHelper.Push(ConfigHelper.DataDockingQueueName, new Model.MonitorDataDockingCorpRecord()
                        {
                            CorpID = configure.CorpID,
                            ConfigureID = configure.ID,
                            Records = receiveList
                        });
                        if (bol)
                        {
                            if (ConfigHelper.Smi_Expert_IsWriteLog)
                            {
                                LogHelper.Info($"恩普特推入通道 {receiveList.Count} 条振动数据");
                            }
                            return true;
                        }
                    }
                }
            }

            return false;
        }

        /// <summary>
        /// 通过 ObjectId 查询最近(已过时)
        /// </summary>
        [Route("QueryLastRecordByObjectId")]
        [HttpGet]
        public List<SmiExpertVibrationRecordDto> QueryLastRecordByObjectId(string ProductId, string ObjectId)
        {
            if (string.IsNullOrEmpty(ObjectId))
            {
                return default;
            }
            var objectIds = ObjectId.Split(',');
            if (objectIds == null || objectIds.Count() < 1)
            {
                return default;
            }
            var redisHelper = new RedisCache.SmiExpertVibrationRecord();
            var modelList = redisHelper.GetLastRecord(objectIds);
            if (ConfigHelper.Smi_Expert_IsWriteLog)
            {
                LogHelper.Info($"恩普特通过ObjectId： {ObjectId} 获取 {(modelList == null ? 0 : modelList.Count)} 条");
            }
            var dtoList = modelList?.Select(x => x.Adapt<Model.SmiExpertVibrationRecord, SmiExpertVibrationRecordDto>()).ToList();
            return dtoList;
        }

        /// <summary>
        /// 通过 ProductId 查询最近
        /// </summary>
        [Route("QueryLastRecordByProductId")]
        [HttpGet]
        public List<SmiExpertVibrationRecordDto> QueryLastRecordByProductId(string ProductId)
        {
            if (string.IsNullOrEmpty(ProductId))
            {
                return default;
            }

            var redisHelper = new RedisCache.SmiExpertVibrationRecord();
            var modelList = redisHelper.GetLastRecordStartWith(ProductId);
            if (ConfigHelper.Smi_Expert_IsWriteLog)
            {
                LogHelper.Info($"恩普特通过ProductId： {ProductId} 获取 {(modelList == null ? 0 : modelList.Count)} 条");
            }
            var dtoList = modelList?.Select(x => x.Adapt<Model.SmiExpertVibrationRecord, SmiExpertVibrationRecordDto>()).ToList();
            return dtoList;
        }














    }
}