public/AllinSSL
1
0
Fork 0
mirror of https://gitee.com/mirrors/AllinSSL.git synced 2026-03-08 07:41:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复并行分支config问题

Browse Source 
修复跳过通知取值问题
This commit is contained in:
v-me-50
2025-06-25 10:24:34 +08:00
parent b4e04a3d2e
commit de4838db0c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
backend/internal/workflow/executor.go
View File

@@ -209,7 +209,7 @@ func notify(params map[string]any) (any, error) {
if v, ok := fromNodeData["skip"].(bool); ok && v { if v, ok := fromNodeData["skip"].(bool); ok && v {
// 如果 skip 是 true，则跳过通知 // 如果 skip 是 true，则跳过通知
var skip bool var skip bool
switch v := fromNodeData["skip"].(type) { switch v := params["skip"].(type) {
case int: case int:
skip = v == 1 skip = v == 1
case float64: case float64:

2
backend/internal/workflow/workflow.go
View File

@@ -246,7 +246,7 @@ func RunNode(node *WorkflowNode, ctx *ExecutionContext) error {
errChan := make(chan error, len(node.ConditionNodes)) errChan := make(chan error, len(node.ConditionNodes))
for _, branch := range node.ConditionNodes { for _, branch := range node.ConditionNodes {
if branch.ChildNode != nil { if branch.ChildNode != nil {
if branch.ChildNode.ChildNode == nil { if branch.ChildNode.Config == nil {
branch.ChildNode.Config = make(map[string]any) branch.ChildNode.Config = make(map[string]any)
} }
branch.ChildNode.Config["fromNodeData"] = node.Config["fromNodeData"] branch.ChildNode.Config["fromNodeData"] = node.Config["fromNodeData"]