From 5a15fa73d5f6a39917013871a65eb11a8c013391 Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期三, 05 十一月 2025 17:30:56 +0800
Subject: [PATCH] 1

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_AllocateOutboundOrderService.cs |   55 +++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 39 insertions(+), 16 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_AllocateOutboundOrderService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_AllocateOutboundOrderService.cs"
index bf48961..26f63aa 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_AllocateOutboundOrderService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_AllocateOutboundOrderService.cs"
@@ -11,6 +11,7 @@
 using WIDESEA_DTO.Order;
 using WIDESEA_DTO.Stock;
 using WIDESEA_DTO.WMS;
+using WIDESEA_IBusinessesRepository;
 using WIDESEA_IOrderRepository;
 using WIDESEA_IOrderServices;
 using WIDESEA_IStorageBasicRepository;
@@ -38,6 +39,7 @@
         private readonly IDt_TaskRepository _taskRepository;
         private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
         private readonly IDt_OrderOutDetailsRepository _outDetailsRepository;
+        private readonly IDt_AreaInfoRepository _areaInfoRepository;
 
         public Dt_AllocateOutboundOrderService(IDt_AllocateOutboundOrderRepository BaseDal,
                                         IUnitOfWorkManage unitOfWorkManage,
@@ -49,7 +51,8 @@
                                         ILocationInfoRepository locationRepository,
                                         IDt_TaskRepository taskRepository,
                                         ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
-                                        IDt_OrderOutDetailsRepository outDetailsRepository) : base(BaseDal)
+                                        IDt_OrderOutDetailsRepository outDetailsRepository,
+                                        IDt_AreaInfoRepository areaInfoRepository) : base(BaseDal)
         {
             _unitOfWorkManage = unitOfWorkManage;
             _allocateoutboundOrderDetailRepository = allocateoutboundOrderDetailRepository;
@@ -61,6 +64,7 @@
             _taskRepository = taskRepository;
             _locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
             _outDetailsRepository = outDetailsRepository;
+            _areaInfoRepository = areaInfoRepository;
         }
         public WebResponseContent GetAllocateOutboundOrder(OutboundOrderGetDTO outboundOrderGetDTO)
         {
@@ -149,6 +153,11 @@
             {
                 foreach (var orderId in requestOut.orderIds)
                 {
+                    Dt_AreaInfo areaInfo = null;
+                    if (requestOut.Warehouse != "")
+                        areaInfo = _areaInfoRepository.QueryFirst(x => x.AreaCode == requestOut.Warehouse);
+
+
                     List<RequestTaskDto> taskDtos = new List<RequestTaskDto>();
                     Dt_AllocateOutboundOrderDetail allocateoutboundOrderdetail = _allocateoutboundOrderDetailRepository.QueryFirst(x => x.Id == orderId);
                     Dt_AllocateOutboundOrder outboundOrder = BaseDal.QueryFirst(x => x.Id == allocateoutboundOrderdetail.OrderId);
@@ -174,25 +183,30 @@
                                 MaterielCode = allocateoutboundOrderdetail.MaterielCode,
                                 Position = item.LocationCode,
                                 PalletCode = item.PalletCode,
-                                AreaId = Convert.ToInt32(requestOut.AreaId),
+                                //AreaId = Convert.ToInt32(requestOut.AreaId),
+                                AreaId = Convert.ToInt32(2),
                             };
                             taskDtos.Add(task);
                             item.StockInfoDetails.Where(x => x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).FirstOrDefault().Status = (int)StockStateEmun.鍑哄簱閿佸畾;
                             item.StockStatus = (int)StockStateEmun.鍑哄簱閿佸畾;
-                            item.Remark = requestOut.Warehouse;
                             item.OrderNo = outboundOrder.UpperOrderNo;
-                            outDetails.Add(new Dt_OrderOutDetails()
+
+                            item.StockInfoDetails.Where(x => x.OutboundQuantity > 0 && x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).ForEach(x =>
                             {
-                                OrderNo = outboundOrder.UpperOrderNo,
-                                PalletCode = item.PalletCode,
-                                OrderType = outboundOrder.OrderType,
-                                ERPOrderId = allocateoutboundOrderdetail.ERPOrderId,
-                                MaterielCode = allocateoutboundOrderdetail.MaterielCode,
-                                MaterielName = allocateoutboundOrderdetail.MaterielName,
-                                AllocateWarehouse = requestOut.Warehouse == null ? item.StockInfoDetails.Where(x => x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).FirstOrDefault().Warehouse : requestOut.Warehouse,
-                                Warehouse = "鏅鸿兘绔嬪簱",
-                                WareHouseId = allocateoutboundOrderdetail.WareHouseId,
-                                OutboundQuantity = item.StockInfoDetails.Where(x => x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).Sum(x => x.Quantity),
+                                outDetails.Add(new Dt_OrderOutDetails()
+                                {
+                                    OrderNo = outboundOrder.UpperOrderNo,
+                                    PalletCode = item.PalletCode,
+                                    OrderType = outboundOrder.OrderType,
+                                    ERPOrderId = allocateoutboundOrderdetail.ERPOrderId,
+                                    MaterielCode = allocateoutboundOrderdetail.MaterielCode,
+                                    MaterielName = allocateoutboundOrderdetail.MaterielName,
+                                    AllocateWarehouse = areaInfo == null ? item.StockInfoDetails.Where(x => x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).FirstOrDefault().Warehouse : areaInfo.AreaName,
+                                    AllocateWarehouseId = areaInfo == null ? item.StockInfoDetails.Where(x => x.MaterielCode == allocateoutboundOrderdetail.MaterielCode).FirstOrDefault().WareHouseId : areaInfo.AreaCode,
+                                    Warehouse = "鏅鸿兘绔嬪簱",
+                                    WareHouseId = "107",
+                                    OutboundQuantity = x.OutboundQuantity,
+                                });
                             });
                         });
                         List<Dt_Task> taskNews = new List<Dt_Task>();
@@ -200,10 +214,13 @@
                         foreach (var item in taskDtos)
                         {
                             taskNews.Add(await _taskService.RequestOutboundTaskAsync(item));
-
                         }
                         List<DtLocationStatusChangeRecord> locationStatusChangeRecords = new List<DtLocationStatusChangeRecord>();
                         List<DtLocationInfo> locations = new List<DtLocationInfo>();
+                        if(taskNews.Count <= 0)
+                        {
+                            throw new Exception($"{allocateoutboundOrderdetail.MaterielCode}鏈壘鍒板彲鍑哄簱鎵樼洏");
+                        }
                         foreach (var item in taskNews)
                         {
                             taskDTOs.Add(CreateTaskDTO(item));
@@ -214,9 +231,10 @@
                             locations.AddRange(result1.Item2);
                             locations.AddRange(result2.Item2);
                         }
-
+                        outboundOrder.OrderStatus = (int)OrderStateEmun.寮�濮�;
                         await _unitOfWorkManage.UseTranAsync(async () =>
                         {
+                            BaseDal.UpdateData(outboundOrder);
                             _taskRepository.AddData(taskNews);
                             _stockInfoRepository.UpdateDataNav(result.Item1);
                             await _locationStatusChangeRecordRepository.AddDataAsync(locationStatusChangeRecords);
@@ -306,11 +324,16 @@
 
             }
             allocateoutboundOrderdetail.OverOutQuantity = allocateoutboundOrderdetail.OrderQuantity - needQuantity;
+            allocateoutboundOrderdetail.NotOutQuantity = allocateoutboundOrderdetail.OrderQuantity - allocateoutboundOrderdetail.OverOutQuantity;
 
             if (allocateoutboundOrderdetail.OverOutQuantity != 0)
             {
                 allocateoutboundOrderdetail.OrderDetailStatus = (int)OrderStateEmun.寮�濮�;
             }
+            if (allocateoutboundOrderdetail.OverOutQuantity == allocateoutboundOrderdetail.OrderQuantity)
+            {
+                allocateoutboundOrderdetail.OrderDetailStatus = (int)OrderStateEmun.宸插畬鎴�;
+            }
             return (outStockNews, allocateoutboundOrderdetail);
         }
 

--
Gitblit v1.9.3