Cold_Api/models/Warning/WarningSand.go

package Warning

import (
	"Cold_Api/models/Account"
	"fmt"
	"github.com/beego/beego/v2/adapter/orm"
	orm2 "github.com/beego/beego/v2/client/orm"
	_ "github.com/go-sql-driver/mysql"
	"strconv"
	"time"
)

// 模板
// 报警发送统计
type WarningSand struct {
	Id int `orm:"column(ID);size(11);auto;pk"`

	T_pid    int    `orm:"index;size(100);null"` // Account.Company 绑定公司， -1：未知   0：管理员  >0 :绑定公司
	T_tp     int    `orm:"index;size(20);null"`  // 报警类型   ->WarningList
	T_Notice string `orm:"size(256);null"`       // 18888888888
	T_type   int    `orm:"index;size(4);null"`   // 1 短信   2 电话
	T_Remark string `orm:"size(256);null"`       // 备注

	CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间
}

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

func init() {
	//注册模型
	orm.RegisterModel(new(WarningSand))
	orm.Debug = true
}

// ---------------- 特殊方法 -------------------

// 获取 ById
func Read_WarningWx_ById(id int) (r WarningSand) {
	o := orm.NewOrm()
	r = WarningSand{Id: id}
	err := o.Read(&r) // o.Read(&r,"Tokey") 如果不是 主键 就得指定字段名
	if err != nil {
		fmt.Println(err)
	}
	return r
}

// 添加
func Add_WarningHand(m WarningSand) {
	warningWxList := Read_DeviceWarning(m)
	if len(warningWxList) == 0 {
		Add_WarningHand(m)
	}
}

// 添加
func Add_WarningSand(m WarningSand) (id int64, err error) {
	o := orm.NewOrm()
	id, err = o.Insert(&m)
	//if err != nil {
	//	fmt.Println(err)
	//}
	return id, err
}

// 获取列表
func Read_DeviceWarning(Warning WarningSand) (r []WarningSand) {

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

	qs := o.QueryTable(new(WarningSand))
	now := time.Now()
	// N 个小时前
	dd, _ := time.ParseDuration("-1m") //"s", "m", "h".
	currentTime := now.Add(dd)

	qs.Filter("T_pid", Warning.T_pid).Filter("T_tp", Warning.T_tp).Filter("T_Notice", Warning.T_Notice).Filter("T_type", Warning.T_type).Filter("CreateTime__gte", currentTime.Format("2006-01-02 15:04:05")).OrderBy("-Id").All(&r)
	// 记录 ++
	if len(r) > 0 {
		ColAdd_DeviceWarningBy_ID(r[0].Id)
	}
	return r
}

// 获取时  累加 1
func ColAdd_DeviceWarningBy_ID(id int) {
	o := orm.NewOrm()
	// 也可以直接使用 Model 结构体作为表名
	design := new(WarningSand)
	qs := o.QueryTable(design)
	// 获取时  累加 1
	qs.Filter("Id", id).Update(orm2.Params{"T_Filter": orm2.ColValue(orm.ColAdd, 1)})
	return
}

func Read_WarningSand_ALL_T_sn_TIME_Count(T_sn string) (cnt int) {
	o := orm.NewOrm()
	var maps_z []orm2.ParamsList

	now := time.Now()
	timeStr := now.Format("2006-01-02") + " 00:00:00"

	sql := "SELECT COUNT(ID) FROM warning_sand WHERE t__title NOT LIKE '%恢复%' AND t__ut > '" + timeStr + "' AND t_sn LIKE '%" + T_sn + "%' "
	fmt.Println(sql)
	_, err := o.Raw(sql).ValuesList(&maps_z)
	if err != nil {
		return 0
	}
	if len(maps_z) == 0 {
		return 0
	}

	//value, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", cnt), 64)
	key, _ := strconv.Atoi(maps_z[0][0].(string))
	return key
}

func Read_WarningSand_ALL_T_Bind_TIME_Count(user_ Account.Admin, T_sn string) (cnt int) {
	o := orm.NewOrm()
	var maps_z []orm2.ParamsList

	now := time.Now()
	timeStr := now.Format("2006-01-02") + " 00:00:00"

	T_Bind := "U" + strconv.Itoa(user_.Id) + "|"

	sql := "SELECT COUNT(ID) FROM warning_sand WHERE t__title NOT LIKE '%恢复%' AND t__ut > '" + timeStr + "' AND t__bind LIKE '%" + T_Bind + "%' AND t_sn  LIKE '%" + T_sn + "%'"
	fmt.Println(sql)
	_, err := o.Raw(sql).ValuesList(&maps_z)
	if err != nil {
		return 0
	}
	if len(maps_z) == 0 {
		return 0
	}

	//value, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", cnt), 64)
	key, _ := strconv.Atoi(maps_z[0][0].(string))
	return key
}