| | |
| | | ruleResult := CallSo(sdk.Id, groupRule.Rules[j], areaMap,lable,args,message) |
| | | logger.Info("前置连接符:",groupRule.Rules[j]) |
| | | if groupRule.Rules[j].RuleWithPre == "⊇" && len(ruleResult.Target) > 0 { |
| | | assembleDta(resultSplice[len(resultSplice)-1].Target,ruleResult.Target,) |
| | | assembleDta(resultSplice[len(resultSplice)-1].Target,ruleResult.Target) |
| | | // 把当前小规则结果置空 |
| | | ruleResult = structure.LittleRuleResult{} |
| | | } |
| | |
| | | } |
| | | 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()) |
| | | } |