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("++++++++++++++++++++++++++++追踪开始++++++++++++++++++++++++") 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 len(faceParam.Faces) == TrackPond[msg.Cid].Yolo { // yolo的如果数量相同则视为不变、把yolo的sdkData清空 faceParam.Faces = (faceParam.Faces)[0:0] } else { TrackPond[msg.Cid].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 } logger.Info("================追踪之前yolo的个数:",len(yoloParam.Infos)) if len(yoloParam.Infos) == TrackPond[msg.Cid].Yolo { // yolo的如果数量相同则视为不变、把yolo的sdkData清空 yoloParam.Infos = (yoloParam.Infos)[0:0] } else { TrackPond[msg.Cid].Yolo = len(yoloParam.Infos) } } 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 //}