From 59ec1051feb6cbff1e4b2937939213f8620a4f14 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期六, 13 七月 2019 16:54:30 +0800
Subject: [PATCH] 定时器位置变更
---
insertdata/insertDataToEs.go | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index c2e4fee..51ed49c 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -6,6 +6,7 @@
"fmt"
"io/ioutil"
"net"
+ "os"
"ruleprocess/cache"
"ruleprocess/logger"
"strings"
@@ -114,9 +115,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 +276,7 @@
if err1 != nil {
logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
}
+ InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}
// 寰�es涓彃鍏olo鏁版嵁
@@ -360,6 +361,9 @@
logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
//os.Exit(1)
}
+ logger.Debug("============鐬呯瀰缂撳瓨鏁版嵁锛�",msg.RuleResult["cacheData"].(ruleserver.ResultMsg).RuleResult)
+ InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
+ os.Exit(1)
}
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {
--
Gitblit v1.8.0