From 72b2b494d5d69b64f4b094f21bc8ac7837b8d9e6 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期六, 13 七月 2019 15:36:08 +0800
Subject: [PATCH] 换个地儿插缓存数据
---
insertdata/insertDataToEs.go | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index c2e4fee..a444429 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -114,9 +114,8 @@
}
if timeLabel == "10" { // 瀹氭椂鍣ㄧ姸鎬佽鎻掑叆鐨勯甯ф姤璀︽暟鎹�傝繛甯︾潃瀹氭椂鍣ㄥ紑鍚椂鐨勯偅甯�
InsertFace(msg)
- InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
InsertYolo(msg)
- InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
+
}
if timeLabel == "12" { // 骞堕潪鎶ヨ鏁版嵁锛屽彧鏄姸鎬佹敼鍙樼殑鏁版嵁
ChangeStatusFace(msg)
@@ -276,6 +275,7 @@
if err1 != nil {
logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
}
+ InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}
// 寰�es涓彃鍏olo鏁版嵁
@@ -360,6 +360,8 @@
logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
//os.Exit(1)
}
+ logger.Debug("============鐬呯瀰缂撳瓨鏁版嵁锛�",msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
+ InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {
--
Gitblit v1.8.0