panlei
2019-07-09 41afac9d7f39ab0cf2591357a3b3df815f0f5299
insertdata/insertDataToEs.go
@@ -59,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"`
@@ -100,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) {
@@ -174,6 +175,7 @@
               localConfig.ServerName,
               serverIp,
               "",
               face.Score,
               1,
               0,
               0,
@@ -187,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("查询本机信息失败!")
@@ -247,6 +252,7 @@
               localConfig.ServerName,
               serverIp,
               "",
               face.Score,
               1,
               0,
               0,