| | |
| | | String carModel = (String) result.get("carModel");//获取车辆模型 |
| | | Integer drct = (Integer) gpsMap.get("drct");//获取车辆模型 |
| | | Integer speed = (Integer) gpsMap.get("speed"); |
| | | log.info("定位数据:carId:"+carId+"lng:"+lng+"lat:"+lat); |
| | | log.debug("定位数据:carId:"+carId+"lng:"+lng+"lat:"+lat); |
| | | //定义2维空间 |
| | | Point2D.Double point = new Point2D.Double(Double.parseDouble(lng), Double.parseDouble(lat)); |
| | | List<Point2D.Double> pts = new ArrayList<Point2D.Double>(); |
| | |
| | | @Override//消息订阅者收到消息后触发的回调 |
| | | public void messageArrived(String topic, MqttMessage message) throws Exception { |
| | | try { |
| | | log.info("【车辆锁主题】:"+topic+"【车辆锁信息】:"+new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | log.debug("【车辆锁主题】:"+topic+"【车辆锁信息】:"+new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | //出来回调数据 |
| | | List<ArdSyCarLock> ardSyCarLocks = carLockService.data(new String(message.getPayload(), StandardCharsets.UTF_8)); |
| | | //根据topic查询RTUID |