es数据

panlei

2019-11-18 d0c072e7e8714a9503e256f505ac7d5d157e9832

 insertdata/insertDataToEs.go

@@ -56,10 +56,10 @@
   AnalyServerName string                `json:"analyServerName"`
   AnalyServerIp   string                `json:"analyServerIp"`
   ClusterId       string                `json:"clusterId"`
   IsAlarm         int                   `json:"isAlarm"`
   IsAckAlarm      int                   `json:"isAckAlarm"`
   IsCollect       int                   `json:"isCollect"`
   IsDelete        int                   `json:"isDelete"`
   IsAlarm         bool                  `json:"isAlarm"`
   IsAckAlarm      bool                  `json:"isAckAlarm"`
   IsCollect       bool                  `json:"isCollect"`
   IsDelete        bool                  `json:"isDelete"`
   BaseInfo        []*structure.BaseInfo `json:"baseInfo"`
   TargetInfo      []Target              `json:"targetInfo"`
   LinkTag         string                `json:"linkTag"`
@@ -86,10 +86,10 @@
   AnalyServerName string                `json:"analyServerName"`
   AnalyServerIp   string                `json:"analyServerIp"`
   ClusterId       string                `json:"clusterId"`
   IsAlarm         int                   `json:"isAlarm"`
   IsAckAlarm      int                   `json:"isAckAlarm"`
   IsCollect       int                   `json:"isCollect"`
   IsDelete        int                   `json:"isDelete"`
   IsAlarm         bool                  `json:"isAlarm"`
   IsAckAlarm      bool                  `json:"isAckAlarm"`
   IsCollect       bool                  `json:"isCollect"`
   IsDelete        bool                  `json:"isDelete"`
   BaseInfo        []*structure.BaseInfo `json:"baseInfo"`
   TargetInfo      []Target              `json:"targetInfo"`
}
@@ -240,10 +240,10 @@
                     msg.Push.ServerName,
                     msg.Push.LocalIp,
                     "",
                     1,
                     0,
                     0,
                     0,
                     true,
                     false,
                     false,
                     false,
                     face.Liker,
                     targetInfos,
                     "",
@@ -400,7 +400,7 @@
         if len(linkTagInfos) > 0 {
            linkTag = "联动任务"
         }
         isAlarm := 0
         isAlarm := false
         resp := make(map[string]interface{})
         // 解压缩并上传图片
         bdata, err := util.UnCompress(msg.Data)
@@ -410,7 +410,7 @@
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         if len(alarmRules) > 0 {
            isAlarm = 1
            isAlarm = true
            //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
            resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
            if err != nil {
@@ -420,7 +420,7 @@
               logger.Info("上传的图片信息：", resp)
            }
         } else {
            isAlarm = 0
            isAlarm = false
            // 不是报警数据不存
            return
         }
@@ -448,9 +448,9 @@
               msg.Push.LocalIp,
               "",
               isAlarm,
               0,
               0,
               0,
               false,
               false,
               false,
               nil,
               targetInfos,
               linkTag,
@@ -539,7 +539,7 @@
            if len(linkTagInfos) > 0 {
               linkTag = "联动任务"
            }
            isAlarm := 0
            isAlarm := false
            resp := make(map[string]interface{})
            // 解压缩并上传本帧数据图片
            bdata1, err := util.UnCompress(msg.Data)
@@ -549,7 +549,7 @@
            i := protomsg.Image{}
            err = proto.Unmarshal(bdata1, &i)
            if len(alarmRules) > 0 {
               isAlarm = 1
               isAlarm = true
               //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
               resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["target"].([]structure.Result), weedfsUrl)
               if err != nil {
@@ -559,7 +559,7 @@
                  logger.Info("上传的图片信息：", resp)
               }
            } else {
               isAlarm = 0
               isAlarm = false
               // 不是报警数据不存
               return
            }
@@ -609,9 +609,9 @@
                  msg.Push.LocalIp,
                  "",
                  isAlarm,
                  0,
                  0,
                  0,
                  false,
                  false,
                  false,
                  nil,
                  nil,
                  linkTag,
@@ -848,7 +848,7 @@
               }
            }
         }
         isAlarm := 0
         isAlarm := false
         resp := make(map[string]interface{})
         // 解压缩并上传图片
         bdata, err := util.UnCompress(msg.Data)
@@ -858,7 +858,7 @@
         i := protomsg.Image{}
         err = proto.Unmarshal(bdata, &i)
         if len(alarmRules) > 0 {
            isAlarm = 1
            isAlarm = true
            //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
            resp, err = util.DrawPolygonOnImageForYolo(msg.Cid, i, msg.RuleResult["yolo"].([]structure.Result), weedfsUrl)
            if err != nil {
@@ -868,7 +868,7 @@
               logger.Info("上传的图片信息：", resp)
            }
         } else {
            isAlarm = 0
            isAlarm = false
            // 不是报警数据不存
            return nil
         }
@@ -896,9 +896,9 @@
               msg.Push.LocalIp,
               "",
               isAlarm,
               0,
               0,
               0,
               false,
               false,
               false,
               nil,
               targetInfos,
            }