package api

import (
	"changeme/internal/logic/db"
	"changeme/internal/logic/util/response"
	"changeme/internal/model"

	"github.com/gogf/gf/v2/net/ghttp"
)

func AddDbData(r *ghttp.Request)  {
	var req *model.AddData
	//获取参数&参数校验
	if err := r.Parse(&req); err != nil {
		//fmt.Fprintf(w,gconv.String(g.Map{"code":"-1","msg":err.Error()}))
		response.FailJson(true, r, err.Error())
		return 
	}
	DBFunc := db.GetInstance()
	err := DBFunc.Add(req)
	if err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	response.SusJson(true, r, "查询成功")
}

func Page(r *ghttp.Request)  {
	var req *model.PageReqData
	//获取参数&参数校验
	if err := r.Parse(&req); err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	DBFunc := db.GetInstance()
	list,err := DBFunc.List(req)
	if err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	response.SusJson(true, r, "查询成功",list)
}

func UpdateDbData(r *ghttp.Request)  {
	var req *model.Data
	//获取参数&参数校验
	if err := r.Parse(&req); err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	DBFunc := db.GetInstance()
	err := DBFunc.Update(req)
	if err != nil {
		response.FailJson(true, r, err.Error())
		return
	}
	response.SusJson(true, r, "更新成功")
}



func DeleteDbData(r *ghttp.Request)  {
	var req *model.DeleteReqData
	//获取参数&参数校验
	if err := r.Parse(&req); err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	DBFunc := db.GetInstance()
	err := DBFunc.Delete(req)
	if err != nil {
		response.FailJson(true, r, err.Error())
		return 
	}
	response.SusJson(true, r, "操作成功")
}