From eb4dcf58beb8d42580f1e371591dcddb3e433da9 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 09 七月 2019 13:51:28 +0800
Subject: [PATCH] ---

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

diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go
index 354b682..9a54e1c 100644
--- a/insertdata/insertDataToEs.go
+++ b/insertdata/insertDataToEs.go
@@ -1,13 +1,13 @@
 package insertdata
 
 import (
+	"ruleprocess/logger"
 	"encoding/json"
 	"errors"
 	"fmt"
 	"io/ioutil"
 	"net"
 	"ruleprocess/cache"
-	"ruleprocess/logger"
 	"strings"
 	"time"
 
@@ -20,18 +20,18 @@
 )
 var weedfsUrl string
 type conf struct {
-	PhotoUrl string
+	PhotoUrl string `yaml:"photoUrl"`
 }
 func init() {
-	logger.Info("_________________________________________鑰佸瓙鎯崇湅浣犳墽琛屼簡娌�")
-	fmt.Println("_________________________________________鑰佸瓙鎯崇湅浣犳墽琛屼簡娌�")
-	data, _ := ioutil.ReadFile("conf.yml")
+	data, err := ioutil.ReadFile("./config/conf.yml")
+	if err != nil {
+		fmt.Println("璇诲彇閰嶇疆鏂囦欢鍑洪敊--",err)
+		logger.Error("璇诲彇閰嶇疆鏂囦欢鍑洪敊--",err)
+	}
 	c := conf{}
 	//鎶妝aml褰㈠紡鐨勫瓧绗︿覆瑙f瀽鎴恠truct绫诲瀷
 	yaml.Unmarshal(data, &c)
 	weedfsUrl = c.PhotoUrl
-	fmt.Println("weedfsUrl鐨勫�间负锛�",weedfsUrl)
-	logger.Info("weedfsUrl鐨勫�间负锛�",weedfsUrl)
 }
 
 // 浜鸿劯鐨勬暟鎹粨鏋�
@@ -100,7 +100,7 @@
 func InsertToEs(msg ruleserver.ResultMsg) {
 
 	// 鐩存帴浠庤鍒欑殑鏍囩鏁版嵁閲屾嬁绗﹀悎瑙勫垯鐨勪汉鑴哥粨鏋�
-	logger.Info("------------------------------------浠庨厤缃枃浠惰鍙栫殑鍊硷細",weedfsUrl)
+	//logger.Info("------------------------------------浠庨厤缃枃浠惰鍙栫殑鍊硷細",weedfsUrl)
 	if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.Arg)) > 0 {
 		logger.Info("寰�ES鎻掍汉鑴告暟鎹�")
 		for _, face := range msg.RuleResult["face"].([]ruleserver.Arg) {
@@ -187,7 +187,10 @@
 					return
 
 				}
-				err = EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
+				err1 := EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
+				if err1 != nil {
+					logger.Error("涓婁紶ES鍑洪敊锛�---",err1)
+				}
 				//logger.Info(err.Error())
 			} else {
 				// 浜鸿劯鎻愬彇

--
Gitblit v1.8.0