panlei
2019-07-03 033f6617f74471a8178c4375f2034504ba3de421
insertdata/insertDataToEs.go
@@ -43,9 +43,9 @@
   AnalyServerName string   `json:"analyServerName"`
   AnalyServerIp   string   `json:"analyServerIp"`
   ClusterId       string   `json:"clusterId"`
   IsAlarm         string   `json:"isAlarm"`
   IsAckAlarm      string   `json:"isAckAlarm"`
   IsCollect       string   `json:"isCollect"`
   IsAlarm         int      `json:"isAlarm"`
   IsAckAlarm      int      `json:"isAckAlarm"`
   IsCollect       int      `json:"isCollect"`
   IsDelete        int      `json:"isDelete"`
   BaseInfo        []Base   `json:"baseInfo"`
}
@@ -82,9 +82,9 @@
   PicSmUrl        []string    `json:"picSmUrl"`
   PicDate         string      `json:"picDate"`
   VideoUrl        string      `json:"videoUrl"`
   IsAlarm         string      `json:"isAlarm"`
   IsAckAlarm      string      `json:"isAckAlarm"`
   IsCollect       string      `json:"isCollect"`
   IsAlarm         int         `json:"isAlarm"`
   IsAckAlarm      int         `json:"isAckAlarm"`
   IsCollect       int         `json:"isCollect"`
   IsDelete        int         `json:"isDelete"`
}
@@ -170,9 +170,9 @@
               localConfig.ServerName,
               serverIp,
               "",
               "",
               "",
               "",
               1,
               0,
               0,
               0,
               []Base{},
            }
@@ -199,10 +199,10 @@
         alarm := ChangeToString(yoloResult.AlarmLevel)
         alarmRules = append(alarmRules, AlarmRule{yoloResult.RuleGroupId, alarm, yoloResult.RuleText})
      }
      isAlarm := ""
      isAlarm := 0
      resp := make(map[string]interface{})
      if len(alarmRules) > 0 {
         isAlarm = "1"
         isAlarm = 1
         // 解压缩并上传图片
         bdata, err := util.UnCompress(msg.Data)
         if err != nil {
@@ -218,7 +218,7 @@
            log.Println("已报警并上传改帧图片到服务器")
         }
      } else {
         isAlarm = "0"
         isAlarm = 0
         // 不是报警数据不存
         return
      }
@@ -252,8 +252,8 @@
         time.Now().Format("2006-01-02 15:04:05"),
         "",
         isAlarm,
         "",
         "",
         0,
         0,
         0,
      }
      requstbody, err := json.Marshal(peraction)
@@ -267,7 +267,7 @@
      if err != nil {
         log.Println("往ES插入数据失败", err)
      } else {
         log.Println("__________________________________________往ES插入数据yolo成功")
         log.Println("__________________________________________往ES插入yolo数据成功")
      }
   }
}