result结果+=

panlei

2019-08-08 ee4eeaa38e11d3cef51c9bb093da69547bd18c4d

 labelFilter/ruleForLabel.go

@@ -30,7 +30,11 @@
   for _, ruleGroup := range allRules {
      if ruleGroup.Enable { // 大规则开关开启状态
         // 先过时间规则
         timeJudge(label, ruleGroup)
         timeFlag := timeJudge(label, ruleGroup)
         if !timeFlag {
            logger.Info("不在规则的时间范围内，不推送！")
            return
         }
         result := ""
         var Connector string
         if ruleGroup.IsSatisfyAll {
@@ -41,19 +45,19 @@
         for _, rule := range ruleGroup.Rules {
            // 过每一个小规则
            if rule.TopicType == "camera" {
               result = Connector + cameraJudge(label, rule)
               result += Connector + cameraJudge(label, rule)
            }
            if rule.TopicType == "dbtable" {
               result = Connector + baseJudge(label, rule)
               result += Connector + baseJudge(label, rule)
            }
            if rule.TopicType == "task" {
               result = Connector + taskJudge(label, rule)
               result += Connector + taskJudge(label, rule)
            }
            if rule.TopicType == "person" {
               result = Connector + taskJudge(label, rule)
               result += Connector + taskJudge(label, rule)
            }
            if rule.TopicType == "alarmLevel" {
               result = Connector + defenceJudge(label, rule)
               result += Connector + defenceJudge(label, rule)
            }
         }
         // 得出总的判断结果
@@ -85,15 +89,16 @@
}

// 是否符合时间规则
func timeJudge(label *Label, groupRule protomsg.EventPush) string {
func timeJudge(label *Label, groupRule protomsg.EventPush) bool {
   timeNow := time.Now().Format("2006-01-02 15:04:05")
   logger.Info("标签过滤器起始时间为：",groupRule.TimeStart,groupRule.TimeEnd)
   flag1 := isBefore(groupRule.TimeStart, timeNow)
   flag2 := isBefore(timeNow, groupRule.TimeEnd)
   if flag1 && flag2 {
      return "true"
      return true
   } else {
      logger.Info("不在规定的时间范围内！")
      return "false"
      return false
   }
}

@@ -122,6 +127,7 @@
   if rule.TopicArg == "addr" {
      formula = "'" + label.CameraAddr + "'" + rule.Operator + "'" + rule.RuleValue + "'"
   }
   logger.Info("-------打印摄像机规则公式：",formula)
   expression, err := govaluate.NewEvaluableExpression(formula);
   if err != nil {
      logger.Error("表达式有误，请检查！", formula)
@@ -158,6 +164,7 @@
            for _, liker := range arg.Liker {
               formula := "'" + liker.TableId + "'" + rule.Operator + "'" + rule.RuleValue + "'"
               expression, err := govaluate.NewEvaluableExpression(formula);
               logger.Info("-------打印底库规则公式：",formula)
               if err != nil {
                  logger.Error("表达式有误，请检查！", formula)
                  //return "false"
@@ -197,6 +204,7 @@
            // 其他这个值先这么处理
            return "true"
         }
         logger.Info("-------打印人员规则公式：",formula)
         expression, err := govaluate.NewEvaluableExpression(formula);
         if err != nil {
            logger.Error("表达式有误，请检查！", formula)
@@ -220,6 +228,7 @@
            }
         } else {
            formula := strconv.Itoa(int(personGroup.AlarmLevel)) + rule.Operator + formate(rule.RuleValue)
            logger.Info("-------打印人员等级规则公式：",formula)
            expression, err := govaluate.NewEvaluableExpression(formula);
            if err != nil {
               logger.Error("表达式有误，请检查！", formula)
@@ -256,6 +265,7 @@
   } else {
      for _, def := range label.DefenceLevel {
         formula := strconv.Itoa(int(def)) + rule.Operator + formate(rule.RuleValue)
         logger.Info("-------打印布防等级规则公式：",formula)
         expression, err := govaluate.NewEvaluableExpression(formula);
         if err != nil {
            logger.Error("表达式有误，请检查！", formula)
@@ -280,6 +290,7 @@
func taskJudge(label *Label, rule *protomsg.EventPushRule) string {
   formula := "'"+label.TaskId +"'"+ rule.Operator +"'"+ rule.RuleValue+"'"
   expression, err := govaluate.NewEvaluableExpression(formula);
   logger.Info("-------打印任务规则公式：",formula)
   if err != nil {
      logger.Error("表达式有误，请检查！", formula)
      return "false"
@@ -301,7 +312,7 @@
func pushData(urls []*protomsg.PushUrl, data ruleserver.ResultMsg) {
   for _, url := range urls {
      logger.Debug("看看推送地址：",url.Url)
      Push("tcp://"+url.Url, data)
      Push("tcp://192.168.1.123:40012", data)
   }
}