日志设置变动

panlei

2019-08-06 e132fa8aa92c23ae299c480366dd0a9be99a01e3

 insertdata/insertDataToEs.go

@@ -7,7 +7,6 @@
   "fmt"
   "io/ioutil"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "strings"
@@ -166,7 +165,7 @@
   if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.FaceResult)) > 0 {
      logger.Info("往ES插人脸数据")
      faces := []*FaceAndRules{}
      PutFace(faces,msg)
      faces = PutFace(faces,msg)
      logger.Info("整理后的数据：",faces)
      if faces != nil {
         for _,face := range faces {
@@ -178,7 +177,7 @@
            }
            alarmRules := []AlarmRule{}
            logger.Warn("人脸id为：",face.Id,"人脸的规则长度为：",len(face.rules))
            os.Exit(1)
            //os.Exit(1)
            for _,faceResult := range face.rules {
               alarm := ChangeToString(faceResult.DefenceState, faceResult.AlarmLevel)
               alarmRules = append(alarmRules, AlarmRule{faceResult.RuleGroupId, alarm, faceResult.RuleText, faceResult.DefenceState})
@@ -271,15 +270,18 @@
}

// 归置人脸
func PutFace(faces []*FaceAndRules,msg ruleserver.ResultMsg){
func PutFace(faces []*FaceAndRules,msg ruleserver.ResultMsg)[]*FaceAndRules{
   if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.FaceResult)) > 0 {
      logger.Info("整理人脸数据")
      for _, faceResult := range msg.RuleResult["face"].([]ruleserver.FaceResult) {
         hebingFace(faces, faceResult)
         faces = hebingFace(faces, faceResult)
      }
      return faces
   } else {
      return nil
   }
}
func hebingFace(faces []*FaceAndRules, faceResult ruleserver.FaceResult){
func hebingFace(faces []*FaceAndRules, faceResult ruleserver.FaceResult) []*FaceAndRules{
   for _, arg := range faceResult.Args {
      // 拿到每一张人脸
      flag := false
@@ -294,6 +296,7 @@
      }
   }
   logger.Info("整理中的数据",faces)
   return faces
}

// 往es中插入yolo数据