From d8f650de070335be494c33d0705e8105b7a215d6 Mon Sep 17 00:00:00 2001 From: 刘磊 <1161824510@qq.com> Date: 星期四, 26 十二月 2024 14:31:26 +0800 Subject: [PATCH] 同步 --- Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs | 74 ++++++++++++++++++++++++++++-------- 1 files changed, 57 insertions(+), 17 deletions(-) diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs index 49d4563..0b3c520 100644 --- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs +++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/GWTask/RequestInbound.cs @@ -1,19 +1,14 @@ -锘縰sing Newtonsoft.Json; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; +锘縰sing Masuit.Tools; +using Newtonsoft.Json; +using WIDESEAWCS_Common; using WIDESEAWCS_Common.TaskEnum; -using WIDESEAWCS_Core.Helper; using WIDESEAWCS_Core; +using WIDESEAWCS_Core.Helper; using WIDESEAWCS_DTO.TaskInfo; +using WIDESEAWCS_DTO.WMS; using WIDESEAWCS_Model.Models; using WIDESEAWCS_QuartzJob; using WIDESEAWCS_Tasks.ConveyorLineJob; -using WIDESEAWCS_DTO.WMS; -using WIDESEAWCS_Common; -using Masuit.Tools; namespace WIDESEAWCS_Tasks { @@ -76,6 +71,9 @@ case 10: ExecuteStationAction(stationManager, conveyorLine, command, childDeviceCode); break; + //case 16: + // ExecuteStationAction(stationManager, conveyorLine, command, childDeviceCode); + // break; } #region @@ -134,7 +132,6 @@ // } //} #endregion - } private void ExecuteStationAction(Dt_StationManager stationManager, CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode) @@ -144,30 +141,45 @@ case 8: RequestInNextAddress(conveyorLine, command, childDeviceCode); break; + case 9: ConveyorLineInFinish(conveyorLine, command, childDeviceCode); break; + case 10: RequestOutbound(conveyorLine, command, childDeviceCode); break; + case 11: RequestOutNextAddress(conveyorLine, command, childDeviceCode); break; + case 12: ConveyorLineOutFinish(conveyorLine, command, childDeviceCode); break; + case 6: CreateAndSendEmptyTrayTask(conveyorLine, command, childDeviceCode); break; + case 1: + //if (stationManager.stationArea.Contains("GW")) //{ - // var taskGW = _taskRepository.QueryFirst(x => x.TargetAddress == childDeviceCode && (x.TaskState == (int)TaskOutStatusEnum.OutFinish || x.TaskState == (int)TaskOutStatusEnum.OutPending)); - // if (taskGW != null) - // { - // command.ConveyorLineBarcode = taskGW.PalletCode; - // } + //var taskGW = _taskRepository.QueryFirst(x => x.TargetAddress == childDeviceCode && (x.TaskState == (int)TaskOutStatusEnum.OutFinish || x.TaskState == (int)TaskOutStatusEnum.OutPending)); + //if (taskGW != null) + //{ + // command.ConveyorLineBarcode = taskGW.PalletCode; //} + //} + //濡傞珮娓╁嚭搴撳悗浠诲姟鏍囪NG寮傚父鍒欏皢浠诲姟鏇存柊涓哄紓甯告帓鍑轰换鍔� + Dt_Task NGtask = _taskRepository.QueryFirst(x => x.Remark == "NG" && x.Roadway == stationManager.Roadway && x.Roadway.Contains("GW")); + if (NGtask != null) + { + CreateAbNormalOutbound(conveyorLine, command, childDeviceCode, NGtask); + break; + } + RequestWmsTask(conveyorLine, command, childDeviceCode); break; } @@ -308,5 +320,33 @@ //_taskRepository.AddData(taskGW); } } + + /// <summary> + /// 楂樻俯鍑哄簱鍚庝换鍔″畬鎴� 濡傛灉浠诲姟鏍囪瘑NG鍒欏皢浠诲姟鏀逛负寮傚父鎺掑嚭浠诲姟 + /// </summary> + /// <param name="conveyorLine"></param> + /// <param name="command"></param> + /// <param name="childDeviceCode"></param> + /// <param name="task"></param> + /// <exception cref="Exception"></exception> + private void CreateAbNormalOutbound(CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode, Dt_Task task) + { + Dt_StationManager stationManager = _stationManagerRepository.QueryFirst(x => x.stationChildCode == childDeviceCode); + + if (stationManager == null || string.IsNullOrWhiteSpace(stationManager.stationNGChildCode) || string.IsNullOrWhiteSpace(stationManager.stationNGLocation)) + { + throw new Exception("鏈厤缃珯鍙扮殑瀵瑰簲NG鍙d俊鎭�"); + } + + task.SourceAddress = task.TargetAddress; + task.TargetAddress = stationManager.stationNGLocation; + task.TaskState = (int)TaskOutStatusEnum.OutNew; + task.TaskType = (int)TaskOutboundTypeEnum.InToOut; + task.Grade = 10; //姝ゅ 鍑哄簱鑷冲紓甯告帓鍑哄彛鐨勪换鍔″簲闄ょ伀璀﹀鏈�浼樺厛鎵ц + + _taskRepository.UpdateData(task); + //Dt_Task task= _taskRepository.QueryFirst(x=>) + //_taskRepository.QueryFirst() + } } -} +} \ No newline at end of file -- Gitblit v1.9.3