panlei
2019-11-18 d0c072e7e8714a9503e256f505ac7d5d157e9832
es数据
1个文件已修改
60 ■■■■ 已修改文件
insertdata/insertDataToEs.go 60 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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,
                }