package ruleserver
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"github.com/golang/protobuf/proto"
|
"ruleprocess/logger"
|
)
|
|
var TrackPond = make(map[string]*PersonTrack)
|
|
type PersonTrack struct {
|
Face int // 人脸的id数组 改为数量
|
Yolo int // yolo对象的id数组 改为数量
|
}
|
|
func (pt *PersonTrack) Set(msg protomsg.SdkMessage) {
|
|
}
|
|
// 检查是否前后两次的数据id是否完全相同（人脸和yolo）
|
func IsSame(msg *protomsg.SdkMessage) {
|
logger.Debug("++++++++++++++++++++++++++++追踪开始+++++++++++++++++++++摄像机id为：",msg.Cid)
|
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
|
}
|
logger.Info("================追踪之前人脸的个数：",len(faceParam.Faces))
|
if faceParam.Faces != nil && TrackPond[msg.Cid] != nil && len(faceParam.Faces) == TrackPond[msg.Cid].Yolo { // 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 {
|
TrackPond[msg.Cid] = &PersonTrack{Face:len(faceParam.Faces)}
|
}
|
//for i := 0; i < len(faceParam.Faces); {
|
// if flag := IsInPond(msg.Cid,faceParam.Faces[i]);flag { // 已经存在，从msg的人脸数组中删除这个元素，不必传到下一个环节
|
// faceParam.Faces = append(faceParam.Faces[:i], faceParam.Faces[i+1:]...)
|
// } else {
|
// i++
|
// }
|
//}
|
} else {
|
continue
|
}
|
}
|
if sdkinfo.Sdktype == "Yolo" {
|
if len(sdkinfo.Sdkdata) > 1 {
|
yoloParam := protomsg.ParamYoloObj{}
|
err := proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam)
|
if err != nil {
|
logger.Info("解析yolo数据时出现错误", err)
|
continue
|
}
|
var yoloNum int = 0
|
for i := 0;i < len(yoloParam.Infos); i++ {
|
if yoloParam.Infos[i].Typ == 0 {
|
yoloNum++
|
}
|
}
|
logger.Info("================追踪之前yolo的个数：",yoloNum)
|
if yoloParam.Infos != nil && TrackPond[msg.Cid] != nil && yoloNum == TrackPond[msg.Cid].Yolo { // yolo的如果数量相同则视为不变、把yolo的sdkData清空
|
yoloParam.Infos = (yoloParam.Infos)[0:0]
|
sdkinfo.Sdkdata,err = proto.Marshal(&yoloParam)
|
if err != nil {
|
logger.Error("yolo序列化错误",err)
|
}
|
} else {
|
TrackPond[msg.Cid] = &PersonTrack{Yolo:yoloNum}
|
}
|
} else {
|
continue
|
}
|
}
|
}
|
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
|
//}
|
