| | |
|---|
| | | OutputQueue.SHUTTLE.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId())); |
|---|
| | | // log.info(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId())); |
|---|
| | | } |
|---|
| | | log.warn(JSON.toJSONString(shuttleProtocol));//输出小车状态 |
|---|
| | | // log.warn(JSON.toJSONString(shuttleProtocol));//输出小车状态 |
|---|
| | | |
|---|
| | | if (System.currentTimeMillis() - shuttleProtocol.getDeviceDataLog() > 1000 * 5) { |
|---|
| | | //采集时间超过5s，保存一次数据记录 |
|---|
| | | //保存数据记录 |
|---|
| | | DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class); |
|---|
| | | DeviceDataLog deviceDataLog = new DeviceDataLog(); |
|---|
| | | deviceDataLog.setOriginData(JSON.toJSONString(jsonObject)); |
|---|
| | | deviceDataLog.setWcsData(JSON.toJSONString(shuttleProtocol)); |
|---|
| | | deviceDataLog.setType("shuttle"); |
|---|
| | | deviceDataLog.setDeviceNo(shuttleProtocol.getShuttleNo().intValue()); |
|---|
| | | deviceDataLog.setCreateTime(new Date()); |
|---|
| | | deviceDataLogService.insert(deviceDataLog); |
|---|
| | | |
|---|
| | | //更新采集时间 |
|---|
| | | shuttleProtocol.setDeviceDataLog(System.currentTimeMillis()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | |
|---|
| | | if (!(targetNode.getX() == node.getX() && targetNode.getY() == node.getY())) { |
|---|
| | | nodes.remove(nodes.size() - 1);//剔除尾节点 |
|---|
| | | } |
|---|
| | | boolean result = navigateMapUtils.writeNavigateNodeToRedisMap(Utils.getLev(shuttleProtocol.getCurrentLocNo()), nodes, false);//解锁路径 |
|---|
| | | boolean result = navigateMapUtils.writeNavigateNodeToRedisMap(Utils.getLev(shuttleProtocol.getCurrentLocNo()), shuttleProtocol.getShuttleNo().intValue(), nodes, false);//解锁路径 |
|---|
| | | if (!result) { |
|---|
| | | return false;//解锁失败 |
|---|
| | | } |
|---|
