mian函数中加一个异常处理，插入es时大图只插入一次

panlei

2019-09-18 032150859e985bedfb5061320b3aed5984dda476

mian函数中加一个异常处理，插入es时大图只插入一次

 insertdata/insertDataToEs.go

@@ -160,6 +160,8 @@
        faces = PutFace(faces,msg)
        //logger.Info("整理后的数据：",faces)
        if faces != nil {
            var imgMaxUrl string = ""
            var picTime string = ""
            for _,face := range faces {
                // 上传大图
                // 解压缩并上传图片
@@ -174,11 +176,15 @@
                    alarm := ChangeToString(faceResult.DefenceState, faceResult.AlarmLevel)
                    alarmRules = append(alarmRules, AlarmRule{faceResult.RuleGroupId, alarm, faceResult.RuleText, faceResult.DefenceState,faceResult.IsLink,""})
                }
                i := protomsg.Image{}
                err = proto.Unmarshal(bdata, &i)
                bigPhotoUrl := make(map[string]interface{})
                bigPhotoUrl, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
                logger.Debug("========大图路径：", bigPhotoUrl)
                if imgMaxUrl == "" {
                    i := protomsg.Image{}
                    err = proto.Unmarshal(bdata, &i)
                    bigPhotoUrl := make(map[string]interface{})
                    bigPhotoUrl, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
                    logger.Debug("========大图路径：", bigPhotoUrl)
                    imgMaxUrl = bigPhotoUrl["fileUrl"].(string)
                    picTime = i.Timestamp
                }
                // 人脸检测，没有相似的底库人员
                localConfig, err := cache.GetServerInfo()
                if err != nil {
@@ -217,8 +223,8 @@
                    esDataId,
                    msg.Cid,
                    camera.Addr,
                    i.Timestamp,
                    bigPhotoUrl["fileUrl"].(string),
                    picTime,
                    imgMaxUrl,
                    msg.Tasklab.Taskid,
                    msg.Tasklab.Taskname,
                    "人脸",

 main.go

@@ -48,6 +48,11 @@
}
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)
    }()