using Furion.DatabaseAccessor;
using Furion.DatabaseAccessor.Extensions;
using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.FriendlyException;
using iWare.Wms.Core;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using System.Linq.Dynamic.Core;

namespace iWare.Wms.Application
{
    /// <summary>
    /// 设备状态分析服务
    /// </summary>
    [ApiDescriptionSettings("数据查询服务", Name = "EquipmentStatusAnalyse", Order = 100)]
    [Route("api/[Controller]")]
    public class EquipmentStatusAnalyseService : IEquipmentStatusAnalyseService, IDynamicApiController, ITransient
    {
        private readonly IRepository<EquipmentStatusAnalyse,MasterDbContextLocator> _equipmentStatusAnalyseRep;
        private readonly IRepository<SysDictType, MasterDbContextLocator> _sysDictTypeRep;
        private readonly IRepository<SysDictData, MasterDbContextLocator> _sysDictDataRep;
        private readonly IRepository<EquipmentWorkingLog, MasterDbContextLocator> _equipmentWorkingLog;

        /// <summary>
        /// 设备状态分析构造
        /// </summary>
        /// <param name="equipmentStatusAnalyseRep"></param>
        /// <param name="sysDictTypeRep"></param>
        /// <param name="sysDictDataRep"></param>
        public EquipmentStatusAnalyseService(
            IRepository<EquipmentStatusAnalyse,MasterDbContextLocator> equipmentStatusAnalyseRep,
            IRepository<SysDictType, MasterDbContextLocator> sysDictTypeRep,
            IRepository<SysDictData, MasterDbContextLocator> sysDictDataRep,
            IRepository<EquipmentWorkingLog, MasterDbContextLocator> equipmentWorkingLog
        )
        {
            _equipmentStatusAnalyseRep = equipmentStatusAnalyseRep;
            _sysDictTypeRep = sysDictTypeRep;
            _sysDictDataRep = sysDictDataRep;
            _equipmentWorkingLog = equipmentWorkingLog;
        }

        /// <summary>
        /// 获取设备报警分析
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("GetEquipmentAlertAnalyse")]
        public async Task<List<GetEquipmentAlertAnalyseOutput>> GetEquipmentAlertAnalyse([FromQuery] EquipmentStatusAnalyseSearch input)
        {
            DateTime currertTime = input.StartTime;
            List<GetEquipmentAlertAnalyseOutput> outPutLst = new List<GetEquipmentAlertAnalyseOutput>();
            
            while (currertTime < input.EndTime)
            {
                GetEquipmentAlertAnalyseOutput output = new GetEquipmentAlertAnalyseOutput();
                output.CurrentYearMonth = currertTime.ToString("yyyy-MM");

                // 数据来源于设备运行历史表信息   统计每月的次数   然后故障结束时间-故障开始时间    查询条件为：故障开始时间
                List<EquipmentWorkingLog> workingLogsLst = await _equipmentWorkingLog.DetachedEntities
                    .Where(x => x.EquipmentID == input.EquipmentId)
                    .Where(x => x.FailureStartTime >= currertTime.AddDays(1-currertTime.Day))
                    .Where(x => x.FailureStartTime < currertTime.AddDays(1 - currertTime.Day).AddMonths(1))
                    .ToListAsync();
                // 获取设备报警次数
                output.AlertNumber = workingLogsLst.Count;

                // 获取设备报警持续时间
                output.AlertDuration =Convert.ToDecimal(workingLogsLst.Sum(x => x.FailureEndTime?.Second - x.FailureStartTime?.Second)/3600);

                // 月份加一
                currertTime = currertTime.AddMonths(1);

                outPutLst.Add(output);
            }

            return outPutLst;
        }


        /// <summary>
        /// 获取设备状态占比分析
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("GetEquipmentStatuRatioAnalyse")]
        public async Task<List<GetEquipmentStatuRatioAnalyseOutput>> GetEquipmentStatuRatioAnalyse([FromQuery] EquipmentStatusAnalyseSearch input)
        {
            DateTime currertTime = input.StartTime;
            List<GetEquipmentStatuRatioAnalyseOutput> outPutLst = new List<GetEquipmentStatuRatioAnalyseOutput>();
            while (currertTime < input.EndTime)
            {
                GetEquipmentStatuRatioAnalyseOutput outPut = new GetEquipmentStatuRatioAnalyseOutput();
                outPut.CurrentYearMonth = currertTime.ToString("yyyy-MM");

                List<GetEquipmentStatuRatioAnalyseDetailOutput> detailOutputsLst = new List<GetEquipmentStatuRatioAnalyseDetailOutput>();

                // 获取设备状态
                var equipmentStatuInfoLst = await _sysDictDataRep.DetachedEntities
                .Join(_sysDictTypeRep.DetachedEntities, u => u.TypeId, e => e.Id, (u, e) => new { u, e })
                .Where(x => (x.e.Code.Equals("equipment_state")))
                .Select(s => new EquipmentStatuOutput
                {
                   EquipmentState = s.u.Code,
                   //EquipmentStateName = s.u.Value
                })
                .ProjectToType<EquipmentStatuOutput>()
                .ToListAsync();

                // 循环设备状态列表
                foreach (var item in equipmentStatuInfoLst)
                {
                    // 整理数据，追加返回集合列表中
                    GetEquipmentStatuRatioAnalyseDetailOutput detailOutput = new GetEquipmentStatuRatioAnalyseDetailOutput();
                    detailOutput.EquipmentStatu = item.EquipmentState;
                    detailOutput.EquipmentStatuName = item.EquipmentStateName;

                    // 获取当前月份设备状态占比的值
                    var equipmentStatusAnalyses = await _equipmentStatusAnalyseRep.DetachedEntities
                                         .Where(!string.IsNullOrEmpty(input.EquipmentId), u => u.EquipmentId == input.EquipmentId)
                                         .OrderBy(PageInputOrder.OrderBuilder<EquipmentStatusAnalyseSearch>(input))
                                         .ProjectToType<EquipmentStatusAnalyseOutput>()
                                         .ToADPagedListAsync(input.PageNo, input.PageSize);

                    // 设备占比分析值
                    detailOutput.RatioAnalyseValue = 1;

                    detailOutputsLst.Add(detailOutput);
                }

                // 设备占比分析明细集合列表追加
                outPut.getEquipmentStatuRatioLst = detailOutputsLst;
                // 月份加一
                currertTime = currertTime.AddMonths(1);

                outPutLst.Add(outPut);
            } 

            
            return outPutLst;
        }
    }
}