派生自 ruleprocess
ruleserver/ruleToformula.go
@@ -102,18 +102,10 @@ result := false sdkNames := "" polygonId := "" targets := []*structure.Arg{} // 符合条件的目标 // 把一帧数据和一组规则发给算法部分，得出判断结果 result,sdkNames,polygonId = CallMiddleware(args,*groupRule,&label,message) for _, sdkData := range args.Sdkdata { for _, areaMap := range sdkData.AreaMapList { targets = append(targets,areaMap.AlarmObj...) for _,obj := range areaMap.AlarmObj { logger.Info("个体静止的目标",obj.Id,obj.Location) } } } //logger.Info("符合条件的目标数据：",targets) if result { // 最后过持续时间等时间维度的条件 把时间规则位置调整到这个位置是为了缓存数据 ！！！！！ps: 对画面中单个目标做定时器的不用再过画面定时器 cacheId := "" @@ -174,6 +166,17 @@ } } logger.Debug("------locations的内容：", yolos) // 处理目标定时数据 targets := []*structure.Arg{} for _, sdkData := range args.Sdkdata { if sdkData.IpcId == "02D54B61-0F16-C604-8567-FC4BE493C523" && sdkNames != "" { // 把yolo数据的各个目标的坐标输出方便后面画框 for _, areaMap := range sdkData.AreaMapList { if areaMap.IsEffective { targets = append(targets, putTargetsToResult(areaMap)...) } } } } var islink bool if groupRule.SetType == "linkTask" { islink = true @@ -190,6 +193,11 @@ 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"].([]FaceResult))) 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))) //labelTypes = append(labelTypes,2) } // 给持续时间的第一张赋予缓存数据（遍历复制） if cacheId != "" { // 有这帧数据的缓存 @@ -222,6 +230,7 @@ // 结果为假时也要走，有杀死定时器的操作 TimerAlarm(&label, groupRule.GroupId, result) //fmt.Println(timeFlag) logger.Info("不符合规则") return false,[]int{} } } @@ -253,7 +262,14 @@ //logger.Println("-----------------------------------------------听说你是空的？",faces) return locations } func putTargetsToResult(am *structure.AreaMap) []*structure.Arg { locations := []*structure.Arg{} if len(am.AlarmObj) > 0 { locations = am.AlarmObj } //logger.Println("-----------------------------------------------听说你是空的？",faces) return locations } // 联动任务的处理 func LinkTask(args *structure.SdkDatas, groupRule *protomsg.GroupRule, taskId string, message *protomsg.SdkMessage, label structure.Others) { // new一个定时器，如果以此groupId为标志的定时器不存在的话 @@ -406,7 +422,10 @@ func duration(rule *protomsg.Rule, groupId string, am *structure.AreaMap, args *structure.SdkDatas, message *protomsg.SdkMessage) string{ cacheId := "" if rule.PolygonId == am.AreaId { // 首先规则所对应的区域id要跟区域数据的id对的上 配置的算法要对的上 if rule.SdkArgAlias == "duration" && rule.SdkId != "812b674b-2375-4589-919a-5c1c3278a977"{ // 排除对画面中单个目标的算法，个体静止以及靠右行这种 if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a977" { // 排除对画面中单个目标的算法，个体静止以及靠右行这种 return "" } if rule.SdkArgAlias == "duration" { //logger.Info("当前小规则是：---------", rule) // 先看看定时器元素队列中是否有这条规则的定时器,如果有就不能再次创建了 rw.Lock() @@ -419,6 +438,9 @@ } if flag { //m := make(map[string]interface{}) //m["yolo"] = []structure.Result{} //m["yolo"] = append(m["yolo"].([]structure.Result), structure.Result{args.TaskId, "", "", true, 0, "", am.FilterData, am.AreaJson, false,*lable}) timeLength, _ := strconv.Atoi(rule.SdkArgValue) timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, nil}} // 扔进去一个定时器元素（并缓存当前画面帧数据） //TimeEleList = make(map[string]timeElement)
