| | |
| | | AGV_12_UP agv_12_up = (AGV_12_UP) msgBody; |
| | | |
| | | // unlock path |
| | | threadPoolRegulator.getInstance().execute(() -> { |
| | | mapService.unlockPath(protocol.getAgvNo(), agv_12_up.getQrCode()); |
| | | }); |
| | | mapService.unlockPath(protocol.getAgvNo(), agv_12_up.getQrCode()); |
| | | // threadPoolRegulator.getInstance().execute(() -> { |
| | | // |
| | | // }); |
| | | // finish jam |
| | | threadPoolRegulator.getInstance().execute(() -> jamService.checkIfFinish(agvId, agv_12_up.getQrCode())); |
| | | |
| | |
| | | private void sync(AGV_12_UP mesBody, AgvDetail detail) { |
| | | detail.setStatus(mesBody.getStatus()); |
| | | |
| | | Code code = codeService.selectByData(mesBody.getQrCode()); |
| | | Code code = codeService.getCacheByData(mesBody.getQrCode()); |
| | | if (null != code) { |
| | | detail.setCode(code.getId()); |
| | | detail.setLastCode(null); |
| | |
| | | private void sync(AGV_13_UP mesBody, AgvDetail detail) { |
| | | detail.setStatus(mesBody.getStatus()); |
| | | |
| | | Code code = codeService.selectByData(mesBody.getQrCode()); |
| | | Code code = codeService.getCacheByData(mesBody.getQrCode()); |
| | | if (null != code) { |
| | | |
| | | if (!detail.getAgvStatus().equals(AgvStatusType.CHARGE)) { |