Cold_Api/models/Device/DeviceTask.go

package Device

import (
	"github.com/beego/beego/v2/adapter/orm"
	_ "github.com/go-sql-driver/mysql"
	"time"
)

// 模板
type DeviceTask struct {
	Id         int       `orm:"column(ID);size(11);auto;pk"`
	T_sn       string    `orm:"size(256);null"`        // 设备序列号 KF开头，环境监测主机。 YD开头，温途监测主机
	T_Ut_start time.Time `orm:"type(timestamp);null;"` // 采集时间
	T_Ut_end   time.Time `orm:"type(timestamp);null;"` // 采集时间

	T_Ut    time.Time `orm:"type(timestamp);null;"` // 采集时间
	T_State int       `orm:"size(2);1"`
	//  1   start:开始监测任务，
	//  2   stop：结束监测任务，
	//  3   print：中途打印任务
}

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

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

// 获取全部
func Read_DeviceTask_All_Limit_1(T_sn string) (DeviceTask, bool) {
	o := orm.NewOrm()
	qs := o.QueryTable(new(DeviceTask))
	var r_l []DeviceTask
	qs.Limit(1, 0).Filter("T_sn", T_sn).OrderBy("-ID").All(&r_l)
	if len(r_l) > 0 {
		return r_l[0], true
	}
	return DeviceTask{}, false
}

// 获取全部
func Read_DeviceTask_All_50(T_sn string,Time_end string,Time_start string) ([]DeviceTask, bool) {
	o := orm.NewOrm()
	qs := o.QueryTable(new(DeviceTask))
	var r_l []DeviceTask
	qs.Filter("T_sn", T_sn).Filter("T_Ut_start__gte",Time_start ).Filter("T_Ut_end__lte", Time_end).OrderBy("-Id").All(&r_l)

	return r_l, false
}