派生自 ruleprocess
insertdata/insertDataToEs.go
@@ -20,24 +20,18 @@ ) var weedfsUrl string type conf struct { PhotoUrl string PhotoUrl string `yaml:"photoUrl"` } func init() { logger.Info("_________________________________________老子想看你执行了没") fmt.Println("_________________________________________老子想看你执行了没") data, err := ioutil.ReadFile("./config/conf.yml") if err != nil { fmt.Println("读取配置文件出错--",err) logger.Error("读取配置文件出错--",err) } fmt.Println("从配置文件中读取的值为：",string(data)) c := conf{} //把yaml形式的字符串解析成struct类型 yaml.Unmarshal(data, &c) fmt.Println("c.PhotoUrl的值为：",c.PhotoUrl) weedfsUrl = c.PhotoUrl fmt.Println("weedfsUrl的值为：",weedfsUrl) logger.Info("weedfsUrl的值为：",weedfsUrl) } // 人脸的数据结构 @@ -65,6 +59,7 @@ AnalyServerName string `json:"analyServerName"` AnalyServerIp string `json:"analyServerIp"` ClusterId string `json:"clusterId"` DetectScore float64 `json:"detectScore"` IsAlarm int `json:"isAlarm"` IsAckAlarm int `json:"isAckAlarm"` IsCollect int `json:"isCollect"` @@ -106,7 +101,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) { @@ -180,6 +175,7 @@ localConfig.ServerName, serverIp, "", face.Score, 1, 0, 0, @@ -193,10 +189,13 @@ 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 { // 人脸提取 // 人脸比对 localConfig, err := cache.GetServerInfo() if err != nil { logger.Info("查询本机信息失败！") @@ -253,6 +252,7 @@ localConfig.ServerName, serverIp, "", face.Score, 1, 0, 0,
