---

panlei

2019-06-25 b1ecb4a88237e2e2b6550f3b729760b9a694994d

 insertdata/insertDataToEs.go

@@ -2,7 +2,6 @@

import (
   "errors"
   "fmt"
   "encoding/json"
   "log"
   "net"
@@ -93,7 +92,7 @@
}
// 往ES插数据
func InsertToEs(msg ruleserver.ResultMsg) {
   fmt.Println("往ES插数据")
   log.Println("往ES插数据")

   for _, sdkinfo := range msg.Tasklab.Sdkinfos {
      if sdkinfo.Sdktype == "FaceDetect" {
@@ -102,7 +101,7 @@
            faceParam := protomsg.ParamFacePos{}
            err1 := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
            if err1 != nil {
               fmt.Println("解析FACE sdk有误", err1)
               log.Println("解析FACE sdk有误", err1)
               continue
            }
            for _, face := range faceParam.Faces {
@@ -151,13 +150,13 @@
               requstbody, err := json.Marshal(pervideo)

               if err != nil {
                  fmt.Println("json parse error ", err)
                  log.Println("json parse error ", err)
                  return

               }
               err = EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
               if err != nil {
                  fmt.Println("es can not execute right.")
                  log.Println("es can not execute right.")
               }
            }
         } else {
@@ -170,7 +169,7 @@
            yoloObj := protomsg.ParamYoloObj{}
            err1 := proto.Unmarshal(sdkinfo.Sdkdata, &yoloObj)
            if err1 != nil {
               fmt.Println("解析YOLO sdk有误", err1)
               log.Println("解析YOLO sdk有误", err1)
               //continue
            }
            alarmRules := []AlarmRule{}
@@ -189,6 +188,7 @@
               i := protomsg.Image{}
               err = proto.Unmarshal(bdata, &i)
               resp,err = util.PostFormBufferData(weedfsUrl,i.Data,uuid.NewV4().String())
               log.Println("已报警并上传改帧图片到服务器")
            }else {
               isAlarm = "0"
               //continue
@@ -197,12 +197,12 @@
            // 查询本机信息
            flag,localConfig := dbapi.SysSetApi{}.GetServerInfo()
            if !flag {
               fmt.Println("查询本机信息失败！")
               log.Println("查询本机信息失败！")
            }
            // 查询cameraName
            camera,err := dbapi.CameraApi{}.GetCameraById(msg.Cid)
            if err == nil {
               fmt.Println("查询摄像机信息失败")
               log.Println("查询摄像机信息失败")
            }
            serverIp,err := GetLocalIP()
            peraction := Personaction{
@@ -230,13 +230,13 @@
            requstbody, err := json.Marshal(peraction)

            if err != nil {
               fmt.Println("json parse error ", err)
               log.Println("json parse error ", err)
               return

            }
            err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
            if err != nil {
               fmt.Println("es can not execute right.")
               log.Println("es can not execute right.")
            }
         } else {
            continue