package models
|
|
type CameraRuleGroup struct {
|
Id string `gorm:"primary_key;column:id" json:"id"`
|
GroupText string `gorm:"column:group_text" json:"group_text"`
|
AlarmLevel int `gorm:"column:alarm_level;default:1" json:"alarm_level"`
|
SetType string `gorm:"column:set_type" json:"set_type"`
|
|
TemplateId string `gorm:"column:template_id" json:"template_id"` //场景模板id
|
TemplateRule string `gorm:"column:template_rule" json:"template_rule"` //场景模板的配置
|
TimeRuleId string `gorm:"column:time_rule_id" json:"time_rule_id"` //时间段
|
SceneName string `gorm:"column:scene_name" json:"scene_name"` //场景名称，从模板来，修改即自定义
|
Desc string `gorm:"column:desc" json:"desc"` //场景描述
|
Enable bool `gorm:"column:enable;default:1" json:"enable"` //开关，默认开启
|
|
VoiceId string `gorm:"column:voiceId" json:"voiceId"` //事件声音
|
}
|
|
const (
|
Type_SetType_Batch = "batchTask"
|
Type_SetType_Link = "linkTask"
|
RecordNotFound = "record not found"
|
)
|
|
func (CameraRuleGroup) TableName() string {
|
return "camera_rule_group"
|
}
|
|
func (crg *CameraRuleGroup) SelectById(id string) (rows int64, err error) {
|
result := db.Table(crg.TableName()).Where("id = ?", id).First(&crg)
|
if result.Error != nil && result.Error.Error() != RecordNotFound {
|
return 0, result.Error
|
}
|
return result.RowsAffected, nil
|
}
|
|
func (crg *CameraRuleGroup) FindAll() (list []CameraRuleGroup) {
|
if err := db.Table(crg.TableName()).Scan(&list).Error; err != nil {
|
return nil
|
}
|
return list
|
}
|
func (crg *CameraRuleGroup) Insert() (bool, error) {
|
if err := db.Table(crg.TableName()).Create(&crg).Error; err != nil {
|
return false, err
|
}
|
return true, nil
|
}
|
|
func (crg *CameraRuleGroup) FindByCameraId(cameraId string, setType string) (arr []CameraRuleGroup, err error) {
|
sql := "select * from " + crg.TableName() + " where id in (select distinct group_id from " + CameraRuleGroupArg{}.TableName() + " where camera_id='" + cameraId + "')"
|
if setType != "" {
|
sql += " and set_type='batchTask'"
|
}
|
if err := db.Raw(sql).Scan(&arr).Error; err != nil {
|
return nil, err
|
}
|
return arr, nil
|
}
|
|
func (crg *CameraRuleGroup) FindGroupByPolygonId(polygonId string) (list []CameraRuleGroup) {
|
var rga CameraRuleGroupArg
|
err := db.Raw("select * from "+crg.TableName()+" where id in (select distinct group_id from "+rga.TableName()+" where polygon_id=?)", polygonId).Find(&list).Error
|
if err != nil {
|
return nil
|
}
|
return list
|
}
|
|
func (crg *CameraRuleGroup) UpdateText(id string, text string) bool {
|
execResult := db.Exec("update "+crg.TableName()+" set group_text=? where id=?", text, id)
|
if execResult.Error != nil {
|
return false
|
}
|
return execResult.RowsAffected > 0
|
}
|
|
func (crg *CameraRuleGroup) UpdateAlarmLevel(groupId string, alarmLevel int) bool {
|
execResult := db.Exec("update "+crg.TableName()+" set alarm_level=? where id=?", alarmLevel, groupId)
|
if execResult.Error != nil {
|
return false
|
}
|
return execResult.RowsAffected > 0
|
}
|
|
func (crg *CameraRuleGroup) FindByTimeRuleId(timeRuleId string) (list []CameraRuleGroup, e error) {
|
if err := db.Table(crg.TableName()).Where("time_rule_id=?", timeRuleId).Scan(&list).Error; err != nil {
|
return nil, err
|
}
|
return list, nil
|
}
|
