liuxiaolong
2019-07-02 b04d36589f44e3dbc163a0a2a64fc765773d8c64
add camera and localconfig cache
1个文件已修改
39 ■■■■■ 已修改文件
cache/cache.go 39 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
cache/cache.go
@@ -11,9 +11,11 @@
    "strconv"
)
const (
    PREFIX_CAMERA = "CAMERA_"
    PREFIX_POLYGON = "POLYGON_"
    PREFIX_TIME = "TIME_"
    PREFIX_RULE = "RULE_"
    SERVER_KEY = "SERVERINFO"
)
var cMap *shardmap.ShardMap
@@ -44,6 +46,10 @@
    initCameraTaskRules()//初始化摄像机任务规则缓存
    initCamera()//初始化摄像机信息
    initServerInfo()//初始化服务器配置信息
    initChan <- true
}
@@ -64,6 +70,22 @@
    default:
        fmt.Println("unknown operation")
    }
}
func initServerInfo() {
    var api dbapi.SysSetApi
    b, s := api.GetServerInfo()
    if b{
        cMap.Set(SERVER_KEY,s)
    }
}
func initCamera() {
    var api dbapi.CameraApi
    cameras := api.FindAll()
    for _,cam := range cameras {
        cMap.Set(PREFIX_CAMERA + cam.Id,cam)
    }
}
@@ -104,7 +126,24 @@
    }
}
func GetServerInfo() *protomsg.LocalConfig {
    config, b := cMap.Get(SERVER_KEY)
    if b {
        return config.(*protomsg.LocalConfig)
    } else {
        return nil
    }
}
//通过cameraId获取摄像机信息
func GetCameraById(cameraId string) *protomsg.Camera {
    cam, b := cMap.Get(PREFIX_CAMERA + cameraId)
    if b {
        return cam.(*protomsg.Camera)
    } else {
        return nil
    }
}
func GetPolygonsByCameraId(cameraId string) []protomsg.CameraPolygon{
    obj, b := cMap.Get(PREFIX_POLYGON + cameraId)