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 |   47 ++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 40 insertions(+), 7 deletions(-)

diff --git a/cache/cache.go b/cache/cache.go
index 5c1cb97..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,14 +160,11 @@
 		if err := json.Unmarshal(b, &dicss); err == nil {
 			for key, dics1 := range dicss {
 				for _, dic := range dics1 {
-					logger.Info("杞︾墝瀛楀吀锛�", dic.Value, dic.Name, dic.Sort)
-					logger.Debug("瀛楀吀缂撳瓨鍒濆鍖�", PREFIX_DIC+key+dic.Value, dic)
-					cMap.Set(PREFIX_DIC+key+dic.Value, dic)
+					cMap.Set(PREFIX_DIC + key + dic.Value, dic)
 				}
 			}
 		}
 	}
-	logger.Info("鍙栧瓧鍏哥紦瀛橈細", GetDic(PREFIX_DIC+"nCarColor1"))
 }
 
 func initCameraTaskRules() {
@@ -166,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("")
@@ -202,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)
@@ -221,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,10 +265,10 @@
 }
 
 // 鑾峰彇瀛楀吀鍊�
-func GetDic(key string) (value string) {
+func GetDic(key string) (name string) {
 	obj, b := cMap.Get(PREFIX_DIC + key)
 	if b {
-		return obj.(Dic).Value
+		return obj.(Dic).Name
 	} else {
 		return ""
 	}

--
Gitblit v1.8.0