From 8c228f14954dda842cf3ca637bf3915ab691a818 Mon Sep 17 00:00:00 2001
From: guoshengxiong <1923636941@qq.com>
Date: Fri, 17 Oct 2025 18:47:14 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=BF=E6=8D=A2wss?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/zhgd/xmgl/util/HikVideoUtil.java   | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/src/main/java/com/zhgd/xmgl/util/HikVideoUtil.java b/src/main/java/com/zhgd/xmgl/util/HikVideoUtil.java
index f56c8a278..61710f3b5 100644
--- a/src/main/java/com/zhgd/xmgl/util/HikVideoUtil.java
+++ b/src/main/java/com/zhgd/xmgl/util/HikVideoUtil.java
@@ -14,6 +14,7 @@ import com.zhgd.jeecg.common.execption.OpenAlertException;
 import com.zhgd.jeecg.common.util.JSONUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 
 import java.util.*;
 
@@ -25,6 +26,18 @@ import java.util.*;
  **/
 @Slf4j
 public class HikVideoUtil {
+    private static String replaceWssFrom;
+    private static String replaceWssTo;
+
+    @Value("${replaceWssFrom:wss://hrdl.zhgdyun.com}")
+    public void setReplaceWssFrom(String replaceWssFrom) {
+        HikVideoUtil.replaceWssFrom = replaceWssFrom;
+    }
+
+    @Value("${replaceWssTo:wss://sp.szjxj.com}")
+    public void setReplaceWssTo(String replaceWssTo) {
+        HikVideoUtil.replaceWssTo = replaceWssTo;
+    }
 
     private static final String ARTEMIS_PATH = "/artemis";
 
@@ -81,6 +94,10 @@ public class HikVideoUtil {
             if ("0".equals((String) json.get("code"))) {
                 JSONObject object2 = (JSONObject) json.get("data");
                 url = (String) object2.get("url");
+                //替换wss域名
+                if (url.startsWith(HikVideoUtil.replaceWssFrom)) {
+                    url = StrUtil.replace(url, HikVideoUtil.replaceWssFrom, HikVideoUtil.replaceWssTo);
+                }
             }
         } else {
             throw new OpenAlertException(MessageUtil.get("failErr"));