diff --git a/workflow/model/dto/flow/flow_execution_dto.go b/workflow/model/dto/flow/flow_execution_dto.go
index 2ffe70c..2d79c3b 100644
--- a/workflow/model/dto/flow/flow_execution_dto.go
+++ b/workflow/model/dto/flow/flow_execution_dto.go
@@ -74,6 +74,7 @@ type ComposeMessagesReq struct {
 	CallbackUrl string           `json:"callbackUrl"`
 	Form        []map[string]any `json:"form"`
 	UserForm    []map[string]any `json:"userForm"`
+	UserPrompt  string           `json:"userPrompt" dc:"用户提示词"`
 	Consult     []Consult        `json:"consult"`
 	SessionId   string           `json:"sessionId" dc:"会话ID"`
 	NodeId      string           `json:"nodeId"`
diff --git a/workflow/service/flow/lambda_node_util.go b/workflow/service/flow/lambda_node_util.go
index 353f1be..9d5f172 100644
--- a/workflow/service/flow/lambda_node_util.go
+++ b/workflow/service/flow/lambda_node_util.go
@@ -98,11 +98,6 @@ func GetModelInfo(ctx context.Context, req *flowDto.GetModelInfoReq) (res *flowD
 }
 
 func GetComposeResult(ctx context.Context, buildType int, modelName, promptContent, skillName string, form []map[string]any, userForm []map[string]any, fileUrl []string, sessionId, nodeId string, cause string) (res *flowDto.ComposeCallbackReq, err error) {
-	if !g.IsEmpty(promptContent) {
-		userForm = append(userForm, map[string]any{
-			"prompt": promptContent,
-		})
-	}
 	var callbackUrl = utils.GetCallbackURL(ctx, "/flow/execution/composeCallBack")
 	var consult = make([]flowDto.Consult, 0)
 	var collectFileUrls func(val any) (fullyConsumed bool)
@@ -169,6 +164,7 @@ func GetComposeResult(ctx context.Context, buildType int, modelName, promptConte
 		Cause:       cause,
 		Form:        form,
 		UserForm:    newUserForm,
+		UserPrompt:  promptContent,
 		Consult:     consult,
 		SessionId:   sessionId,
 		NodeId:      nodeId,