定时器位置变更

panlei

2019-07-13 59ec1051feb6cbff1e4b2937939213f8620a4f14

 insertdata/insertDataToEs.go

@@ -6,6 +6,7 @@
   "fmt"
   "io/ioutil"
   "net"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "strings"
@@ -114,9 +115,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 +276,7 @@
      if err1 != nil {
         logger.Error("上传ES出错！---", err1)
      }
      InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
}

// 往es中插入yolo数据
@@ -360,6 +361,9 @@
         logger.Warn("__________________________________________往ES插入yolo数据成功")
         //os.Exit(1)
      }
      logger.Debug("============瞅瞅缓存数据：",msg.RuleResult["cacheData"].(ruleserver.ResultMsg).RuleResult)
      InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
      os.Exit(1)
   }
}
func ChangeStatusYolo(msg ruleserver.ResultMsg) {