| | |
|---|
| | | logger.Error("查询摄像机信息失败") |
|---|
| | | } |
|---|
| | | serverIp, err := GetLocalIP() |
|---|
| | | if resp["fileUrl"] != nil { |
|---|
| | | url = append(url, resp["fileUrl"].(string)) |
|---|
| | | esDataId := uuid.NewV4().String() |
|---|
| | | linksId := "" |
|---|
| | | if linkId != "" { |
|---|
| | | linksId = linkId |
|---|
| | | } |
|---|
| | | peraction := Personaction{ |
|---|
| | | esDataId, |
|---|
| | | msg.Cid, |
|---|
| | | camera.Name, |
|---|
| | | camera.Addr, |
|---|
| | | msg.Tasklab.Taskid, |
|---|
| | | msg.Tasklab.Taskname, |
|---|
| | | sdkNames, |
|---|
| | | "", |
|---|
| | | alarmRules, |
|---|
| | | localConfig.ServerId, |
|---|
| | | localConfig.ServerName, |
|---|
| | | serverIp, |
|---|
| | | "", |
|---|
| | | url, |
|---|
| | | i.Timestamp, |
|---|
| | | linksId, |
|---|
| | | "", |
|---|
| | | isAlarm, |
|---|
| | | 0, |
|---|
| | | 0, |
|---|
| | | 0, |
|---|
| | | } |
|---|
| | | requstbody, err := json.Marshal(peraction) |
|---|
| | | |
|---|
| | | url = append(url, resp["fileUrl"].(string)) |
|---|
| | | esDataId := uuid.NewV4().String() |
|---|
| | | linksId := "" |
|---|
| | | if linkId != "" { |
|---|
| | | linksId = linkId |
|---|
| | | } |
|---|
| | | peraction := Personaction{ |
|---|
| | | esDataId, |
|---|
| | | msg.Cid, |
|---|
| | | camera.Name, |
|---|
| | | camera.Addr, |
|---|
| | | msg.Tasklab.Taskid, |
|---|
| | | msg.Tasklab.Taskname, |
|---|
| | | sdkNames, |
|---|
| | | "", |
|---|
| | | alarmRules, |
|---|
| | | localConfig.ServerId, |
|---|
| | | localConfig.ServerName, |
|---|
| | | serverIp, |
|---|
| | | "", |
|---|
| | | url, |
|---|
| | | i.Timestamp, |
|---|
| | | linksId, |
|---|
| | | "", |
|---|
| | | isAlarm, |
|---|
| | | 0, |
|---|
| | | 0, |
|---|
| | | 0, |
|---|
| | | } |
|---|
| | | requstbody, err := json.Marshal(peraction) |
|---|
| | | if err != nil { |
|---|
| | | logger.Info("json parse error ", err) |
|---|
| | | return |
|---|
| | | |
|---|
| | | if err != nil { |
|---|
| | | logger.Info("json parse error ", err) |
|---|
| | | return |
|---|
| | | |
|---|
| | | } |
|---|
| | | resp1, err2 := EsReq("POST", personAction, requstbody) |
|---|
| | | if err2 != nil { |
|---|
| | | logger.Error("往ES插入数据失败", err) |
|---|
| | | } else { |
|---|
| | | logger.Debug("插入es返回的数据信息是：", resp1) |
|---|
| | | // 发出录像信号 |
|---|
| | | 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) |
|---|
| | | } |
|---|
| | | resp1, err2 := EsReq("POST", personAction, requstbody) |
|---|
| | | if err2 != nil { |
|---|
| | | logger.Error("往ES插入数据失败", err) |
|---|
| | | } else { |
|---|
| | | logger.Debug("插入es返回的数据信息是：", resp1) |
|---|
| | | // 发出录像信号 |
|---|
| | | 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) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | logger.Debug("timeLabel条件都不符合！") |
|---|
