lc_smart_admin/server/dao/devices/dev_gateway.go

package devices

import (
	"gorm.io/gorm"
	"server/global"
	"time"
)

type GateWay struct {
	ID             int            `gorm:"primary_key" json:"id"`                          //编号
	GatewayName    string         `gorm:"type:varchar(64)"  json:"gatewayName"`           //网关名称
	GatewayAddress string         `gorm:"type:varchar(64)"  json:"gatewayAddress"`        //网关地址
	GatewayCode    string         `gorm:"type:varchar(60)" json:"gatewayCode"`            //设备编号
	GatewayBrand   string         `gorm:"type:varchar(60)" json:"gatewayBrand"`           //网关品牌
	GatewayModel   string         `gorm:"type:varchar(60)" json:"gatewayModel"`           //网关型号
	IpAddress      string         `gorm:"type:varchar(50)" json:"ipAddress"`              //IP地址
	InstallTime    time.Time      `gorm:"type:date" json:"installTime"`                   //安装时间
	RecentOnline   time.Time      `gorm:"type:datetime;default:null" json:"recentOnline"` //最近在线时间
	IsDeleted      gorm.DeletedAt `gorm:"default:null" json:"isDeleted"`                  //是否删除
	Status         int            `gorm:"type:int;default:1" json:"status"`               //在线状态 0=在线,1=离线
}

func (GateWay) TableName() string {
	return "dev_gateway"
}

func QueryGateWayInfoList(limit, offset int, keyword string) (gatewayList []GateWay, total int64, err error) {
	db := global.GVA_DB.Model(&GateWay{})
	if keyword != "" {
		db.Where("gateway_name like ? or gateway_code like ?", "%"+keyword+"%", "%"+keyword+"%")
	}
	err = db.Count(&total).Error
	if err != nil {
		return
	}
	err = db.Limit(limit).Offset(offset).Find(&gatewayList).Error
	return
}

func (g GateWay) IsExistedByCode() error {
	err := global.GVA_DB.Model(&GateWay{}).Where("gateway_code = ?", g.GatewayCode).First(&g).Error
	return err
}

func (g GateWay) AddGateway() error {
	err := global.GVA_DB.Model(&GateWay{}).Create(&g).Error
	return err
}

func (g GateWay) UpdateGateway() error {
	err := global.GVA_DB.Model(&g).
		Select("gateway_name", "gateway_address", "gateway_brand", "gateway_model", "ip_address", "install_time").
		Where("id=?", g.ID).
		Updates(map[string]interface{}{
			"gateway_name":    g.GatewayName,
			"gateway_address": g.GatewayAddress,
			"gateway_brand":   g.GatewayBrand,
			"gateway_model":   g.GatewayModel,
			"ip_address":      g.IpAddress,
			"install_time":    g.InstallTime,
		}).Error
	return err
}

func (g GateWay) DelGateway(id int) error {
	err := global.GVA_DB.Model(&g).Where("id = ?", id).Delete(&g).Error
	return err
}

func (g GateWay) PublicGateway() (gatewayList []GateWay, err error) {
	err = global.GVA_DB.Model(&GateWay{}).Select("id", "gateway_code", "gateway_name", "recent_online").Find(&gatewayList).Error
	return
}

func UpdateGatewayRecentOnline(code string, recentTime time.Time) error {
	var gateway GateWay
	err := global.GVA_DB.Model(&gateway).
		Select("recent_online").
		Where("gateway_code = ?", code).
		Updates(map[string]interface{}{
			"recent_online": recentTime,
		}).Error
	return err
}

func UpdateGatewayStatus(code string, statu int) error {
	var gateway GateWay
	err := global.GVA_DB.Model(&gateway).
		Select("status").
		Where("gateway_code = ?", code).
		Updates(map[string]interface{}{
			"status": statu,
		}).Error
	return err
}