From 29f20b28392d212c04c0c40a512894f8622cfa53 Mon Sep 17 00:00:00 2001
From: wanshenmean <cathay_xy@163.com>
Date: 星期三, 16 四月 2025 09:32:01 +0800
Subject: [PATCH] 合并

---
 CodeManagement/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs |  107 +++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 74 insertions(+), 33 deletions(-)

diff --git a/CodeManagement/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs b/CodeManagement/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs
index 1138106..268b344 100644
--- a/CodeManagement/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs
+++ b/CodeManagement/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob/CommonConveyorLineJob.cs
@@ -256,29 +256,63 @@
                     }
 
                     // 鏌ヨ骞冲彴淇℃伅
-                    Platform platform = _platFormRepository.QueryFirst(x => x.PLCCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
+                    Platform platform = _platFormRepository.QueryFirst(x => x.DeviceCode == conveyorLine.DeviceCode && x.PlatCode == childDeviceCode && x.Status == "Active");
                     if (platform != null && !string.IsNullOrEmpty(platform.Location))
                     {
-                        var strings = platform.Location.Split(',').ToList();
-                        foreach (var ite in strings)
+                        if (platform.PlatCode == "1299" || platform.PlatCode == "1295" || platform.PlatCode == "1291" || platform.PlatCode == "1287" || platform.PlatCode == "1283")
                         {
-                            // 璇诲彇浠诲姟鍛戒护
-                            ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
-                            if (command1.InteractiveSignal != 2)
+                            Platform platformJZ = _platFormRepository.QueryFirst(x => x.PlatCode == "10086" && x.Status == "Active");
+                            if (platformJZ != null)
                             {
-                                command.InteractiveSignal = writeInteractiveSignal;
-                                int count = strings.Count;
-                                // 鑾峰彇澶勭悊鏂规硶
-                                MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
-                                if (method != null)
+                                var strings = platform.Location.Split(',').ToList();
+                                foreach (var ite in strings)
                                 {
-                                    command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
-                                    // 璋冪敤澶勭悊鏂规硶
-                                    method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
+                                    // 璇诲彇浠诲姟鍛戒护
+                                    ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
+                                    if (command1.InteractiveSignal != 2)
+                                    {
+                                        command.InteractiveSignal = writeInteractiveSignal;
+                                        int count = strings.Count;
+                                        // 鑾峰彇澶勭悊鏂规硶
+                                        MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
+                                        if (method != null)
+                                        {
+                                            command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
+                                            // 璋冪敤澶勭悊鏂规硶
+                                            method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
+                                        }
+                                        
+                                    }
                                 }
-                                ;
                             }
+                            //else
+                            //{
+                            //    //ConsoleHelper.WriteErrorLine("闈欑疆绌烘墭涓嶅厑璁稿嚭鏂�");
+                            //}
                         }
+                        else
+                        {
+                            var strings = platform.Location.Split(',').ToList();
+                            foreach (var ite in strings)
+                            {
+                                // 璇诲彇浠诲姟鍛戒护
+                                ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(ite);
+                                if (command1.InteractiveSignal != 2)
+                                {
+                                    command.InteractiveSignal = writeInteractiveSignal;
+                                    int count = strings.Count;
+                                    // 鑾峰彇澶勭悊鏂规硶
+                                    MethodInfo? method = GetType().GetMethod(platform.ExecutionMethod);
+                                    if (method != null)
+                                    {
+                                        command.InteractiveSignal = commandWrite.WriteInteractiveSignal;
+                                        // 璋冪敤澶勭悊鏂规硶
+                                        method.Invoke(this, new object[] { conveyorLine, command, childDeviceCode, count, platform });
+                                    }
+                                    
+                                }
+                            }
+                        } 
                     }
                     //if (conveyorLine.DeviceCode == "1001")
                     //{
@@ -323,8 +357,18 @@
                     }
                     else
                     {
-                        // 鑾峰彇浠诲姟鐨勪笅涓�鐩爣鍦板潃
-                        var next = task.NextAddress;
+                        if (task.Roadway.Contains("JZ"))
+                        {
+                            if (StaticVariable.isStackerRun)
+                            {
+                                StaticVariable.isLineRun = false;
+                                ExecuteConveyorLineTask(conveyorLine, command, ProtocalDetailValue, childDeviceCode);
+                            }
+                        }
+                        else
+                        {
+                            // 鑾峰彇浠诲姟鐨勪笅涓�鐩爣鍦板潃
+                            var next = task.NextAddress;
                         // 灏嗕换鍔℃槧灏勪负鍛戒护
                         var taskCommand = MapTaskCommand(task, command);
                         // 鎭㈠浠诲姟鐨勪笅涓�鐩爣鍦板潃
@@ -343,12 +387,13 @@
                         ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true);
                         // 鏇存柊浠诲姟鐘舵�佷负涓嬩竴鐘舵��
                         _taskService.UpdateTaskStatusToNext(task);
+                        }
                     }
                 }
                 else
                 {
-                    task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
-                    if (task != null)
+                    var taskInTray = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
+                    if (taskInTray != null && taskInTray.TaskType == (int)TaskInboundTypeEnum.InTray)
                     {
                         RequestInNextAddress(conveyorLine, command, childDeviceCode, ProtocalDetailValue);
                     }
@@ -373,6 +418,10 @@
                 // 鎹曡幏骞惰緭鍑哄紓甯镐俊鎭�
                 Console.Out.WriteLine(ex.ToString());
             }
+            finally
+            {
+                StaticVariable.isLineRun = true;
+            }
         }
 
         public string RequestInboundPlatform(string childDeviceCode, string productLine, bool IsTrayBarcode)
@@ -384,7 +433,7 @@
                 if (platform != null && !string.IsNullOrEmpty(platform.Location))
                 {
                     var Location = platform.Location.Split(',').ToList();
-                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == platform.PLCCode);
+                    IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == platform.DeviceCode);
                     if (device != null)
                     {
                         CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
@@ -393,7 +442,7 @@
                             ConveyorLineTaskCommand command1 = conveyorLine.ReadCustomer<ConveyorLineTaskCommand>(item);
                             if (command1.InteractiveSignal != 2)
                             {
-                                var tasks = _taskRepository.QueryData(x => (x.TaskType == (int)TaskInboundTypeEnum.InTray || x.TaskType == (int)TaskOutboundTypeEnum.OutTray) && x.TargetAddress == childDeviceCode);
+                                var tasks = _taskRepository.QueryData(x => x.TargetAddress == childDeviceCode);
 
                                 // 濡傛灉宸叉湁浠诲姟鏁伴噺灏忎簬鎸囧畾绱㈠紩
                                 if (tasks.Count < Location.Count)
@@ -443,11 +492,6 @@
 
             _noticeService.Logs(userTokenIds, new { conveyorLine.DeviceName, log = log, time = DateTime.Now.ToString("G"), color = "red" });
             WriteInfo(conveyorLine.DeviceName, log);
-            //if (childDeviceCode == "1279")
-            //{
-            //    var stationManager = _stationManagerRepository.QueryFirst(x => x.stationChildCode == childDeviceCode && x.stationPLC == conveyorLine.DeviceCode);
-            //    CreateAndSendEmptyTrayTask(conveyorLine, command, childDeviceCode, ProtocalDetailValue, stationManager);
-            //}
 
             Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.TaskNum, childDeviceCode);
             if (task != null)
@@ -856,7 +900,6 @@
 
                 // 瑙f瀽浠诲姟鏁版嵁
                 taskDTO = JsonConvert.DeserializeObject<WMSTaskDTO>(content.Data.ToString());
-                WriteInfo("鍑哄簱", $"銆恵JsonConvert.SerializeObject(taskDTO)}銆�");
 
                 #endregion 璋冪敤WMS鑾峰彇鍑哄簱浠诲姟
 
@@ -871,7 +914,6 @@
         public WebResponseContent CreateAndSendTask(WMSTaskDTO taskDTO)
         {
             var content = _taskService.ReceiveWMSTask(new List<WMSTaskDTO> { taskDTO });
-            WriteInfo("鍑哄簱", $"銆恵JsonConvert.SerializeObject(content)}銆�");
             if (content.Status)
             {
                 Console.WriteLine($"{taskDTO.TargetAddress}鍛煎彨鎴愬姛");
@@ -913,7 +955,6 @@
 
             if (result1.Success)
             {
-                ConsoleHelper.WriteWarningLine("1");
                 var serialNosError = result1.SerialNos.Where(x => x.SerialNoStatus != 1 && x.SerialNoStatus != 4).ToList();
                 if (serialNosError.Count > 0)
                 {
@@ -924,7 +965,7 @@
                 //璁惧NG澶勭悊
                 if (stationManager.remark == "DeviceNG")
                 {
-                    ConsoleHelper.WriteWarningLine($"銆恵stationManager.stationChildCode}NG绔欏彴鍏ュ簱銆�");
+                    ConsoleHelper.WriteWarningLine($"銆恵stationManager.stationChildCode}NG绔欏彴瀹炴墭鍏ュ簱銆�");
                     if (result1.SerialNos.Count <= 0)
                     {
                         ConsoleHelper.WriteWarningLine("1000");
@@ -933,7 +974,7 @@
                     }
                     else
                     {
-                        ConsoleHelper.WriteWarningLine("2");
+                        ConsoleHelper.WriteWarningLine($"銆恵stationManager.stationChildCode}NG绔欏彴绌烘墭鍏ヨ澶囥��");
                         ConsoleHelper.WriteWarningLine(stationManager.stationLocation);
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTaskNum, 5, stationManager.stationChildCode);
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTargetAddress, stationManager.stationLocation, stationManager.stationChildCode);
@@ -944,14 +985,14 @@
                 {
                     if (result1.SerialNos.Count <= 0)
                     {
-                        ConsoleHelper.WriteWarningLine("2");
+                        ConsoleHelper.WriteWarningLine($"銆恵stationManager.stationChildCode}NG绔欏彴绌烘墭鍏ュ簱銆�");
                         ConsoleHelper.WriteWarningLine(stationManager.stationLocation);
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTaskNum, 5, stationManager.stationChildCode);
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTargetAddress, stationManager.stationLocation, stationManager.stationChildCode);
                     }
                     else
                     {
-                        ConsoleHelper.WriteWarningLine("1000");
+                        ConsoleHelper.WriteWarningLine($"銆恵stationManager.stationChildCode}NG绔欏彴瀹炴墭鍏ヨ澶囥��");
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTaskNum, 5, stationManager.stationChildCode);
                         conveyorLine.SetValue(ConveyorLineDBName.WriteConveyorLineTargetAddress, 1000, stationManager.stationChildCode);
                     }

--
Gitblit v1.9.3