Method evaluateCondition

pkg/workflow/engine.go:821–848

evaluateCondition 评估条件

(execution *WorkflowExecution, condition *ConditionDef)

// evaluateCondition 评估条件
func (e *Engine) evaluateCondition(execution *WorkflowExecution, condition *ConditionDef) (bool, error) {
	evaluator := NewExpressionEvaluator(execution.Context.Variables)

	switch condition.Type {
	case ConditionTypeAnd:
		for _, rule := range condition.Rules {
			if result, err := e.evaluateConditionRule(execution, rule, evaluator); err != nil {
				return false, err
			} else if !result {
				return false, nil
			}
		}
		return true, nil
	case ConditionTypeOr:
		for _, rule := range condition.Rules {
			if result, err := e.evaluateConditionRule(execution, rule, evaluator); err != nil {
				return false, err
			} else if result {
				return true, nil
			}
		}
		return false, nil
	case ConditionTypeCustom:
		return evaluator.EvaluateBool(condition.Custom)
	default:
		return false, fmt.Errorf("unsupported condition type: %s", condition.Type)
	}
}

// evaluateConditionRule 评估条件规则
func (e *Engine) evaluateConditionRule(execution *WorkflowExecution, rule ConditionRule, evaluator *ExpressionEvaluator) (bool, error) {