From 879e8b6f01e369efdb6fbbf53e3153086b8ea6f9 Mon Sep 17 00:00:00 2001
From: pan <antony1029@163.com>
Date: 星期一, 01 十二月 2025 15:29:01 +0800
Subject: [PATCH] 提交

---
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_BasicService/InvokeMESService.cs |  161 +++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 119 insertions(+), 42 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 34e8220..1ce63f5 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"
@@ -14,6 +14,7 @@
 using WIDESEA_Common.StockEnum;
 using WIDESEA_Core;
 using WIDESEA_Core.BaseRepository;
+using WIDESEA_Core.Helper;
 using WIDESEA_DTO.Allocate;
 using WIDESEA_DTO.Basic;
 using WIDESEA_DTO.Inbound;
@@ -115,9 +116,11 @@
 
         public async Task<ResponseModel> FeedbackAllocate(AllocateDto model)
         {
+            _logger.LogInformation($"InvokeMESService  FeedbackAllocate  搴忓垪鍖栧墠: {JsonConvert.SerializeObject(model)}");
             string json = JsonConvert.SerializeObject(model, new JsonSerializerSettings
             {
-                ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
+                ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver(),
+                NullValueHandling = NullValueHandling.Include
             });
             var content = new StringContent(json, Encoding.UTF8, "application/json");
             var _client = _httpClientFactory.CreateClient("MESUrl");
@@ -246,42 +249,89 @@
                                 var inboundOrder = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>().First(x => x.InboundOrderNo == lists.FirstOrDefault().OrderNo);
                                 if (inboundOrder != null)
                                 {
-                                    var feedmodel = new FeedbackInboundRequestModel
+                                    if (inboundOrder.OrderType == (int)InOrderTypeEnum.AllocatInbound)//璋冩嫧鍏ュ簱
                                     {
-                                        reqCode = Guid.NewGuid().ToString(),
-                                        reqTime = DateTime.Now.ToString(),
-                                        business_type = inboundOrder.BusinessType,
-                                        factoryArea = inboundOrder.FactoryArea,
-                                        operationType = 1,
-                                        Operator = inboundOrder.Operator,
-                                        orderNo = inboundOrder.UpperOrderNo,
-                                        status = inboundOrder.OrderStatus,
-                                        details = new List<FeedbackInboundDetailsModel>()
+                                        var allocate = SqlSugarHelper.DbWMS.Queryable<Dt_AllocateOrder>().Where(x => x.OrderNo == inboundOrder.InboundOrderNo).First();
+                                        var allocatefeedmodel = new AllocateDto
+                                        {
+                                            ReqCode = Guid.NewGuid().ToString(),
+                                            ReqTime = DateTime.Now.ToString(),
+                                            BusinessType = "2",
+                                            FactoryArea = inboundOrder.FactoryArea,
+                                            OperationType = 1,
+                                            Operator = inboundOrder.Operator,
+                                            OrderNo = inboundOrder.UpperOrderNo,
+                                            fromWarehouse = allocate?.FromWarehouse ?? "",
+                                            toWarehouse = allocate?.ToWarehouse ?? "",
+                                            Details = new List<AllocateDtoDetail>()
 
-                                    };
+                                        };
 
-                                    var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
-                                       .Select(group => new FeedbackInboundDetailsModel
-                                       {
-                                           materialCode = group.Key.MaterielCode,
-                                           supplyCode = group.Key.SupplyCode,
-                                           batchNo = group.Key.BatchNo,
-                                           lineNo = group.Key.InboundOrderRowNo,
-                                           qty = group.Sum(x => x.BarcodeQty),
-                                           // warehouseCode = group.Key.WarehouseCode=="0"?"1072": group.Key.WarehouseCode,
-                                           warehouseCode = group.Key.WarehouseCode,
-                                           unit = group.Key.BarcodeUnit,
-                                           barcodes = group.Select(row => new FeedbackBarcodesModel
+                                        var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
+                                           .Select(group => new AllocateDtoDetail
                                            {
-                                               barcode = row.Barcode,
-                                               qty = row.BarcodeQty
-                                           }).ToList()
-                                       }).ToList();
-                                    feedmodel.details = groupedData;
-                                    var result = await FeedbackInbound(feedmodel);
-                                    if (result != null && result.code == 200)
+                                               MaterialCode = group.Key.MaterielCode,
+                                               LineNo = group.Key.InboundOrderRowNo,
+                                               WarehouseCode = group.Key.WarehouseCode,
+                                               Qty = group.Sum(x => x.BarcodeQty),
+                                               // warehouseCode= "1072",
+                                               Unit = group.Key.BarcodeUnit,
+                                               Barcodes = group.Select(row => new BarcodeInfo
+                                               {
+                                                   Barcode = row.Barcode,
+                                                   Qty = row.BarcodeQty,
+                                                   BatchNo = row.BatchNo,
+                                                   SupplyCode = row.SupplyCode,
+                                                   Unit = row.Unit
+                                               }).ToList()
+                                           }).ToList();
+                                        allocatefeedmodel.Details = groupedData;
+
+                                        var result = await FeedbackAllocate(allocatefeedmodel);
+                                        if (result != null && result.code == 200)
+                                        {
+                                            _feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
+                                        }
+                                    }
+                                    else
                                     {
-                                        _feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
+                                        var feedmodel = new FeedbackInboundRequestModel
+                                        {
+                                            reqCode = Guid.NewGuid().ToString(),
+                                            reqTime = DateTime.Now.ToString(),
+                                            business_type = inboundOrder.BusinessType,
+                                            factoryArea = inboundOrder.FactoryArea,
+                                            operationType = 1,
+                                            Operator = inboundOrder.Operator,
+                                            orderNo = inboundOrder.UpperOrderNo,
+                                            status = inboundOrder.OrderStatus,
+                                            details = new List<FeedbackInboundDetailsModel>()
+
+                                        };
+
+                                        var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
+                                           .Select(group => new FeedbackInboundDetailsModel
+                                           {
+                                               materialCode = group.Key.MaterielCode,
+                                               supplyCode = group.Key.SupplyCode,
+                                               batchNo = group.Key.BatchNo,
+                                               lineNo = group.Key.InboundOrderRowNo,
+                                               qty = group.Sum(x => x.BarcodeQty),
+                                               // warehouseCode = group.Key.WarehouseCode=="0"?"1072": group.Key.WarehouseCode,
+                                               warehouseCode = group.Key.WarehouseCode,
+                                               unit = group.Key.BarcodeUnit,
+                                               barcodes = group.Select(row => new FeedbackBarcodesModel
+                                               {
+                                                   barcode = row.Barcode,
+                                                   qty = row.BarcodeQty
+                                               }).ToList()
+                                           }).ToList();
+                                        feedmodel.details = groupedData;
+                                        var result = await FeedbackInbound(feedmodel);
+                                        if (result != null && result.code == 200)
+                                        {
+                                            _feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
+                                        }
                                     }
                                 }
                             }
@@ -385,16 +435,16 @@
                         materialCode = detail.MaterielCode,
                         lineNo = detail.lineNo, // 娉ㄦ剰锛氳繖閲屽彲鑳介渶瑕佽皟鏁村瓧娈靛悕
                         warehouseCode = detail.WarehouseCode,
-                        qty = detail.OverOutQuantity, // 浣跨敤璁㈠崟鏄庣粏鐨勫凡鍑哄簱鏁伴噺
-                        currentDeliveryQty = detail.OverOutQuantity,
-                        unit = detail.Unit,
+                        qty = detail.BarcodeQty, // 浣跨敤璁㈠崟鏄庣粏鐨勫凡鍑哄簱鏁伴噺
+                        currentDeliveryQty = detail.BarcodeQty,
+                        unit = detail.BarcodeUnit,
                         barcodes = detailLocks.Select(lockInfo => new WIDESEA_DTO.Outbound.BarcodesModel
                         {
                             barcode = lockInfo.CurrentBarcode,
                             supplyCode = lockInfo.SupplyCode,
                             batchNo = lockInfo.BatchNo,
-                            unit = lockInfo.Unit,
-                            qty = lockInfo.PickedQty // 鏉$爜绾у埆鐨勬暟閲忎粛鐢ㄩ攣瀹氳褰�
+                            unit = lockInfo.BarcodeUnit,
+                            qty = lockInfo.BarcodeQty // 鏉$爜绾у埆鐨勬暟閲忎粛鐢ㄩ攣瀹氳褰�
                         }).ToList()
                     };
 
@@ -420,6 +470,33 @@
                           .SetColumns(x => x.ReturnToMESStatus == 1)
                           .Where(x => x.OrderNo == orderNo)
                           .ExecuteCommandAsync();
+                    }
+                    else
+                    {
+                        var dborderDetails = await _outboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
+                              .LeftJoin<Dt_OutboundOrder>((o, item) => o.OrderId == item.Id)
+                              .Where((o, item) => item.OrderNo == orderNo && item.ReturnToMESStatus != 1)
+                              .Select((o, item) => o)
+                              .ToListAsync();                
+                        var secallCompleted = true;
+                        foreach (var detail in orderDetails.Where(x => x.ReturnToMESStatus == 0).ToList())
+                        {
+                            if (detail.OverOutQuantity < detail.NeedOutQuantity)
+                            {
+                                secallCompleted = false;
+                            }
+                        }
+                        if (secallCompleted)
+                        {
+                            await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
+                                 .SetColumns(it => new Dt_OutboundOrder
+                                 {
+                                     ReturnToMESStatus = 1,
+                                     OrderStatus = OutOrderStatusEnum.鍑哄簱瀹屾垚.ObjToInt(),
+                                 })
+                                 .Where(x => x.OrderNo == orderNo)
+                                 .ExecuteCommandAsync();
+                        }
                     }
                 }
                 else
@@ -509,16 +586,16 @@
                             materialCode = detail.MaterielCode,
                             lineNo = detail.lineNo, // 娉ㄦ剰锛氳繖閲屽彲鑳介渶瑕佽皟鏁村瓧娈靛悕
                             warehouseCode = detail.WarehouseCode,
-                            qty = detail.OverOutQuantity, // 浣跨敤璁㈠崟鏄庣粏鐨勫凡鍑哄簱鏁伴噺
-                            currentDeliveryQty = detail.OverOutQuantity,
-                            unit = detail.Unit,
+                            qty = detail.BarcodeQty,  
+                            currentDeliveryQty = detail.BarcodeQty,
+                            unit = detail.BarcodeUnit,
                             barcodes = detailLocks.Select(lockInfo => new WIDESEA_DTO.Outbound.BarcodesModel
                             {
                                 barcode = lockInfo.CurrentBarcode,
                                 supplyCode = lockInfo.SupplyCode,
                                 batchNo = lockInfo.BatchNo,
-                                unit = lockInfo.Unit,
-                                qty = lockInfo.PickedQty // 鏉$爜绾у埆鐨勬暟閲忎粛鐢ㄩ攣瀹氳褰�
+                                unit = lockInfo.BarcodeUnit,
+                                qty = lockInfo.BarcodeQty // 鏉$爜绾у埆鐨勬暟閲忎粛鐢ㄩ攣瀹氳褰�
                             }).ToList()
                         };
 

--
Gitblit v1.9.3