merge V1.0

panlei

2019-11-07 0e441dc5137776776d367f4075f7a2f62ae03628

 main.go

@@ -13,16 +13,10 @@
   "time"

   "basic.com/valib/logger.git"
   //"bufio"
   //"bytes"
   "flag"
   "fmt"
   "github.com/golang/protobuf/proto"
   "github.com/spf13/viper"
   //"gocv.io/x/gocv"
   //"image"
   //"image/color"
   //"os"
   "ruleprocess/cache"
   "ruleprocess/ruleserver"
   "sync"
@@ -103,6 +97,7 @@
               ruleserver.Judge(&arg, &m) // 把sdkMessage传进去，方便缓存数据时拼出一个resultMag
               // 把arg里的打的标签拿出来给m再封装一层
               resultMsg := structure.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult}
               ruleserver.GetAttachInfo(resultMsg.SdkMessage)
               ruleEnd := time.Since(start)
               logger.Debug("规则判断完所用时间：", ruleEnd)
               // 将打完标签的数据插入到ES
@@ -110,9 +105,7 @@
               esEnd := time.Since(start)
               logger.Debug("插入完Es所用时间：", esEnd)
               //事件推送
               //labelFilter.PushSomthing(resultMsg)
               //pushEnd := time.Since(start)
               //logger.Info("事件推送完所用时间：",ruleEnd,esEnd,pushEnd)
               labelFilter.PushSomthing(resultMsg)
            }(msg)
         }
      }