---

panlei

2019-11-19 d4f2636c1773edd8f16ca34598e2e1f9d603ee5f

 insertdata/insertDataToEs.go

@@ -112,33 +112,6 @@
   Y float64 `json:"y"`
}

//  yolo行为的数据结构
//type Personaction struct {
//   Id              string      `json:"id"`
//   CameraId        string      `json:"cameraId"`
//   CameraName      string      `json:"cameraName"`
//   CameraAddr      string      `json:"cameraAddr"`
//   TaskId          string      `json:"taskId"`
//   TaskName        string      `json:"taskName"`
//   SdkName         string      `json:"sdkName"`
//   Content         string      `json:"content"`
//   AlarmRules      []AlarmRule `json:"alarmRules"`
//   AnalyServerId   string      `json:"analyServerId"`
//   AnalyServerName string      `json:"analyServerName"`
//   AnalyServerIp   string      `json:"analyServerIp"`
//   ClusterId       string      `json:"clusterId"`
//   PicSmUrl        []string    `json:"picSmUrl"`
//   PicDate         string      `json:"picDate"`
//   VideoUrl        string      `json:"videoUrl"`
//   IsAlarm         int         `json:"isAlarm"`
//   IsAckAlarm      int         `json:"isAckAlarm"`
//   IsCollect       int         `json:"isCollect"`
//   IsDelete        int         `json:"isDelete"`
//   TargetInfo      []Target    `json:"targetInfo"`
//   LinkTag         string      `json:"linkTag"`
//   LinkTagInfo     []*LinkInfo `json:"linkTagInfo"`
//}

type AlarmRule struct {
   GroupId      string `json:"groupId"`
   AlarmLevel   string `json:"alarmLevel"`
@@ -154,11 +127,11 @@
}

func InsertToEs(msg structure.ResultMsg) {
   //defer func() {
   //   if err := recover(); err != nil {
   //      logger.Error("es模块儿的异常捕获：", err)
   //   }
   //}()
   defer func() {
      if err := recover(); err != nil {
         logger.Error("es模块儿的异常捕获：", err)
      }
   }()
   localConfig1, err := cache.GetServerInfo()
   if err != nil {
      panic("配置文件不合法")