From c30ac3ad95328c1a34661ecde471e4215df9dab3 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期五, 17 十月 2025 19:54:03 +0800
Subject: [PATCH] 添加盘点功能、添加立方智能库补货功能(入库平库调拨出库,立库调拨入库)

---
 新建文件夹/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs |  203 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 200 insertions(+), 3 deletions(-)

diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs"
index 44e7072..415829a 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/CabinOrderServices.cs"
@@ -1,5 +1,6 @@
 锘縰sing 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,186 @@
         //        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}銆戝凡绂佺敤锛岃鎭㈠姝e父鍐嶄娇鐢�");
+                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,
+                    TaskNum = cabinOrderDetail.Id,
+                    TaskStatus = SupplyStatusEnum.InFinish.ObjToInt(),
+                    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 +424,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,

--
Gitblit v1.9.3