追踪

panlei

2019-07-27 2554f829d3b66b65bb323dfccd7e287d2226b2d9

 ruleserver/personTrack.go

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

type PersonTrack struct {
   Face  int // 人脸的id数组  改为数量
   FaceN int // 添加容错，初始值为5，连续5次不对才算不对
   Yolo  int // yolo对象的id数组 改为数量
   YoloN int // 添加容错，初始值为5，连续5次不对才算不对
   Face int // 人脸的id数组  改为数量
   Yolo int // yolo对象的id数组 改为数量
}

// 检查是否前后两次的数据id是否完全相同（人脸和yolo）     改为直接检查数量是否一致
@@ -28,35 +26,34 @@
               logger.Info("解析face sdk数据时出现错误", err)
               continue
            }
            logger.Info("================追踪之前人脸的个数：", len(faceParam.Faces))
            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)
               }
               TrackPond[msg.Cid].FaceN = 2
               logger.Info("===================追踪中途人脸的个数", len(faceParam.Faces))
            } else {
               if TrackPond[msg.Cid] != nil {
                  if TrackPond[msg.Cid].FaceN > 0 {
                     TrackPond[msg.Cid].FaceN--
                     faceParam.Faces = (faceParam.Faces)[0:0]
                     sdkinfo.Sdkdata, err = proto.Marshal(&faceParam)
                     if err != nil {
                        logger.Error("人脸序列化错误", err)
                     }
                     logger.Info("此时容错值为：",TrackPond[msg.Cid].FaceN)
                  }
                  if TrackPond[msg.Cid].FaceN == 0 { //此时连续五次不对
                     TrackPond[msg.Cid].Face = len(faceParam.Faces)
                     TrackPond[msg.Cid].FaceN = 2
                  }
                  logger.Info("更新当前摄像机缓存池中的人脸个数：", len(faceParam.Faces))
                  TrackPond[msg.Cid].Face = len(faceParam.Faces)
               } else {
                  TrackPond[msg.Cid] = &PersonTrack{Face: len(faceParam.Faces),FaceN:2}
                  logger.Info("新建当前摄像机缓存池中的人脸个数：", len(faceParam.Faces))
                  TrackPond[msg.Cid] = &PersonTrack{Face: len(faceParam.Faces)}
               }
            }
         } else {
            if TrackPond[msg.Cid] != nil {
               TrackPond[msg.Cid].Face = 0
            } else {
               TrackPond[msg.Cid] = &PersonTrack{Face: 0}
            }
            logger.Info("没有人脸，被重置为0")
            continue
         }
      }
@@ -74,35 +71,34 @@
                  yoloNum++
               }
            }
            logger.Info("================追踪之前yolo的个数：", yoloNum)
            if TrackPond[msg.Cid] != nil {
               logger.Info("================追踪之前yolo的个数：", yoloNum, "现在缓存池中记录的个数：", TrackPond[msg.Cid].Yolo)
            } else {
               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)
               }
               TrackPond[msg.Cid].YoloN = 2
               logger.Info("跟之前相同，清空yolo数据")
            } else {
               if TrackPond[msg.Cid] != nil {
                  logger.Info("更新当前摄像机缓存池中的yolo个数：", yoloNum)
                  TrackPond[msg.Cid].Yolo = yoloNum
                  if TrackPond[msg.Cid].YoloN > 0 {
                     TrackPond[msg.Cid].YoloN--
                     yoloParam.Infos = (yoloParam.Infos)[0:0]
                     sdkinfo.Sdkdata, err = proto.Marshal(&yoloParam)
                     if err != nil {
                        logger.Error("yolo序列化错误", err)
                     }
                     logger.Info("此时容错值为：",TrackPond[msg.Cid].YoloN)
                  }
                  if TrackPond[msg.Cid].YoloN == 0 { //此时连续五次不对
                     TrackPond[msg.Cid].Yolo = yoloNum
                     TrackPond[msg.Cid].YoloN = 2
                  }
               } else {
                  TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum,YoloN:2}
                  logger.Info("新建当前摄像机缓存池中的yolo个数：", yoloNum)
                  TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum}
               }
            }
         } else {
            if TrackPond[msg.Cid] != nil {
               TrackPond[msg.Cid].Yolo = 0
            } else {
               TrackPond[msg.Cid] = &PersonTrack{Yolo: 0}
            }
            logger.Info("没有yolo，被重置为0")
            continue
         }
      }