panlei
2019-07-31 81c415b1cfccc2db3dfd437d2da24f11b255fabe
insertdata/insertDataToEs.go
@@ -7,6 +7,7 @@
   "fmt"
   "io/ioutil"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "strings"
@@ -111,27 +112,34 @@
}
// 往ES插数据
//func InsertToEs(msg ruleserver.ResultMsg) {
//   var timeLabel string
//   // 直接从规则的标签数据里拿符合规则的人脸结果
//   if msg.RuleResult["timeLabel"] != nil {
//      timeLabel = msg.RuleResult["timeLabel"].(string)
//   }
//   logger.Debug("插入数据前看看报警标志位:", timeLabel)
//   if timeLabel == "01" { // 无定时器状态要插入的报警数据
//      InsertFace(msg)
//      flag := ruleserver.BodyIsSame(msg.SdkMessage)
//      if !flag {
//         InsertYolo(msg)
//      }
//   }
//   if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
//      InsertFace(msg)
//      InsertYolo(msg)
//   }
//   //if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
//   //   //ChangeStatusFace(msg)
//   //   ChangeStatusYolo(msg)
//   //}
//}
func InsertToEs(msg ruleserver.ResultMsg) {
   var timeLabel string
   // 直接从规则的标签数据里拿符合规则的人脸结果
   if msg.RuleResult["timeLabel"] != nil {
      timeLabel = msg.RuleResult["timeLabel"].(string)
   }
   logger.Debug("插入数据前看看报警标志位:", timeLabel)
   if timeLabel == "01" { // 无定时器状态要插入的报警数据
      InsertFace(msg)
      flag := ruleserver.BodyIsSame(msg.SdkMessage)
      if !flag {
   //flag := ruleserver.BodyIsSame(msg.SdkMessage)
   //if !flag {
         InsertYolo(msg)
      }
   }
   if timeLabel == "10" { // 定时器状态要插入的首帧报警数据。连带着定时器开启时的那帧
      InsertFace(msg)
      InsertYolo(msg)
   }
   //if timeLabel == "12" { // 并非报警数据,只是状态改变的数据
   //   //ChangeStatusFace(msg)
   //   ChangeStatusYolo(msg)
   //}
}
@@ -366,6 +374,7 @@
         }
         if linkFlag {
            // 联动数据中包含本帧数据,插入联动数据后就不需要插入本帧数据了
            os.Exit(1)
            return
         }
         isAlarm := 0