panlei
2019-07-13 72b2b494d5d69b64f4b094f21bc8ac7837b8d9e6
insertdata/insertDataToEs.go
@@ -114,9 +114,8 @@
   }
   if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
      InsertFace(msg)
      InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      InsertYolo(msg)
      InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
   }
   if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
      ChangeStatusFace(msg)
@@ -276,6 +275,7 @@
      if err1 != nil {
         logger.Error("上传ES出错!---", err1)
      }
      InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}
// 往es中插入yolo数据
@@ -360,6 +360,8 @@
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
      logger.Debug("============瞅瞅缓存数据:",msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
   }
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {