logger改用公共库

panlei

2019-09-27 b20ee0733822c4cc636657789f482eaefc1e134a

 ruleserver/readyDataForRule.go

@@ -13,7 +13,7 @@
   "nanomsg.org/go-mangos/transport/tcp"
   "net"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "basic.com/valib/logger.git"
   "strconv"
   "time"
)
@@ -219,7 +219,7 @@
         if groupRule.Rules[j].SdkArgAlias == "compareBase" && groupRule.Rules[j].SdkArgValue == "" { // 配的参数是比对全部底库
            compareFlag = 1
         }
         if groupRule.Rules[j].SdkArgAlias == "threshold" {
         if groupRule.Rules[j].SdkArgAlias == "cmpThreshold" {
            v2, err := strconv.ParseFloat(groupRule.Rules[j].SdkArgValue, 32)
            if err != nil {
               logger.Error("string转float32失败！")
@@ -246,14 +246,14 @@
                     //logger.Info("--------------看看compareFlag的值和tableId和areaMap.args的长度：",compareFlag,tableIds,len(areaMap.args))
                     for _, arg := range areaMap.args {
                        arg.Liker = arg.Liker[0:0]
                        logger.Info("清空之后看看之前打的人脸标签变了没：")
                        if args.RuleResult["face"] != nil && len(args.RuleResult["face"].([]FaceResult)) > 0 {
                           for _, faceResult := range args.RuleResult["face"].([]FaceResult) {
                              for _,arg := range faceResult.Args {
                                 logger.Info("人员分值是：",arg.Score,"liker的数量为",arg.Liker)
                              }
                           }
                        }
                        //logger.Info("清空之后看看之前打的人脸标签变了没：")
                        //if args.RuleResult["face"] != nil && len(args.RuleResult["face"].([]FaceResult)) > 0 {
                        //   for _, faceResult := range args.RuleResult["face"].([]FaceResult) {
                        //      for _,arg := range faceResult.Args {
                        //         logger.Info("人员分值是：",arg.Score,"liker的数量为",arg.Liker)
                        //      }
                        //   }
                        //}
                        if compareFlag == 1 {
                           arg.fillLiker(nil, threshold)
                        }
@@ -384,6 +384,7 @@
      // case <-ctx.Done():
      //    return
      case data := <- sender:
         logger.Info("比对进程入参：",data.TableIds,data.CompareThreshold)
         bytes,err1 := proto.Marshal(data)
         logger.Info("数据长度为：",len(bytes))
         if err1 != nil {