| | |
| | | |
| | | import ( |
| | | "basic.com/pubsub/protomsg.git" |
| | | "ruleprocess/logger" |
| | | "github.com/golang/protobuf/proto" |
| | | "basic.com/valib/logger.git" |
| | | "ruleprocess/structure" |
| | | "sync" |
| | | ) |
| | |
| | | logger.Info("新建当前摄像机缓存池中的yolo个数:", yoloNum) |
| | | TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum} |
| | | } |
| | | logger.Debug("---------------------------------人体追踪结束--------------------------------------") |
| | | return false |
| | | } |
| | | } else { |
| | |
| | | logger.Debug("---------------------------------人体追踪结束--------------------------------------") |
| | | return false |
| | | } |
| | | |
| | | func TrackOrNot(label map[string]interface{}) bool { |
| | | if label["yolo"] != nil && len(label["yolo"].([]structure.Result)) > 0 { |
| | | for _, res := range label["yolo"].([]structure.Result) { |
| | |
| | | for _, face := range faceParam.Faces { |
| | | facesTemp = append(facesTemp, *face) // 先把数据转存一份,不然一会儿数据删减之后找不到原始数据,不能让缓存数据更新了 |
| | | } |
| | | |
| | | for i := 0; i < len(faceParam.Faces); { |
| | | faceFlag := false |
| | | for _, val := range TrackPond[cameraId].Faces { |
| | |
| | | } |
| | | } |
| | | logger.Info("反序列化重新装配之前人脸的个数:", len(faceParam.Faces)) |
| | | |
| | | logger.Info("临时存储的新来数据:") |
| | | for _, temp := range facesTemp { |
| | | logger.Info("临时存储的新来的的face数据:", temp.Pos.FaceID, temp.Pos.FAngle.Confidence) |