派生自 ruleprocess
ruleserver/ruleToformula.go
@@ -5,7 +5,7 @@ "github.com/knetic/govaluate" "plugin" "ruleprocess/cache" logger "github.com/jeanphorn/log4go" logger "github.com/alecthomas/log4go" "ruleprocess/structure" "sort" "strconv" @@ -160,7 +160,7 @@ //for _,face := range faces { // //logger.Debug("————————————————________________看看人脸的坐标:",face.Location) //} logger.Warn("___________________________________________________________________________终于走完万里长征") //logger.Warn("___________________________________________________________________________终于走完万里长征") // 把他们的位置数据也传下去 yolos := []*structure.Arg{} for _, sdkData := range args.Sdkdata { @@ -172,7 +172,7 @@ } } } logger.Debug("------locations的内容：", yolos) //logger.Debug("------locations的内容：", yolos) // 处理目标定时数据 targets := []*structure.Arg{} for _, sdkData := range args.Sdkdata { @@ -187,7 +187,7 @@ // 车辆目标统计 cars := []*structure.Arg{} for _, sdkData := range args.Sdkdata { logger.Info("看看sdkNames",sdkNames) //logger.Info("看看sdkNames",sdkNames) if sdkData.IpcId == "91d923ef-6200-4549-ab1b-8e773e85d729" { // 把车牌数据的各个目标的坐标输出方便后面画框 for _, areaMap := range sdkData.AreaMapList { if areaMap.IsEffective { @@ -202,7 +202,7 @@ } else { islink = false } logger.Info("触发的区域id：",polygonId) //logger.Info("触发的区域id：",polygonId) var labelTypes []int // 0为yolo标签，1为face标签 2为两者标签 if sdkNames != "" && len(targets) == 0 { args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, yolos, polygonId, islink,label}) @@ -211,17 +211,17 @@ } if faceFlag { args.RuleResult["face"] = append(args.RuleResult["face"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, faces, polygonId, islink,label}) logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]structure.Result))) //logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]structure.Result))) labelTypes = append(labelTypes,1) } if len(targets) > 0 { args.RuleResult["target"] = append(args.RuleResult["target"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, targets, polygonId, islink,label}) logger.Info("-------------------目标持续结果标签", len(args.RuleResult["target"].([]structure.Result))) //logger.Info("-------------------目标持续结果标签", len(args.RuleResult["target"].([]structure.Result))) //labelTypes = append(labelTypes,2) } if len(cars) > 0 { args.RuleResult["plate"] = append(args.RuleResult["plate"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, cars, polygonId, islink,label}) logger.Info("-------------------车牌结果标签", len(args.RuleResult["plate"].([]structure.Result))) //logger.Info("-------------------车牌结果标签", len(args.RuleResult["plate"].([]structure.Result))) //labelTypes = append(labelTypes,2) } // 给持续时间的第一张赋予缓存数据（遍历复制） @@ -255,7 +255,7 @@ // 结果为假时也要走，有杀死定时器的操作 TimerAlarm(&label, groupRule.GroupId, result) //fmt.Println(timeFlag) logger.Info("不符合规则") //logger.Info("不符合规则") return false,[]int{} } } @@ -354,7 +354,7 @@ } } va.CacheData = structure.ResultMsg{message, tempMap} logger.Info("这个摄像机--", args.CameraId, "--被赋予了result", va.Result) //logger.Info("这个摄像机--", args.CameraId, "--被赋予了result", va.Result) } } // 判断结果数组是否完满(即被赋值完毕)可得出报警结果 @@ -374,12 +374,12 @@ for _, va := range timeEle.RuleResults { completeFormula = completeFormula + va.RuleWithPre + "" + va.Result } logger.Info("---------------------------联动任务的公式", completeFormula) //logger.Info("---------------------------联动任务的公式", completeFormula) if completeFormula != "" { expression, _ := govaluate.NewEvaluableExpression(completeFormula) result, _ := expression.Evaluate(nil) // 得到数学公式的结果 if result.(bool) { logger.Info("___________________________________________________________________联动任务报警") //logger.Info("___________________________________________________________________联动任务报警") rw.RLock() if TimeEleList[groupRule.GroupId] != nil { // 极偶尔有情况会等于nil，不知道为啥，做个判断以防宕机 // 把数组里缓存的数据取出来一起报警 @@ -403,7 +403,7 @@ } } } else { logger.Warn("数组不圆满不打标签") //logger.Warn("数组不圆满不打标签") // 倒是把打的组规则标签给去掉了啊 for _,val := range labelTypes { if val == 0 { @@ -432,7 +432,7 @@ for k, _ := range TimeEleList { if k == groupRule.GroupId { delete(TimeEleList, k) logger.Debug("因为定时器的一帧数据结果为false，干掉定时器") //logger.Debug("因为定时器的一帧数据结果为false，干掉定时器") } } rw.Unlock() @@ -467,7 +467,7 @@ timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, m}} // 扔进去一个定时器元素（并缓存当前画面帧数据） //TimeEleList = make(map[string]timeElement) TimeEleList[groupId+"+"+rule.Id] = &timeEle // 定时器元素以当前持续时间小规则id为键 logger.Info("创建了计数器") //logger.Info("创建了计数器") //cacheId = groupId+"+"+rule.Id } rw.Unlock()
