package {{PackageTableName}}ser

import (
	"time"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/bson/primitive"
	"{{ModuleName}}/models/commod"
	"{{ModuleName}}/models/cache/{{PackageTableName}}data"
	"{{ModuleName}}/models/v/{{PackageTableName}}mod"
)

type {{VariablePrefix}}ListReq struct {
	commod.Page
}
type {{VariablePrefix}}ListRes struct {
	Total   int64            `json:"total"`
	HasNext bool             `json:"hasNext"`
	List    []{{PackageTableName}}mod.{{StructName}} `json:"list"`
}

// GetList 获取列表
func (q *{{VariablePrefix}}ListReq) GetList() (res {{VariablePrefix}}ListRes, err error) {
	filter := bson.M{}
	res.List, res.Total, res.HasNext, err = {{PackageTableName}}mod.GetList(filter, int64(q.Skip()), int64(q.Limit()), q.GetSort())

	return
}

type {{VariablePrefix}}CreateReq struct {
	{{CreateReqFields}}
}

// Create 发布数据
func (p *{{VariablePrefix}}CreateReq) Create() error {
	data := {{PackageTableName}}mod.{{StructName}}{
	{{CreateStatement}}
	}

	// 创建数据
	if _, err := {{PackageTableName}}data.InsertData(nil, data); err != nil {
		return err
	}

	return nil
}

type {{VariablePrefix}}UpdateReq struct {
	ID primitive.ObjectID `json:"id" binding:"required"`
	{{UpdateReqFields}}
}

// Update 更新数据
func (p *{{VariablePrefix}}UpdateReq) Update() error {
	_, err := {{PackageTableName}}mod.GetInfo(p.ID)
	if err != nil {
		return err
	}

	data := make(map[string]interface{})
	{{UpdateStatement}}

	if _, err = {{PackageTableName}}data.UpdateData(nil, p.ID.Hex(), data); err != nil {
		return err
	}

	return nil
}

type {{VariablePrefix}}DeleteReq struct {
	ID primitive.ObjectID `json:"id" binding:"required"`
}

// Delete 删除数据
func (p *{{VariablePrefix}}DeleteReq) Delete() error {
	if err := {{PackageTableName}}data.DeleteData(nil, p.ID); err != nil {
		return err
	}

	return nil
}