~jinersong/ruleprocess.git

			@@ -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("无效数据，直接返回")
			@@ -72,11 +71,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)
			}
			}
			}
			@@ -137,6 +136,7 @@
			logger.Info("符合摄像机规则!")
			return "true"
			}
			logger.Info("不符合摄像机规则!")
			return "false"
			}

			@@ -174,6 +174,7 @@
			}
			}
			}
			logger.Info("不符合底库规则!")
			return "false"
			}
			}
			@@ -299,7 +300,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)
			}
			}