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 = "KnifeToolEquipmentMonitor", Order = 102)]
    [Route("api/[Controller]")]
    public class KnifeToolEquipmentMonitorService : IKnifeToolEquipmentMonitorService, IDynamicApiController, ITransient
    {
        private readonly IRepository<KnifeToolEquipmentMonitor,MasterDbContextLocator> _knifeToolEquipmentMonitorRep;
        private readonly IRepository<EquipmentBaseInfo, MasterDbContextLocator> _equipmentBaseInfoRep;
        private readonly IRepository<KnifeToolEquipmentInfo, MasterDbContextLocator> _knifeToolEquipmentInfoRep;


        public KnifeToolEquipmentMonitorService(
            IRepository<KnifeToolEquipmentMonitor,MasterDbContextLocator> knifeToolEquipmentMonitorRep,
IRepository<EquipmentBaseInfo, MasterDbContextLocator> equipmentBaseInfoRep,
            IRepository<KnifeToolEquipmentInfo, MasterDbContextLocator> knifeToolEquipmentInfoRep
        )
        {
            _knifeToolEquipmentMonitorRep = knifeToolEquipmentMonitorRep;
            _equipmentBaseInfoRep = equipmentBaseInfoRep;
            _knifeToolEquipmentInfoRep = knifeToolEquipmentInfoRep;
        }

        /// <summary>
        /// 分页查询设备刀具实时监控信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("page")]
        public async Task<PageResult<KnifeToolEquipmentMonitorOutput>> Page([FromQuery] KnifeToolEquipmentMonitorSearch input)
        {
            var knifeToolEquipmentMonitors = await (from knife in _knifeToolEquipmentMonitorRep.DetachedEntities
                                                    join eqbaseinfo in _equipmentBaseInfoRep.DetachedEntities on knife.EquipmentID equals eqbaseinfo.EquipmentId into eqjoinEmpty
                                                    from eqbaseinfo2 in eqjoinEmpty.DefaultIfEmpty()
                                                    join info in _knifeToolEquipmentInfoRep.DetachedEntities on knife.EquipmentID equals info.EquipmentID into infoempty
                                                    from infoempty2 in infoempty.DefaultIfEmpty()
                                                    where knife.EquipmentID ==  (string.IsNullOrEmpty(input.EquipmentID)? knife.EquipmentID: input.EquipmentID)
                                                    where knife.WorkingProcedure == (string.IsNullOrEmpty(input.WorkingProcedure) ? knife.WorkingProcedure : input.WorkingProcedure)
                                                    where infoempty2.KnifeToolID == (string.IsNullOrEmpty(input.KnifeToolID) ? infoempty2.KnifeToolID : input.KnifeToolID)
                                                    select new KnifeToolEquipmentMonitorOutput
                                                    {
                                                        EquipmentID= knife.EquipmentID,
                                                        EquipmentName= eqbaseinfo2.EquipmentName,
                                                        WorkingProcedure = knife.WorkingProcedure,
                                                        Remarks1 = knife.Remarks1,
                                                        Remarks2 = knife.Remarks2,
                                                        Remarks3 = knife.Remarks3,
                                                        Id = knife.Id,
                                                    }).Distinct()
                                     .OrderBy(PageInputOrder.OrderBuilder<KnifeToolEquipmentMonitorSearch>(input))
                                     .ProjectToType<KnifeToolEquipmentMonitorOutput>()
                                     .ToADPagedListAsync(input.PageNo, input.PageSize);
            return knifeToolEquipmentMonitors;

        }

        /// <summary>
        /// 增加设备刀具实时监控信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("add")]
        public async Task Add(AddKnifeToolEquipmentMonitorInput input)
        {
            var isExist = await _knifeToolEquipmentMonitorRep.AnyAsync(u => u.EquipmentID == input.EquipmentID&&u.WorkingProcedure==input.WorkingProcedure, false);
            if (isExist) throw Oops.Oh($"设备[{input.EquipmentID}]工序[{input.WorkingProcedure}]在系统中已存在，不允许重复添加！");
            var knifeToolEquipmentMonitor = input.Adapt<KnifeToolEquipmentMonitor>();
            await _knifeToolEquipmentMonitorRep.InsertAsync(knifeToolEquipmentMonitor);
        }

        /// <summary>
        /// 删除设备刀具实时监控信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("delete")]
        public async Task Delete(DeleteKnifeToolEquipmentMonitorInput input)
        {
            var knifeToolEquipmentMonitor = await _knifeToolEquipmentMonitorRep.FirstOrDefaultAsync(u => u.Id == input.Id);
            await _knifeToolEquipmentMonitorRep.DeleteAsync(knifeToolEquipmentMonitor);
        }

        /// <summary>
        /// 更新设备刀具实时监控信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("edit")]
        public async Task Update(UpdateKnifeToolEquipmentMonitorInput input)
        {
            var isExist = await _knifeToolEquipmentMonitorRep.AnyAsync(u => u.Id == input.Id, false);
            if (!isExist) throw Oops.Oh(ErrorCode.D3000);

            var knifeToolEquipmentMonitor = input.Adapt<KnifeToolEquipmentMonitor>();
            await _knifeToolEquipmentMonitorRep.UpdateAsync(knifeToolEquipmentMonitor,ignoreNullValues:true);
        }

        /// <summary>
        /// 获取设备刀具实时监控信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("detail")]
        public async Task<KnifeToolEquipmentMonitorOutput> Get([FromQuery] QueryeKnifeToolEquipmentMonitorInput input)
        {
            return (await _knifeToolEquipmentMonitorRep.DetachedEntities.FirstOrDefaultAsync(u => u.Id == input.Id)).Adapt<KnifeToolEquipmentMonitorOutput>();
        }

        /// <summary>
        /// 获取设备刀具实时监控信息列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("list")]
        public async Task<List<KnifeToolEquipmentMonitorOutput>> List([FromQuery] KnifeToolEquipmentMonitorInput input)
        {
            return await _knifeToolEquipmentMonitorRep.DetachedEntities.ProjectToType<KnifeToolEquipmentMonitorOutput>().ToListAsync();
        }    

    }
}