From 36f9871deb418f150b05e89195419ad22eb3d87a Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Tue, 23 Jun 2026 11:00:22 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E6=9B=BF=E6=8D=A2CDN=E5=89=8D=E7=BC=80?=
 =?UTF-8?q?=E4=B8=BAminio=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修复视频URL拼接时硬编码CDN地址的问题，改为从配置中动态读取minio前缀。
---
 workflow/service/flow/lambda_node.go      | 2 +-
 workflow/service/flow/lambda_node_util.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/workflow/service/flow/lambda_node.go b/workflow/service/flow/lambda_node.go
index 520b973..241b43f 100644
--- a/workflow/service/flow/lambda_node.go
+++ b/workflow/service/flow/lambda_node.go
@@ -284,7 +284,7 @@ func VideoModelLambda(ctx context.Context, input any) (any, error) {
 	}
 
 	urlPrefix, err := utils.GetFileAddressPrefix(ctx)
-	newS := strings.ReplaceAll(urlPrefix, "http://cdn.redpowerfuture.com", g.Cfg().MustGet(ctx, "minioPrefix").String())
+	newS := strings.ReplaceAll(urlPrefix, g.Cfg().MustGet(ctx, "filePrefix").String(), g.Cfg().MustGet(ctx, "minioPrefix").String())
 	if err != nil {
 		return nil, err
 	}
diff --git a/workflow/service/flow/lambda_node_util.go b/workflow/service/flow/lambda_node_util.go
index 8b00ef9..d5a1f92 100644
--- a/workflow/service/flow/lambda_node_util.go
+++ b/workflow/service/flow/lambda_node_util.go
@@ -505,7 +505,7 @@ func VideoConcat(ctx context.Context, videoUrls []string) (r any, err error) {
 }
 
 func GetFileBytesFromURL(ctx context.Context, fileUrl string) ([]byte, error) {
-	newS := strings.ReplaceAll(fileUrl, "http://cdn.redpowerfuture.com", g.Cfg().MustGet(ctx, "minioPrefix").String())
+	newS := strings.ReplaceAll(fileUrl, g.Cfg().MustGet(ctx, "filePrefix").String(), g.Cfg().MustGet(ctx, "minioPrefix").String())
 	// 使用 GoFrame 客户端（自带超时、追踪、日志等能力）
 	resp, err := g.Client().Get(ctx, newS)
 	if err != nil {