测试比对进程

panlei

2019-08-08 3636b4af3021e6f8b866d8cc38b990a48ccefeca

测试比对进程

 main.go

@@ -6,6 +6,7 @@
    "basic.com/valib/deliver.git"
    "ruleprocess/insertdata"
    "ruleprocess/util"
    "time"

    //"bufio"
    //"bytes"
@@ -70,13 +71,17 @@
            } else {
                arg := ruleserver.SdkDatas{}
                //paramFormat(msg, &arg)
                logger.Error()
                start := time.Now()
                m := paramFormat(msg, &arg)
                // 进行规则处理判断(打上规则的标签)
                ruleserver.Judge(&arg,&m) // 把sdkMessage传进去，方便缓存数据时拼出一个resultMag
                // 把arg里的打的标签拿出来给m再封装一层
                resultMsg := ruleserver.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult}
                logger.Debug("比对完所用时间：",time.Since(start))
                // 将打完标签的数据插入到ES
                insertdata.InsertToEs(resultMsg)
                logger.Debug("插入完Es所用时间：",time.Since(start))
                //事件推送
                //go labelFilter.Judge(resultMsg)
            }