异常处理

panlei

2019-09-19 04c61912ae829434122291f3706536fddbde42a0

异常处理

 insertdata/insertDataToEs.go

@@ -135,6 +135,11 @@
//    //}
//}
func InsertToEs(msg ruleserver.ResultMsg) {
    defer func() {
        if err := recover(); err != nil {
            logger.Error("es模块儿的异常捕获：",err)
        }
    }()
    InsertFace(msg, "")
    // 如果标签中含有持续时间首次报警的timeLabel的话则不需要过人体追踪，不然就没的插入了
    fk := ruleserver.TrackOrNot(msg.RuleResult)

 main.go

@@ -49,11 +49,6 @@
}
func main() {
    //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕
    defer func() {
        if err := recover(); err != nil {
            logger.Error("最外层的异常捕捉",err.(string))
        }
    }()
    go func() {
        http.ListenAndServe("0.0.0.0:8899",nil)
    }()
@@ -132,7 +127,7 @@
func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage {
    defer func() {
        if err := recover(); err != nil {
            logger.Info("解包过程的错误", err.(string))
            logger.Info("解包过程的异常捕获", err.(string))
        }

    }()

 ruleserver/ruleToformula.go

@@ -116,6 +116,11 @@

// 对单帧图像的判断 thisSdkDatas  当前传入的这帧数据，cacheSdkData 定时器里缓存的一帧数据 没有就返回nil  (thisSdkDatas SdkDatas, cacheSdkDatas SdkDatas)
func Judge(args *SdkDatas, message *protomsg.SdkMessage) {
    defer func() {
        if err := recover(); err != nil {
            logger.Error("规则模块儿的异常捕获：",err)
        }
    }()
    if len(args.Sdkdata) > 0 {
        // 拿到本摄像机的区域
        cameraPolygons := GetPolygons(args.CameraId)