---

panlei

2019-07-09 eb4dcf58beb8d42580f1e371591dcddb3e433da9

 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)
}

// 人脸的数据结构
@@ -106,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) {
@@ -193,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 {
            // 人脸提取