From 3b3f39b55ba6d04a95536bebd6233b2a6e464290 Mon Sep 17 00:00:00 2001
From: xxyy <cathay_xy@163.com>
Date: 星期二, 18 二月 2025 10:20:02 +0800
Subject: [PATCH] 更新命名空间、异常处理和任务逻辑

---
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs |   53 ++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 42 insertions(+), 11 deletions(-)

diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs
index 9ba2a5b..909b441 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs
@@ -1,11 +1,9 @@
 锘縰sing AutoMapper;
 using HslCommunication;
 using Mapster;
-using Microsoft.AspNetCore.Components.Routing;
 using Newtonsoft.Json;
 using SqlSugar;
 using System.Diagnostics.CodeAnalysis;
-using System.Threading.Tasks;
 using WIDESEAWCS_BasicInfoRepository;
 using WIDESEAWCS_BasicInfoService;
 using WIDESEAWCS_Common;
@@ -20,8 +18,6 @@
 using WIDESEAWCS_ITaskInfoRepository;
 using WIDESEAWCS_ITaskInfoService;
 using WIDESEAWCS_Model.Models;
-using WIDESEAWCS_QuartzJob;
-using WIDESEAWCS_QuartzJob.DeviceBase;
 using WIDESEAWCS_QuartzJob.Models;
 using WIDESEAWCS_QuartzJob.Repository;
 using WIDESEAWCS_QuartzJob.Service;
@@ -97,7 +93,7 @@
                     if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.OutbondGroup)
                     {
                         // 鍒ゆ柇浠诲姟鐩爣鍦板潃鍜岃矾寰勬槸鍚︽弧瓒崇壒瀹氭潯浠�
-                        if (task.TargetAddress == "002-021-001" && task.Roadway.Contains("JZ") && task.TaskType == (int)TaskOutboundTypeEnum.OutTray)
+                        if ((task.TargetAddress == "002-021-001" || task.TargetAddress == "001-021-001") && task.Roadway.Contains("JZ"))
                         {
                             // 璁剧疆浠诲姟鐘舵�佷负鍑哄簱鏂板缓
                             task.TaskState = (int)TaskOutStatusEnum.OutNew;
@@ -138,8 +134,11 @@
                     // 鍒ゆ柇浠诲姟绫诲瀷鏄惁涓哄叆搴撲换鍔�
                     else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                     {
+                        var value = _sys_ConfigService.GetByConfigKey(CateGoryConst.CONFIG_SYS_InStation, SysConfigKeyConst.JZNGInBoundStation).ConfigValue;
+                        var valueList = value.Split(',').ToList();
                         // 鍒ゆ柇婧愬湴鍧�鏄惁涓嶇瓑浜�"1359-4"
-                        if (task.SourceAddress != "1359-4")
+                        //if (task.SourceAddress != "1359-4" && task.SourceAddress != "1357-4")
+                        if (!valueList.Contains(task.SourceAddress))
                         {
                             // 鏌ヨ浠庢簮鍦板潃鍒扮洰鏍囧湴鍧�鐨勮矾鐢�
                             List<Dt_Router> routers = _routerService.QueryNextRoutes(item.SourceAddress, item.TargetAddress);
@@ -155,8 +154,13 @@
                         }
                         else
                         {
-                            // 璁剧疆褰撳墠鍦板潃涓�"002-021-001"
-                            task.CurrentAddress = "002-021-001";
+                            task.CurrentAddress = string.Empty;
+                            if (task.SourceAddress == "1325-6")
+                                // 璁剧疆褰撳墠鍦板潃涓�"001-021-001"
+                                task.CurrentAddress = "001-021-001";
+                            else
+                                // 璁剧疆褰撳墠鍦板潃涓�"002-021-001"
+                                task.CurrentAddress = "002-021-001";
                             // 璁剧疆涓嬩竴涓湴鍧�涓虹洰鏍囧湴鍧�
                             task.NextAddress = item.TargetAddress;
                         }
@@ -210,7 +214,7 @@
                     wmsIpAddrss = GetIpAddress(SysConfigKeyConst.WMSIP_BASE, SysConfigKeyConst.RequestTask);
                 }
 
-                var result = await HttpHelper.PostAsync(wmsIpAddrss, new { Position = sourceAddress, PalletCode = palletCode }.ToJsonString());
+                var result = await HttpHelper.PostAsync(wmsIpAddrss, new { Position = sourceAddress, PalletCode = palletCode, stationManager.productLine }.ToJsonString());
                 content = JsonConvert.DeserializeObject<WebResponseContent>(result);
 
                 if (!content.Status)
@@ -227,8 +231,7 @@
                     _Task.TaskState = (int)TaskInStatusEnum.InNew;
                     _Task.CurrentAddress = task.SourceAddress;
                     _Task.NextAddress = station.stationNGChildCode;
-                    _Task.TargetAddress = station.stationNGLocation;
-                    _Task.Roadway = station.Roadway;
+                    _Task.TargetAddress = task.TargetAddress;
 
                     BaseDal.AddData(_Task);
                     _taskExecuteDetailService.AddTaskExecuteDetail(_Task.TaskNum, "鎺ユ敹WMS浠诲姟");
@@ -504,6 +507,12 @@
                         BaseDal.DeleteData(task);
                         _taskHtyRepository.AddData(task_Hty);
                     }
+
+                    if (task.TaskState == (int)TaskOutStatusEnum.SC_OutFinish)
+                    {
+                        content = StackCraneTaskCompleted(task.TaskNum);
+                        return content;
+                    }
                 }
                 else if (task.TaskType.GetTaskTypeGroup() == TaskTypeGroup.InboundGroup)
                 {
@@ -554,6 +563,12 @@
                     }
                     else if (task.TaskState == (int)TaskInStatusEnum.SC_InFinish)
                     {
+                        if (App.User.UserId > 0)
+                        {
+                            content = StackCraneTaskCompleted(task.TaskNum);
+                            return content;
+                        }
+
                         task.ModifyDate = DateTime.Now;
                         task.Modifier = "System";
 
@@ -868,5 +883,21 @@
             }
             return wcsBasez + address;
         }
+
+        #region 閲嶅啓鏂规硶
+
+        public override WebResponseContent DeleteData(object[] key)
+        {
+            foreach (var item in key)
+            {
+                var task = BaseDal.QueryFirst(x => x.TaskId == Convert.ToInt32(item));
+                var taskHty = task.Adapt<Dt_Task_Hty>();
+                taskHty.Creater = App.User.UserName != null ? App.User.UserName : "System";
+                _taskHtyRepository.AddData(taskHty);
+            }
+            return base.DeleteData(key);
+        }
+
+        #endregion 閲嶅啓鏂规硶
     }
 }
\ No newline at end of file

--
Gitblit v1.9.3