Method Execute

pkg/executionplan/executor.go:71–124

Execute 执行计划

(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext)

// Execute 执行计划
func (e *Executor) Execute(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext) error {
	// 检查计划是否可以执行
	if !plan.CanExecute() {
		if plan.Options != nil && plan.Options.RequireApproval && !plan.IsApproved() {
			return errors.New("plan requires user approval before execution")
		}
		if plan.Status == StatusExecuting {
			return errors.New("plan is already executing")
		}
		if plan.IsCompleted() {
			return fmt.Errorf("plan has already completed with status: %s", plan.Status)
		}
		return fmt.Errorf("plan cannot be executed in current state: %s", plan.Status)
	}

	// 更新计划状态
	now := time.Now()
	plan.Status = StatusExecuting
	plan.StartedAt = &now
	plan.UpdatedAt = now

	// 根据配置选择执行方式
	var err error
	if plan.Options != nil && plan.Options.AllowParallel {
		err = e.executeParallel(ctx, plan, toolCtx)
	} else {
		err = e.executeSequential(ctx, plan, toolCtx)
	}

	// 更新计划完成状态
	completedAt := time.Now()
	plan.CompletedAt = &completedAt
	plan.TotalDurationMs = completedAt.Sub(*plan.StartedAt).Milliseconds()
	plan.UpdatedAt = completedAt

	// 确定最终状态
	summary := plan.Summary()
	if summary.Failed > 0 {
		if summary.Completed > 0 {
			plan.Status = StatusPartial
		} else {
			plan.Status = StatusFailed
		}
	} else if summary.Completed == summary.TotalSteps {
		plan.Status = StatusCompleted
	}

	// 触发计划完成回调
	if e.onPlanComplete != nil {
		e.onPlanComplete(plan)
	}

	return err
}

// executeSequential 顺序执行步骤
func (e *Executor) executeSequential(ctx context.Context, plan *ExecutionPlan, toolCtx *tools.ToolContext) error {