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