---

panlei

2019-07-05 bc2b97eafce90ba3356d34fe06302ac01b74cb30

 cache/cache.go

@@ -5,6 +5,7 @@
   "basic.com/pubsub/cache.git/shardmap"
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/gopherdiscovery.git"
   "errors"
   "fmt"
   "github.com/gogo/protobuf/proto"
   "github.com/satori/go.uuid"
@@ -61,10 +62,16 @@
      return
   }
   switch newUpdateMsg.Table {
   case protomsg.TableChanged_T_Server:
      initServerInfo()
   case protomsg.TableChanged_T_Camera:
      initCamera()
   case protomsg.TableChanged_T_CameraPolygon://更新摄像机多变形
      initPolygons()
   case protomsg.TableChanged_T_TimeRule://更新时间规则
      initTimeRules()
   case protomsg.TableChanged_T_CameraTask://更新摄像机规则配置参数
      initCameraTaskRules()
   case protomsg.TableChanged_T_CameraTaskArgs://更新摄像机规则配置参数
      initCameraTaskRules()
   default:
@@ -126,22 +133,22 @@
   }
}

func GetServerInfo() *protomsg.LocalConfig {
func GetServerInfo() (con protomsg.LocalConfig,err error) {
   config, b := cMap.Get(SERVER_KEY)
   if b {
      return config.(*protomsg.LocalConfig)
      return config.(protomsg.LocalConfig),nil
   } else {
      return nil
      return con,errors.New("conf not found")
   }
}

//通过cameraId获取摄像机信息
func GetCameraById(cameraId string) *protomsg.Camera {
func GetCameraById(cameraId string) (c protomsg.Camera,err error) {
   cam, b := cMap.Get(PREFIX_CAMERA + cameraId)
   if b {
      return cam.(*protomsg.Camera)
      return cam.(protomsg.Camera),nil
   } else {
      return nil
      return c,errors.New("camera not found")
   }
}