| | |
| | | { |
| | | Dt_Router routers = _routerRepository.QueryFirst(x => x.StartPosi == task.NextAddress); |
| | | _taskService.UpdateTask(task, TaskStatusEnum.RGV_Finish, currentAddress: task.NextAddress, nextAddress: routers.NextPosi); |
| | | device.SetValue(W_RGVConveyorLineDBName.W_ACK, true, item.StationCode); |
| | | } |
| | | else |
| | | { |
| | | //出库任务是否需要跟出库口输送线对接完成任务 |
| | | WriteDebug(device.DeviceName, $"任务完成,任务号:{task.TaskNum}"); |
| | | device.SetValue(W_RGVConveyorLineDBName.W_ACK, true, item.StationCode); |
| | | _taskService.TaskCompleted(task.TaskNum); |
| | | |
| | | } |
| | | for (int i = 0; i < 3; i++) |
| | | { |
| | | device.SetValue(W_RGVConveyorLineDBName.W_ACK, true, item.StationCode); |
| | | Thread.Sleep(100); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | _taskService.UpdateTask(task, TaskStatusEnum.RGV_Executing); |
| | | } |
| | | Dt_Task task1 = _taskRepository.QueryFirst(x => x.TaskType >= TaskTypeEnum.Outbound.ObjToInt() && x.TaskType <= TaskTypeEnum.Inbound.ObjToInt() && x.TaskState == TaskStatusEnum.RGV_Execute.ObjToInt() && x.RGVCode == item.StationCode); |
| | | Dt_Task task1 = _taskRepository.QueryFirst(x => x.TaskType >= TaskTypeEnum.Outbound.ObjToInt() && x.TaskType < TaskTypeEnum.Inbound.ObjToInt() && x.TaskState == TaskStatusEnum.RGV_Execute.ObjToInt() && x.RGVCode == item.StationCode); |
| | | if (task1 != null) |
| | | { |
| | | for (int i = 0; i < 3; i++) |