追加数据

panlei

2019-12-16 1b14a0ec217e5b6816f9f6b3254106be0db61fad

追加数据

 algorithm/middleware/insertDataToEs.go

@@ -193,6 +193,52 @@
                }
                //logger.Info("人脸目标target:",targetInfos)


                if key == "track" && len(face.Liker) == 1{
                    pervideo1 := LinkInfo{
                        id,
                        msg.Cid,
                        msg.Push.Cam.Addr,
                        msg.Push.Cam.Name,
                        picTime,
                        imgMaxUrl,
                        msg.Tasklab.Taskid,
                        msg.Tasklab.Taskname,
                        sdkname,
                        "",
                        alarmRules,
                        time.Now().Format("2006-01-02 15:04:05"), // 只检测，没有比对时间
                        lable,
                        lableAttach,
                        "",
                        msg.Push.ServerId,
                        msg.Push.ServerName,
                        msg.Push.LocalIp,
                        "",
                        true,
                        false,
                        false,
                        false,
                        face.Liker,
                        targetInfos,
                    }
                    requstbody, err := json.Marshal(pervideo1)

                    if err != nil {
                        logger.Info("json parse error ", err)
                        return
                    }
                    esid := face.Liker[0].TargetId
                    logger.Info("liker信息：",*face.Liker[0])
                    returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),structure.EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
                    if err1 != nil {
                        logger.Error("追加数据出错！---", err1)
                    } else {
                        logger.Info("插入es返回的信息：", returnMsg)
                        // 发出录像信号
                        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: face.Uuid, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{"-1"}, Type: 1})
                    }
                } else {
                pervideo := PerVideoPicture{LinkInfo{
                    id,
                    msg.Cid,
@@ -229,18 +275,6 @@
                    logger.Info("json parse error ", err)
                    return
                }
                if key == "track" && len(face.Liker) == 1{
                    esid := face.Liker[0].TargetId
                    logger.Info("liker信息：",*face.Liker[0])
                    returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),structure.EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
                    if err1 != nil {
                        logger.Error("追加数据出错！---", err1)
                    } else {
                        logger.Info("插入es返回的信息：", returnMsg)
                        // 发出录像信号
                        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: face.Uuid, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{"-1"}, Type: 1})
                    }
                } else {
                    resp1, err1 := insertdata.EsReq("POST", videoPersonUrl, requstbody)
                    if err1 != nil {
                        logger.Error("上传ES出错！---", err1)