From 85d9ca4ec972ce4d020db046d930e8991709ae2d Mon Sep 17 00:00:00 2001
From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com>
Date: 星期一, 03 十一月 2025 17:14:49 +0800
Subject: [PATCH] 1

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs |   37 ++++++++++++++++++++++++++++++-------
 1 files changed, 30 insertions(+), 7 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs"
index 6529c86..c1ab047 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs"
@@ -18,7 +18,9 @@
 using WIDESEA_IStorageTaskRepository;
 using WIDESEA_IStorageTaskServices;
 using WIDESEA_Model.Models;
+using WIDESEA_Model.Models.ERP;
 using WIDESEA_Model.Models.Order;
+using WIDESEA_OrderRepository;
 
 namespace WIDESEA_OrderServices
 {
@@ -32,7 +34,8 @@
         private readonly IDt_TaskService _taskService;
         private readonly ILocationInfoRepository _locationRepository;
         private readonly IDt_TaskRepository _taskRepository;
-        private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
+        private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository; 
+        private readonly IDt_OrderOutDetailsRepository _outDetailsRepository;
 
         public Dt_ProductionOutboundOrderService(IDt_ProductionOutboundOrderRepository BaseDal,
                                         IUnitOfWorkManage unitOfWorkManage,
@@ -43,7 +46,8 @@
                                         IDt_TaskService taskService,
                                         ILocationInfoRepository locationRepository,
                                         IDt_TaskRepository taskRepository,
-                                        ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository) : base(BaseDal)
+                                        ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
+                                        IDt_OrderOutDetailsRepository outDetailsRepository) : base(BaseDal)
         {
             _unitOfWorkManage = unitOfWorkManage;
             _productionoutboundOrderDetailRepository = productionoutboundOrderDetailRepository;
@@ -54,8 +58,8 @@
             _locationRepository = locationRepository;
             _taskRepository = taskRepository;
             _locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
+            _outDetailsRepository = outDetailsRepository;
         }
-
         public WebResponseContent GetProductOutboundOrder(OutboundOrderGetDTO outboundOrderGetDTO)
         {
             WebResponseContent content = new WebResponseContent();
@@ -158,7 +162,7 @@
                         {
                             return content.Error($"璁㈠崟{outboundOrder.UpperOrderNo}鐗╂枡缂栫爜{outboundOrderdetail.MaterielCode}鏈壘鍒板簱瀛樺垎閰嶏紝璇风‘璁ゆ槸鍚﹀瓨鍦ㄥ簱瀛樻垨鍗曟嵁鏁伴噺宸插嚭瀹�");
                         }
-
+                        List<Dt_OrderOutDetails> outDetails = new List<Dt_OrderOutDetails>();
                         result.Item1.Distinct().ForEach(item =>
                         {
                             RequestTaskDto task = new RequestTaskDto
@@ -173,16 +177,35 @@
                             taskDtos.Add(task);
                             item.StockInfoDetails.Where(x => x.MaterielCode == outboundOrderdetail.MaterielCode).FirstOrDefault().Status = (int)StockStateEmun.鍑哄簱閿佸畾;
                             item.StockStatus = (int)StockStateEmun.鍑哄簱閿佸畾;
+
+                            item.StockInfoDetails.Where(x => x.OutboundQuantity > 0 && x.MaterielCode == outboundOrderdetail.MaterielCode).ForEach(x =>
+                            {
+                                outDetails.Add(new Dt_OrderOutDetails()
+                                {
+                                    OrderNo = outboundOrder.UpperOrderNo,
+                                    PalletCode = item.PalletCode,
+                                    OrderType = outboundOrder.OrderType,
+                                    ERPOrderId = outboundOrderdetail.ERPOrderId,
+                                    MaterielCode = outboundOrderdetail.MaterielCode,
+                                    MaterielName = outboundOrderdetail.MaterielName,
+                                    Warehouse = "鏅鸿兘绔嬪簱",
+                                    WareHouseId = "107",
+                                    OutboundQuantity = x.OutboundQuantity,
+                                });
+                            });
                         });
                         List<Dt_Task> taskNews = new List<Dt_Task>();
                         List<WMSTaskDTO> taskDTOs = new List<WMSTaskDTO>();
                         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($"{outboundOrderdetail.MaterielCode}鏈壘鍒板彲鍑哄簱鎵樼洏");
+                        }
                         foreach (var item in taskNews)
                         {
                             taskDTOs.Add(CreateTaskDTO(item));
@@ -201,6 +224,7 @@
                             await _locationStatusChangeRecordRepository.AddDataAsync(locationStatusChangeRecords);
                             await _locationRepository.UpdateDataAsync(locations);
                             _productionoutboundOrderDetailRepository.UpdateData(result.Item2);
+                            _outDetailsRepository.AddData(outDetails);
                         });
                         content = await _taskService.SendWCSTask(taskDTOs);
                     }
@@ -250,8 +274,7 @@
 
             foreach (var item in outStocks)
             {
-                var stockDetail = item.StockInfoDetails
-                .Where(d => d.MaterielCode == outboundOrderdetail.MaterielCode && d.Quantity > 0);
+                var stockDetail = item.StockInfoDetails.Where(d => d.MaterielCode == outboundOrderdetail.MaterielCode && d.Quantity > 0);
                 if (needQuantity <= 0)
                 {
                     continue;

--
Gitblit v1.9.3