package models
|
|
import "basic.com/valib/logger.git"
|
|
type CameraArea struct {
|
Cameraid string `json:"cameraId"`
|
Areaid string `json:"areaId"`
|
}
|
|
func (CameraArea) TableName() string {
|
return "camera_area"
|
}
|
|
//摄像机所属区域新增
|
func (ca *CameraArea) Insert() (result bool, err error) {
|
var row int
|
if err := db.Raw("select count(1) from camera_area where cameraid=? and areaid=?", ca.Cameraid, ca.Areaid).Scan(&row).Error; err != nil {
|
return false, err
|
}
|
if row == 0 {
|
result := db.Table("camera_area").Save(&ca)
|
if result.Error != nil {
|
return false, result.Error
|
}
|
return true, nil
|
}
|
return true, nil
|
}
|
|
//删除摄像机所属的某一区域
|
func (ca *CameraArea) Delete() (result bool, err error) {
|
exeResult := db.Exec("delete from camera_area where cameraid=? and areaid=?", ca.Cameraid, ca.Areaid)
|
if exeResult.Error != nil {
|
return false, exeResult.Error
|
}
|
if exeResult.RowsAffected > 0 {
|
return true, nil
|
}
|
return false, nil
|
}
|
|
func (ca *CameraArea) UpdateArea(cameraId string, areaId string) bool {
|
var err error
|
tx := GetDB().Begin()
|
defer func() {
|
if err != nil && tx != nil {
|
tx.Rollback()
|
}
|
}()
|
if err = tx.Exec("delete from camera_area where cameraId=?", cameraId).Error; err != nil {
|
logger.Debug("err:", err)
|
return false
|
}
|
if err = tx.Exec("insert into camera_area(cameraId,areaId) values (?,?)", cameraId, areaId).Error; err != nil {
|
logger.Debug("err:", err)
|
return false
|
}
|
tx.Commit()
|
return true
|
}
|
|
func (ca *CameraArea) FindAll() (cams []CameraArea, err error) {
|
dberr := db.Table(ca.TableName()).Find(&cams)
|
if dberr.Error != nil {
|
return nil, err
|
}
|
return cams, nil
|
}
|
