From 7af9bc6b2a6a5beffccb19205afd263da1853f45 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期六, 22 六月 2019 18:09:14 +0800
Subject: [PATCH] ---
---
insertdata/insertDataToEs.go | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index d41ff73..082e6b3 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -86,7 +86,7 @@
type AlarmRule struct {
GroupId string `json:"groupId"`
- AlarmLevel string `json:"alarmLevel"`
+ AlarmLevel int32 `json:"alarmLevel"`
RuleText string `json:"ruleText"`
}
@@ -98,7 +98,7 @@
faceParam := protomsg.ParamFacePos{}
err1 := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
if err1 != nil {
- fmt.Println("瑙ｆ瀽sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err1)
+ fmt.Println("瑙ｆ瀽FACE sdk鏈夎", err1)
continue
}
for _, face := range faceParam.Faces {
@@ -161,8 +161,8 @@
yoloObj := protomsg.ParamYoloObj{}
err1 := proto.Unmarshal(sdkinfo.Sdkdata, &yoloObj)
if err1 != nil {
- fmt.Println("瑙ｆ瀽sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err1)
- continue
+ fmt.Println("瑙ｆ瀽YOLO sdk鏈夎", err1)
+ //continue
}
alarmRules := []AlarmRule{}
for _,result := range msg.RuleResult {
@@ -173,6 +173,7 @@
isAlarm = "1"
}else {
isAlarm = "0"
+ continue
}
// 鏌ヨ鏈満淇℃伅
flag,localConfig := dbapi.SysSetApi{}.GetServerInfo()
@@ -214,7 +215,7 @@
return
}
- err = EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
+ err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
if err != nil {
fmt.Println("es can not execute right.")
}
--
Gitblit v1.8.0