| | |
| | | logger.Info("往ES插人脸数据") |
| | | faces := []*FaceAndRules{} |
| | | faces = PutFace(faces,msg) |
| | | logger.Info("整理后的数据:",faces) |
| | | //logger.Info("整理后的数据:",faces) |
| | | if faces != nil { |
| | | for _,face := range faces { |
| | | // 上传大图 |
| | |
| | | // 归置人脸 |
| | | func PutFace(faces []*FaceAndRules,msg ruleserver.ResultMsg)[]*FaceAndRules{ |
| | | if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.FaceResult)) > 0 { |
| | | logger.Info("整理人脸数据") |
| | | for _, faceResult := range msg.RuleResult["face"].([]ruleserver.FaceResult) { |
| | | faces = hebingFace(faces, faceResult) |
| | | } |
| | |
| | | // 拿到每一张人脸 |
| | | flag := false |
| | | for _, face := range faces { |
| | | logger.Info("归置人脸时相似者的数量:",len(face.Liker)) |
| | | for _,lik := range face.Liker { |
| | | logger.Warn("--------合并人脸时相似者:",lik.PersonId,lik.TableName) |
| | | } |
| | | if arg.Id == face.Id { |
| | | flag = true |
| | | face.rules = append(face.rules,faceResult.Result) |
| | |
| | | faces = append(faces, &FaceAndRules{arg, []ruleserver.Result{faceResult.Result}}) |
| | | } |
| | | } |
| | | logger.Info("整理中的数据",faces) |
| | | return faces |
| | | } |
| | | |