feat: support multi-level approval flow for data export workflow (CE)

Author: LordofAvernus

internal/dms/biz/data_export_workflow.go

@@ -108,6 +108,7 @@ type WorkflowRepo interface {
 	GetDataExportWorkflowsByIds(ctx context.Context, dataExportWorkflowUid []string) ([]*Workflow, error)
 	CancelWorkflow(ctx context.Context, workflowRecordIds []string, workflowSteps []*WorkflowStep, operateId string) error
 	AuditWorkflow(ctx context.Context, dataExportWorkflowUid string, status DataExportWorkflowStatus, step *WorkflowStep, operateId, reason string) error
+	AdvanceWorkflowStep(ctx context.Context, dataExportWorkflowUid string, currentStep *WorkflowStep, nextStepId uint64, operateId string) error
 	GetDataExportWorkflowsForView(ctx context.Context, userUid string) ([]string, error)
 	GetProjectDataExportWorkflowsForView(ctx context.Context, projectUid string) ([]string, error)
 	GetDataExportWorkflowsByStatus(ctx context.Context, status string) ([]string, error)

internal/dms/storage/workflow.go

@@ -285,6 +285,25 @@ func (d *WorkflowRepo) AuditWorkflow(ctx context.Context, dataExportWorkflowUid
 	})
 }
 
+// AdvanceWorkflowStep 推进工单审批到下一步骤：标记当前步骤为 approved 并更新 CurrentWorkflowStepId，工单状态保持 wait_for_approve
+func (d *WorkflowRepo) AdvanceWorkflowStep(ctx context.Context, dataExportWorkflowUid string, currentStep *biz.WorkflowStep, nextStepId uint64, operateId string) error {
+	return transaction(d.log, ctx, d.db, func(tx *gorm.DB) error {
+		// 更新当前步骤状态为 approved
+		operateTime := time.Now()
+		stepFields := map[string]interface{}{"operation_user_uid": operateId, "operate_at": operateTime, "state": currentStep.State}
+		if err := tx.WithContext(ctx).Model(&model.WorkflowStep{}).Where("step_id = ? and workflow_record_uid = ?", currentStep.StepId, currentStep.WorkflowRecordUid).Updates(stepFields).Error; err != nil {
+			return fmt.Errorf("failed to update current workflow step, err: %v", err)
+		}
+
+		// 推进 CurrentWorkflowStepId 到下一步
+		if err := tx.WithContext(ctx).Model(&model.WorkflowRecord{}).Where("uid = ?", dataExportWorkflowUid).Update("current_workflow_step_id", nextStepId).Error; err != nil {
+			return fmt.Errorf("failed to advance workflow step, err: %v", err)
+		}
+
+		return nil
+	})
+}
+
 func (d *WorkflowRepo) UpdateWorkflowStatusById(ctx context.Context, dataExportWorkflowUid string, status biz.DataExportWorkflowStatus) error {
 	return transaction(d.log, ctx, d.db, func(tx *gorm.DB) error {
 		if err := tx.WithContext(ctx).Model(&model.WorkflowRecord{}).Where("uid = ?", dataExportWorkflowUid).Update("status", status).Error; err != nil {