| | |
| | | |
| | | shuttleThread.reset(null); |
| | | return R.ok(); |
| | | } else if (param.getShuttleTaskMode().equals("requestWaiting")) { |
| | | //申请确认 |
| | | Device device = deviceService.getOne(new LambdaQueryWrapper<Device>() |
| | | .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val()) |
| | | .eq(Device::getStatus, 1) |
| | | .eq(Device::getDeviceNo, shuttleNo)); |
| | | if (device == null) { |
| | | return R.error("设备不存在"); |
| | | } |
| | | |
| | | ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue()); |
| | | if (shuttleThread == null) { |
| | | return R.error("设备离线"); |
| | | } |
| | | |
| | | shuttleThread.requestWaiting(); |
| | | return R.ok(); |
| | | } |
| | | |
| | | Task task = new Task(); |