From f693f036dff3fe6180fe42caf8cb9f4e350bb339 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Sat, 11 Jan 2025 02:00:30 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=9C=E7=A8=8Bwvp=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../entity/wvp_active/WvpActiveStorageConfig.java   |  1 +
 .../device/operator/WvpActiveStorageOperator.java   | 13 ++++++++++++-
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/ycwl/basic/device/entity/wvp_active/WvpActiveStorageConfig.java b/src/main/java/com/ycwl/basic/device/entity/wvp_active/WvpActiveStorageConfig.java
index 6324f4d..e5a3c4c 100644
--- a/src/main/java/com/ycwl/basic/device/entity/wvp_active/WvpActiveStorageConfig.java
+++ b/src/main/java/com/ycwl/basic/device/entity/wvp_active/WvpActiveStorageConfig.java
@@ -5,6 +5,7 @@ import lombok.Data;
 @Data
 public class WvpActiveStorageConfig {
     private String host;
+    private String zlmHost;
     private String loginName;
     private String loginPassword;
     private String app = "rtp";
diff --git a/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java b/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java
index bc0b420..05e5ab4 100644
--- a/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java
+++ b/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java
@@ -9,7 +9,9 @@ import com.ycwl.basic.device.entity.common.FileObject;
 import com.ycwl.basic.device.entity.wvp_active.WvpActiveStorageConfig;
 import com.ycwl.basic.storage.exceptions.StorageConfigException;
 import com.ycwl.basic.storage.exceptions.StorageUnsupportedException;
+import org.apache.commons.lang3.StringUtils;
 
+import java.net.URI;
 import java.text.SimpleDateFormat;
 import java.util.Collections;
 import java.util.Date;
@@ -97,7 +99,16 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator {
         JSONObject result = JSON.parseObject(jsonResult);
         if (result.getInteger("code") == 0) {
             JSONObject data = result.getJSONObject("data");
-            return data.getString("httpPath");
+            String httpPath = data.getString("httpPath");
+            if (StringUtils.isBlank(this.config.getZlmHost())) {
+                return httpPath;
+            }
+            // 替换host
+            URI uri = URI.create(httpPath);
+            if (uri.getQuery() == null) {
+                return this.config.getZlmHost() + uri.getPath();
+            }
+            return this.config.getZlmHost() + uri.getPath() + "?" + uri.getQuery();
         } else {
             throw new StorageUnsupportedException("获取播放地址失败，原因为：" + result.getString("msg"));
         }