| | |
| | | //跑库系统 |
| | | @PreAuthorize("hasAuthority('core:basShuttle:operator')") |
| | | @PostMapping("/basShuttle/moveLoc") |
| | | @Transactional |
| | | public synchronized R shuttleMoveLoc(@RequestBody ShuttleMoveLocParam param) { |
| | | Device device = deviceService.getOne(new LambdaQueryWrapper<Device>() |
| | | .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val()) |
| | |
| | | return R.ok(); |
| | | } |
| | | |
| | | //跑库系统关闭 |
| | | @PreAuthorize("hasAuthority('core:basShuttle:operator')") |
| | | @PostMapping("/basShuttle/moveLocClose") |
| | | public synchronized R shuttleMoveLocClose(@RequestBody ShuttleMoveLocParam param) { |
| | | Device device = deviceService.getOne(new LambdaQueryWrapper<Device>() |
| | | .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val()) |
| | | .eq(Device::getStatus, 1) |
| | | .eq(Device::getHostId, getHostId()) |
| | | .eq(Device::getDeviceNo, param.getShuttleNo())); |
| | | if (device == null) { |
| | | return R.error(); |
| | | } |
| | | |
| | | ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue()); |
| | | if (shuttleThread == null) { |
| | | return R.error(); |
| | | } |
| | | |
| | | ShuttleProtocol shuttleProtocol = shuttleThread.getStatus(); |
| | | if (shuttleProtocol == null) { |
| | | return R.error(); |
| | | } |
| | | |
| | | shuttleThread.enableMoveLoc(null, false); |
| | | return R.ok(); |
| | | } |
| | | |
| | | } |