派生自 ruleprocess
labelFilter/ruleForLabel.go
@@ -4,17 +4,16 @@ "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "github.com/knetic/govaluate" "os" "ruleprocess/logger" "ruleprocess/ruleserver" "strconv" "time" ) func Judge(result ruleserver.ResultMsg) { func Judge(msg ruleserver.ResultMsg) { // 装配成自己可以识别的数据 label := new(Label) label.DataFormatToLabel(result) label.DataFormatToLabel(msg) logger.Info("label的信息：", label.CameraName, label.DefenceLevel, label.Time) if label.CameraName == "" { logger.Error("无效数据，直接返回") @@ -31,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 { @@ -42,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) } } // 得出总的判断结果 @@ -64,6 +67,7 @@ expression, err := govaluate.NewEvaluableExpression(result); if err != nil { logger.Error("表达式有误，请检查！") return } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -72,11 +76,11 @@ if result.(bool) { logger.Info("通过规则，表达式为：", result) // 推送服务器 pushData(ruleGroup.Urls, result.(ruleserver.ResultMsg)) os.Exit(1) pushData(ruleGroup.Urls, msg) //os.Exit(1) } else { logger.Info("没通过规则,表达式为：", result) os.Exit(1) //os.Exit(1) } } } @@ -86,15 +90,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 } } @@ -103,6 +108,7 @@ expression, err := govaluate.NewEvaluableExpression("t1 < t2"); if err != nil { logger.Error("表达式有误，请检查！") return false } parameters := make(map[string]interface{}, 8) parameters["t1"] = time1 @@ -123,6 +129,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) @@ -159,9 +166,10 @@ 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" return "false" } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -198,10 +206,11 @@ // 其他这个值先这么处理 return "true" } logger.Info("-------打印人员规则公式：",formula) expression, err := govaluate.NewEvaluableExpression(formula); if err != nil { logger.Error("表达式有误，请检查！", formula) //return "false" return "false" } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -221,10 +230,11 @@ } } 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) //return "false" return "false" } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -256,11 +266,12 @@ } } else { for _, def := range label.DefenceLevel { formula := strconv.Itoa(int(def)) + rule.Operator + formate(rule.RuleValue) formula := strconv.Itoa(int(def)) + rule.Operator + rule.RuleValue logger.Info("-------打印布防等级规则公式：",formula) expression, err := govaluate.NewEvaluableExpression(formula); if err != nil { logger.Error("表达式有误，请检查！", formula) //return "false" return "false" } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -281,6 +292,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 +313,8 @@ // 调用目标服务器的插入接口 func pushData(urls []*protomsg.PushUrl, data ruleserver.ResultMsg) { for _, url := range urls { Push(url.Url, data) logger.Debug("看看推送地址：",url.Url) Push("tcp://192.168.1.123:40012", data) } }
