package labelFilter
|
|
import (
|
"github.com/knetic/govaluate"
|
"ruleprocess/logger"
|
"ruleprocess/ruleserver"
|
)
|
|
func Judge(){
|
//拿到所有规则组
|
|
//遍历所有的规则组，看看符合哪个规则组，就把数据插入到哪个规则组的目标机器上
|
|
//先判断时间规则，不符合此规则，直接略过
|
|
//遍历规则组中的小规则，每个小规则得出一个string类型的bool值，然后用 && 或 || 拼接起来
|
|
//得出总的判断结果
|
|
//符合本规则组的就把数据推送到该目的服务器上
|
}
|
// 是否符合时间规则
|
func timeJudge(label *Label,groupRule *GroupRule) string{
|
|
}
|
// 传入两个时间的字符串，判断第一个时间是否小于第二个时间
|
func isBefore(time1 string,time2 string) bool{
|
expression, err:= govaluate.NewEvaluableExpression("t1 < t2");
|
if err != nil {
|
logger.Error("表达式有误，请检查！")
|
}
|
parameters := make(map[string]interface{},8)
|
parameters["t1"] = time1
|
parameters["t2"] = time2
|
result, err1:= expression.Evaluate(parameters)
|
if err1 != nil {
|
logger.Error("带入参数有误")
|
}
|
return result.(bool)
|
}
|
|
// 是否符合摄像机规则
|
func cameraJudge(label *Label,rule *Rule) string{
|
return "true"
|
}
|
|
// 是否符合底库规则
|
func baseJudge(label *Label,rule *Rule) string{
|
return "true"
|
}
|
|
//是否符合人员规则
|
func personJudge(label *Label,rule *Rule) string{
|
return "true"
|
}
|
|
// 是否符合布防等级规则
|
func defenceJudge(label *Label,rule *Rule) string{
|
return "true"
|
}
|
// 调用目标服务器的插入接口
|
func pushData (data ruleserver.ResultMsg){
|
|
}
|
