package flow_definition

import (
	"approveflow/app/http/base"
	"approveflow/app/provider/flow_definition"
	"approveflow/app/utils"
	"github.com/Superdanda/hade/framework/gin"
	"net/http"
)

type StepAddParam struct {
	FlowID      int64  `json:"flow_id"`
	ToStepKey   string `json:"to_step_key"`
	FromStepKey string `json:"from_step_key"`
	StepCode    string `json:"step_code"`
}

// StepAdd 添加步骤
// @Summary 添加步骤到流程
// @Description 根据传入的参数，添加步骤到指定的流程中
// @ID flow-definition-step-add
// @Tags flow-definition
// @Accept json
// @Produce json
// @Param stepAddParam body StepAddParam true "添加步骤请求参数"
// @Success 200 {object} base.Result "操作成功"
// @Failure 400 {object} base.Result "参数错误"
// @Failure 500 {object} base.Result "操作失败"
// @Router /definition/step/add [post]
func (a *FlowDefinitionApi) StepAdd(context *gin.Context) {
	param := utils.QuickBind[StepAddParam](context)
	definitionService := context.MustMake(flow_definition.FlowDefinitionKey).(flow_definition.Service)
	step := flow_definition.NewApprovalStepByType(param.StepCode)

	if step == nil {
		context.ISetStatus(http.StatusInternalServerError).IJson(base.Fail("添加步骤不能为空"))
		return
	}

	err := definitionService.AddStepWithPosition(context, param.FlowID, step, param.FromStepKey, param.ToStepKey)
	if err != nil {
		context.ISetStatus(http.StatusInternalServerError).IJson(base.Fail(err.Error()))
		return
	}
	context.ISetOkStatus().IJson(base.SuccessWithOKMessage())
}