Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_ITaskInfoService/ITaskService.cs
@@ -130,6 +130,14 @@ Dt_Task QueryExecutingConveyorLineTask(int taskNum, string nextAddress); /// <summary> /// 根据托盘号、下一地址查询输送线执行中的任务 /// </summary> /// <param name="taskNum">任务号</param> /// <param name="nextAddress">下一地址</param> /// <returns></returns> Dt_Task QueryExecutingTaskByBarcode(string barcode, string nextAddress); /// <summary> /// 根据任务号、当前地址查询输送线完成的任务 /// </summary> /// <param name="taskNum">任务号</param> Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_TaskInfoService/TaskService.cs
@@ -784,6 +784,11 @@ public Dt_Task QueryRelocationTask(string deviceNo) { return BaseDal.QueryFirst(x => x.Roadway == deviceNo && x.TaskType == (int)TaskRelocationTypeEnum.Relocation && x.TaskState == (int)TaskStatus.Created); } public Dt_Task QueryExecutingTaskByBarcode(string barcode, string nextAddress) { return BaseDal.QueryFirst(x => x.PalletCode == barcode && x.NextAddress == nextAddress && (x.TaskState == (int)TaskInStatusEnum.Line_InExecuting || x.TaskState == (int)TaskOutStatusEnum.Line_OutExecuting), TaskOrderBy); } } } Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_GW/CommonConveyorLine_GWJob.cs
@@ -226,6 +226,12 @@ Dt_Task task = _taskService.QueryExecutingConveyorLineTask(command.ConveyorLineTaskNum, childDeviceCode); if (task != null) { if (command.ConveyorLineBarcode != task.PalletCode) { conveyorLine.SetValue(ConveyorLineDBName_After.ResponState, 2, childDeviceCode); return; } Dt_Task? newTask = _taskService.UpdatePosition(task.TaskNum, task.CurrentAddress); if (newTask != null) { @@ -250,7 +256,7 @@ /// <param name="ProtocalDetailValue">线体当前bool读取偏移地址</param> public void ConveyorLineInFinish(CommonConveyorLine_GW conveyorLine, ConveyorLineTaskCommand_After command, string childDeviceCode) { var task = _taskService.QueryExecutingConveyorLineTask(command.ConveyorLineTaskNum, childDeviceCode); var task = _taskService.QueryExecutingTaskByBarcode(command.ConveyorLineBarcode, childDeviceCode); if (task != null && task.TaskState != (int)TaskInStatusEnum.Line_InFinish) { //ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true); @@ -313,7 +319,7 @@ TrayCellsStatusDto trayCells = new TrayCellsStatusDto() { Software = "WMS", TrayBarcode = task.PalletCode, TrayBarcode = command.ConveyorLineBarcode, EquipmentCode = stationManager.stationEquipMOM, SessionId = Guid.NewGuid().ToString(), EmployeeNo = "MITest", Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Dt_TaskService.cs
@@ -892,6 +892,9 @@ try { // 调用BaseDal.QueryFirstAsync方法,查询任务 var task = await BaseDal.QueryFirstAsync(x => x.PalletCode == input.PalletCode); if (task != null && task.TaskState == (int)TaskInStatusEnum.InNew) @@ -911,7 +914,6 @@ }; return content.OK(data: task); } var stationManagers = _stationManagerRepository.QueryData(x => x.stationType == 6 && x.stationChildCode == input.Position).FirstOrDefault(); if (stationManagers == null)