From cde56aae50adc11ff8db84e424d873843c566bfd Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期一, 24 二月 2025 23:40:41 +0800
Subject: [PATCH] 优化WCS移库逻辑

---
 项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs |   79 ++++++++++++++++++++++++++++++++-------
 1 files changed, 64 insertions(+), 15 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
index 0bcc363..5394bb0 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs"
@@ -61,6 +61,8 @@
 
         public List<int> TaskOutboundTypes => typeof(TaskOutboundTypeEnum).GetEnumIndexList();
 
+        public List<int> TaskRelocationTypes => typeof(TaskRelocationTypeEnum).GetEnumIndexList();
+
         public TaskService(ITaskRepository BaseDal, IRouterService routerService, ITaskExecuteDetailService taskExecuteDetailService, ITaskExecuteDetailRepository taskExecuteDetailRepository, ITaskHtyService taskHtyService, IMapper mapper) : base(BaseDal)
         {
             _routerService = routerService;
@@ -174,9 +176,9 @@
         /// <param name="taskNum">浠诲姟鍙�</param>
         /// <param name="currentAddress">褰撳墠鍦板潃</param>
         /// <returns></returns>
-        public Dt_Task QueryCompletedConveyorLineTask(int taskNum, string currentAddress)
+        public Dt_Task QueryCompletedConveyorLineTask(string Barcode, string currentAddress)
         {
-            return BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.CurrentAddress == currentAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InFinish || x.TaskState == (int)TaskOutStatusEnum.Line_OutFinish), TaskOrderBy);
+            return BaseDal.QueryFirst(x => x.PalletCode == Barcode && x.CurrentAddress == currentAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InFinish || x.TaskState == (int)TaskOutStatusEnum.Line_OutFinish), TaskOrderBy);
         }
 
         public Dt_Task QuertOutProductionLineTask(bool NextAddIsNull)
@@ -202,7 +204,26 @@
                 return BaseDal.QueryFirst(x => x.Roadway == deviceNo && TaskOutboundTypes.Contains(x.TaskType) && x.TaskState == (int)TaskOutStatusEnum.OutNew, TaskOrderBy);
             return null;
         }
-
+        /// <summary>
+        /// 鏌ヨ搴撳唴绉诲簱浠诲姟
+        /// </summary>
+        /// <param name="deviceNo"></param>
+        /// <param name="currentAddress"></param>
+        /// <returns></returns>
+        public Dt_Task QueryStackerCraneRelocationTask(string deviceNo, string currentAddress = "")
+        {
+            Dt_Task task = null;
+            List<Dt_Task> tasks = new List<Dt_Task>();
+            if (string.IsNullOrEmpty(currentAddress))
+                tasks = BaseDal.QueryData(x => x.Roadway == deviceNo && TaskRelocationTypes.Contains(x.TaskType) && x.TaskState < TaskRelocationStatusEnum.SC_RelocationExecuting.ObjToInt()).OrderBy(x => x.TaskNum).ToList();
+            else
+                tasks = BaseDal.QueryData(x => x.Roadway == deviceNo && x.CurrentAddress == currentAddress && TaskRelocationTypes.Contains(x.TaskType) && x.TaskState < TaskRelocationStatusEnum.SC_RelocationExecuting.ObjToInt()).OrderBy(x => x.TaskNum).ToList();
+            if (tasks != null && tasks.Count > 0)
+            {
+                task = tasks.First();
+            }
+            return task;
+        }
         /// <summary>
         /// 鏍规嵁璁惧缂栧彿銆佸綋鍓嶅湴鍧�鎸夌収浼樺厛绾т互鍙婂垱寤烘椂闂存帓搴忔煡璇换鍔℃睜鏂板鐨勪换鍔�
         /// </summary>
@@ -344,8 +365,9 @@
                     }
 
                     int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskOutStatusEnum>();
-
                     task.TaskState = nextStatus;
+                    if (task.SourceIsPickPlace && task.TaskState == TaskOutStatusEnum.OutNew.ObjToInt())
+                        task.TaskState = TaskOutStatusEnum.SC_OutExecuting.ObjToInt();
                 }
                 else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                 {
@@ -373,15 +395,29 @@
                     }
                     int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskRelocationStatusEnum>();
                     task.TaskState = nextStatus;
+                    if (task.SourceIsPickPlace && task.TaskState == TaskRelocationStatusEnum.RelocationNew.ObjToInt())
+                        task.TaskState = TaskRelocationStatusEnum.SC_RelocationExecuting.ObjToInt();
                 }
                 else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OtherGroup)//搴撳唴绉昏溅
                 {
-                    if (task.TaskState >= (int)TaskCarStatusEnum.RelocationCarFinish)
+                    if (task.TaskType == TaskOtherTypeEnum.RelocationCar.ObjToInt())
                     {
-                        return content = WebResponseContent.Instance.Error($"璇ヤ换鍔$姸鎬佷笉鍙烦杞埌涓嬩竴姝�,浠诲姟鍙�:銆恵task.TaskNum}銆�,浠诲姟鐘舵��:銆恵task.TaskState}銆�");
+                        if (task.TaskState >= (int)TaskCarStatusEnum.RelocationCarFinish)
+                        {
+                            return content = WebResponseContent.Instance.Error($"璇ヤ换鍔$姸鎬佷笉鍙烦杞埌涓嬩竴姝�,浠诲姟鍙�:銆恵task.TaskNum}銆�,浠诲姟鐘舵��:銆恵task.TaskState}銆�");
+                        }
+                        int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskCarStatusEnum>();
+                        task.TaskState = nextStatus;
                     }
-                    int nextStatus = task.TaskState.GetNextNotCompletedStatus<TaskCarStatusEnum>();
-                    task.TaskState = nextStatus;
+                    else if (task.TaskType == TaskOtherTypeEnum.RelocationCarCharging.ObjToInt())
+                    {
+                        if (task.TaskState >= (int)CarChargingTaskEnum.RelocationCarFinish)
+                        {
+                            return content = WebResponseContent.Instance.Error($"璇ヤ换鍔$姸鎬佷笉鍙烦杞埌涓嬩竴姝�,浠诲姟鍙�:銆恵task.TaskNum}銆�,浠诲姟鐘舵��:銆恵task.TaskState}銆�");
+                        }
+                        int nextStatus = task.TaskState.GetNextNotCompletedStatus<CarChargingTaskEnum>();
+                        task.TaskState = nextStatus;
+                    }
                 }
                 else
                 {
@@ -534,15 +570,18 @@
             }
             return content;
         }
-
-        /// <summary>
-        /// 鏍规嵁浠诲姟鍙锋煡璇换鍔�
-        /// </summary>
-        /// <param name="taskNum"></param>
-        /// <returns></returns>
         public Dt_Task GetTaskInfo(int taskNum)
         {
             return BaseDal.QueryFirst(x => x.TaskNum == taskNum);
+        }
+        /// <summary>
+        /// 鏍规嵁浠诲姟鍙峰拰浠诲姟鐘舵�佹煡璇换鍔�
+        /// </summary>
+        /// <param name="taskNum"></param>
+        /// <returns></returns>
+        public Dt_Task GetTaskInfo(int taskNum, int taskState)
+        {
+            return BaseDal.QueryFirst(x => x.TaskNum == taskNum && x.TaskState == taskState);
         }
         /// <summary>
         /// 鏍规嵁浠诲姟鐘舵�併�佺被鍨嬫煡璇换鍔�
@@ -572,13 +611,23 @@
         /// <exception cref="NotImplementedException"></exception>
         public WebResponseContent AddRelocationCarTask(string SourceAddress, string TargetAddress, string ShuttleCarCode = "", string remark = "")
         {
+            if (!string.IsNullOrEmpty(SourceAddress) && SourceAddress != "")
+            {
+                Dt_Task? task = BaseDal.QueryFirst(x => x.SourceAddress == SourceAddress && x.TaskType == TaskOtherTypeEnum.RelocationCar.ObjToInt());
+                if (task != null) return WebResponseContent.Instance.Error();
+            }
+            if (!string.IsNullOrEmpty(TargetAddress) && TargetAddress != "")
+            {
+                Dt_Task? task = BaseDal.QueryFirst(x => x.SourceAddress == TargetAddress && x.TaskType == TaskOtherTypeEnum.RelocationCar.ObjToInt());
+                if (task != null) return WebResponseContent.Instance.Error();
+            }
             #region 鍒涘缓鍫嗗灈鏈虹Щ杞︿换鍔�
             Dt_Task dt_Task = new Dt_Task()
             {
                 TaskNum = Convert.ToInt32(DateTime.Now.ToString("HHmmss")),
                 Grade = 2,
                 Roadway = "SC01",
-                TaskType = (int)TaskOtherTypeEnum.RelocationCar,
+                TaskType = string.IsNullOrEmpty(remark) ? (int)TaskOtherTypeEnum.RelocationCar : (int)TaskOtherTypeEnum.RelocationCarCharging,
                 SourceAddress = SourceAddress,
                 TargetAddress = TargetAddress,
                 CurrentAddress = SourceAddress,

--
Gitblit v1.9.3