package System

import (
	"Cold_Api/conf"
	"github.com/beego/beego/v2/adapter/orm"
	"time"
)

type DeviceLogs struct {
	Id       int    `orm:"column(ID);size(11);auto;pk"`
	T_sn     string `orm:"size(256);null"`  //
	Logs_Txt string `orm:"type(text);null"` // 详情

	CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now 每次 model 保存时都会对时间自动更新
}

func (t *DeviceLogs) TableName() string {
	return "DeviceLogs" // 数据库名称   // ************** 替换 FormulaList **************
}

func init() {
	//注册模型
	orm.RegisterModel(new(DeviceLogs))
}

// 添加  System.Add_DeviceLogs("MqttServer","参数请求 [Rt_Parameter]","base")
func Add_DeviceLogs(T_sn string, Logs_Txt string) {
	o := orm.NewOrm()
	m := DeviceLogs{T_sn: T_sn, Logs_Txt: Logs_Txt}
	o.Insert(&m)
}

// 获取列表
func Read_DeviceLogs_ALL(page int, T_sn string) (r []DeviceLogs, cnt int64) {

	o := orm.NewOrm()
	// 也可以直接使用 Model 结构体作为表名

	qs := o.QueryTable(new(DeviceLogs))
	var offset int64
	if page <= 1 {
		offset = 0
	} else {
		offset = int64((page - 1) * conf.Page_size)
	}

	qs.Limit(conf.Page_size, offset).Filter("T_sn", T_sn).OrderBy("-Id").All(&r)
	cnt, _ = qs.Filter("T_sn", T_sn).Count()

	return r, cnt
}