| | |
| | | } |
| | | for _, arg := range am.FilterData { |
| | | fillLiker(threshold,arg,am) |
| | | logger.Info("比完之后的数据追踪数据是:",arg) |
| | | //logger.Info("比完之后的数据追踪数据是:",arg) |
| | | //if len(arg.Liker) == 0 { |
| | | // // 如果没有相似者则删除本目标数据 |
| | | // am.FilterData = append(am.FilterData[:i],am.FilterData[i+1:]...) |
| | |
| | | for { |
| | | select { |
| | | case data := <- sender: |
| | | trackMap := make(map[string]interface{}) |
| | | _ = json.Unmarshal(data, &trackMap) |
| | | logger.Info("请求张增飞比对数据参数:",trackMap) |
| | | //trackMap := make(map[string]interface{}) |
| | | //_ = json.Unmarshal(data, &trackMap) |
| | | //logger.Info("请求张增飞比对数据参数:",trackMap) |
| | | if err = sock.Send(data); err != nil { |
| | | logger.Error("推送socket发送数据失败: %s", err.Error()) |
| | | } |