From 23c837bc4d5b4312c0bb5eb96260c90e887882ac Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期四, 07 十一月 2019 15:10:23 +0800
Subject: [PATCH] git add .
---
insertdata/insertDataToEs.go | 22 ++++++++++++----------
1 files changed, 12 insertions(+), 10 deletions(-)
diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index a77c422..a54a5c3 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -218,7 +218,7 @@
race := getRaceString(face.ThftRes.Race)
ageDescription := getDescription(face.ThftRes.Age)
logger.Info(ageDescription)
- esDataId := uuid.NewV4().String()
+ //esDataId := uuid.NewV4().String()
linksId := ""
if linkId != "" {
linksId = linkId
@@ -230,7 +230,7 @@
//logger.Info("浜鸿劯鐨刬d:",strconv.FormatUint(face.Id, 10))
logger.Info("%%%%%%%%%%%%%%%%%%%%%鐩爣淇℃伅锛�",*target)
pervideo := PerVideoPicture{
- esDataId,
+ msg.Push.PushId,
msg.Cid,
msg.Push.Cam.Addr,
picTime,
@@ -249,7 +249,7 @@
face.ThftRes.Beauty,
base64.StdEncoding.EncodeToString(face.Feature),
[]string{resp["fileUrl"].(string)},
- msg.Push.VideoUrl,
+ "",
msg.Push.ServerId,
msg.Push.ServerName,
msg.Push.LocalIp,
@@ -275,7 +275,7 @@
} else {
logger.Info("鎻掑叆es杩斿洖鐨勪俊鎭細", resp1)
// 鍙戝嚭褰曞儚淇″彿
- ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl:msg.Push.VideoUrl,ImgId: i.Id, SdkIds: []string{}, Type: 1})
+ ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl:msg.Push.VideoUrl,ImgId: i.Id, SdkIds: []string{}, Type: 1})
}
}
}
@@ -368,6 +368,10 @@
}
i := protomsg.Image{}
err = proto.Unmarshal(bdata, &i)
+ logger.Debug("鎸佺画鏃堕棿绗竴寮犵敾妗嗭細")
+ for _,res := range msg1.RuleResult["yolo"].([]structure.Result) {
+ logger.Debug("鎸佺画鏃堕棿绗竴寮犺鍒欙細",res)
+ }
resp1, err1 := util.DrawPolygonOnImageForYolo(msg1.Cid, i, msg1.RuleResult["yolo"].([]structure.Result), weedfsUrl)
if err1 != nil {
logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
@@ -445,13 +449,13 @@
if resp["fileUrl"] != nil {
url = append(url, resp["fileUrl"].(string))
- esDataId := uuid.NewV4().String()
+ //esDataId := uuid.NewV4().String()
linksId := ""
if linkId != "" {
linksId = linkId
}
peraction := Personaction{
- esDataId,
+ msg.Push.PushId,
msg.Cid,
msg.Push.Cam.Name,
msg.Push.Cam.Addr,
@@ -467,7 +471,7 @@
url,
i.Timestamp,
linksId,
- msg.Push.VideoUrl,
+ "",
isAlarm,
0,
0,
@@ -479,7 +483,6 @@
if err != nil {
logger.Info("json parse error ", err)
return
-
}
resp1, err2 := EsReq("POST", personAction, requstbody)
if err2 != nil {
@@ -487,8 +490,7 @@
} else {
logger.Debug("鎻掑叆es杩斿洖鐨勬暟鎹俊鎭槸锛�", resp1)
// 鍙戝嚭褰曞儚淇″彿
- logger.Info("缁欏綍鍍忕殑瑙嗛鍦板潃锛�",msg.Push.VideoUrl)
- ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid,VideoUrl:msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{}, Type: 2})
+ ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: msg.Push.PushId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid,VideoUrl:msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{}, Type: 2})
logger.Warn("__________________________________________寰�ES鎻掑叆yolo鏁版嵁鎴愬姛")
//os.Exit(1)
}
--
Gitblit v1.8.0