liuxiaolong
2019-07-01 bc17494992d76fda1ff2a609549ab1d301d3c3b4
cache/cache.go
@@ -20,8 +20,8 @@
func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){
   urlSurvey := dbIp + strconv.Itoa(surveyPort)
   urlPubSub := dbIp + strconv.Itoa(pubSubPort)
   urlSurvey := "tcp://" + dbIp + strconv.Itoa(surveyPort)
   urlPubSub := "tcp://" + dbIp + strconv.Itoa(pubSubPort)
   client, _ := gopherdiscovery.ClientWithSub(urlSurvey, urlPubSub, uuid.NewV4().String())
   recvMsg := client.HeartBeatMsg()
   fmt.Println(<-recvMsg)
@@ -70,14 +70,16 @@
   var api dbapi.CameraApi
   data := api.FindAllPolygons()
   for _, item := range data {
      cameraId :=item.CameraId
      arr, b := cMap.Get(PREFIX_POLYGON + cameraId)
      if b {
         list := arr.([]protomsg.CameraPolygon)
         list = append(list,item)
         cMap.Set(PREFIX_POLYGON + cameraId,list)
      } else {
         cMap.Set(PREFIX_POLYGON + cameraId,[]protomsg.CameraPolygon{ item })
      if item.Type != "line" {
         cameraId :=item.CameraId
         arr, b := cMap.Get(PREFIX_POLYGON + cameraId)
         if b {
            list := arr.([]protomsg.CameraPolygon)
            list = append(list,item)
            cMap.Set(PREFIX_POLYGON + cameraId,list)
         } else {
            cMap.Set(PREFIX_POLYGON + cameraId,[]protomsg.CameraPolygon{ item })
         }
      }
   }
}