package controller

/*
   @Title  文件名称 : tableNameController.go
   @Description 描述: 服务TableNameController

   @Author  作者: leijianming  时间(2021-10-23 12:25:18)
   @Update  作者: leijianming  时间(2021-10-23 12:25:18)

*/

import (
	basedto "gitee.com/ichub/go-factroy2024/cms/base/dto"
	"gitee.com/ichub/go-factroy2024/cms/shop/dto"
	"gitee.com/ichub/go-factroy2024/cms/shop/esservice"
	_ "gitee.com/ichub/go-factroy2024/cms/shop/inter"
	"gitee.com/ichub/go-factroy2024/cms/shop/model"
	"gitee.com/ichub/go-factroy2024/cms/shop/service"

	"encoding/json"
	"fmt"
	"github.com/gin-gonic/gin"
	"io/ioutil"
	"strconv"
)

type TableNameController struct {
	tableNameService   service.TableNameService
	esTableNameService esservice.ESTableNameService
}

var InstTableNameController TableNameController

func (cInst *TableNameController) Query(ctx *gin.Context) {
	defer ctx.Request.Body.Close()
	var bodyBytes []byte
	bodyBytes, err := ioutil.ReadAll(ctx.Request.Body)

	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}
	// 新建缓冲区并替换原有Request.body
	//ctx.Request.DataBody = ioutil.NopCloser(bytes.NewBuffer(bodyBytes))

	var param dto.TableNameQueryParam
	err = json.Unmarshal(bodyBytes, &param)
	if err != nil {

		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}

	//ctx.String(basedto.CODE_SUCCESS, result.ToString())
	var result *dto.TableNamePageResult
	if param.EsQuery {
		result = cInst.esTableNameService.Query(&param)
	} else {
		result = cInst.tableNameService.Query(&param)
	}

	fmt.Println(result.String())
	ctx.Header("Content-Type", "application/json")
	ctx.String(basedto.CODE_SUCCESS, result.String())
}

func (cInst *TableNameController) FindById(ctx *gin.Context) {

	sid := ctx.DefaultQuery("id", "0")

	id, err := strconv.Atoi(sid)
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}
	result := cInst.tableNameService.FindById(int64(id))

	fmt.Println(result.ToString())
	ctx.Header("Content-Type", "application/json")
	ctx.String(basedto.CODE_SUCCESS, result.ToString())

}

func (cInst *TableNameController) DeleteById(ctx *gin.Context) {

	sid := ctx.DefaultQuery("id", "0")

	id, err := strconv.Atoi(sid)
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}
	result := cInst.tableNameService.DeleteById(int64(id))
	data, _ := json.Marshal(result)
	ctx.Header("Content-Type", "application/json")
	ctx.String(basedto.CODE_SUCCESS, string(data))

}

/*
 @title     函数名称: Save
 @description      : 保存接口  主键%s为nil，0新增，!=nil修改
                     Save(ctx *gin.Context)
 @auth      作者    :   leijianming 时间: 2021-10-23 12:25:18
 @param     输入参数名:  ctx *gin.Context
 @return    返回参数名:  无

*/
func (cInst *TableNameController) Save(ctx *gin.Context) {
	defer ctx.Request.Body.Close()
	var bodyBytes []byte
	bodyBytes, err := ioutil.ReadAll(ctx.Request.Body)
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}

	// 新建缓冲区并替换原有Request.body
	//ctx.Request.DataBody = ioutil.NopCloser(bytes.NewBuffer(bodyBytes))
	var entity model.TableName
	err = json.Unmarshal(bodyBytes, &entity)
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}
	result := cInst.tableNameService.Save(&entity)

	fmt.Println(result.ToString())
	ctx.Header("Content-Type", "application/json")
	ctx.String(basedto.CODE_SUCCESS, result.ToString())

}

func (cInst *TableNameController) UpdateNotNullProps(ctx *gin.Context) {
	defer ctx.Request.Body.Close()
	var bodyBytes []byte
	bodyBytes, err := ioutil.ReadAll(ctx.Request.Body)
	defer ctx.Request.Body.Close()
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}

	// 新建缓冲区并替换原有Request.body
	//ctx.Request.DataBody = ioutil.NopCloser(bytes.NewBuffer(bodyBytes))
	var entity model.TableName
	err = json.Unmarshal(bodyBytes, &entity)
	if err != nil {
		ctx.String(basedto.CODE_REQUEST_BAD, "bad request!")
		return
	}
	result := cInst.tableNameService.UpdateNotNullProps(&entity)

	fmt.Println(result.ToString())
	ctx.Header("Content-Type", "application/json")
	ctx.String(basedto.CODE_SUCCESS, result.ToString())
}