From bd8147d7890bf60d88e4007c1af726ba5f364cf5 Mon Sep 17 00:00:00 2001
From: baizonghao <1719256278@qq.com>
Date: 星期二, 14 三月 2023 11:24:31 +0800
Subject: [PATCH] 拼接地址

---
 ycl-platform/src/main/java/com/ycl/util/VideoUtil.java |   26 +++++++++++++++++++-------
 1 files changed, 19 insertions(+), 7 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/util/VideoUtil.java b/ycl-platform/src/main/java/com/ycl/util/VideoUtil.java
index 00fdbb1..1f829e1 100644
--- a/ycl-platform/src/main/java/com/ycl/util/VideoUtil.java
+++ b/ycl-platform/src/main/java/com/ycl/util/VideoUtil.java
@@ -22,24 +22,34 @@
 public class VideoUtil {
 
     @Value("${videoPoint.url}")
-    private  String url;
+    private String url;
 
     @Value("${videoPoint.userName}")
-    private  String userName;
+    private String userName;
 
     @Value("${videoPoint.passWord}")
-    private  String passWord;
+    private String passWord;
 
     @Value("${videoPoint.ip}")
-    private  String ip;
+    private String ip;
 
+    /*
+     * @Description  subType:绫诲瀷int锛岄�夊～銆傜爜娴佺被鍨嬶紝0:涓荤爜娴併��1:杈呮祦1銆�2:杈呮祦2銆傞粯璁や负0涓荤爜娴併�俿cheme:绫诲瀷string锛岄�夊～銆傚崗璁被鍨嬶紝鏀寔RTSP銆丗LV_HTTP銆丠LS涓夌锛岄粯璁TSP銆�
+     * @Param [code, scheme, subType]
+     * @return java.lang.String
+     **/
     @SneakyThrows
-    public  String getVideo(String code, String scheme,Integer subType) {
+    public String getVideo(String code, String scheme, Integer subType) {
+        System.out.println("寮�濮嬭棰戣姹傦細" + code);
         String clientType = "winpc";
         String reqUrl = "/videoService/accounts/authorize";
         String deviceUrl = "/videoService/devicesManager/devices";
-        String monitorUrl = "/videoService/realmonitor/uri?subType=" + subType + "&scheme=" + scheme + "&channelId=";
+//        String monitorUrl = "/videoService/realmonitor/uri?subType=" + subType + "&scheme=" + scheme + "&channelId=";
 
+        String monitorUrl = "/videoService/realmonitor/uri?trackId=&encryptedInfo=&userId=&urlType=1&keyIndex=&regionId=&packtype=Private&planId=&subType=" + subType + "&isroute=false&streamType=&locationEnable=false&domainId=&duration=600&scheme=RTSP&dataType=2&extend=&channelId=";
+        if (!"RTSP".equals(scheme)) {
+            monitorUrl = "/videoService/realmonitor/uri?subType=" + subType + "&scheme=" + scheme + "&channelId=";
+        }
         RestTemplate restTemplate = new RestTemplate();
         restTemplate.setErrorHandler(new DefaultResponseErrorHandler() {
             @Override
@@ -69,7 +79,7 @@
 
         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);
@@ -93,7 +103,9 @@
         HttpEntity<Object> deviceEntity = new HttpEntity<>(deviceHeaders);
         ResponseEntity<String> exchange = restTemplate.exchange(url + deviceUrl + "/" + code, HttpMethod.GET, deviceEntity, String.class);
         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);
         ResponseEntity<String> monitorReq = restTemplate.exchange(url + monitorUrl + channelId, HttpMethod.GET, deviceEntity, String.class);
+        System.out.println("瑙嗛璇锋眰杩斿洖鍙傛暟锛�" + monitorReq.getBody());
         return objectMapper.readTree(monitorReq.getBody()).get("url").textValue();
     }
 }

--
Gitblit v1.8.0