package operations

import (
	"errors"
	"net/http"
	"time"

	"github.com/gin-gonic/gin"
	"github.com/gin-gonic/gin/binding"
	"github.com/go-admin-team/go-admin-core/sdk/api"
	"github.com/go-admin-team/go-admin-core/sdk/pkg/jwtauth/user"
	coreService "github.com/go-admin-team/go-admin-core/sdk/service"

	"git.ilapage.cn/ila/yovision/Sense/server/common"
)

const auditSuccess, auditFailure = "1", "2"

type API struct{ api.Api }

func (e *API) service(c *gin.Context) (*Service, error) {
	base := coreService.Service{}
	if err := e.MakeContext(c).MakeOrm().MakeService(&base).Errors; err != nil {
		return nil, err
	}
	return NewService(base.Orm), nil
}

func (e *API) List(c *gin.Context) {
	service, err := e.service(c)
	if err != nil {
		e.writeError(err)
		return
	}
	request := PageRequest{}
	if err = e.MakeContext(c).Bind(&request).Errors; err != nil {
		e.audit(c, service, "List", auditFailure, "运维中心查询条件格式不正确")
		e.Error(http.StatusBadRequest, err, "查询条件格式不正确")
		return
	}
	response, err := service.List(request)
	if err != nil {
		e.audit(c, service, "List", auditFailure, "运维中心列表查询失败")
		e.writeError(err)
		return
	}
	e.audit(c, service, "List", auditSuccess, "读取运维中心问题列表")
	e.OK(response, "查询成功")
}

func (e *API) Get(c *gin.Context) {
	service, err := e.service(c)
	if err != nil {
		e.writeError(err)
		return
	}
	item, err := service.Get(c.Param("id"))
	if err != nil {
		e.audit(c, service, "Get", auditFailure, "运维问题详情查询失败")
		e.writeError(err)
		return
	}
	e.audit(c, service, "Get", auditSuccess, "读取运维问题详情 "+item.ID)
	e.OK(item, "查询成功")
}

func (e *API) Retry(c *gin.Context) {
	service, err := e.service(c)
	if err != nil {
		e.writeError(err)
		return
	}
	request := RetryRequest{}
	if err = e.MakeContext(c).Bind(&request, binding.JSON).Errors; err != nil {
		e.audit(c, service, "Retry", auditFailure, "受控重试请求格式不正确")
		e.Error(http.StatusBadRequest, err, "请求格式不正确")
		return
	}
	item, err := service.Retry(c.Request.Context(), c.Param("id"), request.ExpectedVersion, user.GetUserId(c))
	if err != nil {
		e.audit(c, service, "Retry", auditFailure, "受控重试被拒绝")
		e.writeError(err)
		return
	}
	e.audit(c, service, "Retry", auditSuccess, "受控重试已排队 "+item.ID)
	e.OK(item, "重试任务已排队")
}

func (e *API) audit(c *gin.Context, service *Service, action, status, remark string) {
	err := WriteAudit(service.DB, Audit{Action: action, Method: c.Request.Method, Status: status, Username: user.GetUserName(c), UserID: user.GetUserId(c), ClientIP: common.GetClientIP(c), Route: c.FullPath(), Remark: remark, At: time.Now()})
	if err != nil {
		api.GetRequestLogger(c).Errorf("operations audit failed: %s", err.Error())
	}
}

func (e *API) writeError(err error) {
	switch {
	case errors.Is(err, ErrInvalidFilter):
		e.Error(http.StatusBadRequest, err, err.Error())
	case errors.Is(err, ErrVersionConflict), errors.Is(err, ErrRetryInProgress), errors.Is(err, ErrRetryNotAllowed):
		e.Error(http.StatusConflict, err, err.Error())
	case errors.Is(err, ErrProblemNotFound):
		e.Error(http.StatusNotFound, err, err.Error())
	default:
		e.Error(http.StatusInternalServerError, err, "运维中心操作失败")
	}
}