追踪

panlei

2019-07-27 bb215e57c6a8ae527820697b59cec900d4d3fdfe

 ruleserver/personTrack.go

@@ -19,76 +19,80 @@
   logger.Debug("---------------------缓存池--------------------------：", TrackPond)
   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)
         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)}
               }
            }
         } else {
            TrackPond[msg.Cid].Face = 0
            logger.Info("没有人脸，被重置为0")
            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)}
            }
         }
         //} 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)
         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++
               }
            }
            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)
               }
               logger.Info("跟之前相同，清空yolo数据")
            } else {
               if TrackPond[msg.Cid] != nil {
                  logger.Info("更新当前摄像机缓存池中的yolo个数：", yoloNum)
                  TrackPond[msg.Cid].Yolo = yoloNum
               } else {
                  logger.Info("新建当前摄像机缓存池中的yolo个数：", yoloNum)
                  TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum}
               }
            }
         } else {
            TrackPond[msg.Cid].Yolo = 0
            logger.Info("没有yolo，被重置为0")
            continue
         }
         var yoloNum int = 0
         for i := 0; i < len(yoloParam.Infos); i++ {
            if yoloParam.Infos[i].Typ == 0 {
               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)
            }
            logger.Info("跟之前相同，清空yolo数据")
         } else {
            if TrackPond[msg.Cid] != nil {
               logger.Info("更新当前摄像机缓存池中的yolo个数：", yoloNum)
               TrackPond[msg.Cid].Yolo = yoloNum
            } else {
               logger.Info("新建当前摄像机缓存池中的yolo个数：", yoloNum)
               TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum}
            }
         }
         //} else {
         //   continue
         //}
      }
   }
   logger.Debug("---------------------------------------追踪结束--------------------------------------")