lc_veterans/app/dao/alarmDao.go

package dao

import (
	"github.com/jinzhu/gorm"
	"time"
)

// Alarm 一键报警服务
type Alarm struct {
	ID          int        `gorm:"primary_key" json:"id"`              //编号
	ServeName   string     `gorm:" varchar(64)" json:"serveName"`      //设备名称
	ServeSN     string     `gorm:"type:varchar(60)" json:"serveSN"`    //设备序编码
	BrandID     int        `gorm:"type:int" json:"brandID"`            //设备品牌ID
	ModelID     int        `gorm:"type:int" json:"modelID"`            //设备型号ID
	ServeType   int        `gorm:"type: int" json:"serveType"`         //服务
	ServeIP     string     `gorm:"type:varchar(50)" json:"serveIP"`    //所属服务IP地址
	ServeProt   int        `gorm:"type:int  " json:"serveProt"`        //端口
	Account     string     `gorm:"type:varchar(4000) " json:"account"` //账号
	Pwd         string     `gorm:"type:varchar(4000) " json:"pwd"`     //密码
	Numeration  int        `gorm:"type:int" json:"numeration"`         //编号
	IPAddress   string     `gorm:"type:varchar(50)" json:"ipAddress"`  //IP地址
	InstallTime *time.Time `gorm:"type:date" json:"installTime"`       //安装时间
	TenantId    string     `gorm:"type:varchar(12)" json:"tenantId"`   //租户id
	CreateTime  time.Time  `gorm:"type:datetime" json:"createTime"`    //新增时间
	CreateUser  string     `gorm:"type:varchar(60)" json:"createUser"` //新增记录操作用户ID
	UpdateTime  time.Time  `gorm:"type:datetime" json:"updateTime"`    //修改时间
	UpdateUser  string     `gorm:"type:varchar(60)" json:"updateUser"` //修改用户
	IsDeleted   int        `gorm:"type:int" json:"isDeleted"`          //是否删除 0=未删除,1=删除
	Status      int        `gorm:"type:int  " json:"status"`           //告警状态 1处理完成2待处理3无需处理
	Tag         string     `gorm:"type:varchar(255)" json:"tag"`       //标签，(备用，逗号区分)
}

func (Alarm) TableName() string {
	return "t_dev_a_key_alarm_serve"
}

func (c Alarm) Delete() error {
	return GDb.Model(&c).Where("id = ?", c.ID).Updates(map[string]interface{}{"update_time": c.UpdateTime,
		"update_user": c.UpdateUser, "is_deleted": c.IsDeleted}).Error
}

func (c Alarm) IsExistedBySN() bool {
	var count = 0
	_ = GDb.Model(&c).Where("  serve_sn = ? and is_deleted = ?",
		c.ServeSN, c.IsDeleted).Count(&count).Error
	return count > 0
}

func (c Alarm) IsExistedByNameAndCode() bool {
	var devices []Alarm
	err := GDb.Model(&c).Where(" serve_sn = ? and is_deleted = ?",
		c.ServeSN, c.IsDeleted).Find(&devices).Error
	//如果查询不到，返回相应的错误
	if gorm.IsRecordNotFoundError(err) {
		return false
	}
	for _, d := range devices {
		if d.ID != c.ID {
			return true
		}
	}
	return false
}

func (c *Alarm) Create() error {
	return GDb.Model(&c).Save(&c).Error
}

func (c *Alarm) Update() error {
	return GDb.Model(&c).Where(" id = ? ", c.ID).Update(&c).Error
}

func (c *Alarm) GetDevice() error {
	err := GDb.Model(&c).Where(" id = ? ", c.ID).Scan(&c).Error
	return err
}

func (c Alarm) GetDevices(offset, limit int) ([]Alarm, error) {
	var devices []Alarm
	err := GDb.Model(&c).Where(" serve_name like ? and is_deleted = 0", "%"+c.ServeName+"%").Offset(offset).Limit(limit).Find(&devices).Error
	return devices, err
}

func (c Alarm) GetAllDevices() ([]*Alarm, error) {
	var devices []*Alarm
	err := GDb.Model(&c).Where(" tenant_id = ? and is_deleted = ? ", c.TenantId, c.IsDeleted).Scan(&devices).Error
	return devices, err
}