追踪

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("---------------------------------------追踪结束--------------------------------------")