| | |
| | | faces = PutFace(faces, results.([]structure.Result)) |
| | | //logger.Info("整理后的数据:",faces) |
| | | if faces != nil { |
| | | logger.Warn("face不为nil") |
| | | logger.Warn("目标不为nil") |
| | | var imgMaxUrl []string = []string{} |
| | | var picTime string = "" |
| | | for _, face := range faces { |
| | |
| | | } |
| | | 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) |
| | |
| | | trackArg["cameraId"] = am.CameraId |
| | | trackArg["bodyFeature"] = arg.Feature |
| | | trackArg["faceFeature"] = arg.AttachArg.Feature |
| | | logger.Info("请求张增飞比对数据参数:",trackArg) |
| | | b,err := json.Marshal(trackArg) |
| | | if err != nil { |
| | | logger.Error("json序列化错误", err) |
| | |
| | | case data := <- sender: |
| | | trackMap := make(map[string]interface{}) |
| | | _ = json.Unmarshal(data, &trackMap) |
| | | logger.Info("推送数据:",trackMap) |
| | | logger.Info("请求张增飞比对数据参数:",trackMap) |
| | | if err = sock.Send(data); err != nil { |
| | | logger.Error("推送socket发送数据失败: %s", err.Error()) |
| | | } |