From 490e62a0f7b33249dabb74e000725bd8555ca186 Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期日, 22 三月 2026 12:56:52 +0800
Subject: [PATCH] 添加3F、4F循环任务;平库表添加状态和托盘号;海康AGV任务反馈添加更新平库货位信息

---
 代码管理/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJJob.cs |   67 +++++++++++++++++++--------------
 1 files changed, 39 insertions(+), 28 deletions(-)

diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJJob.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJJob.cs"
index 870675c..e27a421 100644
--- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJJob.cs"
+++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/TSJJob.cs"
@@ -41,7 +41,6 @@
 
         public Task Execute(IJobExecutionContext context)
         {
-
             bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
             if (flag && value != null)
             {
@@ -103,16 +102,31 @@
                         }
                         else if(task.TaskType == TaskTypeEnum.CK3F.ObjToInt()) //鍑哄簱
                         {
-                            ////鍑哄簱鏂欑缂撳瓨鏁伴噺
+                            ////鍑哄簱鏂欑缂撳瓨鏁伴噺(杩欎釜鏄簱鍖烘煡璇㈢殑鏃跺�欒鏌ヤ竴涓嬶紝杩旂粰wms)
                             //if (device.GetValue<HoistEnum, short>(HoistEnum.Outboundmaterialbox, "TSJ") == 0) throw new Exception("娌℃湁鍑哄簱鏂欑缂撳瓨鏁伴噺涓虹┖");
                             //璇诲彇3妤煎嚭搴撴枡绠卞埌浣�
-                            if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, "TSJ") != 1) throw new Exception("3妤煎嚭搴撴枡绠辨病鏈夊埌浣�");
+                            if (device.GetValue<HoistEnum, short>(HoistEnum.SOutboundmaterialbox, "TSJ") != 1)
+                            {
+                                if (task.ExceptionMessage != "3妤煎嚭搴撴枡绠辨病鏈夊埌浣�")
+                                {
+                                    task.ExceptionMessage = "3妤煎嚭搴撴枡绠辨病鏈夊埌浣�";
+                                    Uptasks.Add(task);
+                                }
+                                continue;
+                            }
                             //鐒跺悗璋冪敤杈撻�佺嚎鎺ュ彛锛岄�氱煡杈撻�佺嚎鏈夋枡绠遍渶瑕佸叆搴擄紝浠诲姟涓捐鎵ц
-                            if (_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Status == false) throw new Exception($"3妤煎嚭搴撲换鍔′妇琛屾墽琛屽け璐ワ紝閿欒淇℃伅{_taskService.Hikvisiontaskscontinue(task.WMSTaskNum).Message}");//缁欎换鍔″彿
-
-                            //鍘绘洿鏂颁换鍔¢噷鍐欏��
-                            //鍐�3妤煎嚭搴撶鍙栬揣瀹屾垚
-                            device.SetValue<HoistEnum, short>(HoistEnum.Outboundboxon, 1);
+                            var result = _taskService.Hikvisiontaskscontinue(task.WMSTaskNum);
+                            if (result.Status == false) 
+                            {
+                                if (task.ExceptionMessage != result.Message)
+                                {
+                                    task.ExceptionMessage = result.Message;
+                                    Uptasks.Add(task);
+                                }
+                                continue;
+                            }
+                            task.TaskState = (int)TaskStatusEnum.AGV_ToExecute;
+                            Uptasks.Add(task);
                         }
                         else if (task.TaskType == TaskTypeEnum.Q1TSJ4.ObjToInt())//4妤煎叆搴�
                         {
@@ -129,7 +143,7 @@
                         {
                             
                             //4妤煎嚭搴撴枡绠卞埌浣�
-                            if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox, "TSJ") == 2) throw new Exception("4妤煎嚭搴撴枡绠辨病鏈夊埌浣�");
+                            if (device.GetValue<HoistEnum, short>(HoistEnum.FOutboundmaterialbox,"TSJ") == 2) throw new Exception("4妤煎嚭搴撴枡绠辨病鏈夊埌浣�");
                             //鍐欎互涓�涓嚭搴撳畬鎴愪俊鍙�
                             device.SetValue(HoistEnum.Outboundboxretrievalcompleted, "TSJ", "1");
                         }
@@ -139,40 +153,37 @@
 
 
                     //鏌ユ壘涓夋ゼ鍏ュ簱浠诲姟鐘舵�佷负CheckPalletCodeing鐨勪换鍔℃墭鐩樺彿纭涓�
-                    var RK3FTasks = taskList.Where(x => x.TaskType == TaskTypeEnum.RK3F.ObjToInt()&&x.TaskState== (int)TaskStatusEnum.CheckPalletCodeing).ToList();
-                    foreach (var item in RK3FTasks)
+                    var RK3FTasks = _taskService.Repository.QueryFirst(x => x.TaskType == TaskTypeEnum.RK3F.ObjToInt() && x.TaskState == (int)TaskStatusEnum.CheckPalletCodeing);
+                    if (RK3FTasks!=null)
                     {
                         var Barcode = device.SetValue<HoistEnum, short>(HoistEnum.Codereadingtriggered, 1);
                         //妫�鏌�3妤煎叆搴撶鍙锋槸澶氬皯锛岀劧鍚庝紶缁檞ms
                         var BinNumber = device.GetValue<HoistEnum, string>(HoistEnum.Inboxnumber, "TSJ");
                         //鏍规嵁璇诲埌鐨勭鍙疯繘琛屾枡绠辨楠岋紝妫�楠岄�氳繃灏辫Е鍙戣鐮佸櫒璇诲彇锛屽鏋滀笉閫氳繃灏辨姏鍑哄紓甯�
-                        var Verification = _taskService.MaterialBoxInspection(item.WMSTaskNum, BinNumber.ToString());
-                        if (!Verification.Status) 
+                        var Verification = _taskService.MaterialBoxInspection(RK3FTasks.WMSTaskNum, BinNumber.ToString());
+                        if (!Verification.Status)
                         {
-                            if (!(item.ExceptionMessage == Verification.Message))
+                            if (!(RK3FTasks.ExceptionMessage == Verification.Message))
                             {
-                                item.ExceptionMessage = Verification.Message;
-                                Uptasks.Add(item);
+                                RK3FTasks.ExceptionMessage = Verification.Message;
+                                Uptasks.Add(RK3FTasks);
                             }
                             //鏂欑楠岃瘉鍐欏ソ鍚庯紝闇�瑕佹洿鏀�
-                            item.TargetAddress = Verification.Data.ToString();
-                        } 
-                        
+                            RK3FTasks.TargetAddress = Verification.Data.ToString();
+                        }
+
                         //濡傛灉鏂欑妫�楠屾垚鍔熷氨鍐欏叆璇荤爜鍣ㄧ殑鍊�
-                        var result = _taskService.Hikvisiontaskscontinue(item.WMSTaskNum, item.TargetAddress);
+                        var result = _taskService.Hikvisiontaskscontinue(RK3FTasks.WMSTaskNum, RK3FTasks.TargetAddress);
                         if (result.Status == false)
                         {
-                            if (item.ExceptionMessage != result.Message)
+                            if (RK3FTasks.ExceptionMessage != result.Message)
                             {
-                                item.ExceptionMessage = result.Message;
-                                Uptasks.Add(item);
+                                RK3FTasks.ExceptionMessage = result.Message;
+                                Uptasks.Add(RK3FTasks);
                             }
-                            continue;
                         }
-                        item.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;
-
-
-                        Uptasks.Add(item);
+                        RK3FTasks.TaskState = (int)TaskStatusEnum.CheckPalletCodeFinish;
+                        Uptasks.Add(RK3FTasks);
                     }
                     if (Uptasks.Count > 0)
                     {

--
Gitblit v1.9.3