From fe77f3c9d11e3087c1efa56fd6205ffc10e39991 Mon Sep 17 00:00:00 2001
From: helongyang <647556386@qq.com>
Date: 星期四, 05 六月 2025 18:45:23 +0800
Subject: [PATCH] 更新

---
 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs |   81 +++++++++++++++++++++++++++++++++++++---
 1 files changed, 75 insertions(+), 6 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
index a225003..8a041a3 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs"
@@ -88,7 +88,9 @@
                         TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                         TaskStatus = TaskStatusEnum.New.ObjToInt(),
                         WarehouseId = stockInfo.WarehouseId,
-                        PalletType = stockInfo.PalletType
+                        PalletType = stockInfo.PalletType,
+                        MaterielCode = stockInfo.Details.Where(x => x.StockId == stockInfo.Id).FirstOrDefault()?.MaterielCode,
+                        Quantity = (float)stockInfo.Details.Where(x => x.StockId == stockInfo.Id).FirstOrDefault()?.StockQuantity,
                     };
                     //鑾峰彇鏄惁瀛樺湪鍏ュ簱鍗�
                     Dt_InboundOrder? inboundOrder =  null;
@@ -278,7 +280,7 @@
         /// <param name="roadwayNo"></param>
         /// <param name="palletCode"></param>
         /// <returns></returns>
-        public WebResponseContent DeviceRequestInboundTask(string stationCode, string roadwayNo, string palletCode)
+        public WebResponseContent DeviceRequestInboundTask(string stationCode, string roadwayNo, string palletCode,string materielBoxCode = "")
         {
             try
             {
@@ -293,7 +295,72 @@
                 {
                     return WebResponseContent.Instance.Error($"璇ョ珯鐐瑰凡鏈夋湭鎵ц鐨勪换鍔�");
                 }
+                if (!string.IsNullOrEmpty(materielBoxCode))
+                {
+                    _unitOfWorkManage.BeginTran();
+                    WebResponseContent responseGroup = _inboundOrderService.MaterielPPorGM(materielBoxCode);
+                    if (!responseGroup.Status)
+                    {
+                        return WebResponseContent.Instance.Error($"{responseGroup.Message}");
+                    }
+                    Dt_StockInfo stockInfoPPorGM = responseGroup.Data as Dt_StockInfo ?? null;
+                    if (stockInfoPPorGM==null)
+                    {
+                        return WebResponseContent.Instance.Error($"缁勭洏鏁版嵁杞崲澶辫触");
+                    }
+                    Dt_LocationInfo? locationInfoPPorGM = _basicService.LocationInfoService.AssignLocation(roadwayNo, stockInfoPPorGM.PalletType, stockInfoPPorGM.WarehouseId);
+                    if (locationInfoPPorGM == null)
+                    {
+                        return WebResponseContent.Instance.Error($"璐т綅鍒嗛厤澶辫触,鏈壘鍒板彲鍒嗛厤璐т綅");
+                    }
+                    Dt_Task newTaskPPorGM = new Dt_Task()
+                    {
+                        CurrentAddress = stationCode,
+                        Grade = 0,
+                        NextAddress = locationInfoPPorGM.LocationCode,
+                        PalletCode = stockInfoPPorGM.PalletCode,
+                        Roadway = roadwayNo,
+                        SourceAddress = stationCode,
+                        TargetAddress = locationInfoPPorGM.LocationCode,
+                        TaskType = TaskTypeEnum.Inbound.ObjToInt(),
+                        TaskStatus = TaskStatusEnum.New.ObjToInt(),
+                        WarehouseId = stockInfoPPorGM.WarehouseId,
+                        PalletType = stockInfoPPorGM.PalletType,
+                        TaskLength= stockInfoPPorGM.StockLength
+                    };
 
+                    //鑾峰彇鏄惁瀛樺湪鍏ュ簱鍗�
+                    Dt_InboundOrder? inboundOrderPPorGM = null;
+                    if (stockInfoPPorGM != null && stockInfoPPorGM.Details.Count > 0)
+                    {
+                        string? orderNo = stockInfoPPorGM.Details.FirstOrDefault()?.OrderNo ?? "";
+                        inboundOrderPPorGM = _inboundOrderService.Repository.QueryFirst(x => x.InboundOrderNo == orderNo && x.OrderStatus < InOrderStatusEnum.鍏ュ簱瀹屾垚.ObjToInt());
+                    }
+
+                    if (inboundOrderPPorGM != null)
+                    {
+                        if (inboundOrderPPorGM.OrderType == InOrderTypeEnum.Allocat.ObjToInt())
+                        {
+                            newTaskPPorGM.TaskType = TaskTypeEnum.InAllocate.ObjToInt();
+                        }
+                        else if (inboundOrderPPorGM.OrderType == InOrderTypeEnum.Return.ObjToInt())
+                        {
+                            newTaskPPorGM.TaskType = TaskTypeEnum.ProductionReturn.ObjToInt();
+                        }
+                    }
+                    stockInfoPPorGM.StockStatus = StockStatusEmun.鍏ュ簱纭.ObjToInt();
+                    LocationStatusEnum lastStatusPPorGM = (LocationStatusEnum)locationInfoPPorGM.LocationStatus;
+                    _recordService.LocationStatusChangeRecordSetvice.AddLocationStatusChangeRecord(locationInfoPPorGM, lastStatusPPorGM, LocationStatusEnum.Lock, LocationChangeType.InboundAssignLocation);
+                    _basicService.LocationInfoService.UpdateLocationStatus(locationInfoPPorGM, newTaskPPorGM.PalletType, LocationStatusEnum.Lock, newTaskPPorGM.WarehouseId);
+                    int taskIdPPorGM = BaseDal.AddData(newTaskPPorGM);
+                    newTaskPPorGM.TaskId = taskIdPPorGM;
+                    _stockRepository.StockInfoRepository.Db.InsertNav(stockInfoPPorGM).Include(x => x.Details).ExecuteCommand();
+                    _unitOfWorkManage.CommitTran();
+                    WMSTaskDTO wMSTaskDTOPPorGM = _mapper.Map<WMSTaskDTO>(newTaskPPorGM);
+
+                    PushTasksToWCS(new List<Dt_Task> { newTaskPPorGM });
+                    return WebResponseContent.Instance.OK(data: wMSTaskDTOPPorGM);
+                }
                 Dt_StockInfo stockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => x.PalletCode == palletCode).Includes(x => x.Details).First();
                 if (stockInfo == null)
                 {
@@ -326,7 +393,7 @@
                     TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = stockInfo.WarehouseId,
-                    PalletType = stockInfo.PalletType
+                    PalletType = stockInfo.PalletType,
                 };
 
                 //鑾峰彇鏄惁瀛樺湪鍏ュ簱鍗�
@@ -434,7 +501,7 @@
                     TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = stockInfo.WarehouseId,
-                    PalletType = stockInfo.PalletType
+                    PalletType = stockInfo.PalletType,
                 };
 
 
@@ -533,7 +600,7 @@
                     TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = stockInfo.WarehouseId,
-                    PalletType = stockInfo.PalletType
+                    PalletType = stockInfo.PalletType,
                 };
 
                 if (stockInfo.StockStatus == StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt())
@@ -761,7 +828,9 @@
                     TaskType = TaskTypeEnum.InProductBack.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = warePoint.WarehouseId,
-                    PalletType = proStockInfo.PalletType
+                    PalletType = proStockInfo.PalletType,
+                    MaterielCode = proStockInfo.proStockInfoDetails.Where(x => x.ProStockId == proStockInfo.Id).FirstOrDefault()?.ProductCode,
+                    Quantity = (float)proStockInfo.proStockInfoDetails.Where(x => x.ProStockId == proStockInfo.Id).Sum(x => x.StockPcsQty)
                 };
                 _unitOfWorkManage.BeginTran();
                 int taskId = BaseDal.AddData(newTask);

--
Gitblit v1.9.3