~jinersong/ruleprocess.git

			@@ -3,15 +3,20 @@
			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(msg ruleserver.ResultMsg) {
			func PushSomthing(msg structure.ResultMsg) {
			defer func() {
			if err := recover(); err != nil {
			logger.Error("事件推送模块儿的异常捕获：",err)
			}
			}()

			// 装配成自己可以识别的数据
			label := new(Label)
			label.DataFormatToLabel(msg)
			@@ -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 {
			@@ -73,10 +83,10 @@
			logger.Info("通过规则，表达式为：", result)
			// 推送服务器
			pushData(ruleGroup.Urls, msg)
			os.Exit(1)
			//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)
			@@ -159,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 {
			@@ -198,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 {
			@@ -221,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 {
			@@ -256,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 {
			@@ -281,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"
			@@ -299,10 +317,11 @@
			}

			// 调用目标服务器的插入接口
			func pushData(urls []*protomsg.PushUrl, data ruleserver.ResultMsg) {
			func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) {
			for _, url := range urls {
			logger.Debug("看看推送地址：",url.Url)
			Push("tcp://"+url.Url, data)
			pool <- &data
			//logger.Info("urlPool大小： ", len(urlPool[url.Url]))
			}
			}