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 = "IExWarehouse", Order = 100)]
    //[Route("api/[Controller]")]
    public class ExWarehouseService : IExWarehouseService, IDynamicApiController, ITransient
    {
        private readonly IRepository<WmsContainer, MasterDbContextLocator> _wmsContainerRep;
        private readonly IRepository<WmsMaterial, MasterDbContextLocator> _wmsMaterialRep;
        private readonly IRepository<WmsMaterialContainer, MasterDbContextLocator> _wmsMaterialContainerRep;
        private readonly IRepository<WmsArea, MasterDbContextLocator> _wmsAreaRep;
        private readonly IRepository<WmsPlace, MasterDbContextLocator> _wmsPlaceRep;
        private readonly IRepository<WmsTask, MasterDbContextLocator> _wmsTaskRep;
        private readonly IRepository<WmsMaterialStock, MasterDbContextLocator> _wmsMaterialStockRep;
        private readonly IRepository<WmsContainerPlace, MasterDbContextLocator> _wmsContainerPlaceRep;


        public ExWarehouseService(
            IRepository<WmsContainer, MasterDbContextLocator> wmsContainerRep,
            IRepository<WmsMaterial, MasterDbContextLocator> wmsMaterialRep,
            IRepository<WmsMaterialContainer, MasterDbContextLocator> wmsMaterialContainerRep,
            IRepository<WmsArea, MasterDbContextLocator> wmsAreaRep,
            IRepository<WmsPlace, MasterDbContextLocator> wmsPlaceRep,
            IRepository<WmsTask, MasterDbContextLocator> wmsTaskRep,
            IRepository<WmsMaterialStock, MasterDbContextLocator> wmsMaterialStockRep,
            IRepository<WmsContainerPlace, MasterDbContextLocator> wmsContainerPlaceRep
        )
        {
            _wmsContainerRep = wmsContainerRep;
            _wmsMaterialRep = wmsMaterialRep;
            _wmsMaterialContainerRep = wmsMaterialContainerRep;
            _wmsAreaRep = wmsAreaRep;
            _wmsPlaceRep = wmsPlaceRep;
            _wmsTaskRep = wmsTaskRep;
            _wmsMaterialStockRep = wmsMaterialStockRep;
            _wmsContainerPlaceRep = wmsContainerPlaceRep;
        }

        /// <summary>
        /// 分页查询库存表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("page")]
        public async Task<PageResult<WmsMaterialStockOutput>> Page([FromQuery] WmsMaterialStockSearch input)
        {
            var wmsMaterialStocks = await _wmsMaterialStockRep.DetachedEntities
                                     .Where(!string.IsNullOrEmpty(input.Materialno), u => EF.Functions.Like(u.MaterialNo, $"%{input.Materialno.Trim()}%"))
                                     .Where(input.Materialtype != null, u => u.MaterialType == input.Materialtype)
                                     .Where(!string.IsNullOrEmpty(input.Materialbatch), u => EF.Functions.Like(u.MaterialBatch, $"%{input.Materialbatch.Trim()}%"))
                                     .Where(!string.IsNullOrEmpty(input.Materialname), u => EF.Functions.Like(u.MaterialName, $"%{input.Materialname.Trim()}%"))
                                     .Where(!string.IsNullOrEmpty(input.Materialspec), u => EF.Functions.Like(u.MaterialSpec, $"%{input.Materialspec.Trim()}%"))
                                     .Where(input.Inspectionmethod != null, u => u.InspectionMethod == input.Inspectionmethod)
                                     .Where(input.Unittype != null, u => u.UnitType == input.Unittype)
                                     .Where(input.Unitno != null, u => u.UnitNo == input.Unitno)
                                     .Where(u => u.StockNumber != 0)
                                     .Where(!string.IsNullOrEmpty(input.Placecode), u => u.PlaceCode == input.Placecode)
                                     .Where(!string.IsNullOrEmpty(input.Containercode), u => u.ContainerCode == input.Containercode)
                                     .OrderBy(PageInputOrder.OrderBuilder(input))
                                     .ProjectToType<WmsMaterialStockOutput>()
                                     .ToADPagedListAsync(input.PageNo, input.PageSize);
            return wmsMaterialStocks;
        }

        /// <summary>
        /// 手动出库
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("ManualWare")]
        [UnitOfWork]
        public async Task ManualWare(ExManualWarehouseInput input)
        {
            //检查是正在出库
            var isExit = await _wmsTaskRep.AnyAsync(n => n.TaskStatus != Core.Enum.TaskStatus.WANCHENG && n.ContainerCode==input.Containercode);
            if (isExit) throw Oops.Oh("存在出库任务!");
            //检查库位信息
            var placeModel = await _wmsPlaceRep.DetachedEntities.Where(p => p.PlaceCode == input.Placecode).ProjectToType<WmsPlace>().FirstOrDefaultAsync();
            if (placeModel == null) throw Oops.Oh("库位不存在!");
            if (placeModel.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
            if (placeModel.PlaceStatus != Core.Enum.PlaceStatus.CUNHUO) throw Oops.Oh("库位异常货!");

            //容器信息
            var containerModel = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == input.Containercode && n.ContainerStatus == Core.Enum.ContainerStatus.KUWEI);
            if (containerModel == null) throw Oops.Oh("托盘信息不存在!");

            //库位容器关系
            var containerPlaceModel = await _wmsContainerPlaceRep.FirstOrDefaultAsync(p => p.ContainerCode == containerModel.ContainerCode
               && p.ContainerId == containerModel.Id && p.PlaceCode == placeModel.PlaceCode && p.PlaceId == placeModel.Id
               && p.ContainerPlaceStatus == CommonStatus.ENABLE);
            if (containerPlaceModel == null) throw Oops.Oh("库位容器关系不存在!");

            //库存物料信息
            var materialStockModelList = await _wmsMaterialStockRep.Where(n => n.ContainerCode == input.Containercode
            && n.PlaceCode == input.Placecode).ToListAsync();
            if (materialStockModelList.Count == 0) throw Oops.Oh("物料信息不存在!");

            //关系对应出库的物料
            var materialContainersList = await _wmsMaterialContainerRep.Where(p => p.ContainerCode == containerModel.ContainerCode
                && p.BindStatus == CommonStatus.ENABLE).ToListAsync();

            //单据号
            var orderNo = "N/A";
            //创建任务
            if (materialContainersList.Count > 0) orderNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
            var takmodel = new WmsTask()
            {
                TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
                TaskModel = Core.Enum.TaskModel.SHOUDONG,
                TaskType = Core.Enum.TaskType.CHUKU,
                TaskLevel = 1,
                TaskStatus = Core.Enum.TaskStatus.WANCHENG,
                ContainerCode = input.Containercode,
                SourcePlace = input.Placecode,
                Aisle = placeModel.Aisle,
                ToPlace = "N/A",
                AreaName = placeModel.WmsArea.AreaName,
                OrderNo = orderNo,
            };
            await _wmsTaskRep.InsertAsync(takmodel);
            //托盘状态
            if (orderNo == "N/A") containerModel.ContainerStatus = Core.Enum.ContainerStatus.KOUXIAN;
            else containerModel.ContainerStatus = Core.Enum.ContainerStatus.ZUPANG;
            await _wmsContainerRep.UpdateAsync(containerModel);
            //组盘信息
            //入库时组盘信息逻辑删除
            foreach (var item in materialContainersList)
            {
                //修改
                item.BindStatus = CommonStatus.DELETED;
                await _wmsMaterialContainerRep.UpdateAsync(item);
            }

            foreach (var item in materialContainersList)
            {
                //新增出库绑定记录  禁用
                var bindentranceModel = new WmsMaterialContainer()
                {
                    ContainerId = item.ContainerId,
                    ContainerCode = item.ContainerCode,
                    MaterialName = item.MaterialName,
                    MaterialNo = item.MaterialNo,
                    MaterialBatch = item.MaterialBatch,
                    MaterialSpec = item.MaterialSpec,
                    MaterialId = item.MaterialId,
                    BindQuantity = item.BindQuantity,
                    BindStatus = CommonStatus.DISABLE,
                    OrderNo = orderNo,
                };
                await _wmsMaterialContainerRep.InsertNowAsync(bindentranceModel);

                //新增组盘绑定记录 正常
                var newbindentranceModel = new WmsMaterialContainer()
                {
                    ContainerId = item.ContainerId,
                    ContainerCode = item.ContainerCode,
                    MaterialName = item.MaterialName,
                    MaterialNo = item.MaterialNo,
                    MaterialBatch = item.MaterialBatch,
                    MaterialSpec = item.MaterialSpec,
                    MaterialId = item.MaterialId,
                    BindQuantity = item.BindQuantity,
                    BindStatus = CommonStatus.ENABLE,
                    OrderNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
                };
                await _wmsMaterialContainerRep.InsertNowAsync(newbindentranceModel);
            }
            //库位
            placeModel.PlaceStatus = Core.Enum.PlaceStatus.KONGXIAN;
            placeModel.EmptyContainer = YesOrNot.N;
            await _wmsPlaceRep.UpdateAsync(placeModel);
            //修改库存
            foreach (var item in materialStockModelList)
            {
                item.PlaceCode = "N/A";
                item.AreaId = 0;
                item.StockNumber = 0;
                await _wmsMaterialStockRep.UpdateAsync(item);
            }
            //删除托盘库位关系
            containerPlaceModel.ContainerPlaceStatus = CommonStatus.DELETED;
            await _wmsContainerPlaceRep.UpdateAsync(containerPlaceModel);
        }


        /// <summary>
        /// 自动出库
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("AutoWare")]
        [UnitOfWork]
        public async Task AutoWare(ExAutoWarehouseInput input)
        {
            //检查是正在出库
            var isExit = await _wmsTaskRep.AnyAsync(n => n.TaskStatus != Core.Enum.TaskStatus.WANCHENG && n.ContainerCode == input.Containercode);
            if (isExit) throw Oops.Oh("存在出库任务!");
            //检查库位信息
            var placeModel = await _wmsPlaceRep.DetachedEntities.Where(p => p.PlaceCode == input.Placecode).ProjectToType<WmsPlace>().FirstOrDefaultAsync();
            if (placeModel == null) throw Oops.Oh("库位不存在!");
            if (placeModel.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
            if (placeModel.PlaceStatus != Core.Enum.PlaceStatus.CUNHUO) throw Oops.Oh("库位异常货!");

            //容器信息
            var containerModel = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == input.Containercode && n.ContainerStatus == Core.Enum.ContainerStatus.KUWEI);
            if (containerModel == null) throw Oops.Oh("托盘信息不存在!");

            //库位容器关系
            var containerPlaceModel = await _wmsContainerPlaceRep.FirstOrDefaultAsync(p => p.ContainerCode == containerModel.ContainerCode
               && p.ContainerId == containerModel.Id && p.PlaceCode == placeModel.PlaceCode && p.PlaceId == placeModel.Id && p.ContainerPlaceStatus == CommonStatus.ENABLE);
            if (containerPlaceModel == null) throw Oops.Oh("库位容器关系不存在!");

            //物料信息
            var materialStockList = await _wmsMaterialStockRep.Where(n => n.ContainerCode == input.Containercode
            && n.PlaceCode == input.Placecode).ToListAsync();
            if (materialStockList.Count == 0) throw Oops.Oh("物料信息不存在!");

            //关系对应出库的物料
            var materialContainersList = await _wmsMaterialContainerRep.Where(n => n.ContainerCode == input.Containercode && n.BindStatus == CommonStatus.ENABLE).ToListAsync();


            //单据信息
            var orderNo = "N/A";
            if (materialContainersList.Count > 0) orderNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString();

            //创建任务
            var takmodel = new WmsTask()
            {
                TaskNo = Yitter.IdGenerator.YitIdHelper.NextId().ToString(),
                TaskModel = Core.Enum.TaskModel.ZIDONG,
                TaskType = Core.Enum.TaskType.CHUKU,
                TaskLevel = 1,
                Aisle=placeModel.Aisle,
                TaskStatus = Core.Enum.TaskStatus.WEIZHIXING,
                ContainerCode = input.Containercode,
                SourcePlace = input.Placecode,
                ToPlace = input.Entrance,
                AreaName = placeModel.WmsArea.AreaName,
                OrderNo = orderNo,
            };
            await _wmsTaskRep.InsertAsync(takmodel);
            //组盘信息
            foreach (var item in materialContainersList)
            {
                //修改
                item.BindStatus = CommonStatus.DISABLE;
                await _wmsMaterialContainerRep.UpdateAsync(item);
                //新增
                var bindentranceModel = new WmsMaterialContainer()
                {
                    ContainerId = item.ContainerId,
                    ContainerCode = item.ContainerCode,
                    MaterialName = item.MaterialName,
                    MaterialNo = item.MaterialNo,
                    MaterialBatch = item.MaterialBatch,
                    MaterialSpec = item.MaterialSpec,
                    MaterialId = item.MaterialId,
                    BindQuantity = item.BindQuantity,
                    BindStatus = CommonStatus.ENABLE,
                    OrderNo = orderNo,
                };
                await _wmsMaterialContainerRep.InsertNowAsync(bindentranceModel);
            }
            //库位
            placeModel.PlaceStatus = Core.Enum.PlaceStatus.DAICHU;
            await _wmsPlaceRep.UpdateAsync(placeModel);
           
        }

    }
}