package models
|
|
import "errors"
|
|
//国标的摄像机信息
|
type VssChannel struct {
|
PublicID string `gorm:"column:publicId;not null;unique;" json:"publicId"` //国标资源通道20位id （用于请求视频、控制等操作）
|
DevPubID string `gorm:"column:devPubId" json:"devPubId"` //通道的设备id
|
ResType int `gorm:"column:resType;default:1;" json:"resType"` //1-通道资源 2-资源组
|
Name string `gorm:"column:name;" json:"name"` //资源名称
|
Alive int `gorm:"column:alive;default:0;" json:"alive"` // 状态 0：不在线 1：在线
|
Corp string `gorm:"column:corp" json:"corp"` //厂商
|
Model string `gorm:"column:model" json:"model"` //设备类型
|
Owner string `gorm:"column:owner" json:"owner"` //设备归属
|
CivilCode string `gorm:"column:civilCode" json:"civilCode"` //行政区域 （可以按照行政区域进行划分资源组）
|
Address string `gorm:"column:address" json:"address"` //地址
|
ParentId string `gorm:"column:parentId" json:"parentId"` //父节点id
|
IP string `gorm:"column:ip" json:"ip"` //IP
|
Port int `gorm:"column:port" json:"port"` //端口
|
Longitude float64 `gorm:"column:longitude;default:0;" json:"longitude"` //经度
|
Latitude float64 `gorm:"column:latitude;default:0;" json:"latitude"` //纬度
|
PTZType int `gorm:"column:ptzType;default:0;" json:"ptzType"` //控制类型 1-球机；2-半球；3-固定枪机；4-遥控枪机；
|
StreamType int `gorm:"column:streamType;default:0;" json:"streamType"` //码流类型 0-H264；1-MPEG2；2-MPEG4；3-SVAC；4-3GP；5-H265；
|
RealRtspUrl string `gorm:"column:realRtspUrl" json:"realRtspUrl"` //实时视频的rtsp地址
|
ChanRtspUrl string `gorm:"column:chanRtspUrl" json:"chanRtspUrl"`
|
DMarker int `gorm:"column:dMarker;default:1;" json:"dMarker"`
|
ChanPubID string `gorm:"column:chanPubId;" json:"chanPubId"`
|
}
|
|
func (VssChannel) TableName() string {
|
return "VSSChannelTbl"
|
}
|
|
func (v *VssChannel) Insert() (bool,error) {
|
result := db.Table(v.TableName()).Create(&v)
|
if result.Error != nil {
|
return false, result.Error
|
}
|
if result.RowsAffected > 0 {
|
return true, nil
|
}
|
return false, errors.New("新增失败")
|
}
|
|
func (v *VssChannel) Update() (bool,error) {
|
result := db.Table(v.TableName()).Save(&v)
|
if result.Error != nil {
|
return false, result.Error
|
}
|
if result.RowsAffected > 0 {
|
return true, nil
|
}
|
return false, errors.New("更新失败")
|
}
|
|
func (v *VssChannel) Exist(publicId string) bool {
|
dbSelect := db.Table(v.TableName()).Where("publicId=?", publicId).First(&v)
|
if dbSelect.Error != nil || dbSelect.RowsAffected ==0 {
|
return false
|
}
|
return true
|
}
|
|
func (v *VssChannel) FindAll() (list []VssChannel, err error) {
|
err = db.Table(v.TableName()).Find(&list).Error
|
if err != nil {
|
return []VssChannel{},err
|
}
|
return list,nil
|
}
|
|
func (v *VssChannel) FindAllMap() map[string]VssChannel {
|
m := make(map[string]VssChannel)
|
list, _ := v.FindAll()
|
for _, c := range list {
|
m[c.PublicID] = c
|
}
|
|
return m
|
}
|
