From 81117ff938bfebc06801017d26176a9ffa4d0731 Mon Sep 17 00:00:00 2001
From: Admin <Admin@ADMIN>
Date: 星期三, 14 一月 2026 17:47:33 +0800
Subject: [PATCH] 接口信息

---
 项目代码/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs |   84 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 84 insertions(+), 0 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
index 408a9cb..0112781 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/TaskService.cs"
@@ -17,9 +17,13 @@
 
 using AutoMapper;
 using SqlSugar;
+using System.Reflection;
 using WIDESEA_Common.TaskEnum;
+using WIDESEA_Core;
 using WIDESEA_Core.BaseRepository;
 using WIDESEA_Core.BaseServices;
+using WIDESEA_Core.Helper;
+using WIDESEA_DTO.Task;
 using WIDESEA_IBasicService;
 using WIDESEA_IInboundService;
 using WIDESEA_IOutboundService;
@@ -34,6 +38,10 @@
     {
         private readonly IMapper _mapper;
         private readonly IUnitOfWorkManage _unitOfWorkManage;
+        private readonly IStockInfoService _stockInfoService;
+        private readonly ILocationInfoService _locationInfoService;
+        private readonly IWarehouseService _warehouseService;
+        private readonly IRoadWayinfoService _roadWayinfoService;
 
         public IRepository<Dt_Task> Repository => BaseDal;
 
@@ -53,5 +61,81 @@
             _unitOfWorkManage = unitOfWorkManage;
         }
 
+
+        /// <summary>
+        /// 浠诲姟瀹屾垚鎺ュ彛
+        /// </summary>
+        /// <param name="wCSTask"></param>
+        /// <returns></returns>
+        public WebResponseContent TaskCompleted(WCSTaskDTO wCSTask)
+        {
+            try
+            {
+                Dt_Task task = BaseDal.QueryFirst(x => x.TaskId == wCSTask.TaskNum && x.PalletCode == wCSTask.PalletCode);
+                if (task == null)
+                    return WebResponseContent.Instance.Error("鏈壘鍒颁换鍔′俊鎭�");
+
+                switch ((TaskTypeEnum)task.TaskType)
+                {
+                    case TaskTypeEnum.Inbound:
+                        return HandleInboundTask(task, wCSTask.TaskType);
+                    case TaskTypeEnum.Outbound:
+                        return HandleOutboundTask(task, wCSTask.TaskType);
+                    case TaskTypeEnum.Relocation:
+                        return HandleRelocationTask(task, wCSTask.TaskType);
+                    default:
+                        return WebResponseContent.Instance.Error($"浠诲姟绫诲瀷閿欒锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode},绫诲瀷锛歿task.TaskType}");
+                }
+            }
+            catch (Exception ex)
+            {
+                return WebResponseContent.Instance.Error($"WMS浠诲姟瀹屾垚閿欒锛歿ex.Message}");
+            }
+        }
+
+        private WebResponseContent HandleInboundTask(Dt_Task task, int wcsTaskType)
+        {
+            switch (wcsTaskType)
+            {
+                case 1:
+                    task.TaskStatus = (int)InTaskStatusEnum.PLC_InFinish;
+                    BaseDal.UpdateData(task);
+                    return WebResponseContent.Instance.OK($"宸叉帴鏀跺叆搴撹緭閫佺嚎瀹屾垚淇℃伅锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode}");
+                case 2:
+                    task.TaskStatus = (int)InTaskStatusEnum.SC_OutFinish;
+                    BaseDal.UpdateData(task);
+                    return WebResponseContent.Instance.OK($"宸叉帴鏀跺叆搴撳爢鍨涙満瀹屾垚淇℃伅锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode}");
+                default:
+                    return WebResponseContent.Instance.Error($"WCS涓婃姤绫诲瀷閿欒锛歿wcsTaskType}");
+            }
+        }
+
+        private WebResponseContent HandleOutboundTask(Dt_Task task, int wcsTaskType)
+        {
+            switch (wcsTaskType)
+            {
+                case 1:
+                    task.TaskStatus = (int)OutTaskStatusEnum.PLC_OutFinish;
+                    BaseDal.UpdateData(task);
+                    return WebResponseContent.Instance.OK($"宸叉帴鏀跺嚭搴撹緭閫佺嚎瀹屾垚淇℃伅锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode}");
+                case 2:
+                    task.TaskStatus = (int)OutTaskStatusEnum.SC_OutFinish;
+                    BaseDal.UpdateData(task);
+                    return WebResponseContent.Instance.OK($"宸叉帴鏀跺嚭搴撳爢鍨涙満瀹屾垚淇℃伅锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode}");
+                default:
+                    return WebResponseContent.Instance.Error($"WCS涓婃姤绫诲瀷閿欒锛歿wcsTaskType}");
+            }
+        }
+
+        private WebResponseContent HandleRelocationTask(Dt_Task task, int wcsTaskType)
+        {
+            if (wcsTaskType == 2)
+            {
+                task.TaskStatus = (int)RelocationTaskStatusEnum.RelocationFinish;
+                BaseDal.UpdateData(task);
+                return WebResponseContent.Instance.OK($"宸叉帴鏀剁Щ搴撳爢鍨涙満瀹屾垚淇℃伅锛屼换鍔″彿锛歿task.TaskId},鎵樼洏缂栧彿锛歿task.PalletCode}");
+            }
+            return WebResponseContent.Instance.Error($"WCS涓婃姤绫诲瀷閿欒锛歿wcsTaskType}");
+        }
     }
 }

--
Gitblit v1.9.3