---

panlei

2019-08-02 8ba4b575f5d0059eabe62e88bdc37e4259a2e500

 insertdata/insertDataToEs.go

@@ -148,9 +148,11 @@
   // 如果标签中含有持续时间首次报警的timeLabel的话则不需要过人体追踪，不然就没的插入了
   fk := ruleserver.TrackOrNot(msg.RuleResult)
   if fk {
      logger.Warn("捕捉一个持续时间任务.....")
      InsertYolo(msg, "")
      os.Exit(1)
      //if msg.Cid == "61de081a-7ed9-4970-8432-41d642c35456" {
      //   logger.Warn("捕捉188摄像机的持续时间任务.....")
      //   os.Exit(1)
      //}
   } else {
      flag := ruleserver.BodyIsSame(msg.SdkMessage)
      if !flag {
@@ -173,7 +175,7 @@
               panic("解压缩图片时出现错误")
            }
            alarmRules := []AlarmRule{}
            logger.Warn("人脸的规则长度为：",len(face.rules))
            logger.Warn("人脸id为：",face.Id,"人脸的规则长度为：",len(face.rules))
            os.Exit(1)
            for _,faceResult := range face.rules {
               alarm := ChangeToString(faceResult.DefenceState, faceResult.AlarmLevel)
@@ -270,13 +272,15 @@
func PutFace(msg ruleserver.ResultMsg) []FaceAndRules{
   if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.FaceResult)) > 0 {
      logger.Info("整理人脸数据")
      os.Exit(1)
      faces := []FaceAndRules{}
      for _, faceResult := range msg.RuleResult["face"].([]ruleserver.FaceResult) {
         hebingFace(faces, faceResult)
      }
      return faces
   } else {
      return nil
   }
   return nil
}
func hebingFace(faces []FaceAndRules, faceResult ruleserver.FaceResult) {
   for _, arg := range faceResult.Args {