package controllers

import (
	"github.com/gin-gonic/gin"
	"strconv"
	"wms/extend/code"
	"wms/extend/util"
	"wms/models"
	"wms/pkg/logx"
	"wms/pkg/structx"
	"wms/request"
)

type AttributeValueController struct {
}

// AddAttributeValue
// @Tags      属性值和对象
// @Summary   添加属性值和对象
// @Produce   application/json
// @Param     object  body  request.AddAttributeValue true  "属性值和对象信息"
// @Success   200 {object} util.Response "成功"
// @Router    /api-wms/v1/attributeValue/add [post]
func (slf *AttributeValueController) AddAttributeValue(c *gin.Context) {
	var params request.AddAttributeValue
	var attributeValue models.AttributeValue
	if err := c.BindJSON(&params); err != nil {
		util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
		return
	}
	if err := structx.AssignTo(params, &attributeValue); err != nil {
		util.ResponseFormat(c, code.RequestParamError, "数据转换错误"+err.Error())
		return
	}
	attributeValueSearch := models.NewAttributeValueSearch()
	attributeValues, err := attributeValueSearch.FindByQueryNotTotal("entity_id = ? AND attribute_id = ?", []interface{}{attributeValue.EntityID, attributeValue.AttributeID})
	if len(attributeValues) > 0 {
		util.ResponseFormat(c, code.SaveFail, "添加失败：属性值和对象已存在")
		return
	}
	if err != nil {
		util.ResponseFormat(c, code.SaveFail, "添加失败："+err.Error())
		return
	}
	err = attributeValueSearch.Create(&attributeValue)
	if err != nil {
		logx.Errorf("AttributeValue create err: %v", err)
		util.ResponseFormat(c, code.SaveFail, "添加失败："+err.Error())
		return
	}
	util.ResponseFormat(c, code.Success, "添加成功")
}

// UpdateAttributeValue
// @Tags      属性值和对象
// @Summary   更新属性值和对象
// @Produce   application/json
// @Param     object  body  request.UpdateAttributeValue true  "属性值和对象信息"
// @Success   200 {object} util.Response "成功"
// @Router    /api-wms/v1/attributeValue/update [post]
func (slf *AttributeValueController) UpdateAttributeValue(c *gin.Context) {
	var params request.UpdateAttributeValue
	if err := c.BindJSON(&params); err != nil {
		util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
		return
	}

	attributeValueSearch := models.NewAttributeValueSearch()
	attributeValue, err := attributeValueSearch.SetID(params.ID).First()
	if err != nil {
		util.ResponseFormat(c, code.RequestParamError, "属性值和对象不存在")
		return
	}
	attributeValues, err := attributeValueSearch.FindByQueryNotTotal("entity_id = ? AND attribute_id = ? AND id != ?", []interface{}{params.EntityID, params.AttributeID, params.ID})
	if len(attributeValues) > 0 {
		util.ResponseFormat(c, code.SaveFail, "修改失败：属性值和对象已存在")
		return
	}
	if err != nil {
		util.ResponseFormat(c, code.SaveFail, "修改失败："+err.Error())
		return
	}
	attributeValue.EntityID = params.EntityID
	attributeValue.AttributeID = params.AttributeID
	attributeValue.Value = params.Value
	err = attributeValueSearch.Save(attributeValue)
	if err != nil {
		logx.Errorf("AttributeValue update err: %v", err)
		util.ResponseFormat(c, code.SaveFail, "修改失败："+err.Error())
		return
	}
	util.ResponseFormat(c, code.Success, "修改成功")
}

// DeleteAttributeValue
// @Tags      属性值和对象
// @Summary   删除属性值和对象
// @Param		id	path		string			true	"id"
// @Success   200 {object} util.Response "成功"
// @Router    /api-wms/v1/attributeValue/delete/{id} [delete]
func (slf *AttributeValueController) DeleteAttributeValue(c *gin.Context) {
	id, _ := strconv.ParseUint(c.Param("id"), 10, 64)
	if id == 0 {
		util.ResponseFormat(c, code.RequestParamError, "无效id")
		return
	}
	err := models.NewAttributeValueSearch().SetID(uint(id)).Delete()
	if err != nil {
		logx.Errorf("AttributeValue delete err: %v", err)
		util.ResponseFormat(c, code.RequestParamError, "删除失败")
		return
	}
	util.ResponseFormat(c, code.Success, "删除成功")
}

// ListAttributeValue
// @Tags      属性值和对象
// @Summary   查询属性值和对象 分页条件筛选Value like '%v%' 模糊查询
// @Produce   application/json
// object  body  request.OperationList true  "查询参数"
// @Success   200 {object} util.Response "成功"
// @Router    /api-wms/v1/attributeValue/list [post]
func (slf *AttributeValueController) ListAttributeValue(c *gin.Context) {
	var params request.AttributeValueList
	if err := c.BindJSON(&params); err != nil {
		util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
		return
	}
	search := models.NewAttributeValueSearch()
	search.SetPage(params.Page, params.PageSize)
	if params.EntityID != "" {
		search.SetEntityID(params.EntityID)
	}
	if params.AttributeID != 0 {
		search.SetAttributeID(params.AttributeID)
	}
	if params.Value != "" {
		search.SetValue(params.Value)
	}
	list, total, err := search.Find()
	if err != nil {
		util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error())
		return
	}
	util.ResponseFormatListWithPage(c, code.Success, list, int(total), params.Page, params.PageSize)
}

// PrimaryAttributeValue
// @Tags      属性值和对象
// @Summary   查询属性值和对象 通过主键ID查询
// object  body  request.OperationList true  "查询参数"
// @Success   200 {object} util.Response "成功"
// @Router    /api-wms/v1/attributeValue/primary/{id}  [get]
func (slf *AttributeValueController) PrimaryAttributeValue(c *gin.Context) {
	id, _ := strconv.ParseUint(c.Param("id"), 10, 64)
	if id == 0 {
		util.ResponseFormat(c, code.RequestParamError, "无效id")
		return
	}
	attributeValue, err := models.NewAttributeValueSearch().SetID(uint(id)).First()
	if err != nil {
		util.ResponseFormat(c, code.RequestParamError, "查询失败")
		return
	}
	util.ResponseFormat(c, code.Success, attributeValue)
}