方舱智能密集库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2025-10-17 10283f5b4c0c130ab9f1653b05a359d2994eb1e3 
 н¨Îļþ¼Ð/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs


@@ -1,5 +1,6 @@


using HslCommunication;


using MailKit.Search;


using Microsoft.AspNetCore.Mvc;


using Newtonsoft.Json;


using SqlSugar;


using System;


@@ -8,12 +9,18 @@


using System.Text;


using System.Threading.Tasks;


using WIDESEA_Common;


using WIDESEA_Common.LocationEnum;


using WIDESEA_Common.OrderEnum;


using WIDESEA_Common.StockEnum;


using WIDESEA_Common.TaskEnum;


using WIDESEA_Core;


using WIDESEA_Core.BaseRepository;


using WIDESEA_Core.BaseServices;


using WIDESEA_Core.Enums;


using WIDESEA_Core.Helper;


using WIDESEA_IBasicService;


using WIDESEA_ISquareCabinServices;


using WIDESEA_IWMsInfoServices;


using WIDESEA_Model.Models;




using static System.Net.WebRequestMethods;


@@ -29,11 +36,22 @@


        static string SearchDate = "";


        private readonly IBasicService _basicService;


        private readonly IMedicineGoodsServices _medicineGoodsServices;


        private readonly IUnitOfWorkManage _unitOfWorkManage;


        private readonly IInventory_BatchServices _inventory_BatchServices;


        private readonly IInventoryInfoService _inventoryInfoService;


        private readonly ICabinOrderDetailServices _cabinOrderDetailServices;


        private readonly ISupplyTaskService _supplyTaskService;


        public IRepository<Dt_CabinOrder> Repository => BaseDal;




        public CabinOrderServices(IRepository<Dt_CabinOrder> BaseDal, IBasicService basicService, IMedicineGoodsServices medicineGoodsServices) : base(BaseDal)


        public CabinOrderServices(IRepository<Dt_CabinOrder> BaseDal, IBasicService basicService, IMedicineGoodsServices medicineGoodsServices, IUnitOfWorkManage unitOfWorkManage, IInventory_BatchServices inventory_BatchServices, IInventoryInfoService inventoryInfoService, ICabinOrderDetailServices cabinOrderDetailServices, ICabinOrderHtyServices cabinOrderHtyServices, ICabinOrderDetailHtyServices cabinOrderDetailHtyServices, ISupplyTaskService supplyTaskService) : base(BaseDal)


        {


            _basicService = basicService;


            _medicineGoodsServices = medicineGoodsServices; 


            _medicineGoodsServices = medicineGoodsServices;


            _unitOfWorkManage = unitOfWorkManage;


            _inventory_BatchServices = inventory_BatchServices;


            _inventoryInfoService = inventoryInfoService;


            _cabinOrderDetailServices = cabinOrderDetailServices;


            _supplyTaskService = supplyTaskService;


        }




        /// <summary>


@@ -134,7 +152,184 @@


        //        return responseContent.Error("同步失败: " + ex.Message);


        //    }


        //}


        public WebResponseContent GetCabinOrders(SaveModel saveModel)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                int pageNo = saveModel.MainData["pageNo"].ObjToInt();


                string warehouseCode = saveModel.MainData["warehouseId"].ToString();


                string orderNo = saveModel.MainData["orderNo"].ToString();


                List<Dt_CabinOrder> dt_ReceiveOrders = new List<Dt_CabinOrder>();


                if (string.IsNullOrEmpty(orderNo))


                {


                    dt_ReceiveOrders = Db.Queryable<Dt_CabinOrder>().Where(x => (x.OdrderStatus == "新建" || x.OdrderStatus == "开始") && x.Warehouse_no == warehouseCode).Includes(x => x.Details).OrderByDescending(x => x.CreateDate).ToPageList(pageNo, 5);


                }


                else


                {


                    dt_ReceiveOrders = Db.Queryable<Dt_CabinOrder>().Where(x => (x.Order_no.Contains(orderNo) || x.Supplier_no.Contains(orderNo)) && (x.OdrderStatus == "新建" || x.OdrderStatus == "开始") && x.Warehouse_no == warehouseCode).OrderByDescending(x => x.CreateDate).Includes(x => x.Details).ToPageList(pageNo, 5);


                }




                content.OK(data: dt_ReceiveOrders);


            }


            catch (Exception)


            {




                throw;


            }


            return content;


        }


        public WebResponseContent GetCabinOrderDetail(int pageNo, string orderNo)


        {


            WebResponseContent content = new WebResponseContent();


            Dt_CabinOrder cabinOrder = Db.Queryable<Dt_CabinOrder>().Includes(x => x.Details).First(x => x.Order_no == orderNo);


            List<Dt_CabinOrderDetail> cabinOrderDetails = cabinOrder.Details.Where(x => x.Reservoirarea == pageNo.ToString()).ToList();


            content.OK(data: cabinOrderDetails);


            return content;


        }


        public WebResponseContent FeedbackIn([FromBody] SaveModel saveModel)


        {


            WebResponseContent content = new WebResponseContent();


            try


            {


                var LocationCode = saveModel.MainData["LocationCode"].ToString();


                var orderNo = saveModel.MainData["orderNo"].ToString();


                var batchNo = saveModel.MainData["batchNo"].ToString();


                var Inqty = saveModel.MainData["Inqty"].ObjToInt();


                var warehouseCode = saveModel.MainData["warehouseCode"].ToString();


                Dt_CabinOrder cabinOrder = BaseDal.Db.Queryable<Dt_CabinOrder>().Where(x => x.Order_no == orderNo && x.Warehouse_no == warehouseCode).Includes(x => x.Details).First();


                if (cabinOrder == null) return WebResponseContent.Instance.Error($"入库单已完成");


                Dt_CabinOrderDetail cabinOrderDetail = cabinOrder.Details.Where(x => x.Batch_num == batchNo && x.Reservoirarea == warehouseCode).First();


                if (cabinOrderDetail == null) return WebResponseContent.Instance.Error($"入库单明细已完成");


                Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == cabinOrderDetail.Goods_no);


                if (materielInfo == null) return WebResponseContent.Instance.Error($"请维护物料编号【{cabinOrderDetail.Goods_no}】的物料信息");


                cabinOrderDetail.Order_Inqty += Inqty;


                if (cabinOrderDetail.Order_Inqty > cabinOrderDetail.Order_qty)


                    return WebResponseContent.Instance.Error($"入库数量不可超出单据数量");




                #region å¤„理入库单，货位，库存，库存批次信息


                _unitOfWorkManage.BeginTran();




                #region å…¥åº“单


                cabinOrder.OdrderStatus = "开始";


                cabinOrderDetail.OrderDetailStatus = "开始";


                if (cabinOrderDetail.Order_Inqty == cabinOrderDetail.Order_qty)


                {


                    cabinOrderDetail.OrderDetailStatus = "已完成";


                    _cabinOrderDetailServices.Repository.DeleteAndMoveIntoHty(cabinOrderDetail, OperateTypeEnum.自动完成);


                }


                else


                {


                    _cabinOrderDetailServices.Repository.UpdateData(cabinOrderDetail);


                }


                var cabinOrder1 = BaseDal.Db.Queryable<Dt_CabinOrder>().Where(x => x.Order_no == cabinOrder.Order_no).Includes(x => x.Details).First();


                if (cabinOrder1.Details == null || cabinOrder1.Details.Count < 1) cabinOrder.OdrderStatus = "已完成";


                Repository.UpdateData(cabinOrder);


                #endregion




                #region è´§ä½


                var location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == LocationCode);


                if (location == null) return WebResponseContent.Instance.Error($"请维护货位编号【{LocationCode}】的货位信息");


                if (location.EnableStatus == EnableStatusEnum.Disable.ObjToInt())


                    return WebResponseContent.Instance.Error($"货位编号【{LocationCode}】已禁用，请恢复正常再使用");


                if (location.LocationStatus != LocationStatusEnum.InStock.ObjToInt())


                {


                    location.LocationStatus = LocationStatusEnum.InStock.ObjToInt();


                    _basicService.LocationInfoService.UpdateData(location);


                }


                #endregion




                #region åº“å­˜


                Dt_InventoryInfo inventoryInfo = _inventoryInfoService.Repository.QueryFirst(x => x.BatchNo == cabinOrderDetail.Batch_num && x.MaterielCode == cabinOrderDetail.Goods_no && x.LocationCode == LocationCode);


                if (inventoryInfo != null)


                {


                    inventoryInfo.StockQuantity += Inqty;


                    _inventoryInfoService.UpdateData(inventoryInfo);


                }


                else


                {


                    inventoryInfo = new Dt_InventoryInfo()


                    {


                        LocationCode = LocationCode,


                        MaterielCode = materielInfo.MaterielCode,


                        MaterielName = materielInfo.MaterielName,


                        MaterielSpec = materielInfo.MaterielSpec,


                        OutboundQuantity = 0,


                        StockQuantity = Inqty,


                        StockStatus = StockStatusEmun.入库完成.ObjToInt(),


                        ValidityPeriod = cabinOrderDetail.Exp_date,


                        WarehouseCode = cabinOrderDetail.Reservoirarea,


                        SupplyQuantity = 0,


                        InDate = DateTime.Now,


                        BatchNo = cabinOrderDetail.Batch_num,


                        Creater = App.User.UserName,


                        CreateDate = DateTime.Now,


                    };


                    _inventoryInfoService.AddData(inventoryInfo);


                }


                #endregion




                #region ä»»åŠ¡è®°å½•


                Dt_SupplyTask supplyTask = new Dt_SupplyTask()


                {


                    WarehouseCode = cabinOrderDetail.Reservoirarea,


                    BatchNo=inventoryInfo.BatchNo,


                    MaterielName= inventoryInfo.MaterielName,


                    MaterielCode= inventoryInfo.MaterielCode,


                    MaterielSpec= inventoryInfo.MaterielSpec,


                    TaskType=TaskTypeEnum.InPick.ObjToInt(),


                    CreateDate = DateTime.Now,


                    Creater = App.User.UserName,


                    LocationCode = location.LocationCode,


                    OrderNo = cabinOrder.Order_no,


                    StockQuantity = Inqty,


                    SupplyQuantity = 0,


                    Remark = "入库"


                };


                _supplyTaskService.AddData(supplyTask);


                #endregion




                #region åº“存批次


                Dt_Inventory_Batch inventory_Batch = _inventory_BatchServices.Repository.QueryFirst(x => x.BatchNo == inventoryInfo.BatchNo && x.MaterielCode == inventoryInfo.MaterielCode);


                if (inventory_Batch != null)


                {


                    inventory_Batch.StockQuantity += Inqty;


                    _inventory_BatchServices.UpdateData(inventory_Batch);


                }


                else


                {


                    inventory_Batch = new Dt_Inventory_Batch()


                    {


                        BatchNo = inventoryInfo.BatchNo,


                        CreateDate = inventoryInfo.CreateDate,


                        Creater = inventoryInfo.Creater,


                        MaterielCode = inventoryInfo.MaterielCode,


                        ERPStockQuantity = 0,


                        MaterielName = inventoryInfo.MaterielName,


                        MaterielSpec = inventoryInfo.MaterielSpec,


                        OutboundQuantity = inventoryInfo.OutboundQuantity,


                        ProductionDate = inventoryInfo.ProductionDate,


                        Status = false,


                        StockQuantity = inventoryInfo.StockQuantity,


                        ValidityPeriod = inventoryInfo.ValidityPeriod,


                        SupplyQuantity = inventoryInfo.SupplyQuantity,


                    };


                    _inventory_BatchServices.AddData(inventory_Batch);


                }


                #endregion




                _unitOfWorkManage.CommitTran();


                #endregion




                content.OK(cabinOrderDetail.Order_Inqty.ToString());


            }


            catch (Exception ex)


            {


                _unitOfWorkManage.RollbackTran();


                content.Error(ex.Message);


            }


            return content;


        }




        public WebResponseContent GetUpstreamOrder()


        {


@@ -227,7 +422,7 @@


                            {


                                Dt_CabinOrderDetail orderDetail = new Dt_CabinOrderDetail()


                                {


                                    Reservoirarea= order.warehouse_no,


                                    Reservoirarea = order.warehouse_no,


                                    Goods_no = item.goods_no,


                                    Order_qty = item.order_qty,


                                    Batch_num = item.batch_num,