panlei
2019-09-16 0abfd0126dcb316f24da5c207bdf38fc729ac907
insertdata/insertDataToEs.go
@@ -29,7 +29,7 @@
   DbTablePersons string `yaml:"dbTablePersons"`
}
func init() {
func InitInsertEs() {
   weedfsUrl = "http://"+WeedFs.Ip+":"+strconv.Itoa(WeedFs.UploadPort)+"/submit"
   videoPersonUrl = "http://"+EsInfo.Masterip+":"+EsInfo.Httpport+"/"+EsInfo.EsIndex.VideoPersons.IndexName+"/"+EsInfo.EsIndex.VideoPersons.IndexType
   personAction = "http://"+EsInfo.Masterip+":"+EsInfo.Httpport+"/"+EsInfo.EsIndex.Personaction.IndexName+"/"+EsInfo.EsIndex.Personaction.IndexType
@@ -356,11 +356,13 @@
                     } else {
                        logger.Info("上传的图片信息:", resp1)
                     }
                     if resp1["fileUrl"] != nil {
                     url = append(url, resp1["fileUrl"].(string))
                  }
               }
            }
         }
         }
         linkFlag := false
         for _, yoloResult := range msg.RuleResult["yolo"].([]ruleserver.Result) {
            if (yoloResult.Others.TimeLabel == "01" || yoloResult.Others.TimeLabel == "10") && yoloResult.Others.LinkCache != nil && len(yoloResult.Others.LinkCache) > 1 {