---

panlei

2019-12-16 c10f46d7c207c2c02cbf07a5678d41c9c02b0c72

 labelFilter/ruleForLabel.go

@@ -3,7 +3,7 @@
import (
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   logger "github.com/jeanphorn/log4go"
   "basic.com/valib/logger.git"
   "github.com/golang/protobuf/proto"
   "github.com/knetic/govaluate"
   "ruleprocess/structure"
@@ -266,10 +266,10 @@
func defenceJudge(label *Label, rule *protomsg.EventPushRule) string {
   if rule.RuleValue == "all" { // 布防等级为全部时只有有布防等级即为通过
      if len(label.DefenceLevel) > 0 {
         logger.Info("符合布防等级规则，布防等级为全部")
         //logger.Info("符合布防等级规则，布防等级为全部")
         return "true"
      } else {
         logger.Info("不符合布防等级规则")
         //logger.Info("不符合布防等级规则")
         return "false"
      }
   } else {
@@ -287,11 +287,11 @@
            //return "false"
         }
         if result.(bool) {
            logger.Info("符合布防等级规则!")
            //logger.Info("符合布防等级规则!")
            return "true"
         }
      }
      logger.Info("不符合布防等级规则")
      //logger.Info("不符合布防等级规则")
      return "false"
   }
}
@@ -311,17 +311,17 @@
      return "false"
   }
   if result.(bool) {
      logger.Info("符合任务规则!")
      //logger.Info("符合任务规则!")
      return "true"
   }
   logger.Info("不符合任务规则")
   //logger.Info("不符合任务规则")
   return "false"
}

// 调用目标服务器的插入接口
func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) {
   for _, url := range urls {
      logger.Debug("推送地址：",url.Url)
      //logger.Debug("推送地址：",url.Url)
      bytes,err1 := proto.Marshal(data)
      if err1 != nil {
         logger.Info("序列化失败：",err1)