---

panlei

2019-08-06 de102062b29cff395b1abe1605198bf8bfdc0cea

 labelFilter/ruleForLabel.go

@@ -84,6 +84,7 @@

   //符合本规则组的就把数据推送到该目的服务器上
}

// 是否符合时间规则
func timeJudge(label *Label,groupRule protomsg.EventPush) string{
   timeNow := time.Now().Format("2006-01-02 15:04:05")
@@ -96,6 +97,7 @@
      return "false"
   }
}

// 传入两个时间的字符串，判断第一个时间是否小于第二个时间
func isBefore(time1 string,time2 string) bool{
   expression, err:= govaluate.NewEvaluableExpression("t1 < t2");
@@ -116,10 +118,10 @@
func cameraJudge(label *Label,rule *protomsg.EventPushRule) string{
   formula := ""
   if rule.TopicArg == "name" {
      formula = label.CameraName + rule.Operator + rule.RuleValue
      formula = "'" + label.CameraName + "'" + rule.Operator + "'" + rule.RuleValue + "'"
   }
   if rule.TopicArg == "addr" {
      formula = label.CameraAddr + rule.Operator + rule.RuleValue
      formula = "'" + label.CameraAddr + "'" + rule.Operator + "'" + rule.RuleValue + "'"
   }
   expression, err:= govaluate.NewEvaluableExpression(formula);
   if err != nil {
@@ -154,7 +156,7 @@
      for _,personGroup := range label.Persons  {
         for _,arg := range personGroup.Args {
            for _,liker := range arg.Liker{
               formula := liker.TableId + rule.Operator + rule.RuleValue
               formula := "'" + liker.TableId + "'" + rule.Operator + "'" + rule.RuleValue + "'"
               expression, err:= govaluate.NewEvaluableExpression(formula);
               if err != nil {
                  logger.Error("表达式有误，请检查！",formula)
@@ -216,7 +218,7 @@
               return "true"
            }
         } else {
            formula := strconv.Itoa(int(personGroup.AlarmLevel)) + rule.Operator + rule.RuleValue
            formula := strconv.Itoa(int(personGroup.AlarmLevel)) + rule.Operator + formate(rule.RuleValue)
            expression, err:= govaluate.NewEvaluableExpression(formula);
            if err != nil {
               logger.Error("表达式有误，请检查！",formula)
@@ -252,7 +254,7 @@
      }
   } else {
      for _,def := range label.DefenceLevel {
         formula := strconv.Itoa(int(def)) + rule.Operator + rule.RuleValue
         formula := strconv.Itoa(int(def)) + rule.Operator + formate(rule.RuleValue)
         expression, err:= govaluate.NewEvaluableExpression(formula);
         if err != nil {
            logger.Error("表达式有误，请检查！",formula)
@@ -272,9 +274,10 @@
      return "false"
   }
}

// 是否符合任务规则
func taskJudge(label *Label,rule *protomsg.EventPushRule) string{
   formula := label.TaskId + rule.Operator + rule.RuleValue
   formula := "'"+label.TaskId +"'"+ rule.Operator +"'"+ rule.RuleValue+"'"
   expression, err:= govaluate.NewEvaluableExpression(formula);
   if err != nil {
      logger.Error("表达式有误，请检查！",formula)
@@ -292,9 +295,31 @@
   logger.Info("不符合任务规则")
   return "false"
}

// 调用目标服务器的插入接口
func pushData (urls []*protomsg.PushUrl, data ruleserver.ResultMsg){
   for _,url := range urls {
      Push(url.Url,data)
   }
}

// 把报警等级转化成汉字
func formate(str string) string {
   var i string
   if str == "一级" {
      i = "1"
   }
   if str == "二级" {
      i = "2"
   }
   if str == "三级" {
      i = "3"
   }
   if str == "四级" {
      i = "4"
   }
   if str == "五级" {
      i = "5"
   }
   return i
}