package cluster
import (
"strconv"
"github.com/weibaohui/k8m/internal/dao"
"github.com/weibaohui/k8m/pkg/comm/utils/amis"
"github.com/weibaohui/k8m/pkg/plugins/modules/demo/models"
"github.com/weibaohui/k8m/pkg/response"
"k8s.io/klog/v2"
)
// List 返回演示列表数据
// 方法内进行角色校验，仅允许“user”角色访问（平台管理员通行）
func List(c *response.Context) {
klog.V(6).Infof("获取演示列表")
params := dao.BuildParams(c)
m := &models.Item{}
items, total, err := dao.GenericQuery(params, m)
if err != nil {
amis.WriteJsonError(c, err)
return
}
amis.WriteJsonListWithTotal(c, total, items)
}
// Create 新增演示项
func Create(c *response.Context) {
// 平台管理员校验
var req models.Item
if err := c.ShouldBindJSON(&req); err != nil {
amis.WriteJsonError(c, err)
return
}
klog.V(6).Infof("新增演示项请求，名称=%s", req.Name)
params := dao.BuildParams(c)
err := dao.GenericSave(params, &req)
if err != nil {
amis.WriteJsonError(c, err)
return
}
amis.WriteJsonData(c, req)
}
// Update 更新演示项
func Update(c *response.Context) {
idStr := c.Param("id")
id64, err := strconv.ParseUint(idStr, 10, 64)
if err != nil {
amis.WriteJsonError(c, err)
return
}
var req models.Item
if err = c.ShouldBindJSON(&req); err != nil {
amis.WriteJsonError(c, err)
return
}
klog.V(6).Infof("更新演示项请求，ID=%d", id64)
req.ID = uint(id64)
params := dao.BuildParams(c)
err = dao.GenericSave(params, &req)
if err != nil {
amis.WriteJsonError(c, err)
return
}
amis.WriteJsonOK(c)
}
// Delete 删除演示项
func Delete(c *response.Context) {
idStr := c.Param("id")
id64, err := strconv.ParseUint(idStr, 10, 64)
if err != nil {
amis.WriteJsonError(c, err)
return
}
klog.V(6).Infof("删除演示项请求，ID=%d", id64)
params := dao.BuildParams(c)
err = dao.GenericDelete(params, &models.Item{}, []int64{int64(id64)})
if err != nil {
amis.WriteJsonError(c, err)
return
}
amis.WriteJsonOK(c)
}
