| | |
| | | |
| | | HttpEntity<String> firstEntity = new HttpEntity<>(objectMapper.writeValueAsString(firstReq), httpHeaders); |
| | | ResponseEntity<String> responseEntity = restTemplate.postForEntity(url + reqUrl, firstEntity, String.class); |
| | | System.out.println("开始视频身份请求结果:" + responseEntity.getBody()); |
| | | |
| | | FirstRes firstRes = objectMapper.readValue(responseEntity.getBody(), FirstRes.class); |
| | | |
| | | String signature = MD5Util.md5Encrypt(passWord); |
| | |
| | | HttpHeaders deviceHeaders = new HttpHeaders(); |
| | | deviceHeaders.add("X-Subject-Token", objectMapper.readTree(secondResEntity.getBody()).get("token").textValue()); |
| | | HttpEntity<Object> deviceEntity = new HttpEntity<>(deviceHeaders); |
| | | // System.out.println("视频设备请求地址:" + url + deviceUrl + "/" + code); |
| | | ResponseEntity<String> exchange = restTemplate.exchange(url + deviceUrl + "/" + code, HttpMethod.GET, deviceEntity, String.class); |
| | | // System.out.println("开始视频身份请求结果:" + exchange.getBody()); |
| | | String channelId = objectMapper.readTree(objectMapper.readTree(objectMapper.readTree(exchange.getBody()).get("encoderUnit").toString()).get("channels").get(0).toString()).get("channelId").textValue(); |
| | | System.out.println("视频请求地址:" + url + monitorUrl + channelId); |
| | | // System.out.println("视频请求地址:" + url + monitorUrl + channelId); |
| | | ResponseEntity<String> monitorReq = restTemplate.exchange(url + monitorUrl + channelId, HttpMethod.GET, deviceEntity, String.class); |
| | | System.out.println("视频请求返回参数:" + monitorReq.getBody()); |
| | | // System.out.println("视频请求返回参数:" + monitorReq.getBody()); |
| | | return objectMapper.readTree(monitorReq.getBody()).get("url").textValue(); |
| | | } |
| | | } |