From 3a454e86f28c0e5a50332c2d3760598d36d800da Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期一, 09 十二月 2019 17:43:54 +0800 Subject: [PATCH] es模块儿做成so --- cache/cache.go | 42 +++++++++++++++++++++++++++++++++++++----- 1 files changed, 37 insertions(+), 5 deletions(-) diff --git a/cache/cache.go b/cache/cache.go index 0b8d280..9f4381d 100644 --- a/cache/cache.go +++ b/cache/cache.go @@ -50,7 +50,9 @@ initTimeRules() //鍒濆鍖栨椂闂磋鍒欑紦瀛� - initCameraTaskRules() //鍒濆鍖栨憚鍍忔満浠诲姟瑙勫垯缂撳瓨 + initCameraTaskRules() //鍒濆鍖栨憚鍍忔満浠诲姟瑙勫垯缂撳瓨鎸夋憚鍍忔満 + + initCameraTaskRulesAll() // 鍒濆鍖栨憚鍍忔満浠诲姟瑙勫垯缂撳瓨鍏ㄩ儴 initCamera() //鍒濆鍖栨憚鍍忔満淇℃伅 @@ -85,6 +87,7 @@ initCameraTaskRules() case protomsg.TableChanged_T_CameraTaskArgs: //鏇存柊鎽勫儚鏈鸿鍒欓厤缃弬鏁� initCameraTaskRules() + initCameraTaskRulesAll() case protomsg.TableChanged_T_Sdk: //鏇存柊sdk閰嶇疆 initSdks() default: @@ -127,6 +130,16 @@ cMap.Set(PREFIX_POLYGON+k, v) } } +// 缂撳瓨鍖哄煙骞朵笉鏍规嵁id +func initPolygonsById() { + var api dbapi.CameraApi + data := api.FindAllPolygons() + for _, item := range data { + if item.Type != "line" { + cMap.Set(PREFIX_POLYGON+item.Id, item) + } + } +} func initTimeRules() { var api dbapi.CameraApi @@ -147,13 +160,11 @@ if err := json.Unmarshal(b, &dicss); err == nil { for key, dics1 := range dicss { for _, dic := range dics1 { - logger.Debug("瀛楀吀缂撳瓨鍒濆鍖�", PREFIX_DIC + key + dic.Value, dic) cMap.Set(PREFIX_DIC + key + dic.Value, dic) } } } } - logger.Info("鍙栧瓧鍏哥紦瀛橈細", GetDic(PREFIX_DIC + "nCarColor2")) } func initCameraTaskRules() { @@ -165,6 +176,11 @@ } } +func initCameraTaskRulesAll() { + var api dbapi.CameraTaskArgsApi + all := api.FindAll() + cMap.Set(PREFIX_RULE, all) +} func initSdks() { var api dbapi.SdkApi sdks := api.FindAll("") @@ -201,6 +217,15 @@ } } +func GetPolygonsById(id string) *protomsg.CameraPolygon { + obj, b := cMap.Get(PREFIX_POLYGON + id) + if b { + return obj.(*protomsg.CameraPolygon) + } else { + return nil + } +} + //浠庣紦瀛樹腑鑾峰彇鏃堕棿瑙勫垯 func GetTimeRuleById(id string) (exist bool, rule protomsg.CameraTimerule) { obj, b := cMap.Get(PREFIX_TIME + id) @@ -220,6 +245,15 @@ return nil } } +//鏍规嵁鎽勫儚鏈篿d浠庣紦瀛樹腑鑾峰彇鎽勫儚鏈虹殑浠诲姟瑙勫垯璁剧疆 +func GetCameraTaskRulesAll() []*protomsg.TaskGroupArgs { + obj, b := cMap.Get(PREFIX_RULE) + if b { + return obj.([]*protomsg.TaskGroupArgs) + } else { + return nil + } +} func GetSdkById(sdkId string) (sdk protomsg.Sdk, err error) { obj, b := cMap.Get(PREFIX_SDK + sdkId) @@ -232,9 +266,7 @@ // 鑾峰彇瀛楀吀鍊� func GetDic(key string) (name string) { - logger.Info("瀛楀吀鍊糼ey:",PREFIX_DIC + key) obj, b := cMap.Get(PREFIX_DIC + key) - logger.Info("鍙栧瓧鍏稿�硷細",obj.(Dic)) if b { return obj.(Dic).Name } else { -- Gitblit v1.8.0