追踪添加容错

panlei

2019-07-23 5433ad847a4eb284658dc7543fa3d94680e5e5bd

追踪添加容错

 insertdata/insertDataToEs.go

@@ -214,6 +214,7 @@
                logger.Error("上传ES出错！---", err1)
            } else {
                logger.Info("插入es返回的信息：", resp1)
                // 发出录像信号
                ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
            }
        }
@@ -287,6 +288,7 @@
        logger.Error("上传ES出错！---", err1)
    } else {
        logger.Info("插入es返回的信息：", resp1)
        // 发出录像信号
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
    }
    //if msg.RuleResult["cacheData"] != nil {
@@ -340,6 +342,11 @@
            logger.Error("查询摄像机信息失败")
        }
        serverIp, err := GetLocalIP()
        if msg.RuleResult["cacheData"] != nil {
            InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
            // 把缓存的数据上传后得到地址存进去
			
        }
        peraction := Personaction{
            uuid.NewV4().String(),
            msg.Cid,
@@ -378,9 +385,6 @@
            ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
            logger.Warn("__________________________________________往ES插入yolo数据成功")
            //os.Exit(1)
        }
        if msg.RuleResult["cacheData"] != nil {
            InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg))
        }
    }
}
@@ -447,6 +451,7 @@
        logger.Error("往ES插入数据失败", err)
    } else {
        logger.Info("插入es返回的信息：", resp1)
        // 发出录像信号
        ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: resp1["_id"].(string), CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, ImgId: i.Id, SdkIds: []string{}})
        logger.Warn("__________________________________________往ES插入yolo数据成功")
        //os.Exit(1)

 ruleserver/personTrack.go

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

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

// 检查是否前后两次的数据id是否完全相同（人脸和yolo）     改为直接检查数量是否一致
func IsSame(msg *protomsg.SdkMessage) {
    logger.Debug("+++++++++++++++++++++追踪开始+++++++++++++++摄像机id为：",msg.Cid)
    logger.Debug("---------------------缓存池--------------------------：",TrackPond)
    logger.Debug("+++++++++++++++++++++追踪开始+++++++++++++++摄像机id为：", msg.Cid)
    logger.Debug("---------------------缓存池--------------------------：", TrackPond)
    for _, sdkinfo := range msg.Tasklab.Sdkinfos { // 遍历各算法的sdkData
        if sdkinfo.Sdktype == "FaceDetect" { // 人脸检测
            if len(sdkinfo.Sdkdata) > 1 {
@@ -26,19 +28,25 @@
                    logger.Info("解析face sdk数据时出现错误", err)
                    continue
                }
                logger.Info("================追踪之前人脸的个数：",len(faceParam.Faces))
                if faceParam.Faces != nil && TrackPond[msg.Cid] != nil  && len(faceParam.Faces) == TrackPond[msg.Cid].Face { // yolo的如果数量相同则视为不变、把yolo的sdkData清空
                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)
                    sdkinfo.Sdkdata, err = proto.Marshal(&faceParam)
                    if err != nil {
                        logger.Error("人脸序列化错误",err)
                        logger.Error("人脸序列化错误", err)
                    }
                    logger.Info("===================追踪中途人脸的个数",len(faceParam.Faces))
                    logger.Info("===================追踪中途人脸的个数", len(faceParam.Faces))
                } else {
                    if TrackPond[msg.Cid] != nil {
                        TrackPond[msg.Cid].Face = len(faceParam.Faces)
                     } else {
                        TrackPond[msg.Cid] = &PersonTrack{Face:len(faceParam.Faces)}
                        if TrackPond[msg.Cid].FaceN > 0 {
                            TrackPond[msg.Cid].FaceN--
                        }
                        if TrackPond[msg.Cid].FaceN == 0 { //此时连续五次不对
                            TrackPond[msg.Cid].Face = len(faceParam.Faces)
                            TrackPond[msg.Cid].FaceN = 5
                        }
                    } else {
                        TrackPond[msg.Cid] = &PersonTrack{Face: len(faceParam.Faces),FaceN:5}
                    }
                }
                //for i := 0;  i < len(faceParam.Faces); {
@@ -61,23 +69,30 @@
                    continue
                }
                var yoloNum int = 0
                for i := 0;i < len(yoloParam.Infos); i++ {
                for i := 0; i < len(yoloParam.Infos); i++ {
                    if yoloParam.Infos[i].Typ == 0 {
                        yoloNum++
                    }
                }
                logger.Info("================追踪之前yolo的个数：",yoloNum)
                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)
                    sdkinfo.Sdkdata, err = proto.Marshal(&yoloParam)
                    if err != nil {
                        logger.Error("yolo序列化错误",err)
                        logger.Error("yolo序列化错误", err)
                    }
                } else {
                    if TrackPond[msg.Cid] != nil {
                        TrackPond[msg.Cid].Yolo = yoloNum
                        if TrackPond[msg.Cid].YoloN > 0 {
                            TrackPond[msg.Cid].YoloN--
                        }
                        if TrackPond[msg.Cid].YoloN == 0 { //此时连续五次不对
                            TrackPond[msg.Cid].Yolo = yoloNum
                            TrackPond[msg.Cid].YoloN = 5
                        }
                    } else {
                        TrackPond[msg.Cid] = &PersonTrack{Yolo:yoloNum}
                        TrackPond[msg.Cid] = &PersonTrack{Yolo: yoloNum,YoloN:5}
                    }
                }
            } else {
@@ -87,6 +102,7 @@
    }
    logger.Debug("---------------------------------------追踪结束--------------------------------------")
}

//// 判断一个人脸id在不在追踪池中
//func FaceIsInPond(cameraId string,face *protomsg.ResultFaceDetect) bool{
//    if TrackPond[cameraId].Face > 0 {
@@ -111,4 +127,4 @@
//        return false
//    }
//    return false
//}
//}

 ruleserver/ruleToformula.go

@@ -89,6 +89,12 @@
    Location     []Rect // 目标的坐标
    AlarmPolygon string // 触发的报警框
}

// 过规则库打上的标签
type FaceResult struct {
    Result
    Args         []*Arg
}
type LittleRuleResult struct {
    SdkName string // 记录下此结果是哪个sdk的结果
    Result  string // 已包含了前置连接符