From afbd572a8c6631ed9b5d85ebcafa4a99bab7d330 Mon Sep 17 00:00:00 2001
From: heshaofeng <heshaofeng@hnkhzn.com>
Date: 星期三, 03 十二月 2025 15:09:58 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhongRui/ALDbanyunxiangmu

---
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs   |  140 ++++++++++++++++++----------------
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs |   60 +-------------
 2 files changed, 80 insertions(+), 120 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs"
index ff10286..3169a94 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs"
@@ -129,7 +129,7 @@
             _client.DefaultRequestHeaders.Clear();
             _client.DefaultRequestHeaders.Add("Accept", "application/json");
 
-            _logger.LogInformation("InvokeMESService  FeedbackOutbound :  " + json);
+            _logger.LogInformation("InvokeMESService  FeedbackOutbound :  "+ model.orderNo +"  , " + json);
 
             var response = await _client.PostAsync("AldMaterialOutbound/MaterialOutbound", content);
             string body = await response.Content.ReadAsStringAsync();
@@ -248,58 +248,7 @@
             }
         }
 
-        /// <summary>
-        /// 鍑嗗鍥炰紶鏁版嵁
-        /// </summary>
-        private TransferDataDto PrepareTransferData(List<Dt_PickingRecord> pickingRecords)
-        {
-            var transferData = new TransferDataDto
-            {
-                TransferTime = DateTime.Now,
-                Items = new List<TransferItemDto>()
-            };
-
-            // 鎸夌墿鏂欏垎缁�
-            var materialGroups = pickingRecords
-                .GroupBy(x => x.MaterielCode)
-                .ToList();
-
-            foreach (var group in materialGroups)
-            {
-                var item = new TransferItemDto
-                {
-                    MaterialCode = group.Key,
-                    TotalQuantity = group.Sum(x => x.PickQuantity),
-                    Locations = new List<LocationInfoDto>()
-                };
-
-                // 鎸夎揣浣嶅垎缁�
-                var locationGroups = group
-                    .GroupBy(x => x.LocationCode)
-                    .ToList();
-
-                foreach (var locationGroup in locationGroups)
-                {
-                    var location = new LocationInfoDto
-                    {
-                        LocationCode = locationGroup.Key,
-                        Quantity = locationGroup.Sum(x => x.PickQuantity),
-                        Barcodes = locationGroup.Select(x => new BarcodeInfoDto
-                        {
-                            Barcode = x.Barcode,
-                            Quantity = x.PickQuantity
-                        }).ToList()
-                    };
-
-                    item.Locations.Add(location);
-                }
-
-                transferData.Items.Add(item);
-            }
-
-            return transferData;
-        }
-
+   
         /// <summary>
         /// 
         /// </summary>
@@ -828,6 +777,11 @@
                             .Where(x => x.OrderNo == orderNo)
                             .ExecuteCommandAsync();
 
+                        await _pickingRecoreRepository.Db.Updateable<Dt_PickingRecord>()
+                                 .SetColumns(x => x.ReturnToMESStatus == 1)
+                            .Where(x => x.OrderNo == orderNo)
+                            .ExecuteCommandAsync();
+
                         return WebResponseContent.Instance.OK("鍥炰紶MES鎴愬姛");
                     }
                     else
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
index 9cc3fde..956fcca 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS\346\227\240\344\273\223\345\202\250\347\211\210/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
@@ -1105,85 +1105,91 @@
                         //涓嶇敤鍥炰紶
                     }
                     else
-                    {
-                        var feedmodel = new FeedbackOutboundRequestModel
+                    {                    
+                        if (outboundOrder != null && outboundOrder.IsBatch == 0)
                         {
-                            reqCode = Guid.NewGuid().ToString(),
-                            reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
-                            business_type = outboundOrder.BusinessType,
-                            factoryArea = outboundOrder.FactoryArea,
-                            operationType = 1,
-                            Operator = outboundOrder.Operator,
-                            orderNo = outboundOrder.UpperOrderNo,
-                            documentsNO = outboundOrder.OrderNo,
-                            status = outboundOrder.OrderStatus,
-                            details = new List<FeedbackOutboundDetailsModel>()
-                        };
-
-
-                        foreach (var detail in orderDetails)
-                        {
-                            // 鑾峰彇璇ユ槑缁嗗搴旂殑鏉$爜淇℃伅锛堜粠閿佸畾璁板綍锛�
-                            var detailLocks = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
-                                .Where(x => x.OrderNo == orderNo &&
-                                           x.OrderDetailId == detail.Id &&
-                                           (x.Status == (int)OutLockStockStatusEnum.鎷i�夊畬鎴� || x.Status == (int)OutLockStockStatusEnum.宸插洖搴�))
-                                .ToListAsync();
-
-                            var detailModel = new FeedbackOutboundDetailsModel
+                            var feedmodel = new FeedbackOutboundRequestModel
                             {
-                                materialCode = detail.MaterielCode,
-                                lineNo = detail.lineNo, // 娉ㄦ剰锛氳繖閲屽彲鑳介渶瑕佽皟鏁村瓧娈靛悕
-                                warehouseCode = detail.WarehouseCode,
-                                qty = 0,
-                                currentDeliveryQty = 0,
-                                unit = detail.Unit,
-                                barcodes = new List<WIDESEA_DTO.Outbound.BarcodesModel>()
+                                reqCode = Guid.NewGuid().ToString(),
+                                reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
+                                business_type = outboundOrder.BusinessType,
+                                factoryArea = outboundOrder.FactoryArea,
+                                operationType = 1,
+                                Operator = outboundOrder.Operator,
+                                orderNo = outboundOrder.UpperOrderNo,
+                                documentsNO = outboundOrder.OrderNo,
+                                status = outboundOrder.OrderStatus,
+                                details = new List<FeedbackOutboundDetailsModel>()
                             };
-                            foreach (var item in detailLocks)
+                            foreach (var detail in orderDetails)
                             {
-                                if (item.PickedQty > 0)
+                                // 鑾峰彇璇ユ槑缁嗗搴旂殑鏉$爜淇℃伅锛堜粠閿佸畾璁板綍锛�
+                                var detailLocks = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
+                                    .Where(x => x.OrderNo == orderNo &&
+                                               x.OrderDetailId == detail.Id &&
+                                               (x.Status == (int)OutLockStockStatusEnum.鎷i�夊畬鎴� || x.Status == (int)OutLockStockStatusEnum.宸插洖搴�))
+                                    .ToListAsync();
+
+                                var detailModel = new FeedbackOutboundDetailsModel
                                 {
-                                    var barModel = new WIDESEA_DTO.Outbound.BarcodesModel
+                                    materialCode = detail.MaterielCode,
+                                    lineNo = detail.lineNo, // 娉ㄦ剰锛氳繖閲屽彲鑳介渶瑕佽皟鏁村瓧娈靛悕
+                                    warehouseCode = detail.WarehouseCode,
+                                    qty = 0,
+                                    currentDeliveryQty = 0,
+                                    unit = detail.Unit,
+                                    barcodes = new List<WIDESEA_DTO.Outbound.BarcodesModel>()
+                                };
+                                foreach (var item in detailLocks)
+                                {
+                                    if (item.PickedQty > 0)
                                     {
-                                        barcode = item.CurrentBarcode,
-                                        supplyCode = item.SupplyCode,
-                                        batchNo = item.BatchNo,
-                                        unit = item.BarcodeUnit,
-                                        qty = item.PickedQty
-                                    };
-                                    // 鍗曚綅涓嶄竴鑷存椂杞崲
-                                    if (detail.BarcodeUnit != detail.Unit)
-                                    {
-                                        var convertResult = await _materialUnitService.ConvertAsync(item.MaterielCode, item.PickedQty, detail.Unit, detail.BarcodeUnit);
-                                        barModel.unit = convertResult.Unit;
-                                        barModel.qty = convertResult.Quantity;
+                                        var barModel = new WIDESEA_DTO.Outbound.BarcodesModel
+                                        {
+                                            barcode = item.CurrentBarcode,
+                                            supplyCode = item.SupplyCode,
+                                            batchNo = item.BatchNo,
+                                            unit = item.BarcodeUnit,
+                                            qty = item.PickedQty
+                                        };
+                                        // 鍗曚綅涓嶄竴鑷存椂杞崲
+                                        if (detail.BarcodeUnit != detail.Unit)
+                                        {
+                                            var convertResult = await _materialUnitService.ConvertAsync(item.MaterielCode, item.PickedQty, detail.Unit, detail.BarcodeUnit);
+                                            barModel.unit = convertResult.Unit;
+                                            barModel.qty = convertResult.Quantity;
+                                        }
+                                        else
+                                        {
+                                            barModel.qty = item.PickedQty;
+                                        }
+                                        detailModel.qty += barModel.qty;
+                                        detailModel.currentDeliveryQty += barModel.qty;
+                                        detailModel.barcodes.Add(barModel);
                                     }
-                                    else
-                                    {
-                                        barModel.qty = item.PickedQty;
-                                    }
-                                    detailModel.qty += barModel.qty;
-                                    detailModel.currentDeliveryQty += barModel.qty;
-                                    detailModel.barcodes.Add(barModel);
                                 }
+                                feedmodel.details.Add(detailModel);
                             }
-                            feedmodel.details.Add(detailModel);
-                        }
 
-                        var result = await _invokeMESService.FeedbackOutbound(feedmodel);
-                        if (result != null && result.code == 200)
+                            var result = await _invokeMESService.FeedbackOutbound(feedmodel);
+                            if (result != null && result.code == 200)
+                            {
+                                await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
+                                    .SetColumns(x => x.ReturnToMESStatus == 1)
+                                    .Where(x => x.OrderId == outboundOrder.Id)
+                                    .ExecuteCommandAsync();
+
+                                await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
+                                    .SetColumns(x => x.ReturnToMESStatus == 1)
+                                    .Where(x => x.OrderNo == orderNo)
+                                    .ExecuteCommandAsync();
+                            }
+                        }
+                        else if (outboundOrder != null && outboundOrder.IsBatch == 1)
                         {
-                            await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
-                                .SetColumns(x => x.ReturnToMESStatus == 1)
-                                .Where(x => x.OrderId == outboundOrder.Id)
-                                .ExecuteCommandAsync();
-
-                            await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
-                                .SetColumns(x => x.ReturnToMESStatus == 1)
-                                .Where(x => x.OrderNo == orderNo)
-                                .ExecuteCommandAsync();
+                           await  _invokeMESService.BatchOrderFeedbackToMes(new List<string>(){outboundOrder.OrderNo },2);
                         }
+
                     }
                 }
             }

--
Gitblit v1.9.3