关掉yolo插入es

panlei

2019-07-10 45184ccbcb5f787f09b62b0ddf4308004a46d27a

 cache/cache.go

@@ -17,6 +17,7 @@
   PREFIX_TIME = "TIME_"
   PREFIX_RULE = "RULE_"
   SERVER_KEY = "SERVERINFO"
   PREFIX_SDK = "SDK_"
)

var cMap *shardmap.ShardMap
@@ -51,6 +52,8 @@

   initServerInfo()//初始化服务器配置信息

   initSdks() //初始化sdk列表信息

   initChan <- true
}

@@ -70,8 +73,12 @@
      initPolygons()
   case protomsg.TableChanged_T_TimeRule://更新时间规则
      initTimeRules()
   case protomsg.TableChanged_T_CameraTask://更新摄像机规则配置参数
      initCameraTaskRules()
   case protomsg.TableChanged_T_CameraTaskArgs://更新摄像机规则配置参数
      initCameraTaskRules()
   case protomsg.TableChanged_T_Sdk://更新sdk配置
      initSdks()
   default:
      fmt.Println("unknown operation")

@@ -131,6 +138,14 @@
   }
}

func initSdks(){
   var api dbapi.SdkApi
   sdks := api.FindAll("")
   for _,sdk :=range sdks {
      cMap.Set(PREFIX_SDK+sdk.Id,sdk)
   }
}

func GetServerInfo() (con protomsg.LocalConfig,err error) {
   config, b := cMap.Get(SERVER_KEY)
   if b {
@@ -177,4 +192,13 @@
   } else {
      return nil
   }
}

func GetSdkById(sdkId string) (sdk protomsg.Sdk,err error){
   obj,b :=cMap.Get(PREFIX_SDK + sdkId)
   if b {
      return obj.(protomsg.Sdk),nil
   } else {
      return sdk,errors.New("sdk not found")
   }
}