From 696edbff3c8812e4b820f624d66a02ae6ddb1a06 Mon Sep 17 00:00:00 2001
From: 647556386 <647556386@qq.com>
Date: 星期四, 16 四月 2026 13:40:18 +0800
Subject: [PATCH] Merge branch 'htq20251215' of http://115.159.85.185:8098/r/ZhongRui/ALDbanyunxiangmu into htq20251215

---
 项目代码/WMS无仓储版/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService_Inbound.cs |   83 ++++++++++++++---------------------------
 1 files changed, 28 insertions(+), 55 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_TaskInfoService/TaskService_Inbound.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_Inbound.cs"
index e72189b..c025179 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_Inbound.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_Inbound.cs"
@@ -5,6 +5,7 @@
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using WIDESEA_BasicService;
 using WIDESEA_Common.CommonEnum;
 using WIDESEA_Common.LocationEnum;
 using WIDESEA_Common.OrderEnum;
@@ -32,7 +33,12 @@
                 Dt_Task dbtask = Repository.Db.Queryable<Dt_Task>().Where(x => x.PalletCode == palletCode).OrderByDescending(x=>x.CreateDate).First();
                 if (dbtask != null)
                 {
-                    if (dbtask.TaskType == TaskTypeEnum.Outbound.ObjToInt() || dbtask.TaskType == TaskTypeEnum.OutAllocate.ObjToInt())
+                    _logger.LogInformation($"浠诲姟绫诲瀷{dbtask.TaskType.ToString()} ,{dbtask.TaskNum}  ");
+                    if (dbtask.TaskType == TaskTypeEnum.Outbound.ObjToInt())
+                    {
+                        return WebResponseContent.Instance.Error($"鍑哄簱寰呭垎鎷d换鍔�");
+                    }
+                    else if (dbtask.TaskType == TaskTypeEnum.OutAllocate.ObjToInt())
                     {
                         return WebResponseContent.Instance.Error($"鍑哄簱寰呭垎鎷d换鍔�");
                     }
@@ -48,7 +54,7 @@
                     return WebResponseContent.Instance.Error($"鏈壘鍒扮粍鐩樹俊鎭�");
                 }
 
-                if (stockInfo.StockStatus != StockStatusEmun.缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鎷i�夊畬鎴�.ObjToInt())
+                if (stockInfo.StockStatus != StockStatusEmun.缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鎵嬪姩缁勭洏鏆傚瓨.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鎷i�夊畬鎴�.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.鏅轰粨鍏ユ櫤浠撶粍鐩樻殏瀛�.ObjToInt() && stockInfo.StockStatus != StockStatusEmun.閫佹搴撳瓨瀹屾垚.ObjToInt())
                 {
                     return WebResponseContent.Instance.Error($"璇ユ墭鐩樼姸鎬佷笉姝g‘,涓嶅彲鐢宠鍏ュ簱");
                 }
@@ -63,28 +69,35 @@
                     return WebResponseContent.Instance.Error($"璐т綅鍒嗛厤澶辫触,鏈壘鍒板彲鍒嗛厤璐т綅");
                 }
 
-
                 var newTask = new Dt_Task()
                 {                    
-                    CurrentAddress = stationCode,
+                    CurrentAddress = stations.GetValueOrDefault(stationCode) ?? "",
                     Grade = 0,
-                    NextAddress = stations.GetValueOrDefault(stationCode) ?? "",
+                    NextAddress = locationInfo.LocationCode,
                     PalletCode = palletCode,
                     Roadway = locationInfo.RoadwayNo,
-                    SourceAddress = stationCode,
+                    SourceAddress = stations.GetValueOrDefault(stationCode) ?? "",
                     TargetAddress = locationInfo.LocationCode,
                     TaskType = TaskTypeEnum.Inbound.ObjToInt(),
                     TaskStatus = TaskStatusEnum.New.ObjToInt(),
                     WarehouseId = stockInfo.WarehouseId,
                     PalletType = stockInfo.PalletType,
-                    OrderNo= stockInfo.Details.FirstOrDefault()?.OrderNo
-                    
+                    OrderNo= stockInfo.Details.FirstOrDefault()?.OrderNo,
                 };
                 //绌虹
-                if (stockInfo.PalletType == PalletTypeEnum.Empty.ObjToInt())
+                if (stockInfo.PalletType == PalletTypeEnum.Empty.ObjToInt()|| stockInfo.StockStatus == StockStatusEmun.鏅轰粨鍏ユ櫤浠撶粍鐩樻殏瀛�.ObjToInt() || stockInfo.StockStatus == StockStatusEmun.閫佹搴撳瓨瀹屾垚.ObjToInt())
                 {
                     _unitOfWorkManage.BeginTran();
                     newTask.TaskType = TaskTypeEnum.InEmpty.ObjToInt();
+
+                    if (stockInfo.StockStatus == StockStatusEmun.鏅轰粨鍏ユ櫤浠撶粍鐩樻殏瀛�.ObjToInt())
+                    {
+                        newTask.TaskType = TaskTypeEnum.AllocateInWarehouse.ObjToInt();
+                    }
+                    if (stockInfo.StockStatus == StockStatusEmun.閫佹搴撳瓨瀹屾垚.ObjToInt())
+                    {
+                        newTask.TaskType = TaskTypeEnum.InQuality.ObjToInt();
+                    }
                     int taskId = BaseDal.AddData(newTask);
                     newTask.TaskId = taskId;
 
@@ -105,8 +118,6 @@
                         inboundOrder = _inboundOrderService.Repository.QueryFirst(x => x.InboundOrderNo == orderNo && x.OrderStatus < InOrderStatusEnum.鍏ュ簱瀹屾垚.ObjToInt());
                     
                     }
-
-
                     stockInfo.StockStatus = StockStatusEmun.鍏ュ簱纭.ObjToInt();
 
                     LocationStatusEnum lastStatus = (LocationStatusEnum)locationInfo.LocationStatus;
@@ -122,52 +133,14 @@
                     _stockRepository.UpdateData(stockInfo);
                     _unitOfWorkManage.CommitTran();
                 }
-                TaskModel esstask = new TaskModel()
+                await _eSSApiService.MoveContainerAsync(new WIDESEA_DTO.Basic.MoveContainerRequest
                 {
-                    taskType = "putaway",
-                    taskGroupCode = "",
-                    groupPriority = 0,
-                    tasks = new List<TasksType>
-                    {
-                            new()
-                            {
-                                taskCode=newTask.TaskNum.ToString(),
-                                taskPriority=0,
-                                taskDescribe=new TaskDescribeType{
-                                containerCode=palletCode,
-                                containerType= "CT_KUBOT_STANDARD",
-                                fromLocationCode=stations.GetValueOrDefault(stationCode)??"",
-                                toStationCode="",
-                                toLocationCode=locationInfo.LocationCode,
-                                deadline=0,storageTag=""
-                                }
-                            }
-                    }
-                };
- 
-                var result = await _eSSApiService.CreateTaskAsync(esstask);
+                    slotCode = stationCode,
+                    containerCode = palletCode
+                });
 
-                _logger.LogInformation("鍒涘缓浠诲姟杩斿洖:  " + result);
-                if (result)
-                {
-                    try
-                    {
-                        await _eSSApiService.MoveContainerAsync(new WIDESEA_DTO.Basic.MoveContainerRequest
-                        {
-                            slotCode = stationCode,
-                            containerCode = palletCode
-                        });
-                    }
-                    catch (Exception ex) { 
-                    
-
-                    }
-                    return WebResponseContent.Instance.OK();
-                }
-                else
-                {
-                    return WebResponseContent.Instance.Error("涓嬪彂鏈哄櫒浜轰换鍔″け璐ワ紒");
-                }
+            return WebResponseContent.Instance.OK();
+                
             }
             catch (Exception ex)
             {

--
Gitblit v1.9.3