From 0c50178f0aca0663fdfcaf55b370923c9853a042 Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Thu, 25 Jun 2026 14:10:21 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=AD=97=E5=B9=95?=
 =?UTF-8?q?=E8=8A=82=E7=82=B9=E6=95=B0=E6=8D=AE=E8=BD=AC=E6=8D=A2=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 workflow/service/flow/lambda_node_imp.go | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/workflow/service/flow/lambda_node_imp.go b/workflow/service/flow/lambda_node_imp.go
index 0387182..8019385 100644
--- a/workflow/service/flow/lambda_node_imp.go
+++ b/workflow/service/flow/lambda_node_imp.go
@@ -776,6 +776,21 @@ func VideoOptimizeNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInpu
 }
 
 func DataConversionNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInput, skillName string, form []map[string]any, userForm []map[string]any) ([]node.NodeFormField, error) {
+	if strings.Contains(nodeInput.Config.Name, "字幕") {
+		jsonStr := ``
+		for _, field := range nodeInput.Config.OutputConfig {
+			jsonStr, _ = sjson.Set(jsonStr, field.Field, field.Value)
+		}
+		outputRes := make([]node.NodeFormField, 0)
+		outputRes = append(outputRes, node.NodeFormField{
+			Field: fmt.Sprintf("data_conversion"),
+			Value: gconv.Map(jsonStr),
+			Label: fmt.Sprintf("data_conversion"),
+			Type:  "string",
+		})
+		return outputRes, nil
+	}
+
 	jsonStr := ``
 	jsonVal := "输出字段规范："
 	for _, field := range nodeInput.Config.OutputConfig {
@@ -784,7 +799,6 @@ func DataConversionNode(ctx context.Context, nodeInput *flowDto.NodeExecutionInp
 	}
 	jsonVal += fmt.Sprintf("输出模板结构,仅修改每个字段对应数值：%s", jsonStr)
 	nodeInput.Config.PromptContent = fmt.Sprintf("%s;%s", nodeInput.Config.PromptContent, jsonVal)
-
 	mapTaskResult, err := GetModelResult(ctx, "", nodeInput, skillName, form, userForm)
 	if err != nil {
 		return nil, err