派生自 ruleprocess
labelFilter/ruleForLabel.go
@@ -3,18 +3,23 @@ import ( "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" "github.com/knetic/govaluate" "os" "ruleprocess/logger" "ruleprocess/ruleserver" "ruleprocess/structure" "strconv" "time" ) func Judge(result ruleserver.ResultMsg) { func PushSomthing(msg structure.ResultMsg) { defer func() { if err := recover(); err != nil { logger.Error("事件推送模块儿的异常捕获：",err) } }() // 装配成自己可以识别的数据 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 +36,11 @@ for _, ruleGroup := range allRules { if ruleGroup.Enable { // 大规则开关开启状态 // 先过时间规则 timeJudge(label, ruleGroup) timeFlag := timeJudge(label, ruleGroup) if !timeFlag { logger.Info("不在规则的时间范围内，不推送！") continue } result := "" var Connector string if ruleGroup.IsSatisfyAll { @@ -42,19 +51,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 +73,7 @@ expression, err := govaluate.NewEvaluableExpression(result); if err != nil { logger.Error("表达式有误，请检查！") return } result, err1 := expression.Evaluate(nil) if err1 != nil { @@ -72,11 +82,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 +96,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 +114,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 +135,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) @@ -137,6 +150,7 @@ logger.Info("符合摄像机规则!") return "true" } logger.Info("不符合摄像机规则!") return "false" } @@ -158,9 +172,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 { @@ -174,6 +189,7 @@ } } } logger.Info("不符合底库规则!") return "false" } } @@ -196,10 +212,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 { @@ -219,10 +236,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 { @@ -254,11 +272,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 { @@ -279,6 +298,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" @@ -297,9 +317,11 @@ } // 调用目标服务器的插入接口 func pushData(urls []*protomsg.PushUrl, data ruleserver.ResultMsg) { func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) { for _, url := range urls { Push(url.Url, data) logger.Debug("看看推送地址：",url.Url) pool <- &data //logger.Info("urlPool大小： ", len(urlPool[url.Url])) } }
