更新人脸追踪

panlei

2019-07-27 d7675e60a5d6056b898e7bc567c898fd6f8bfc0b

更新人脸追踪

 ruleserver/personTrack.go

@@ -9,8 +9,12 @@
var TrackPond = make(map[string]*PersonTrack)

type PersonTrack struct {
    Face int // 人脸的id数组  改为数量
    Yolo int // yolo对象的id数组 改为数量
    Faces []*Face // 人脸的数组  改为数量
    Yolo int     // yolo对象的id数组 改为数量
}
type Face struct {
    Id    uint64
    Score float32
}

// 检查是否前后两次的数据id是否完全相同（人脸和yolo）     改为直接检查数量是否一致
@@ -20,40 +24,14 @@
    for _, sdkinfo := range msg.Tasklab.Sdkinfos { // 遍历各算法的sdkData
        if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测
            if len(sdkinfo.Sdkdata) > 1 {
                faceParam := protomsg.ParamFacePos{}
                err := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
                if err != nil {
                    logger.Info("解析face sdk数据时出现错误", err)
                    continue
                }
                if TrackPond[msg.Cid] != nil {
                    logger.Info("================追踪之前人脸的个数：", len(faceParam.Faces), "现在缓存池中记录的个数：", TrackPond[msg.Cid].Face)
                } else {
                    logger.Info("================追踪之前人脸的个数：", len(faceParam.Faces), "还没有这个摄像机的缓存")
                }
                if faceParam.Faces != nil && TrackPond[msg.Cid] != nil && len(faceParam.Faces) == TrackPond[msg.Cid].Face { // yolo的如果数量相同则视为不变、把yolo的sdkData清空
                    faceParam.Faces = (faceParam.Faces)[0:0]
                    sdkinfo.Sdkdata, err = proto.Marshal(&faceParam)
                    if err != nil {
                        logger.Error("人脸序列化错误", err)
                    }
                    logger.Info("===================追踪中途人脸的个数", len(faceParam.Faces))
                } else {
                    if TrackPond[msg.Cid] != nil {
                        logger.Info("更新当前摄像机缓存池中的人脸个数：", len(faceParam.Faces))
                        TrackPond[msg.Cid].Face = len(faceParam.Faces)
                    } else {
                        logger.Info("新建当前摄像机缓存池中的人脸个数：", len(faceParam.Faces))
                        TrackPond[msg.Cid] = &PersonTrack{Face: len(faceParam.Faces)}
                    }
                }
                FaceIsInPond(msg.Cid,sdkinfo)
            } else {
                if TrackPond[msg.Cid] != nil {
                    TrackPond[msg.Cid].Face = 0
                    TrackPond[msg.Cid].Faces = nil
                } else {
                    TrackPond[msg.Cid] = &PersonTrack{Face: 0}
                    TrackPond[msg.Cid] = &PersonTrack{Faces: nil}
                }
                logger.Info("摄像机:"+msg.Cid+"-没有人脸，被重置为0")
                logger.Info("摄像机:" + msg.Cid + "-没有人脸，被重置为空")
                continue
            }
        }
@@ -98,7 +76,7 @@
                } else {
                    TrackPond[msg.Cid] = &PersonTrack{Yolo: 0}
                }
                logger.Info("摄像机:"+msg.Cid+"-没有yolo，被重置为0")
                logger.Info("摄像机:" + msg.Cid + "-没有yolo，被重置为0")
                continue
            }
        }
@@ -106,28 +84,51 @@
    logger.Debug("---------------------------------------追踪结束--------------------------------------")
}

//// 判断一个人脸id在不在追踪池中
//func FaceIsInPond(cameraId string,face *protomsg.ResultFaceDetect) bool{
//    if TrackPond[cameraId].Face > 0 {
//        for key,val := range TrackPond  {
//            if key == cameraId {
//                faceFlag := false
//                for faceId := range val.Face  {
//                    if face.Pos.FaceID == uint64(faceId) { // 此人脸已在池子中，不需要它到下一个环节了
//                        faceFlag = true
//                        return true
//                    }
//                }
//                if !faceFlag { // 此人脸不在池子中
//                    val.Face = append(val.Face,face.Pos.FaceID)
//                    return false
//                }
//            }else {
//                return false
//            }
//        }
//    } else {
//        return false
//    }
//    return false
//}
// 过滤掉那些已在缓存中且分值更低的人脸，更新缓存（没有的加上，分值更新为更高的，多的删除）
func FaceIsInPond(cameraId string, sdkinfo *protomsg.SdkmsgWithTask) string {
    if len(TrackPond[cameraId].Faces) > 0 {
        faceParam := protomsg.ParamFacePos{}
        err := proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
        if err != nil {
            logger.Info("解析face sdk数据时出现错误", err)
        }
        var facesTemp = faceParam.Faces   // 先把数据转存一份，不然一会儿数据删减之后找不到原始数据，不能让缓存数据更新了
        for  i := 0 ;i < len(faceParam.Faces); {
            faceFlag := false
            for _, val := range TrackPond[cameraId].Faces {
                if faceParam.Faces[i].Pos.FaceID == val.Id && faceParam.Faces[i].Pos.FAngle.Confidence <=  val.Score{ // 在池子里并且分值更低，是要抛弃的数据
                    faceFlag = true
                    //return "true"
                    faceParam.Faces = append(faceParam.Faces[:i], faceParam.Faces[i+1:]...)
                    break
                }
                if faceParam.Faces[i].Pos.FaceID == val.Id && faceParam.Faces[i].Pos.FAngle.Confidence <=  val.Score{ // 在池子里并且分值更高，更新缓存
                    faceFlag = true
                    val.Score = faceParam.Faces[i].Pos.FAngle.Confidence
                }
            }
            if !faceFlag { // 此人脸不在池子中
                TrackPond[cameraId].Faces = append(TrackPond[cameraId].Faces, &Face{faceParam.Faces[i].Pos.FaceID,faceParam.Faces[i].Pos.FAngle.Confidence})
                i++
            }
        }
        // 反向循环 ，看那些缓存有而数据没有的
        for i := 0; i < len(TrackPond[cameraId].Faces); {
            flag := false
            for _,temp := range facesTemp {
                if TrackPond[cameraId].Faces[i].Id == temp.Pos.FaceID {
                    flag = true
                }
            }
            if flag {
                i++
            } else {
                // 此数据在缓存中但不在来的数据帧中，删除此数据更新缓存
                TrackPond[cameraId].Faces = append(TrackPond[cameraId].Faces[:i],TrackPond[cameraId].Faces[i+1:]...)
            }
        }
    } else {
        return "false"
    }
    return "false"
}