过滤目标’

panlei

2019-12-17 5b6c78545cbb565380aa9b1f68bc26e747314206

 ruleserver/readyDataForRule.go

@@ -3,6 +3,7 @@
import (
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   "encoding/base64"
   "encoding/json"
   "errors"
   "fmt"
@@ -115,9 +116,10 @@
// 给目标填充liker
func fillLiker(tableId []string, compareThreshold float32,arg *structure.Arg) {
   //bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
   decodeBytes, _ := base64.StdEncoding.DecodeString(arg.Feature)
   comArg := &protomsg.CompareArgs{
      TableIds:tableId,
      FaceFeature:arg.Feature,
      FaceFeature:decodeBytes,
      CompareThreshold:compareThreshold,
      Source:false,
   }
@@ -281,12 +283,12 @@
   //}
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   if errSize != nil {
      _ = logger.Error("Failed set MaxRecvSize: %v", err)
      logger.Error("Failed set MaxRecvSize: %v", err)
      return nil
   }
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      _ = logger.Error("请求socket拨号失败: %s", err.Error())
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
@@ -300,11 +302,11 @@
   logger.Debug("推送数据")
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      _ = logger.Error("推送socket发送数据失败: %s", err.Error())
      logger.Error("推送socket发送数据失败: %s", err.Error())
      //os.Exit(1)
   }
   if msg, err = sock.Recv(); err != nil {
      _ = logger.Error("接收响应失败: %s", err.Error())
      logger.Error("接收响应失败: %s", err.Error())
      //os.Exit(1)
   }
   logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
@@ -317,17 +319,17 @@
   var msg []byte

   if sock, err = req.NewSocket(); err != nil {
      _ = logger.Error("创建请求socket失败: %s", err.Error())
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   if errSize != nil {
      _ = logger.Error("Failed set MaxRecvSize: %v", err)
      logger.Error("Failed set MaxRecvSize: %v", err)
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      _ = logger.Error("请求socket拨号失败: %s", err.Error())
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   logger.Info("序列化数据")

@@ -344,10 +346,10 @@
         }
         logger.Debug("推送数据")
         if err = sock.Send(bytes); err != nil {
            _ = logger.Error("推送socket发送数据失败: %s", err.Error())
            logger.Error("推送socket发送数据失败: %s", err.Error())
         }
         if msg, err = sock.Recv(); err != nil {
            _ = logger.Error("接收响应失败: %s", err.Error())
            logger.Error("接收响应失败: %s", err.Error())
         }
         logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
         receiver <- msg