---
panlei
2019-07-05 30138186e43ebc373466d8c0bae01b5a350dbd48
---
2个文件已修改
22 ■■■■ 已修改文件
insertdata/insertDataToEs.go 20 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/ruleToformula.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
insertdata/insertDataToEs.go
@@ -102,7 +102,7 @@
                // 人脸检测,没有相似的底库人员
                localConfig, err := cache.GetServerInfo()
                if err != nil {
                    logger.Info("查询本机信息失败!")
                    logger.Error("查询本机信息失败!")
                }
                serverIp, err := GetLocalIP()
                // 解压缩并上传图片
@@ -113,7 +113,7 @@
                // 查询cameraName
                camera, err := cache.GetCameraById(msg.Cid)
                if err != nil {
                    logger.Info("查询摄像机信息失败")
                    logger.Error("查询摄像机信息失败")
                }
                i := protomsg.Image{}
                err = proto.Unmarshal(bdata, &i)
@@ -121,7 +121,7 @@
                bytes := util.SubImg(i, int(face.Location.X), int(face.Location.Y), int(face.Location.X+face.Location.Width), int(face.Location.Y+face.Location.Height))
                resp, err := util.PostFormBufferData1(weedfsUrl, bytes, uuid.NewV4().String())
                if err != nil {
                    logger.Info("上传小图出错")
                    logger.Error("上传小图出错")
                }
                sex := ""
                if face.ThftRes.Gender == 1 {
@@ -186,7 +186,7 @@
                // 查询cameraName
                camera, err := cache.GetCameraById(msg.Cid)
                if err != nil {
                    logger.Info("查询摄像机信息失败")
                    logger.Error("查询摄像机信息失败")
                }
                i := protomsg.Image{}
                err = proto.Unmarshal(bdata, &i)
@@ -194,7 +194,7 @@
                bytes := util.SubImg(i, int(face.Location.X), int(face.Location.Y), int(face.Location.X+face.Location.Width), int(face.Location.Y+face.Location.Height))
                resp, err := util.PostFormBufferData1(weedfsUrl, bytes, uuid.NewV4().String())
                if err != nil {
                    logger.Info("上传小图出错")
                    logger.Error("上传小图出错")
                }
                sex := ""
                if face.ThftRes.Gender == 1 {
@@ -237,7 +237,7 @@
                requstbody, err := json.Marshal(pervideo)
                if err != nil {
                    logger.Info("json parse error ", err)
                    logger.Error("json parse error ", err)
                    return
                }
@@ -272,7 +272,7 @@
            //resp, err = util.PostFormBufferData(weedfsUrl, i, uuid.NewV4().String())
            resp, err = util.DrawPolygonOnImage(msg.Cid, i,msg.RuleResult["yolo"].([]ruleserver.Result))
            if err != nil {
                logger.Info("画框或上传图片服务器出错", err)
                logger.Error("画框或上传图片服务器出错", err)
            } else {
                logger.Info("已报警并上传改帧图片到服务器")
            }
@@ -285,12 +285,12 @@
        // 查询本机信息
        localConfig, err := cache.GetServerInfo()
        if err != nil {
            logger.Info("查询本机信息失败!")
            logger.Error("查询本机信息失败!")
        }
        // 查询cameraName
        camera, err := cache.GetCameraById(msg.Cid)
        if err != nil {
            logger.Info("查询摄像机信息失败")
            logger.Error("查询摄像机信息失败")
        }
        serverIp, err := GetLocalIP()
        peraction := Personaction{
@@ -324,7 +324,7 @@
        }
        err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
        if err != nil {
            logger.Info("往ES插入数据失败", err)
            logger.Error("往ES插入数据失败", err)
        } else {
            logger.Info("__________________________________________往ES插入yolo数据成功")
        }
ruleserver/ruleToformula.go
@@ -348,7 +348,7 @@
                }
            }
            if flag {
                logger.Info("___________________________________________________________________________终于走完万里长征")
                logger.Warn("___________________________________________________________________________终于走完万里长征")
                // 如果成功了我应该找到规则中涉及到的sdk,记录下他们的sdkname
                sdkName := ""
                for j := 0; j < len(groupRule.Rules); j++ {