| | |
| | | case 0x04: |
| | | byte[] boxSn = new byte[dataLength - 1]; |
| | | in.readBytes(boxSn); |
| | | SubscribeCommand payload = new SubscribeCommand(new String(boxSn)); |
| | | log.debug("订阅回复: {}", payload.getBoxSn()); |
| | | SubscribeReplyCommand subscribeReply = new SubscribeReplyCommand(new String(boxSn)); |
| | | log.debug("订阅回复: {}", subscribeReply.getBoxSn()); |
| | | break; |
| | | case (byte) 0xA8: |
| | | byte[] uavStatus = new byte[dataLength - 1]; |
| | |
| | | } |
| | | } |
| | | |
| | | @Scheduled(fixedRate = 5000) |
| | | @Scheduled(fixedRate = 3000) |
| | | public void sendHeartBeat() { |
| | | long timestamp = System.currentTimeMillis(); |
| | | log.debug("定时向天宇发送⼼跳,时间戳{}", timestamp); |