把部分fmt改为logger

panlei

2019-07-05 e29fa980a6ec4bb1e21d87b897eece0764d5f3c0

把部分fmt改为logger

 main.go

@@ -7,7 +7,6 @@
    "bufio"
    "bytes"
    "flag"
    "fmt"
    "github.com/golang/protobuf/proto"
    "gocv.io/x/gocv"
    "image"
@@ -41,7 +40,7 @@

    dbapi.Init(*dbIp,*dbPort)
    go cache.Init(initchan,*dbIp,*surveyPort,*pubPort)
    fmt.Println("cache init completed!!!",<- initchan)//dbserver初始化完毕
    logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕

    go ruleserver.TimeTicker()
    nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
@@ -69,16 +68,16 @@
        default:
            msg, err = c.Recv()
            if err != nil {
                fmt.Println("recv error : ", err)
                logger.Info("recv error : ", err)
                continue
            } else {
                arg := ruleserver.SdkDatas{}
                m := paramFormat(msg, &arg)
                fmt.Println("解析出来的数据：", arg)
                logger.Info("解析出来的数据：", arg)
                ruleserver.Judge(&arg)
                // 把arg里的打的标签拿出来给m再封装一层
                resultMag := ruleserver.ResultMsg{SdkMessage: m, RuleResult: arg.RuleResult}
                //fmt.Println("打完标签后的结果：",resultMag)
                //logger.Info("打完标签后的结果：",resultMag)

                // 将打完标签的数据插入到ES
                insertdata.InsertToEs(resultMag)
@@ -101,7 +100,7 @@
func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage {
    defer func() {
        if err := recover(); err != nil {
            fmt.Println("解包过程的错误", err.(string))
            logger.Info("解包过程的错误", err.(string))
        }

    }()
@@ -143,7 +142,7 @@
                yoloParam := protomsg.ParamYoloObj{}
                err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam)
                if err != nil {
                    fmt.Println("解析YOLO sdk数据时出现错误", err)
                    logger.Info("解析YOLO sdk数据时出现错误", err)
                    continue
                }
                logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看yolo中有几个目标：",len(yoloParam.Infos))
@@ -180,7 +179,7 @@
                faceParam := protomsg.ParamFacePos{}
                err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
                if err != nil {
                    fmt.Println("解析FACE sdk数据时出现错误", err)
                    logger.Info("解析FACE sdk数据时出现错误", err)
                    continue
                }
                logger.Info("------当前算法name",sdkinfo.SdkName,"--------------看看人脸检测中有几个目标：",len(faceParam.Faces))
@@ -214,14 +213,14 @@
                faceParam := protomsg.ParamFaceFeature{}
                err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam)
                if err != nil {
                    fmt.Println("解析FACE sdk数据时出现错误", err)
                    logger.Info("解析FACE sdk数据时出现错误", err)
                    continue
                }
                for _,faceExtCom := range faceParam.ExtComp  {
                    binfos := protomsg.Binfos{}
                    err := proto.Unmarshal(faceExtCom.Comp, &binfos)
                    if err != nil {
                        fmt.Println("解析人脸比对数据时出现错误", err)
                        logger.Info("解析人脸比对数据时出现错误", err)
                        continue
                    }
                    logger.Info("_________________________________________________________________解析出的人脸的相似的底库数据",binfos)
@@ -231,7 +230,7 @@
                    baseinfos := protomsg.Binfos{}
                    err1 := proto.Unmarshal(extComp.Comp, &baseinfos)
                    if err1 != nil {
                        fmt.Println("解析FACE sdk数据时出现错误", err)
                        logger.Info("解析FACE sdk数据时出现错误", err)
                        continue
                    }
                    photoMap := ruleserver.PhotoMap{Rects: rectFormat(extComp.Pos.Pos.RcFace), Score: float64(extComp.Pos.Pos.Quality)*100, IsYolo:false,ThftRes:*(extComp.Pos.Result),Liker:baseinfos.Infos}
@@ -253,7 +252,7 @@
    //imgs := gocv.NewMat()
    ddd, err := RetrieveROM("./105.jpg")
    if err != nil {
        fmt.Println("解码有误",err)
        logger.Info("解码有误",err)
    }
    bbb := bytes.NewBuffer(ddd)  // 必须加一个buffer 不然没有read方法就会报错
    rook, _ := gocv.NewMatFromBytes(500, 500, gocv.MatTypeCV8UC3, bbb.Bytes())
@@ -298,11 +297,11 @@
    //        msg := "上传图片服务器异常"
    //        if _, ok := r.(error); ok {
    //            msg = r.(error).Error()
    //            fmt.Println("panic--recover()得到的是error类型")
    //            logger.Info("panic--recover()得到的是error类型")
    //        }
    //        if _, ok := r.(string); ok {
    //            msg = r.(string)
    //            fmt.Println("panic--recover()得到的是string类型")
    //            logger.Info("panic--recover()得到的是string类型")
    //        }
    //        err0 = errors.New(msg)
    //    }
@@ -314,9 +313,9 @@
    //    if err != nil {
    //        logger.Fatal(err)
    //    }
    //    fmt.Println(resp.StatusCode)
    //    //fmt.Println(resp.Header)
    //    fmt.Println(body)
    //    logger.Info(resp.StatusCode)
    //    //logger.Info(resp.Header)
    //    logger.Info(body)
    //    //decoder := json.NewDecoder(strings.NewReader(body.String()))
    //    decoder := make(map[string]interface{})
    //    if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil {

 ruleserver/ruleToformula.go

@@ -2,7 +2,6 @@

import (
    "encoding/json"
    "fmt"
    "ruleprocess/cache"
    "ruleprocess/logger"
    "sort"