| | |
| | | // logger.Info("具体目标:",tar.Location) |
| | | //} |
| | | for _, tar := range structure.StaticMap[am.AreaId].Targets { |
| | | singleResult,arg := SingleStatic(tar,am,lable,95) |
| | | singleResult,arg := SingleStatic(tar,am,lable,90) |
| | | if singleResult { |
| | | flag = "true" |
| | | tars = append(tars,arg) |
| | |
| | | } |
| | | // 把数据装配到label |
| | | func (label *Label)DataFormatToLabel(result structure.ResultMsg) { |
| | | logger.Debug("face结果:",result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.Result)) > 0) |
| | | logger.Debug("yolo结果:",result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0) |
| | | if (result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.Result)) > 0) || (result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0) { // 得有人脸或者yolo规则才可以 |
| | | if (result.RuleResult["face"] != nil && len(result.RuleResult["face"].([]structure.Result)) > 0) || |
| | | (result.RuleResult["yolo"] != nil && len(result.RuleResult["yolo"].([]structure.Result)) > 0) || |
| | | (result.RuleResult["target"] != nil && len(result.RuleResult["target"].([]structure.Result)) > 0){ // 得有人脸或者yolo规则才可以 |
| | | |
| | | // 先判断一下数据带的规则标签是否有报警的可以推送的 |
| | | flag := false |
| | |
| | | result := false |
| | | sdkNames := "" |
| | | polygonId := "" |
| | | //targets11 := []*structure.Arg{} // 符合条件的目标 |
| | | |
| | | // 把一帧数据和一组规则发给算法部分,得出判断结果 |
| | | result,sdkNames,polygonId = CallMiddleware(args,*groupRule,&label,message) |
| | | //for _, sdkData := range args.Sdkdata { |
| | | // for _, areaMap := range sdkData.AreaMapList { |
| | | // targets11 = append(targets11,areaMap.AlarmObj...) |
| | | // for _,obj := range areaMap.AlarmObj { |
| | | // logger.Info("个体静止的目标",obj.Id, obj.Location, obj.CacheData.Cid, len(obj.CacheData.Data)) |
| | | // } |
| | | // } |
| | | //} |
| | | //logger.Info("符合条件的目标数据:",targets) |
| | | |
| | | if result { |
| | | // 最后过持续时间等时间维度的条件 把时间规则位置调整到这个位置是为了缓存数据 !!!!!ps: 对画面中单个目标做定时器的不用再过画面定时器 |
| | | cacheId := "" |
| | |
| | | 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() |
| | |
| | | } |
| | | |
| | | 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) |