From 560fa457a17105975ce9017ec069cf9bc3066671 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 30 七月 2019 16:50:58 +0800
Subject: [PATCH] 追201人脸数据

---
 insertdata/insertDataToEs.go |   20 +++++++++++---------
 1 files changed, 11 insertions(+), 9 deletions(-)

diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index a4bddd7..9b1e92f 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -120,17 +120,19 @@
 	logger.Debug("鎻掑叆鏁版嵁鍓嶇湅鐪嬫姤璀︽爣蹇椾綅锛�", timeLabel)
 	if timeLabel == "01" { // 鏃犲畾鏃跺櫒鐘舵�佽鎻掑叆鐨勬姤璀︽暟鎹�
 		InsertFace(msg)
-		InsertYolo(msg)
+		flag := ruleserver.BodyIsSame(msg.SdkMessage)
+		if !flag {
+			InsertYolo(msg)
+		}
 	}
 	if timeLabel == "10" { // 瀹氭椂鍣ㄧ姸鎬佽鎻掑叆鐨勯甯ф姤璀︽暟鎹�傝繛甯︾潃瀹氭椂鍣ㄥ紑鍚椂鐨勯偅甯�
 		InsertFace(msg)
 		InsertYolo(msg)
-
 	}
-	if timeLabel == "12" { // 骞堕潪鎶ヨ鏁版嵁锛屽彧鏄姸鎬佹敼鍙樼殑鏁版嵁
-		//ChangeStatusFace(msg)
-		ChangeStatusYolo(msg)
-	}
+	//if timeLabel == "12" { // 骞堕潪鎶ヨ鏁版嵁锛屽彧鏄姸鎬佹敼鍙樼殑鏁版嵁
+	//	//ChangeStatusFace(msg)
+	//	ChangeStatusYolo(msg)
+	//}
 }
 
 // 寰�es涓彃鍏ヤ汉鑴告暟鎹�
@@ -354,9 +356,8 @@
 		}
 		serverIp, err := GetLocalIP()
 		url := []string{}
-		url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1])
 		if msg.RuleResult["cacheData"] != nil {
-			InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
+			//InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
 			// 鎶婄紦瀛樼殑鏁版嵁涓婁紶鍚庡緱鍒板湴鍧�瀛樿繘鍘�
 			// 瑙e帇缂╁苟涓婁紶鍥剧墖
 			msg1 := msg.RuleResult["cacheData"].(ruleserver.ResultMsg)
@@ -366,7 +367,7 @@
 			}
 			i := protomsg.Image{}
 			err = proto.Unmarshal(bdata, &i)
-			resp1, err1 := util.DrawPolygonOnImage(msg.Cid, i, msg.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
+			resp1, err1 := util.DrawPolygonOnImage(msg1.Cid, i, msg1.RuleResult["yolo"].([]ruleserver.Result), weedfsUrl)
 			if err1 != nil {
 				logger.Error("缂撳瓨鏁版嵁鐢绘鎴栦笂浼犲浘鐗囨湇鍔″櫒鍑洪敊", err)
 			} else {
@@ -374,6 +375,7 @@
 			}
 			url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
 		}
+		url = append(url, strings.Split(resp["fileUrl"].(string), "/")[1])
 		esDataId := uuid.NewV4().String()
 		peraction := Personaction{
 			esDataId,

--
Gitblit v1.8.0