派生自 ruleprocess
ruleserver/ruleToformula.go
@@ -4,6 +4,7 @@ "encoding/json" "fmt" "log" "os" "ruleprocess/cache" "sort" "strconv" @@ -207,6 +208,7 @@ args.RuleResult["face"] = []Arg{} if len(taskRuleList) > 0 { for _, taskRule := range taskRuleList { //log.Println("------------------------------任务规则：",taskRule) ruleList := taskRule.GroupRules // 获取的是task下面的任务组 taskId := taskRule.TaskId //log.Println("------------本组任务下的规则组的数量：",len(ruleList)) @@ -215,7 +217,7 @@ if len(temp) > 0 { if ruleList[i].SetType == "linkTask" { // groupId中含有link则为联动任务 linkTask(args, ruleList[i], taskId) //LinkTask(args, ruleList[i], taskId) } else { // 独立任务的处理 RunRule(args, ruleList[i], taskId) @@ -231,9 +233,8 @@ if err := recover(); err != nil { fmt.Println("比对规则有误", err.(string)) } }() log.Println("+++++++++++规则开始运行+++++++++++++++++当前规则--：",*groupRule) log.Println("+++++++++++规则开始运行+++++++++++++++++当前规则--：",(*groupRule).GroupText) resultSplice := []*LittleRuleResult{} // 先过完条件规则 for j := 0; j < len(groupRule.Rules); j++ { @@ -256,7 +257,16 @@ } } } args.RuleResult["face"] = faces // 配了人脸的算法才把人脸的数据甩出来打标签 flag := false for j := 0; j < len(groupRule.Rules); j++ { if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a97e" || groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a971" { flag = true } } if flag { args.RuleResult["face"] = faces } // 再过其他数据 这步直接得到结果（真或假） 过目标数量 for j := 0; j < len(groupRule.Rules); j++ { for _, sdkData := range args.Sdkdata { @@ -297,7 +307,7 @@ completeFormula = completeFormula + va.Result } if completeFormula != "" { log.Println("看看公式-----------：", completeFormula) log.Println("结果公式-----------：", completeFormula) expression, _ := govaluate.NewEvaluableExpression(completeFormula) if strings.HasPrefix(completeFormula,"&&") || strings.HasPrefix(completeFormula,"||"){ panic("规则有误，得到的数学公式不可解析") @@ -324,7 +334,7 @@ } } if flag { fmt.Println("----------------------------终于走完万里长征") fmt.Println("___________________________________________________________________________终于走完万里长征") // 如果成功了我应该找到规则中涉及到的sdk，记录下他们的sdkname sdkName := "" for j := 0; j < len(groupRule.Rules); j++ { @@ -353,7 +363,7 @@ func putFaceToResult(rule *protomsg.Rule, am *AreaMap) []Arg { faces := []Arg{} if rule.SdkId == am.sdkId { if rule.SdkId == am.sdkId && rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a97e" || rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a971"{ if len(am.filterData) > 0 { for _, data := range am.filterData { faces = append(faces, data) @@ -436,8 +446,9 @@ } // 联动任务的处理 func linkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) { func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) { // new一个定时器，如果以此groupId为标志的定时器不存在的话 log.Println("------------------------------------------当前是联动任务，规则是：",groupRule.GroupText) var flag bool = true var timeEle = TimeElement{N: 3, InitN: 3, GroupId: groupRule.GroupId} for k, timeEle1 := range TimeEleList { @@ -450,7 +461,7 @@ timeEle := TimeElement{N: 3, InitN: 3, GroupId: groupRule.GroupId} // 扔进去一个定时器元素 //TimeEleList = make(map[string]timeElement) TimeEleList[groupRule.GroupId] = &timeEle // 定时器元素以规则组id为键 fmt.Println("创建了计数器并且计数器集合为：", TimeEleList) fmt.Println("---------------------------------------------联动任务创建了计数器并且计数器集合为：", TimeEleList) // 得出这组完整规则里涉及到几个摄像机，决定着数组里有几个结构体,去重添加方式 for j := 0; j < len(groupRule.Rules); j++ { var flag1 bool = true @@ -490,20 +501,28 @@ for _, va := range timeEle.RuleResults { completeFormula = completeFormula + va.RuleWithPre + "" + va.Result } log.Println("---------------------------联动任务的公式",completeFormula) if completeFormula != "" { expression, _ := govaluate.NewEvaluableExpression(completeFormula) result, _ := expression.Evaluate(nil) // 得到数学公式的结果 if result.(bool) { log.Println("___________________________________________________________________联动任务报警") sdkName := "" for j := 0; j < len(groupRule.Rules); j++ { for _, sdkData := range args.Sdkdata { if groupRule.Rules[j].SdkId == sdkData.SdkId && sdkData.IsYolo { // 只记录yolo符合规则的sdk sdkName = sdkName + "," + sdkData.SdkName if groupRule.Rules[j].SdkId == sdkData.SdkId && sdkData.IsYolo && !strings.Contains(sdkName,sdkData.SdkName) { // 只记录yolo符合规则的sdk 同时要避免重复拼接 sdkName = sdkData.SdkName + " " } } } // 过完规则后打个标签，告诉调用者本帧数据针对哪个任务哪组规则报警了 args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result), Result{taskId, sdkName, groupRule.GroupId, groupRule.AlarmLevel, groupRule.GroupText}) if sdkName != "" { args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result), Result{taskId, sdkName, groupRule.GroupId, groupRule.AlarmLevel, groupRule.GroupText}) log.Println("-------------------yolo结果标签",args.RuleResult["yolo"].([]Result)) } if args.RuleResult["face"] != nil { log.Println("-------------------face结果标签",args.RuleResult["face"].([]Arg)) } os.Exit(0) } } } else { @@ -579,10 +598,13 @@ var formula string if rule.SdkArgAlias == "score" { formula = strconv.FormatFloat(arg.Score, 'f', -1, 64) + " " + rule.Operator + " " + rule.SdkArgValue // 得到字符串公式 log.Println("当前相似度小公式：",formula) } else if rule.SdkArgAlias == "proportion" { formula = strconv.FormatFloat(arg.Proportion, 'f', -1, 64) + " " + rule.Operator + " " + rule.SdkArgValue // 得到字符串公式 log.Println("当前占比小公式：",formula) } else { formula = strconv.FormatFloat(arg.Size, 'f', -1, 64) + " " + rule.Operator + " " + rule.SdkArgValue // 得到字符串公式 log.Println("当前尺寸小公式：",formula) } expression, _ := govaluate.NewEvaluableExpression(formula) // 得到数学公式 result, _ := expression.Evaluate(nil) // 得到数学公式的结果 @@ -759,11 +781,13 @@ } } if rule.Operator == "unsatisfy" || rule.Operator == "!="{ // 不满足所选的时间规则 formula := timeSlot.Start + "<" + am.time formula := "'"+timeSlot.Start + "'" + " < " + "'" + am.time + "'" log.Println("-----------------时间规则不满足的公式start：",formula) expression, _ := govaluate.NewEvaluableExpression(formula) // 得到数学公式 result, _ := expression.Evaluate(nil) // 得到数学公式的结果 formula1 := timeSlot.End + ">" + am.time formula1 := "'"+timeSlot.End +"'"+ " > " +"'" + am.time+ "'" log.Println("-----------------时间规则不满足的公式end：",formula1) expression1, _ := govaluate.NewEvaluableExpression(formula1) // 得到数学公式 result1, _ := expression1.Evaluate(nil) // 得到数学公式的结果 if result.(bool) && result1.(bool) {
