diff --git a/backend/internal/workflow/executor.go b/backend/internal/workflow/executor.go index 9b2d8e2..cf43d6a 100644 --- a/backend/internal/workflow/executor.go +++ b/backend/internal/workflow/executor.go @@ -209,7 +209,7 @@ func notify(params map[string]any) (any, error) { if v, ok := fromNodeData["skip"].(bool); ok && v { // 如果 skip 是 true,则跳过通知 var skip bool - switch v := fromNodeData["skip"].(type) { + switch v := params["skip"].(type) { case int: skip = v == 1 case float64: diff --git a/backend/internal/workflow/workflow.go b/backend/internal/workflow/workflow.go index 02bf4eb..bbe4986 100644 --- a/backend/internal/workflow/workflow.go +++ b/backend/internal/workflow/workflow.go @@ -246,7 +246,7 @@ func RunNode(node *WorkflowNode, ctx *ExecutionContext) error { errChan := make(chan error, len(node.ConditionNodes)) for _, branch := range node.ConditionNodes { if branch.ChildNode != nil { - if branch.ChildNode.ChildNode == nil { + if branch.ChildNode.Config == nil { branch.ChildNode.Config = make(map[string]any) } branch.ChildNode.Config["fromNodeData"] = node.Config["fromNodeData"]