From a770206c91e495b802b3e9371e06834586ad7715 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期四, 30 十月 2025 20:17:30 +0800
Subject: [PATCH] 1

---
 新建文件夹/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/DeliveryOrderServices.cs |  121 +++++++++++++++++++++++++++++++---------
 1 files changed, 94 insertions(+), 27 deletions(-)

diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/DeliveryOrderServices.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/DeliveryOrderServices.cs"
index 5c62803..edbeaf3 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/DeliveryOrderServices.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/DeliveryOrderServices.cs"
@@ -35,18 +35,19 @@
     public partial class DeliveryOrderServices : ServiceBase<Dt_DeliveryOrder, IRepository<Dt_DeliveryOrder>>, IDeliveryOrderServices
     {
         private readonly ICabinOrderServices _cabinOrderServices;
-        private readonly IBasicService _basicService;
         private readonly IUnitOfWorkManage _unitOfWorkManage;
         private readonly IInventory_BatchServices _inventory_BatchServices;
+        private readonly ILocationInfoService _locationInfoService;
         private readonly IInventoryInfoService _inventoryInfoService;
         private readonly IDeliveryOrderDetailServices _deliveryOrderDetailServices;
         private readonly ISupplyTaskService _supplyTaskService;
         private readonly ISupplyTaskHtyService _supplyTaskHtyService;
         private readonly ITacticsService _tacticsService;
+        private readonly IMaterielInfoService _materielInfoService;
+        private readonly IMessageInfoService _messageInfoService;
         public IRepository<Dt_DeliveryOrder> Repository => BaseDal;
-        public DeliveryOrderServices(IRepository<Dt_DeliveryOrder> BaseDal, IBasicService basicService, IUnitOfWorkManage unitOfWorkManage, IInventory_BatchServices inventory_BatchServices, IInventoryInfoService inventoryInfoService, IDeliveryOrderDetailServices deliveryOrderDetailServices, ISupplyTaskService supplyTaskService, ICabinOrderServices cabinOrderServices, ITacticsService tacticsService, ISupplyTaskHtyService supplyTaskHtyService) : base(BaseDal)
+        public DeliveryOrderServices(IRepository<Dt_DeliveryOrder> BaseDal, IUnitOfWorkManage unitOfWorkManage, IInventory_BatchServices inventory_BatchServices, IInventoryInfoService inventoryInfoService, IDeliveryOrderDetailServices deliveryOrderDetailServices, ISupplyTaskService supplyTaskService, ICabinOrderServices cabinOrderServices, ITacticsService tacticsService, ISupplyTaskHtyService supplyTaskHtyService, IMessageInfoService messageInfoService, IMaterielInfoService materielInfoService, ILocationInfoService locationInfoService) : base(BaseDal)
         {
-            _basicService = basicService;
             _unitOfWorkManage = unitOfWorkManage;
             _deliveryOrderDetailServices = deliveryOrderDetailServices;
             _supplyTaskService = supplyTaskService;
@@ -55,6 +56,9 @@
             _cabinOrderServices = cabinOrderServices;
             _tacticsService = tacticsService;
             _supplyTaskHtyService = supplyTaskHtyService;
+            _messageInfoService = messageInfoService;
+            _materielInfoService = materielInfoService;
+            _locationInfoService = locationInfoService;
         }
         #region 鍒涘缓鍑哄簱鍗�
         /// <summary>
@@ -221,11 +225,10 @@
                         #endregion
                         var Order_qty = Math.Abs(detail.order_qty);//鍑哄簱鍗曟暟閲�
                         #region 鏍规嵁鐗╂枡缂栫爜鏌ヨ鐗╂枡淇℃伅
-                        Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == detail.goods_no);
+                        Dt_MaterielInfo materielInfo = _materielInfoService.Repository.QueryFirst(x => x.MaterielCode == detail.goods_no);
                         if (materielInfo == null) throw new Exception($"鏈壘鍒拌嵂鍝佺紪鐮併�恵detail.goods_no}銆戠殑淇℃伅");
                         if (!Enum.IsDefined(typeof(MaterielSourceTypeEnum), materielInfo.MaterielSourceType))
                             throw new Exception($"璇疯缃嵂鍝佺紪鍙枫�恵detail.goods_no}銆戠殑灞炴�у垎绫�");
-                        if (materielInfo.BoxQty < 1) throw new Exception($"璇疯缃嵂鍝佺紪鍙枫�恵detail.goods_no}銆戠殑绠辫鏁伴噺");
                         #endregion
                         #region 澶т欢
                         if (materielInfo.MaterielSourceType == MaterielSourceTypeEnum.PurchasePart)//濡傛灉鐗╂枡鏄ぇ浠�
@@ -307,6 +310,7 @@
                         #endregion
                         else
                         {
+                            if (materielInfo.BoxQty < 1) throw new Exception($"璇疯缃嵂鍝佺紪鍙枫�恵detail.goods_no}銆戠殑绠辫鏁伴噺");
                             List<Dt_SupplyTask> supplyTasks = new List<Dt_SupplyTask>();
                             Dt_DeliveryOrderDetail orderDetail = null;
                             Dt_DeliveryOrderDetail orderDetailLK = null;
@@ -449,6 +453,7 @@
                         BaseDal.Db.InsertNav(entityOrderLK).Include(x => x.Details).ExecuteCommand();
                     #endregion
                 }
+                webResponseContent.OK();
             }
             catch (Exception ex)
             {
@@ -555,7 +560,7 @@
                         if (Qty != item.order_qty) throw new Exception($"鐩樼泩鍏ュ簱鍗曘�恵order.order_no}銆戠墿鏂欑紪鍙枫�恵item.goods_no}銆戠墿鏂欐壒娆°�恵item.batch_num}銆戠殑鐩樼泩鏁伴噺鏈夎");
                         //鎵炬墍鏈夊簱瀛�
                         List<Dt_InventoryInfo> inventoryInfos = _inventoryInfoService.Repository.QueryData(x => x.MaterielCode == inventory_Batch.MaterielCode && x.BatchNo == inventory_Batch.BatchNo);
-                        //鑾峰彇绔嬪簱鐩樼偣宸紓鏁�
+                        //鑾峰彇绔嬪簱鐩樼偣宸紓鏁�.銆傘�傘�傘�傘�傘�傘�傘�傘�傘�傘�傘��
                         var inventoryLK = inventoryInfos.Where(x => x.WarehouseCode == WareCodeLK).First();
                         var LkQty = Math.Abs(inventoryLK.StockQuantity - inventoryLK.SupplyQuantity);
                         //鑾峰彇澶т欢搴撶洏鐐瑰樊寮傛暟
@@ -624,7 +629,8 @@
                                     Status = 2,
                                 }).ToList()
                             };
-                            Repository.AddData(entityOrder);
+                            Db.InsertNav(entityOrder).Include(it => it.Details).ExecuteCommand();
+                            //Repository.AddData(entityOrder);
                             #endregion
                         }
                         else
@@ -653,7 +659,7 @@
                                         OrderNo = order.order_no,
                                         StockQuantity = Math.Abs(inventoryInfo.StockQuantity - inventoryInfo.SupplyQuantity),
                                         SupplyQuantity = 0,
-                                        Remark = "鐩樼泩鍏ュ簱"
+                                        Remark = "鐩樹簭鍑哄簱"
                                     };
                                     _supplyTaskHtyService.AddData(supplyTask_Hty);
                                 }
@@ -689,7 +695,8 @@
                                         Status = 2,
                                     }).ToList()
                                 };
-                                Repository.AddData(cabinOrder);
+                                //Repository.AddData(cabinOrder);
+                                Db.InsertNav(cabinOrder).Include(it => it.Details).ExecuteCommand();
                             }
                             #endregion
 
@@ -714,15 +721,17 @@
                                     Status = 0,
                                 }).ToList()
                             };
-                            Repository.AddData(entityOrder);
+                            Db.InsertNav(entityOrder).Include(it => it.Details).ExecuteCommand();
+                            //Repository.AddData(entityOrder);
                             #endregion
                         }
+                        return WebResponseContent.Instance.OK("鎴愬姛");
                     }
                 }
             }
-            catch (Exception e)
+            catch (Exception ex)
             {
-                content.Error(e.Message);
+                content.Error(ex.Message);
             }
             return content;
         }
@@ -848,6 +857,12 @@
             return content;
         }
 
+
+        /// <summary>
+        /// pad鍑哄簱瀹屾垚
+        /// </summary>
+        /// <param name="saveModel"></param>
+        /// <returns></returns>
         public WebResponseContent OutFinish(SaveModel saveModel)
         {
             WebResponseContent content = new WebResponseContent();
@@ -877,7 +892,7 @@
 
                 Dt_DeliveryOrderDetail? cabinOrderDetail = cabinOrder.Details.Where(x => x.Batch_num == supplyTask.BatchNo && x.Reservoirarea == supplyTask.WarehouseCode && x.Goods_no == supplyTask.MaterielCode).FirstOrDefault();
                 if (cabinOrderDetail == null) return WebResponseContent.Instance.Error($"鍑哄簱鍗曟槑缁嗗凡瀹屾垚");
-                Dt_MaterielInfo materielInfo = _basicService.MaterielInfoService.Repository.QueryFirst(x => x.MaterielCode == cabinOrderDetail.Goods_no);
+                Dt_MaterielInfo materielInfo = _materielInfoService.Repository.QueryFirst(x => x.MaterielCode == cabinOrderDetail.Goods_no);
                 if (materielInfo == null) return WebResponseContent.Instance.Error($"璇风淮鎶ょ墿鏂欑紪鍙枫�恵cabinOrderDetail.Goods_no}銆戠殑鐗╂枡淇℃伅");
                 cabinOrderDetail.Order_Outqty += supplyTask.StockQuantity;
                 if (cabinOrderDetail.Order_Outqty > cabinOrderDetail.Order_qty)
@@ -916,7 +931,7 @@
                 #region 璐т綅
                 if (supplyTask.WarehouseCode != WarehouseEnum.绔嬪簱.ObjToInt().ToString("000"))
                 {
-                    var location = _basicService.LocationInfoService.Repository.QueryFirst(x => x.LocationCode == supplyTask.LocationCode);
+                    var location = _locationInfoService.Repository.QueryFirst(x => x.LocationCode == supplyTask.LocationCode);
                     if (location == null)
                         return WebResponseContent.Instance.Error($"璇风淮鎶よ揣浣嶇紪鍙枫�恵supplyTask.LocationCode}銆戠殑璐т綅淇℃伅");
                     //if (location.EnableStatus == EnableStatusEnum.Disable.ObjToInt())
@@ -925,7 +940,7 @@
                     if (inventoryInfo1 == null)
                     {
                         location.LocationStatus = LocationStatusEnum.Free.ObjToInt();
-                        _basicService.LocationInfoService.UpdateData(location);
+                        _locationInfoService.UpdateData(location);
                     }
                 }
                 #endregion
@@ -935,24 +950,27 @@
                 supplyTask.TaskStatus = SupplyStatusEnum.OutFinish.ObjToInt();
                 _supplyTaskService.Repository.DeleteAndMoveIntoHty(supplyTask, OperateTypeEnum.浜哄伐瀹屾垚);
 
-                #region 搴撳瓨鎵规
-                Dt_Inventory_Batch inventory_Batch = _inventory_BatchServices.Repository.QueryFirst(x => x.BatchNo == inventoryInfo.BatchNo && x.MaterielCode == inventoryInfo.MaterielCode);
-                if (inventory_Batch != null)
+                #region 搴撳瓨鎵规 濡傛灉浠诲姟绫诲瀷鏄皟鎷ㄥ嚭搴撲换鍔★紙8锛夊氨涓嶄慨鏀规壒娆″簱瀛�
+                if (supplyTask.TaskType != TaskTypeEnum.AllocatOut.ObjToInt())
                 {
-                    inventory_Batch.StockQuantity -= supplyTask.StockQuantity;
-                    inventory_Batch.OutboundQuantity -= supplyTask.StockQuantity;
-                    if (inventory_Batch.StockQuantity <= 0)
-                        _inventory_BatchServices.DeleteData(inventory_Batch);
-                    else
-                        _inventory_BatchServices.UpdateData(inventory_Batch);
+                    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 -= supplyTask.StockQuantity;
+                        inventory_Batch.OutboundQuantity -= supplyTask.StockQuantity;
+                        if (inventory_Batch.StockQuantity <= 0)
+                            _inventory_BatchServices.DeleteData(inventory_Batch);
+                        else
+                            _inventory_BatchServices.UpdateData(inventory_Batch);
+                    }
                 }
                 #endregion
                 if (supplyTask.WarehouseCode == WarehouseEnum.绔嬪簱.ObjToInt().ToString("000"))
                 {
                     materielInfo.Business_qty -= supplyTask.StockQuantity;
-                    _basicService.MaterielInfoService.Repository.UpdateData(materielInfo);
-                    //if (materielInfo.Business_qty < materielInfo.MinQty)
-                    //    CreateAllocatInOut(materielInfo);//鍒涘缓璋冩嫧浠诲姟
+                    _materielInfoService.UpdateData(materielInfo);
+                    if (materielInfo.Business_qty < materielInfo.MinQty)
+                        CreateAllocatInOut(materielInfo);//鍒涘缓璋冩嫧浠诲姟
                 }
                 _unitOfWorkManage.CommitTran();
                 #endregion
@@ -964,5 +982,54 @@
             }
             return content;
         }
+
+        /// <summary>
+        /// 浜哄伐鍦ㄥ嚭搴撳崟涓偣鍑诲畬鎴愭寜閽疄鐜颁笂鎶�
+        /// </summary>
+        /// <param name="key">id</param>
+        /// <returns></returns>
+        public WebResponseContent FinishOutOrder(int key)
+        {
+            WebResponseContent content = new WebResponseContent();
+            try
+            {
+                Dt_DeliveryOrder deliveryOrder = BaseDal.QueryFirst(x => x.Id == key);
+                List<Dt_DeliveryOrder> deliveryOrders = Db.Queryable<Dt_DeliveryOrder>().Where(x => x.Out_no == deliveryOrder.Out_no).Includes(x => x.Details).ToList();//鎵惧嚭鎵�鏈夊嚭搴撳崟鍙风浉鍚岀殑鍑哄簱鍗�
+                _unitOfWorkManage.BeginTran();
+
+                foreach (var item in deliveryOrders)
+                {
+                    if (item.Details != null)
+                        _deliveryOrderDetailServices.Repository.DeleteAndMoveIntoHty(item.Details, OperateTypeEnum.浜哄伐瀹屾垚);
+                    item.Modifier = App.User.UserName;
+                    item.ModifyDate = DateTime.Now;
+                    item.Details = null;
+                }
+                BaseDal.DeleteAndMoveIntoHty(deliveryOrders, OperateTypeEnum.浜哄伐瀹屾垚);
+                if (deliveryOrder.Out_type == OutOrderTypeEnum.Allocate.ObjToInt().ToString())
+                    _unitOfWorkManage.CommitTran();
+                else
+                {
+                    var url = "http://121.37.118.63:80/GYZ2/95fck/outOrderOk";
+
+                    var requestDate = new
+                    {
+                        order_no = deliveryOrder.Out_no
+                    };
+                    var result = HttpHelper.Post(url, requestDate.ToJsonString());
+                    var response = JsonConvert.DeserializeObject<UpstreamOrderResponse>(result);
+                    if (response == null) throw new Exception("涓婃姤ERP鍑哄簱鍗曞畬鎴愬け璐ワ紒");
+                    if (response.resultCode != "0") throw new Exception(response.resultMsg);
+                    _unitOfWorkManage.CommitTran();
+                }
+                content.OK();
+            }
+            catch (Exception ex)
+            {
+                _unitOfWorkManage.RollbackTran();
+                content.Error(ex.Message);
+            }
+            return content;
+        }
     }
 }

--
Gitblit v1.9.3