package dao

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

type CarDao struct {
	base.BaseDao
}

// Page 查询车辆管理分页数据
func (this CarDao) Page(query *req.CarQuery, list interface{}) int64 {
	session := this.GetSession().Table(model.Car{}.TableName())

	if query.Id > 0 {
		session.And("id = ?", query.Id)
	}
	if !gotool.StrUtils.HasEmpty(query.CarNo) {
		session.And("car_no = ?", query.CarNo)
	}
	if !gotool.StrUtils.HasEmpty(query.Color) {
		session.And("color = ?", query.Color)
	}
	if !gotool.StrUtils.HasEmpty(query.Owner) {
		session.And("owner = ?", query.Owner)
	}
	if query.CompanyId > 0 {
		session.And("company_id = ?", query.CompanyId)
	}
	if !gotool.StrUtils.HasEmpty(query.EngineNo) {
		session.And("engine_no = ?", query.EngineNo)
	}
	if !gotool.StrUtils.HasEmpty(query.ChassisNo) {
		session.And("chassis_no = ?", query.ChassisNo)
	}
	if !gotool.StrUtils.HasEmpty(query.ProductDate) {
		session.And("product_date = ?", query.ProductDate)
	}
	if query.Cat > 0 {
		session.And("cat = ?", query.Cat)
	}
	if query.State > 0 {
		session.And("state = ?", query.State)
	}
	if !gotool.StrUtils.HasEmpty(query.TransportNo) {
		session.And("transport_no = ?", query.TransportNo)
	}
	if !gotool.StrUtils.HasEmpty(query.TransportDate) {
		session.And("transport_date = ?", query.TransportDate)
	}
	if !gotool.StrUtils.HasEmpty(query.Remark) {
		session.And("remark = ?", query.Remark)
	}
	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)
	}
	session.Desc("id")
	total, err := session.Limit(query.PageSize, page.StartSize(query.PageNum, query.PageSize)).FindAndCount(list)
	if err != nil {
		frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
	}
	return total
}

// List 查询车辆管理分页数据
func (this CarDao) List(query *req.CarQuery, list interface{}) {
	session := this.GetSession().Table(model.Car{}.TableName())

	if query.Id > 0 {
		session.And("id = ?", query.Id)
	}
	if !gotool.StrUtils.HasEmpty(query.CarNo) {
		session.And("car_no = ?", query.CarNo)
	}
	if !gotool.StrUtils.HasEmpty(query.Color) {
		session.And("color = ?", query.Color)
	}
	if !gotool.StrUtils.HasEmpty(query.Owner) {
		session.And("owner = ?", query.Owner)
	}
	if query.CompanyId > 0 {
		session.And("company_id = ?", query.CompanyId)
	}
	if !gotool.StrUtils.HasEmpty(query.EngineNo) {
		session.And("engine_no = ?", query.EngineNo)
	}
	if !gotool.StrUtils.HasEmpty(query.ChassisNo) {
		session.And("chassis_no = ?", query.ChassisNo)
	}
	if !gotool.StrUtils.HasEmpty(query.ProductDate) {
		session.And("product_date = ?", query.ProductDate)
	}
	if query.Cat > 0 {
		session.And("cat = ?", query.Cat)
	}
	if query.State > 0 {
		session.And("state = ?", query.State)
	}
	if !gotool.StrUtils.HasEmpty(query.TransportNo) {
		session.And("transport_no = ?", query.TransportNo)
	}
	if !gotool.StrUtils.HasEmpty(query.TransportDate) {
		session.And("transport_date = ?", query.TransportDate)
	}
	if !gotool.StrUtils.HasEmpty(query.Remark) {
		session.And("remark = ?", query.Remark)
	}
	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)
	}
	session.Desc("id")
	err := session.Find(list)
	if err != nil {
		frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
	}
}