Yunlot_public/models/Product/ProductProt.go

package Product

import (
	"Yunlot/lib"
	"Yunlot/logs"
	"Yunlot/models"
	"github.com/beego/beego/v2/adapter/orm"
	orm2 "github.com/beego/beego/v2/client/orm"
)

// 产品协议
type ProductProt struct {
	Id         string `orm:"size(8);pk" json:"Id" form:"Id"`
	T_uuid     string `orm:"size(8);index" json:"-" form:"T_uuid"`                       // 用户识别码（8位） ，管理员可以为空
	T_name     string `orm:"size(20);index" json:"T_name" form:"T_name"`                 // 协议名称 20 字符
	T_mode     int    `orm:"size(1);default(1)" json:"T_mode" form:"T_mode"`             //接入方式  1：Mqtt  2:tcp    6:http
	T_lang     int    `orm:"size(1);default(1)" json:"T_lang" form:"T_lang"`             //编程语言 0: 无解析   1: go   2: C
	T_analysis string `orm:"type(text);default('')" json:"T_analysis" form:"-"`          //数据解析
	T_text     string `orm:"type(text);default('')" json:"T_text" form:"T_text"`         // 代码内容
	T_describe string `orm:"type(text);default('')" json:"T_describe" form:"T_describe"` // 描述内容
	T_vote     int64  `orm:"default(1)" json:"T_vote" form:"T_vote"`                     // 查看人气

	T_State    int         `orm:"size(1);default(2)" json:"T_State"`                                   //  1 正常   2 等待审核  3 审核失败
	T_log      string      `orm:"type(text);default('')" json:"T_log"`                                 //
	CreateTime models.Time `orm:"column(create_time);type(timestamp);null;auto_now_add" json:"-"`      //auto_now 每次 model 保存时都会对时间自动更新
	UpdateTime models.Time `orm:"column(update_time);type(timestamp);null;auto_now" json:"UpdateTime"` //auto_now_add 第一次保存时才设置时间
}

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

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

}

// 添加
func (t *ProductProt) Add() (is bool) {
	o := orm.NewOrm()
	t.Id = lib.GetRandstring(8, "", 0)
	_, err := o.Insert(t)
	if err != nil {
		return false
	}
	return true
}

// 获取
func (t *ProductProt) Read() (bool bool) {

	if !(len(t.T_uuid) > 0) {

		return false
	}
	if !(len(t.T_name) > 0) {

		return false
	}
	o := orm.NewOrm()
	err := o.Read(t, "T_uuid", "T_name") // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
	if err != nil {
		return false
	}

	return true
}

// 获取
func (t *ProductProt) Read_ID() (bool bool) {

	if !(len(t.Id) > 0) {
		logs.Println("ProductProt.Id:", t.Id)
		return false
	}

	o := orm.NewOrm()
	err := o.Read(t, "Id") // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
	if err != nil {
		return false
	}

	return true
}

// 修改
func (t *ProductProt) Update(cols ...string) bool {
	o := orm.NewOrm()
	if num, err := o.Update(t, cols...); err == nil {
		logs.Println("Number of records updated in database:", num)

		return true
	}
	return false
}

// 删除
func (t *ProductProt) Delete() bool {
	o := orm.NewOrm()
	if num, err := o.Delete(t); err == nil {
		logs.Println("Number of records deleted in database:", num)
	} else {
		return false
	}
	return true
}

// 获取列表
func (t *ProductProt) Lists(PageIndex int, PageSize int) (r []ProductProt, Total int64) {

	o := orm.NewOrm()

	// 也可以直接使用 Model 结构体作为表名
	qs := o.QueryTable(new(ProductProt))
	var offset int64
	if PageIndex <= 1 {
		offset = 0
	} else {
		offset = int64((PageIndex - 1) * PageSize)
	}

	// 筛选参数
	cond := orm.NewCondition()
	if len(t.T_name) > 0 {
		cond = cond.And("T_name__icontains", t.T_name) // .AndNot("status__in", 1).Or("profile__age__gt", 2000)
	}
	if t.T_mode > 0 {
		cond = cond.And("T_mode", t.T_mode) // 用户识别码
	}
	if t.T_lang > 0 {
		cond = cond.And("T_lang", t.T_lang) // 用户识别码
	}
	if len(t.T_uuid) > 0 {
		cond = cond.And("T_uuid", t.T_uuid) // 用户识别码
	}
	if t.T_State > 0 {
		cond = cond.And("T_State", t.T_State) // 用户识别码
	}

	// 执行
	qs.Limit(PageSize, offset).SetCond((*orm2.Condition)(cond)).OrderBy("-UpdateTime").All(&r)
	Total, _ = qs.SetCond((*orm2.Condition)(cond)).Count()

	for i, _ := range r {
		//r[i].T_uuid = "*"
		r[i].T_text = ""
		r[i].T_describe = ""
	}

	return r, Total
}