panlei
2019-07-22 8f3b9f0dcef90b84c1a3f0c7be71f484c6a84e2f
labelFilter/ruleForLabel.go
@@ -1 +1,64 @@
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){
}