package dao

import (
	"github.com/druidcaesa/gotool"
	"ulink-admin/frame"
	"ulink-admin/modules/site/models/model"
	"ulink-admin/modules/site/models/req"
	"ulink-admin/pkg/base"
	"ulink-admin/pkg/page"
)

type SiteDao struct {
	base.BaseDao
}

// Page 查询站点管理分页数据
func (this SiteDao) Page(query *req.SiteQuery) (*[]model.Site, int64) {
	site := make([]model.Site, 0)
	session := this.GetSession().Table(model.Site{}.TableName())

	if query.Id > 0 {
		session.And("id = ?", query.Id)
	}
	if !gotool.StrUtils.HasEmpty(query.Label) {
		session.And("label = ?", query.Label)
	}
	if !gotool.StrUtils.HasEmpty(query.Code) {
		session.And("code = ?", query.Code)
	}
	if !gotool.StrUtils.HasEmpty(query.Describe) {
		session.And("describe = ?", query.Describe)
	}
	if !gotool.StrUtils.HasEmpty(query.Kewords) {
		session.And("kewords = ?", query.Kewords)
	}
	if !gotool.StrUtils.HasEmpty(query.Image) {
		session.And("image = ?", query.Image)
	}
	if !gotool.StrUtils.HasEmpty(query.Content) {
		session.And("content = ?", query.Content)
	}
	if query.Price > 0 {
		session.And("price = ?", query.Price)
	}
	if query.Status > 0 {
		session.And("status = ?", query.Status)
	}
	if query.Sort > 0 {
		session.And("sort = ?", query.Sort)
	}
	if !gotool.StrUtils.HasEmpty(query.CreateBy) {
		session.And("create_by = ?", query.CreateBy)
	}
	if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
		session.And("update_by = ?", query.UpdateBy)
	}
	if !gotool.StrUtils.HasEmpty(query.BeginTime) {
		session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
	}
	if !gotool.StrUtils.HasEmpty(query.EndTime) {
		session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
	}
	total, _ := page.GetTotal(session.Clone())
	err := session.Limit(query.PageSize, page.StartSize(query.PageNum, query.PageSize)).Find(&site)
	if err != nil {
		frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
	}
	return &site, total
}

// List 查询站点管理分页数据
func (this SiteDao) List(query *req.SiteQuery, list interface{}) {
	site := make([]model.Site, 0)
	session := this.GetSession().Table(model.Site{}.TableName())

	if query.Id > 0 {
		session.And("id = ?", query.Id)
	}
	if !gotool.StrUtils.HasEmpty(query.Label) {
		session.And("label = ?", query.Label)
	}
	if !gotool.StrUtils.HasEmpty(query.Code) {
		session.And("code = ?", query.Code)
	}
	if !gotool.StrUtils.HasEmpty(query.Describe) {
		session.And("describe = ?", query.Describe)
	}
	if !gotool.StrUtils.HasEmpty(query.Kewords) {
		session.And("kewords = ?", query.Kewords)
	}
	if !gotool.StrUtils.HasEmpty(query.Image) {
		session.And("image = ?", query.Image)
	}
	if !gotool.StrUtils.HasEmpty(query.Content) {
		session.And("content = ?", query.Content)
	}
	if query.Price > 0 {
		session.And("price = ?", query.Price)
	}
	if query.Status > 0 {
		session.And("status = ?", query.Status)
	}
	if query.Sort > 0 {
		session.And("sort = ?", query.Sort)
	}
	if !gotool.StrUtils.HasEmpty(query.CreateBy) {
		session.And("create_by = ?", query.CreateBy)
	}
	if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
		session.And("update_by = ?", query.UpdateBy)
	}
	if !gotool.StrUtils.HasEmpty(query.BeginTime) {
		session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
	}
	if !gotool.StrUtils.HasEmpty(query.EndTime) {
		session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
	}
	err := session.Find(&site)
	if err != nil {
		frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
	}
}