基础数据新增实体

payne

2024-04-23 6097dd7e7d8a736729c4b8be66ea107eb740d9f1

 iWare_RawMaterialWarehouse_Wms/Admin.NET.Application/Service/Common/BindEntrance/BindEntranceService.cs

@@ -1,518 +1,518 @@
using Furion.DatabaseAccessor;
using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using Yitter.IdGenerator;
using Admin.NET.Core;
//using Furion.DatabaseAccessor;
//using Furion.DependencyInjection;
//using Furion.DynamicApiController;
//using Furion.FriendlyException;
//using Mapster;
//using Microsoft.AspNetCore.Mvc;
//using Microsoft.EntityFrameworkCore;
//using Yitter.IdGenerator;
//using Admin.NET.Core;

namespace Admin.NET.Application
{
    /// <summary>
    /// 入库管理服务
    /// </summary>
    [ApiDescriptionSettings("自己的业务", Name = "BindEntrance", Order = 100)]
    [Route("api/[Controller]")]
    public class BindEntranceService : IDynamicApiController, ITransient
    {
        private readonly IRepository<WmsArea, MasterDbContextLocator> _wmsAreaRep;
        private readonly IRepository<WmsPlace, MasterDbContextLocator> _wmsPlaceRep;
        private readonly IRepository<WmsTask, MasterDbContextLocator> _wmsTaskRep;
        private readonly IRepository<WmsContainer, MasterDbContextLocator> _wmsContainerRep;
        private readonly IRepository<WmsContainerPlace, MasterDbContextLocator> _wmsContainerPlaceRep;
        private readonly IRepository<WmsMaterial, MasterDbContextLocator> _wmsMaterialRep;
        private readonly IRepository<WmsMaterialStock, MasterDbContextLocator> _wmsMaterialStockRep;
        private readonly IRepository<WmsMaterialContainer, MasterDbContextLocator> _wmsMaterialContainerRep;
//namespace Admin.NET.Application
//{
//    /// <summary>
//    /// 入库管理服务
//    /// </summary>
//    [ApiDescriptionSettings("自己的业务", Name = "BindEntrance", Order = 100)]
//    [Route("api/[Controller]")]
//    public class BindEntranceService : IDynamicApiController, ITransient
//    {
//        private readonly IRepository<WmsArea, MasterDbContextLocator> _wmsAreaRep;
//        private readonly IRepository<WmsPlace, MasterDbContextLocator> _wmsPlaceRep;
//        private readonly IRepository<WmsTask, MasterDbContextLocator> _wmsTaskRep;
//        private readonly IRepository<WmsContainer, MasterDbContextLocator> _wmsContainerRep;
//        private readonly IRepository<WmsContainerPlace, MasterDbContextLocator> _wmsContainerPlaceRep;
//        private readonly IRepository<WmsMaterial, MasterDbContextLocator> _wmsMaterialRep;
//        private readonly IRepository<WmsMaterialStock, MasterDbContextLocator> _wmsMaterialStockRep;
//        private readonly IRepository<WmsMaterialContainer, MasterDbContextLocator> _wmsMaterialContainerRep;

        /// <summary>
        /// 构造函数
        /// </summary>
        public BindEntranceService(
                        IRepository<WmsArea, MasterDbContextLocator> wmsAreaRep,
                        IRepository<WmsPlace, MasterDbContextLocator> wmsPlaceRep,
                        IRepository<WmsTask, MasterDbContextLocator> wmsTaskRep,
                        IRepository<WmsContainer, MasterDbContextLocator> wmsContainerRep,
                        IRepository<WmsContainerPlace, MasterDbContextLocator> wmsContainerPlaceRep,
                        IRepository<WmsMaterial, MasterDbContextLocator> wmsMaterialRep,
                        IRepository<WmsMaterialStock, MasterDbContextLocator> wmsMaterialStockRep,
                        IRepository<WmsMaterialContainer, MasterDbContextLocator> wmsMaterialContainerRep)
        {
            this._wmsAreaRep = wmsAreaRep;
            this._wmsPlaceRep = wmsPlaceRep;
            this._wmsTaskRep = wmsTaskRep;
            this._wmsContainerRep = wmsContainerRep;
            this._wmsContainerPlaceRep = wmsContainerPlaceRep;
            this._wmsMaterialRep = wmsMaterialRep;
            this._wmsMaterialStockRep = wmsMaterialStockRep;
            this._wmsMaterialContainerRep = wmsMaterialContainerRep;
        }
//        /// <summary>
//        /// 构造函数
//        /// </summary>
//        public BindEntranceService(
//                        IRepository<WmsArea, MasterDbContextLocator> wmsAreaRep,
//                        IRepository<WmsPlace, MasterDbContextLocator> wmsPlaceRep,
//                        IRepository<WmsTask, MasterDbContextLocator> wmsTaskRep,
//                        IRepository<WmsContainer, MasterDbContextLocator> wmsContainerRep,
//                        IRepository<WmsContainerPlace, MasterDbContextLocator> wmsContainerPlaceRep,
//                        IRepository<WmsMaterial, MasterDbContextLocator> wmsMaterialRep,
//                        IRepository<WmsMaterialStock, MasterDbContextLocator> wmsMaterialStockRep,
//                        IRepository<WmsMaterialContainer, MasterDbContextLocator> wmsMaterialContainerRep)
//        {
//            this._wmsAreaRep = wmsAreaRep;
//            this._wmsPlaceRep = wmsPlaceRep;
//            this._wmsTaskRep = wmsTaskRep;
//            this._wmsContainerRep = wmsContainerRep;
//            this._wmsContainerPlaceRep = wmsContainerPlaceRep;
//            this._wmsMaterialRep = wmsMaterialRep;
//            this._wmsMaterialStockRep = wmsMaterialStockRep;
//            this._wmsMaterialContainerRep = wmsMaterialContainerRep;
//        }

        /// <summary>
        /// 托盘查询组盘物料
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpGet("getcontainer")]
        [UnifyResult(typeof(BindEntranceOutput))]
        public async Task<object> GetContainer([FromQuery] BindEntranceInput input)
        {
            var bindEntranceOutputModel = new BindEntranceOutput();
//        /// <summary>
//        /// 托盘查询组盘物料
//        /// </summary>
//        /// <param name="input"></param>
//        /// <returns></returns>
//        [HttpGet("getcontainer")]
//        [UnifyResult(typeof(BindEntranceOutput))]
//        public async Task<object> GetContainer([FromQuery] BindEntranceInput input)
//        {
//            var bindEntranceOutputModel = new BindEntranceOutput();

            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == input.ContainerCode && n.ContainerStatus != ContainerStatus.JINYONG);
            if (wmsContainer == null)
            {
                var newWmsContainer = new WmsContainerDto();
                newWmsContainer.ContainerCode = input.ContainerCode;
                newWmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
                newWmsContainer.ContainerType = ContainerType.SULIAO;
//            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(n => n.ContainerCode == input.ContainerCode && n.ContainerStatus != ContainerStatus.JINYONG);
//            if (wmsContainer == null)
//            {
//                var newWmsContainer = new WmsContainerDto();
//                newWmsContainer.ContainerCode = input.ContainerCode;
//                newWmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
//                newWmsContainer.ContainerType = ContainerType.SULIAO;

                bindEntranceOutputModel.ContainerCode = input.ContainerCode;
                bindEntranceOutputModel.WmsContainer = newWmsContainer;
//                bindEntranceOutputModel.ContainerCode = input.ContainerCode;
//                bindEntranceOutputModel.WmsContainer = newWmsContainer;

                if (wmsContainer != null)
                {
                    var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
                    if (isWmsTask) return XnRestfulResultProvider.RESTfulMesaage("周转箱号存在未完成任务!");
//                if (wmsContainer != null)
//                {
//                    var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
//                    if (isWmsTask) return XnRestfulResultProvider.RESTfulMesaage("周转箱号存在未完成任务!");

                    bindEntranceOutputModel.WmsContainer = wmsContainer.Adapt<WmsContainerDto>();
                    bindEntranceOutputModel.ContainerCode = wmsContainer.ContainerCode;
//                    bindEntranceOutputModel.WmsContainer = wmsContainer.Adapt<WmsContainerDto>();
//                    bindEntranceOutputModel.ContainerCode = wmsContainer.ContainerCode;

                    // 周转箱号组盘状态
                    if (wmsContainer.ContainerStatus == ContainerStatus.ZUPANG)
                    {
                        bindEntranceOutputModel.WmsMaterials = await _wmsMaterialContainerRep
                            .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ProjectToType<GetMaterialContainerOutput>().ToListAsync();
//                    // 周转箱号组盘状态
//                    if (wmsContainer.ContainerStatus == ContainerStatus.ZUPANG)
//                    {
//                        bindEntranceOutputModel.WmsMaterials = await _wmsMaterialContainerRep
//                            .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ProjectToType<GetMaterialContainerOutput>().ToListAsync();

                        return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
                    }
                    // 周转箱号库位状态
                    if (wmsContainer.ContainerStatus == ContainerStatus.KUWEI)
                    {
                        // 查询周转箱号与库位关系
                        var wmsContainerPlace = await _wmsContainerPlaceRep.FirstOrDefaultAsync(u => u.ContainerId == wmsContainer.Id && u.ContainerCode == wmsContainer.ContainerCode);
//                        return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
//                    }
//                    // 周转箱号库位状态
//                    if (wmsContainer.ContainerStatus == ContainerStatus.KUWEI)
//                    {
//                        // 查询周转箱号与库位关系
//                        var wmsContainerPlace = await _wmsContainerPlaceRep.FirstOrDefaultAsync(u => u.ContainerId == wmsContainer.Id && u.ContainerCode == wmsContainer.ContainerCode);

                        if (wmsContainerPlace != null) bindEntranceOutputModel.PlaceCode = wmsContainerPlace.PlaceCode;
//                        if (wmsContainerPlace != null) bindEntranceOutputModel.PlaceCode = wmsContainerPlace.PlaceCode;

                        return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
                    }
                }
            }
            return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
        }
//                        return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
//                    }
//                }
//            }
//            return XnRestfulResultProvider.RESTfulResult(bindEntranceOutputModel);
//        }

        /// <summary>
        /// 扫码获取物料
        /// </summary>
        /// <returns></returns>
        [HttpGet("GetMaterial")]
        [UnifyResult(typeof(MaterialOutput))]
        public async Task<object> GetMaterial([FromQuery] GetMaterialInput input)
        {
            var material = new MaterialOutput();
            material.MaterialName = "胶合板";
            material.MaterialNo = "JHB20110101";
            material.MaterialId = 43214325321513;
            material.MaterialBatch = "DIYIPICI001";
            material.MaterialType = MaterialType.BAOZHUANGCAILIAO;
            material.InspectionMethod = MaterialInspection.MIANJIAN;
            material.MaterialSpec = "";
            material.MaterialDensity = "";
            material.MaterialUnit = "";
            material.LesWorkshopSection = LesWorkshopSection.CNC;
            return XnRestfulResultProvider.RESTfulResult(material);
//        /// <summary>
//        /// 扫码获取物料
//        /// </summary>
//        /// <returns></returns>
//        [HttpGet("GetMaterial")]
//        [UnifyResult(typeof(MaterialOutput))]
//        public async Task<object> GetMaterial([FromQuery] GetMaterialInput input)
//        {
//            var material = new MaterialOutput();
//            material.MaterialName = "胶合板";
//            material.MaterialNo = "JHB20110101";
//            material.MaterialId = 43214325321513;
//            material.MaterialBatch = "DIYIPICI001";
//            material.MaterialType = MaterialType.BAOZHUANGCAILIAO;
//            material.InspectionMethod = MaterialInspection.MIANJIAN;
//            material.MaterialSpec = "";
//            material.MaterialDensity = "";
//            material.MaterialUnit = "";
//            material.LesWorkshopSection = LesWorkshopSection.CNC;
//            return XnRestfulResultProvider.RESTfulResult(material);

        }
//        }


        /// <summary>
        ///  组盘
        /// </summary>
        /// <returns></returns>
        [HttpPost("AutoWare")]
        public async Task AutoWare(WarehousingInput input)
        {
            // 根据托盘号查询托盘号信息是否已存在
            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
            if (wmsContainer == null)
            {
                // 不存在则添加托盘号信息
                wmsContainer = new WmsContainer
                {
                    ContainerCode = input.ContainerCode,
                    ContainerType = ContainerType.SULIAO,
                    ContainerStatus = ContainerStatus.KOUXIAN,
                    AssetNo = "N/A",
                    ErpNo = "N/A"
                };
                await _wmsContainerRep.InsertNowAsync(wmsContainer);
            }
            // 查询是否任务已存在
            var isExit = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
            if (isExit) throw Oops.Oh("托盘号存在未完成任务中!");
//        /// <summary>
//        ///  组盘
//        /// </summary>
//        /// <returns></returns>
//        [HttpPost("AutoWare")]
//        public async Task AutoWare(WarehousingInput input)
//        {
//            // 根据托盘号查询托盘号信息是否已存在
//            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
//            if (wmsContainer == null)
//            {
//                // 不存在则添加托盘号信息
//                wmsContainer = new WmsContainer
//                {
//                    ContainerCode = input.ContainerCode,
//                    ContainerType = ContainerType.SULIAO,
//                    ContainerStatus = ContainerStatus.KOUXIAN,
//                    AssetNo = "N/A",
//                    ErpNo = "N/A"
//                };
//                await _wmsContainerRep.InsertNowAsync(wmsContainer);
//            }
//            // 查询是否任务已存在
//            var isExit = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
//            if (isExit) throw Oops.Oh("托盘号存在未完成任务中!");

            // 查询已组盘信息
            var wmsMaterialContainerList = await _wmsMaterialContainerRep
                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
            await _wmsMaterialContainerRep.DeleteAsync(wmsMaterialContainerList);
            var orderNo = "N/A";
            if (input.WmsMaterials.Count > 0)
            {
                wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
                orderNo = YitIdHelper.NextId().ToString();
                await _wmsContainerRep.UpdateAsync(wmsContainer);
            }
            // 创建新组盘记录
            foreach (var item in input.WmsMaterials)
            {
                //创建组盘记录
                var bindentranceModel = new WmsMaterialContainer();
                bindentranceModel.ContainerId = wmsContainer.Id;
                bindentranceModel.ContainerCode = wmsContainer.ContainerCode;
                bindentranceModel.MaterialNo = item.MaterialNo;
                bindentranceModel.MaterialId = 478183507525701;
                bindentranceModel.MaterialBatch = item.MaterialBatch;
                bindentranceModel.BindQuantity = 1;
                bindentranceModel.BindStatus = CommonStatus.ENABLE;
                bindentranceModel.OrderNo = orderNo;
                bindentranceModel.MaterialName = item.MaterialName;
                bindentranceModel.MaterialDensity = "N/A";
                await _wmsMaterialContainerRep.InsertNowAsync(bindentranceModel);
            }
        }
//            // 查询已组盘信息
//            var wmsMaterialContainerList = await _wmsMaterialContainerRep
//                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
//            await _wmsMaterialContainerRep.DeleteAsync(wmsMaterialContainerList);
//            var orderNo = "N/A";
//            if (input.WmsMaterials.Count > 0)
//            {
//                wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
//                orderNo = YitIdHelper.NextId().ToString();
//                await _wmsContainerRep.UpdateAsync(wmsContainer);
//            }
//            // 创建新组盘记录
//            foreach (var item in input.WmsMaterials)
//            {
//                //创建组盘记录
//                var bindentranceModel = new WmsMaterialContainer();
//                bindentranceModel.ContainerId = wmsContainer.Id;
//                bindentranceModel.ContainerCode = wmsContainer.ContainerCode;
//                bindentranceModel.MaterialNo = item.MaterialNo;
//                bindentranceModel.MaterialId = 478183507525701;
//                bindentranceModel.MaterialBatch = item.MaterialBatch;
//                bindentranceModel.BindQuantity = 1;
//                bindentranceModel.BindStatus = CommonStatus.ENABLE;
//                bindentranceModel.OrderNo = orderNo;
//                bindentranceModel.MaterialName = item.MaterialName;
//                bindentranceModel.MaterialDensity = "N/A";
//                await _wmsMaterialContainerRep.InsertNowAsync(bindentranceModel);
//            }
//        }



        /// <summary>
        /// 自动入库
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("automaticWarehousing")]
        [UnitOfWork]
        public async Task AutomaticWarehousing(WarehousingInput input)
        {
            // 查询混合料库区信息
            var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
            // 根据料箱号查询周转箱号信息是否已存在
            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
            if (wmsContainer == null)
            {
                // 不存在则添加周转箱号信息
                wmsContainer = new WmsContainer
                {
                    ContainerCode = input.ContainerCode,
                    ContainerType = ContainerType.JINSHU,
                    ContainerStatus = ContainerStatus.KOUXIAN,
                    AssetNo = "N/A",
                    ErpNo = "N/A"
                };
                await _wmsContainerRep.InsertNowAsync(wmsContainer);
            }
            else
            {
                // 更新周转箱号状态为“库位”
                wmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
                await _wmsContainerRep.UpdateAsync(wmsContainer);
            }
//        /// <summary>
//        /// 自动入库
//        /// </summary>
//        /// <param name="input"></param>
//        /// <returns></returns>
//        [HttpPost("automaticWarehousing")]
//        [UnitOfWork]
//        public async Task AutomaticWarehousing(WarehousingInput input)
//        {
//            // 查询混合料库区信息
//            var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
//            // 根据料箱号查询周转箱号信息是否已存在
//            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
//            if (wmsContainer == null)
//            {
//                // 不存在则添加周转箱号信息
//                wmsContainer = new WmsContainer
//                {
//                    ContainerCode = input.ContainerCode,
//                    ContainerType = ContainerType.JINSHU,
//                    ContainerStatus = ContainerStatus.KOUXIAN,
//                    AssetNo = "N/A",
//                    ErpNo = "N/A"
//                };
//                await _wmsContainerRep.InsertNowAsync(wmsContainer);
//            }
//            else
//            {
//                // 更新周转箱号状态为“库位”
//                wmsContainer.ContainerStatus = ContainerStatus.KOUXIAN;
//                await _wmsContainerRep.UpdateAsync(wmsContainer);
//            }

            // 查询周转箱号是否已存在任务
            var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
            if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");
//            // 查询周转箱号是否已存在任务
//            var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
//            if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");

            // 删除已组盘信息
            var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
//            // 删除已组盘信息
//            var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
//                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();

            foreach (var item in oldWmsMaterialContainerList)
            {
                await _wmsMaterialContainerRep.DeleteAsync(item);
            }
//            foreach (var item in oldWmsMaterialContainerList)
//            {
//                await _wmsMaterialContainerRep.DeleteAsync(item);
//            }

            // 组盘单据 默认空料箱单据
            var source = ""; //定义入库来源
            var orderNo = "N/A";
            if (input.WmsMaterials.Count > 0)
            {
                wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
                orderNo = YitIdHelper.NextId().ToString();
                await _wmsContainerRep.UpdateAsync(wmsContainer);
                source = "物料";
            }
            else
            {
                source = "空托";
            }
            // 查询物料Id
            var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");
//            // 组盘单据 默认空料箱单据
//            var source = ""; //定义入库来源
//            var orderNo = "N/A";
//            if (input.WmsMaterials.Count > 0)
//            {
//                wmsContainer.ContainerStatus = ContainerStatus.ZUPANG;
//                orderNo = YitIdHelper.NextId().ToString();
//                await _wmsContainerRep.UpdateAsync(wmsContainer);
//                source = "物料";
//            }
//            else
//            {
//                source = "空托";
//            }
//            // 查询物料Id
//            var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");

            // 创建新组盘记录
            foreach (var item in input.WmsMaterials)
            {
                var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
                wmsMaterialContainer.OrderNo = orderNo;
                wmsMaterialContainer.ContainerId = wmsContainer.Id;
                wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
                wmsMaterialContainer.MaterialId = wmsMaterial.Id;
                wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
                await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
            }
//            // 创建新组盘记录
//            foreach (var item in input.WmsMaterials)
//            {
//                var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
//                wmsMaterialContainer.OrderNo = orderNo;
//                wmsMaterialContainer.ContainerId = wmsContainer.Id;
//                wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
//                wmsMaterialContainer.MaterialId = wmsMaterial.Id;
//                wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
//                await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
//            }


            //if (input.Source == RuKuSourceEnum.KONGTUO)
            //else if (input.Source == RuKuSourceEnum.WULIAO)
//            //if (input.Source == RuKuSourceEnum.KONGTUO)
//            //else if (input.Source == RuKuSourceEnum.WULIAO)

            //创建巷道分配
            var wmsPlace = await _wmsPlaceRep.Where(u => u.PlaceStatus == PlaceStatus.KONGXIAN).ToListAsync();
            var one = wmsPlace.Where(s => s.Aisle==1).ToList().Count;
            var two = wmsPlace.Where(s => s.Aisle == 2).ToList().Count;
            var three = wmsPlace.Where(s => s.Aisle == 3).ToList().Count;
            var Aisle = 0;
            if (one >= two && one >= three)
            {
                Aisle = 1;
            }
            else if (two >= one && two >= three)
            {
                Aisle = 2;
            }
            else
            {
                Aisle = 3;
            }
//            //创建巷道分配
//            var wmsPlace = await _wmsPlaceRep.Where(u => u.PlaceStatus == PlaceStatus.KONGXIAN).ToListAsync();
//            var one = wmsPlace.Where(s => s.Aisle==1).ToList().Count;
//            var two = wmsPlace.Where(s => s.Aisle == 2).ToList().Count;
//            var three = wmsPlace.Where(s => s.Aisle == 3).ToList().Count;
//            var Aisle = 0;
//            if (one >= two && one >= three)
//            {
//                Aisle = 1;
//            }
//            else if (two >= one && two >= three)
//            {
//                Aisle = 2;
//            }
//            else
//            {
//                Aisle = 3;
//            }

            string taskNo = "RUKU"+ DateTime.Today.ToString("yyyyMMdd");
            var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
            if (wmsTaskModel == null)
            {
                taskNo = taskNo + "0001";
            }
            else
            {
                //获取流水号最大的数据
                var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
                taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
            }
//            string taskNo = "RUKU"+ DateTime.Today.ToString("yyyyMMdd");
//            var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
//            if (wmsTaskModel == null)
//            {
//                taskNo = taskNo + "0001";
//            }
//            else
//            {
//                //获取流水号最大的数据
//                var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
//                taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
//            }

            // 创建任务
            var takmodel = new WmsTask()
            {
                TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
                TaskModel = TaskModel.QUANZIDONG,
                TaskType = TaskType.RUKU,
                TaskLevel = 1,
                Aisle = Aisle,
                TaskStatus = TaskStatusEnum.WEIZHIXING,
                ContainerCode = wmsContainer.ContainerCode,
                SourcePlace = "入库口",
                ToPlace = "",
                AreaName = wmsArea != null ? wmsArea.AreaName : "",
                OrderNo = orderNo,
                Description = source, //入库来源
                TaskDodeviceStatus = TaskDodeviceStatusEnum.WZX,
                IsRead = true
            };
            await _wmsTaskRep.InsertAsync(takmodel);
        }
//            // 创建任务
//            var takmodel = new WmsTask()
//            {
//                TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
//                TaskModel = TaskModel.QUANZIDONG,
//                TaskType = TaskType.RUKU,
//                TaskLevel = 1,
//                Aisle = Aisle,
//                TaskStatus = TaskStatusEnum.WEIZHIXING,
//                ContainerCode = wmsContainer.ContainerCode,
//                SourcePlace = "入库口",
//                ToPlace = "",
//                AreaName = wmsArea != null ? wmsArea.AreaName : "",
//                OrderNo = orderNo,
//                Description = source, //入库来源
//                TaskDodeviceStatus = TaskDodeviceStatusEnum.WZX,
//                IsRead = true
//            };
//            await _wmsTaskRep.InsertAsync(takmodel);
//        }





        /// <summary>
        /// 人工入库
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("manualWarehousing")]
        [UnitOfWork]
        public async Task ManualWarehousing(WarehousingInput input)
        {
            // 查询混合料库区信息
            var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
            // 根据料箱号查询周转箱号信息是否已存在
            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
            if (wmsContainer == null)
            {
                // 不存在则添加周转箱号信息
                wmsContainer = new WmsContainer
                {
                    ContainerCode = input.ContainerCode,
                    ContainerType = ContainerType.JINSHU,
                    ContainerStatus = ContainerStatus.KUWEI,
                    AssetNo = "N/A",
                    ErpNo = "N/A"
                };
                await _wmsContainerRep.InsertNowAsync(wmsContainer);
            }
            else
            {
                // 更新周转箱号状态为“库位”
                wmsContainer.ContainerStatus = ContainerStatus.KUWEI;
                await _wmsContainerRep.UpdateAsync(wmsContainer);
            }
//        /// <summary>
//        /// 人工入库
//        /// </summary>
//        /// <param name="input"></param>
//        /// <returns></returns>
//        [HttpPost("manualWarehousing")]
//        [UnitOfWork]
//        public async Task ManualWarehousing(WarehousingInput input)
//        {
//            // 查询混合料库区信息
//            var wmsArea = await _wmsAreaRep.FirstOrDefaultAsync(u => u.AreaName.Contains("绝缘立库"));
//            // 根据料箱号查询周转箱号信息是否已存在
//            var wmsContainer = await _wmsContainerRep.FirstOrDefaultAsync(u => u.ContainerCode == input.ContainerCode);
//            if (wmsContainer == null)
//            {
//                // 不存在则添加周转箱号信息
//                wmsContainer = new WmsContainer
//                {
//                    ContainerCode = input.ContainerCode,
//                    ContainerType = ContainerType.JINSHU,
//                    ContainerStatus = ContainerStatus.KUWEI,
//                    AssetNo = "N/A",
//                    ErpNo = "N/A"
//                };
//                await _wmsContainerRep.InsertNowAsync(wmsContainer);
//            }
//            else
//            {
//                // 更新周转箱号状态为“库位”
//                wmsContainer.ContainerStatus = ContainerStatus.KUWEI;
//                await _wmsContainerRep.UpdateAsync(wmsContainer);
//            }

            // 查询周转箱号是否已存在任务
            var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
            if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");
//            // 查询周转箱号是否已存在任务
//            var isWmsTask = await _wmsTaskRep.AnyAsync(p => p.ContainerCode == wmsContainer.ContainerCode && p.TaskStatus != TaskStatusEnum.WANCHENG);
//            if (isWmsTask) throw Oops.Oh("周转箱号存在未完成任务中!");

            // 删除已组盘信息
            var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();
//            // 删除已组盘信息
//            var oldWmsMaterialContainerList = await _wmsMaterialContainerRep
//                .Where(p => p.ContainerCode == wmsContainer.ContainerCode && p.BindStatus == CommonStatus.ENABLE).ToListAsync();

            foreach (var item in oldWmsMaterialContainerList)
            {
                await _wmsMaterialContainerRep.DeleteAsync(item);
            }
//            foreach (var item in oldWmsMaterialContainerList)
//            {
//                await _wmsMaterialContainerRep.DeleteAsync(item);
//            }

            // 查询库位信息 随机分配库位
            var wmsPlace = new WmsPlace();
            if (string.IsNullOrEmpty(input.PlaceCode))
                wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.Islock == YesOrNot.N && u.PlaceStatus == PlaceStatus.KONGXIAN);
            else
                wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.PlaceCode == input.PlaceCode);
            if (wmsPlace == null) throw Oops.Oh("库位不存在!");
            if (wmsPlace.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
            if (wmsPlace.PlaceStatus != PlaceStatus.KONGXIAN) throw Oops.Oh("库位已存货!");
            // 更新库位状态为“存货”
            wmsPlace.PlaceStatus = PlaceStatus.CUNHUO;
//            // 查询库位信息 随机分配库位
//            var wmsPlace = new WmsPlace();
//            if (string.IsNullOrEmpty(input.PlaceCode))
//                wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.Islock == YesOrNot.N && u.PlaceStatus == PlaceStatus.KONGXIAN);
//            else
//                wmsPlace = await _wmsPlaceRep.FirstOrDefaultAsync(u => u.AreaId == wmsArea.Id && u.PlaceCode == input.PlaceCode);
//            if (wmsPlace == null) throw Oops.Oh("库位不存在!");
//            if (wmsPlace.Islock == YesOrNot.Y) throw Oops.Oh("库位被锁定!");
//            if (wmsPlace.PlaceStatus != PlaceStatus.KONGXIAN) throw Oops.Oh("库位已存货!");
//            // 更新库位状态为“存货”
//            wmsPlace.PlaceStatus = PlaceStatus.CUNHUO;

            // 组盘单据 默认空料箱单据
            var orderNo = "N/A";
            var source = ""; //定义入库来源
            if (input.WmsMaterials.Count > 0)
            {
                orderNo = YitIdHelper.NextId().ToString();
                source = "物料";
            }
            else
            {
                wmsPlace.EmptyContainer = YesOrNot.Y;  //是否空托
                source = "空托";
            }
            // 查询物料Id
            var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");
//            // 组盘单据 默认空料箱单据
//            var orderNo = "N/A";
//            var source = ""; //定义入库来源
//            if (input.WmsMaterials.Count > 0)
//            {
//                orderNo = YitIdHelper.NextId().ToString();
//                source = "物料";
//            }
//            else
//            {
//                wmsPlace.EmptyContainer = YesOrNot.Y;  //是否空托
//                source = "空托";
//            }
//            // 查询物料Id
//            var wmsMaterial = await _wmsMaterialRep.FirstOrDefaultAsync(u => u.MaterialNo == "N/A" && u.MaterialName == "N/A" && u.MaterialBatch == "N/A");

            // 创建新组盘记录
            foreach (var item in input.WmsMaterials)
            {
                var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
                wmsMaterialContainer.OrderNo = orderNo;
                wmsMaterialContainer.ContainerId = wmsContainer.Id;
                wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
                wmsMaterialContainer.MaterialId = wmsMaterial.Id;
                wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;
//            // 创建新组盘记录
//            foreach (var item in input.WmsMaterials)
//            {
//                var wmsMaterialContainer = item.Adapt<WmsMaterialContainer>();
//                wmsMaterialContainer.OrderNo = orderNo;
//                wmsMaterialContainer.ContainerId = wmsContainer.Id;
//                wmsMaterialContainer.ContainerCode = wmsContainer.ContainerCode;
//                wmsMaterialContainer.MaterialId = wmsMaterial.Id;
//                wmsMaterialContainer.BindStatus = CommonStatus.ENABLE;

                await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
            }
//                await _wmsMaterialContainerRep.InsertNowAsync(wmsMaterialContainer);
//            }

            string taskNo = "RUKU" + DateTime.Today.ToString("yyyyMMdd");
            var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
            if (wmsTaskModel == null)
            {
                taskNo = taskNo + "0001";
            }
            else
            {
                //获取流水号最大的数据
                var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
                taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
            }
//            string taskNo = "RUKU" + DateTime.Today.ToString("yyyyMMdd");
//            var wmsTaskModel = await _wmsTaskRep.DetachedEntities.FirstOrDefaultAsync(u => EF.Functions.Like(u.TaskNo, $"%{taskNo}%"));
//            if (wmsTaskModel == null)
//            {
//                taskNo = taskNo + "0001";
//            }
//            else
//            {
//                //获取流水号最大的数据
//                var maxSerialNumber = await _wmsTaskRep.MaxAsync(t => t.TaskNo);
//                taskNo = Comm.GenerateNewInvoiceNumber(maxSerialNumber, 1);
//            }

            // 创建任务
            var takmodel = new WmsTask()
            {
                TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
                TaskModel = TaskModel.SHOUDONG,
                TaskType = TaskType.RUKU,
                TaskLevel = 1,
                Aisle = wmsPlace.Aisle,
                TaskStatus = TaskStatusEnum.WANCHENG,
                ContainerCode = wmsContainer.ContainerCode,
                SourcePlace = "入库口",
                ToPlace = wmsPlace.PlaceCode,
                AreaName = wmsArea != null ? wmsArea.AreaName : "",
                OrderNo = orderNo,
                Description = source, //入库来源
                TaskDodeviceStatus = TaskDodeviceStatusEnum.W,
                UpdatedTime = DateTime.Now,
            };
            await _wmsTaskRep.InsertAsync(takmodel);
//            // 创建任务
//            var takmodel = new WmsTask()
//            {
//                TaskNo = taskNo,//YitIdHelper.NextId().ToString(),
//                TaskModel = TaskModel.SHOUDONG,
//                TaskType = TaskType.RUKU,
//                TaskLevel = 1,
//                Aisle = wmsPlace.Aisle,
//                TaskStatus = TaskStatusEnum.WANCHENG,
//                ContainerCode = wmsContainer.ContainerCode,
//                SourcePlace = "入库口",
//                ToPlace = wmsPlace.PlaceCode,
//                AreaName = wmsArea != null ? wmsArea.AreaName : "",
//                OrderNo = orderNo,
//                Description = source, //入库来源
//                TaskDodeviceStatus = TaskDodeviceStatusEnum.W,
//                UpdatedTime = DateTime.Now,
//            };
//            await _wmsTaskRep.InsertAsync(takmodel);

            // 创建托盘号库位关系表
            var wmsContainerPlaceModel = new WmsContainerPlace()
            {
                PlaceId = wmsPlace.Id,
                PlaceCode = wmsPlace.PlaceCode,
                ContainerId = wmsContainer.Id,
                ContainerCode = wmsContainer.ContainerCode,
                ContainerPlaceStatus = CommonStatus.ENABLE
            };
            await _wmsContainerPlaceRep.InsertAsync(wmsContainerPlaceModel);
//            // 创建托盘号库位关系表
//            var wmsContainerPlaceModel = new WmsContainerPlace()
//            {
//                PlaceId = wmsPlace.Id,
//                PlaceCode = wmsPlace.PlaceCode,
//                ContainerId = wmsContainer.Id,
//                ContainerCode = wmsContainer.ContainerCode,
//                ContainerPlaceStatus = CommonStatus.ENABLE
//            };
//            await _wmsContainerPlaceRep.InsertAsync(wmsContainerPlaceModel);

            // 更新库存
            var wmsMaterialContainerList = await _wmsMaterialContainerRep.DetachedEntities
                .Where(p => p.OrderNo == orderNo && p.BindStatus == CommonStatus.ENABLE).ProjectToType<WmsMaterialContainer>().ToListAsync();
//            // 更新库存
//            var wmsMaterialContainerList = await _wmsMaterialContainerRep.DetachedEntities
//                .Where(p => p.OrderNo == orderNo && p.BindStatus == CommonStatus.ENABLE).ProjectToType<WmsMaterialContainer>().ToListAsync();

            foreach (var item in wmsMaterialContainerList)
            {
                var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(p => p.ContainerCode == wmsContainer.ContainerCode
                && p.MaterialBatch == item.MaterialBatch );
                if (wmsMaterialStock != null)
                {
                    wmsMaterialStock.Source = RuKuSourceEnum.WULIAO;
                    wmsMaterialStock.AreaId = wmsPlace.AreaId;
                    wmsMaterialStock.PlaceCode = wmsPlace.PlaceCode;
                    wmsMaterialStock.StockNumber += item.BindQuantity;
                    await _wmsMaterialStockRep.UpdateAsync(wmsMaterialStock);
                }
                else
                {
                    wmsMaterialStock = new WmsMaterialStock()
                    {
                        InspectionMethod = MaterialInspection.MIANJIAN,
                        UnitType = UnitType.ZHONGLIANG,
                        UnitNo = UnitNoType.T,
                        MaterialNo = item.MaterialNo,
                        MaterialType = MaterialType.CHENGPING,
                        MaterialName = item.MaterialName,
                        MaterialSpec = item.MaterialSpec,
                        MaterialBatch = item.MaterialBatch,
                        MaterialDensity = item.MaterialDensity,
                        StockNumber = 1,
                        PlaceCode = wmsPlace.PlaceCode,
                        ContainerId = wmsContainer.Id,
                        ContainerCode = wmsContainer.ContainerCode,
                        AreaId = wmsPlace.AreaId,
                        Source = RuKuSourceEnum.WULIAO
                };
                    await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
                }
            }
            // 空料箱入库
            if (orderNo == "N/A")
            {
                var wmsMaterialStock = new WmsMaterialStock()
                {
                    InspectionMethod = MaterialInspection.MIANJIAN,
                    UnitType = UnitType.ZHONGLIANG,
                    UnitNo = UnitNoType.T,
                    MaterialNo = "N/A",
                    MaterialType = MaterialType.KONGTUO,
                    MaterialName = "N/A",
                    MaterialSpec = "N/A",
                    MaterialBatch = "N/A",
                    MaterialDensity = "N/A",
                    StockNumber = 0,
                    PlaceCode = wmsPlace.PlaceCode,
                    ContainerId = wmsContainer.Id,
                    ContainerCode = wmsContainer.ContainerCode,
                    AreaId = wmsPlace.AreaId,
                    Source = RuKuSourceEnum.KONGTUO
            };
                await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
            }
        }
    }
}
//            foreach (var item in wmsMaterialContainerList)
//            {
//                var wmsMaterialStock = await _wmsMaterialStockRep.FirstOrDefaultAsync(p => p.ContainerCode == wmsContainer.ContainerCode
//                && p.MaterialBatch == item.MaterialBatch );
//                if (wmsMaterialStock != null)
//                {
//                    wmsMaterialStock.Source = RuKuSourceEnum.WULIAO;
//                    wmsMaterialStock.AreaId = wmsPlace.AreaId;
//                    wmsMaterialStock.PlaceCode = wmsPlace.PlaceCode;
//                    wmsMaterialStock.StockNumber += item.BindQuantity;
//                    await _wmsMaterialStockRep.UpdateAsync(wmsMaterialStock);
//                }
//                else
//                {
//                    wmsMaterialStock = new WmsMaterialStock()
//                    {
//                        InspectionMethod = MaterialInspection.MIANJIAN,
//                        UnitType = UnitType.ZHONGLIANG,
//                        UnitNo = UnitNoType.T,
//                        MaterialNo = item.MaterialNo,
//                        MaterialType = MaterialType.CHENGPING,
//                        MaterialName = item.MaterialName,
//                        MaterialSpec = item.MaterialSpec,
//                        MaterialBatch = item.MaterialBatch,
//                        MaterialDensity = item.MaterialDensity,
//                        StockNumber = 1,
//                        PlaceCode = wmsPlace.PlaceCode,
//                        ContainerId = wmsContainer.Id,
//                        ContainerCode = wmsContainer.ContainerCode,
//                        AreaId = wmsPlace.AreaId,
//                        Source = RuKuSourceEnum.WULIAO
//                };
//                    await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
//                }
//            }
//            // 空料箱入库
//            if (orderNo == "N/A")
//            {
//                var wmsMaterialStock = new WmsMaterialStock()
//                {
//                    InspectionMethod = MaterialInspection.MIANJIAN,
//                    UnitType = UnitType.ZHONGLIANG,
//                    UnitNo = UnitNoType.T,
//                    MaterialNo = "N/A",
//                    MaterialType = MaterialType.KONGTUO,
//                    MaterialName = "N/A",
//                    MaterialSpec = "N/A",
//                    MaterialBatch = "N/A",
//                    MaterialDensity = "N/A",
//                    StockNumber = 0,
//                    PlaceCode = wmsPlace.PlaceCode,
//                    ContainerId = wmsContainer.Id,
//                    ContainerCode = wmsContainer.ContainerCode,
//                    AreaId = wmsPlace.AreaId,
//                    Source = RuKuSourceEnum.KONGTUO
//            };
//                await _wmsMaterialStockRep.InsertAsync(wmsMaterialStock);
//            }
//        }
//    }
//}