测试比对进程

panlei

2019-08-08 7c2fd421ce84a7ef8b9d611b84fa9e2f4ba3efaf

 ruleserver/readyDataForRule.go

@@ -167,22 +167,23 @@

// 给目标填充liker
func (arg *Arg) fillLiker(tableId []string, compareThreshold float32) {
   // bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
   //bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
   comArg := &protomsg.CompareArgs{
      TableIds:tableId,
      FaceFeature:arg.Feature,
      CompareThreshold:compareThreshold,
      Source:false,
   }
   bytes := Push("tcp://192.168.1.182:40010",comArg,sock)
   var m map[string]float32
   err1 := json.Unmarshal(bytes, &m)
   var scResult protomsg.SdkCompareResult
   err1 := proto.Unmarshal(bytes, &scResult)
   if err1 != nil {
      logger.Error("getBaseInfo解压错误", err1)
   }
   //logger.Info("----------------------------------------map是", m)
   ids := []string{}
   for key, _ := range m {
      ids = append(ids, key)
   for _,key := range scResult.CompareResult {
      ids = append(ids, key.Id)
   }
   logger.Info("------------------------------------------------------------------------------------------------------------------------")
   //logger.Info("=====================人员id的集合为：",ids)
@@ -301,7 +302,7 @@
         a.filterData = append(a.filterData, &arg1)
      }
   }
   logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.targetNum,"---",len(a.filterData))
   //logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.targetNum,"---",len(a.filterData))
   a.time = time.Unix(time.Now().Unix(), 0).String()[11:16]
   a.keepRight = arg.KeepRight
   a.isStatic = arg.IsStatic