放开事件推送

panlei

2019-11-06 a45e6bb260a1091c9db6b028119b2d9cda9870a4

 insertdata/insertDataToEs.go

@@ -249,7 +249,7 @@
               face.ThftRes.Beauty,
               base64.StdEncoding.EncodeToString(face.Feature),
               []string{resp["fileUrl"].(string)},
               "暂无集群",
               msg.Push.VideoUrl,
               msg.Push.ServerId,
               msg.Push.ServerName,
               msg.Push.LocalIp,
@@ -467,7 +467,7 @@
               url,
               i.Timestamp,
               linksId,
               "",
               msg.Push.VideoUrl,
               isAlarm,
               0,
               0,
@@ -487,6 +487,7 @@
            } else {
               logger.Debug("插入es返回的数据信息是：", resp1)
               // 发出录像信号
               logger.Info("给录像的视频地址：",msg.Push.VideoUrl)
               ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid,VideoUrl:msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{}, Type: 2})
               logger.Warn("__________________________________________往ES插入yolo数据成功")
               //os.Exit(1)