---

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
}