fix _id to id

liuxiaolong

2019-07-26 cf1ca37ff975c1b4119be485ad3fd5c1de019ded

fix _id to id

 insertdata/insertDataToEs.go

@@ -177,9 +177,9 @@
                }
                race := getRaceString(face.ThftRes.Race)
                ageDescription := getDescription(face.ThftRes.Age)

                esDataId := uuid.NewV4().String()
                pervideo := PerVideoPicture{
                    uuid.NewV4().String(),
                    esDataId,
                    msg.Cid,
                    camera.Addr,
                    i.Timestamp,
@@ -222,7 +222,7 @@
                } else {
                    logger.Info("插入es返回的信息：", resp1)
                    // 发出录像信号
                    ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1})
                    ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1})
                }
            }
        }
@@ -253,8 +253,9 @@
        logger.Error("查询摄像机信息失败")
    }

    esDataId := uuid.NewV4().String()
    pervideo := PerVideoPicture{
        uuid.NewV4().String(),
        esDataId,
        msg.Cid,
        camera.Addr,
        i.Timestamp,
@@ -298,7 +299,7 @@
    } else {
        logger.Info("插入es返回的信息：", resp1)
        // 发出录像信号
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1 })
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:1 })
    }
    //if msg.RuleResult["cacheData"] != nil {
    //    InsertFace(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
@@ -372,8 +373,9 @@
            }
            url = append(url, strings.Split(resp1["fileUrl"].(string), "/")[1])
        }
        esDataId := uuid.NewV4().String()
        peraction := Personaction{
            uuid.NewV4().String(),
            esDataId,
            msg.Cid,
            camera.Name,
            camera.Addr,
@@ -407,7 +409,7 @@
        } else {
            logger.Debug("插入es返回的数据信息是：", resp1)
            // 发出录像信号
            ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
            ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
            logger.Warn("__________________________________________往ES插入yolo数据成功")
            //os.Exit(1)
        }
@@ -442,8 +444,9 @@
        logger.Error("查询摄像机信息失败")
    }
    serverIp, err := GetLocalIP()
    esDataId := uuid.NewV4().String()
    peraction := Personaction{
        uuid.NewV4().String(),
        esDataId,
        msg.Cid,
        camera.Name,
        camera.Addr,
@@ -477,7 +480,7 @@
    } else {
        logger.Info("插入es返回的信息：", resp1)
        // 发出录像信号
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: esDataId, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}, Type:2 })
        logger.Warn("__________________________________________往ES插入yolo数据成功")
        //os.Exit(1)
    }