Cold_Api/models/Device/DeviceWarningList.go

package Device

import (
	"Cold_Api/logs"
	_ "github.com/astaxie/beego/cache/redis"
	"github.com/beego/beego/v2/adapter/orm"
	_ "github.com/go-sql-driver/mysql"
	"time"
)

// 模板
type DeviceWarningList struct {
	Id     int    `orm:"column(ID);size(11);auto;pk"`
	T_name string `orm:"size(256);null"`            // 分类
	T_Tips string `orm:"type(text);size(256);null"` // 提示
}

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

//var redisCache_DeviceWarningList cache.Cache

func init() {
	//注册模型
	orm.RegisterModel(new(DeviceWarningList))
	//
	//config := fmt.Sprintf(`{"key":"%s","conn":"%s","dbNum":"%s","password":"%s"}`,
	//	"redis_DeviceWarningList", conf.Redis_address, conf.Redis_dbNum, conf.Redis_password)
	//fmt.Println(config)
	//var err error
	//redisCache_DeviceWarningList, err = cache.NewCache("redis", config)
	//if err != nil || redisCache_DeviceWarningList == nil {
	//	errMsg := "failed to init redis"
	//	fmt.Println(errMsg, err)
	//	panic(err)
	//}

	//go Read_DeviceWarningList_All_1()
}

// ---------------- Redis -------------------
//Redis_Set(m.T_sn,m) // Redis 更新缓存
//func Redis_DeviceWarningList_Set(r DeviceWarningList) (err error) {
//	//json序列化
//	str, err := json.Marshal(r)
//	if err != nil {
//		fmt.Print(err)
//		return
//	}
//
//	err = redisCache_DeviceWarningList.Put(r.T_name, str, 0)
//	if err != nil {
//		fmt.Println("set key:", r.T_name, ",value:", str, err)
//	}
//	return
//}
//
////if r,is :=Redis_Get(T_sn);is{
////return r,nil
////}
//func Redis_DeviceWarningList_Get(key string) (r DeviceWarningList, is bool) {
//	if redisCache_DeviceWarningList.IsExist(key) {
//		//println("找到key:",key)
//		v := redisCache_DeviceWarningList.Get(key)
//
//		json.Unmarshal(v.([]byte), &r)
//		return r, true
//	}
//	//println("没有 找到key:",key)
//	return DeviceWarningList{}, false
//}
// ---------------- 特殊方法 -------------------
//
//// 获取 ById
//func Read_DeviceWarningList(T_name string) (r DeviceWarningList) {
//
//	if r, is := Redis_DeviceWarningList_Get(T_name); is {
//		//println("Redis_Get  OK")
//		return r
//	}
//	o := orm.NewOrm()
//	r = DeviceWarningList{T_name: T_name}
//	err := o.Read(&r,"T_name") // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
//	if err != nil {
//		o.Insert(&r)
//		o.Read(&r,"T_name")
//	}
//
//	Redis_DeviceWarningList_Set(r)
//	return r
//}
//
//// 修改
//func Update_DeviceWarningList(r DeviceWarningList, cols ...string) bool {
//	o := orm.NewOrm()
//	if num, err := o.Update(&r, cols...); err == nil {
//		fmt.Println("Number of records updated in database:", num)
//		Redis_DeviceWarningList_Set(r) // Redis 更新缓存
//		return true
//	}
//
//	return false
//}
//
//// 获取全部
//func Read_DeviceWarningList_All_1(){
//	logs.Println("=========== 初始化报警规则 =========")
//	time.Sleep(3*time.Second)
//	o := orm.NewOrm()
//	var r []DeviceWarningList
//	qs := o.QueryTable(new(DeviceWarningList))
//	qs.All(&r)
//
//	for _,v := range r{
//		Redis_DeviceWarningList_Set(v)
//	}
//
//	return
//}

// 获取全部
func Read_DeviceWarningList_All_T_Notice_mechanism() string {
	logs.Println("=========== 初始化报警规则 =========")
	time.Sleep(3 * time.Second)
	o := orm.NewOrm()
	var r []DeviceWarningList
	qs := o.QueryTable(new(DeviceWarningList))
	qs.All(&r)
	str := ""
	for _, v := range r {
		str += v.T_Tips
	}

	return str
}