| | |
| | | logger.Debug("---------------------缓存池--------------------------:", TrackPond) |
| | | for _, sdkinfo := range msg.Tasklab.Sdkinfos { // 遍历各算法的sdkData |
| | | if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测 |
| | | logger.Info("数据长度为:",len(sdkinfo.Sdkdata)) |
| | | if len(sdkinfo.Sdkdata) > 1 { |
| | | FaceIsInPond(msg.Cid,sdkinfo) |
| | | } else { |
| | | if TrackPond[msg.Cid] != nil { |
| | | logger.Info("如果不为空:",TrackPond[msg.Cid]) |
| | | TrackPond[msg.Cid].Faces = nil |
| | | } else { |
| | | TrackPond[msg.Cid] = &PersonTrack{Faces: nil} |
| | | logger.Info("如果为空:",TrackPond[msg.Cid]) |
| | | } |
| | | logger.Info("摄像机:" + msg.Cid + "-没有人脸,被重置为空") |
| | | continue |
| | |
| | | } |
| | | |
| | | // 过滤掉那些已在缓存中且分值更低的人脸,更新缓存(没有的加上,分值更新为更高的,多的删除) |
| | | func FaceIsInPond(cameraId string, sdkinfo *protomsg.SdkmsgWithTask) string { |
| | | func FaceIsInPond(cameraId string, sdkinfor *protomsg.SdkmsgWithTask) string { |
| | | logger.Info("人脸个数为:",len(TrackPond[cameraId].Faces),"这个摄像机的缓存等于nil嘛?",TrackPond[cameraId] == nil) |
| | | if TrackPond[cameraId] != nil && len(TrackPond[cameraId].Faces) > 0 { |
| | | logger.Info("----马前炮:",TrackPond[cameraId],"=====",len(TrackPond[cameraId].Faces)) |
| | | faceParam := protomsg.ParamFacePos{} |
| | | err := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) |
| | | err := proto.Unmarshal(sdkinfor.Sdkdata, &faceParam) |
| | | if err != nil { |
| | | logger.Info("解析face sdk数据时出现错误", err) |
| | | } |
| | | if TrackPond[cameraId] != nil { |
| | | logger.Info("================追踪之前人脸的个数:", len(faceParam.Faces), "现在缓存池中记录的个数:", len(TrackPond[cameraId].Faces)) |
| | | } else { |
| | | logger.Info("================追踪之前人脸的个数:", len(faceParam.Faces), "还没有这个摄像机的缓存") |
| | | } |
| | | var facesTemp = faceParam.Faces // 先把数据转存一份,不然一会儿数据删减之后找不到原始数据,不能让缓存数据更新了 |
| | | for i := 0 ;i < len(faceParam.Faces); { |
| | |
| | | } |
| | | if faceParam.Faces[i].Pos.FaceID == val.Id && faceParam.Faces[i].Pos.FAngle.Confidence <= val.Score{ // 在池子里并且分值更高,更新缓存 |
| | | faceFlag = true |
| | | logger.Info("分值由",val.Score,"更新为:",faceParam.Faces[i].Pos.FAngle.Confidence) |
| | | val.Score = faceParam.Faces[i].Pos.FAngle.Confidence |
| | | } |
| | | } |