---

panlei

2019-07-10 34ab325a3da7d937bc27b6ba1116a28a7fac8082

---

 ruleserver/ruleToformula.go

@@ -438,6 +438,7 @@
        } else {
            // 判断持续时间条件，去看池子里是否有与本帧数据有关的定时器，如果有，看此时是否走到0，没有此定时器或有定时器走到0的话返回成功报警
            var flag bool = true
            logger.Info("flag 是：",flag)
            for k, timeEle := range TimeEleList {
                if strings.Contains(k, taskId) {
                    if timeEle.N != 0 { // 跟这个任务有关的定时器要全部等于0
@@ -446,7 +447,7 @@
                    }
                }
            }
            if flag {
            if true {
                // 最后成功报警才把符合条件的人脸数据塞进结果标签里
                // 配了人脸的算法才把人脸的数据甩出来打标签
                logger.Info("------------------------------最后一关")
@@ -797,25 +798,15 @@
}

// 都过滤完条件之后看看是否满足持续时间条件
func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) LittleRuleResult{
func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) {
    if rule.PolygonId == am.areaId { // 首先规则所对应的区域id要跟区域数据的id对的上  配置的算法要对的上
        if rule.SdkArgAlias == "duration" { //
            // 先看看定时器元素队列中是否有这个摄像机这个区域的定时器,如果有就不能再次创建了
            var flag bool = true
            for k,value := range TimeEleList {
            for k,_ := range TimeEleList {
                if k == am.taskId+" "+am.sdkId+" "+am.areaId {
                    flag = false // 有就置为false
                    logger.Info("有这个定时器，不再创建了：")
                    // 看看定时器中的值是否为0 如果为0应该报警，如果不为0返回false，未达到持续时间的要求
                    if value.N == 0 && !value.AlarmFlag{
                        // 报警之后改为置为true 后面的报警图片就不报了,顺便把缓存的那张图片也给结果标签
                        value.AlarmFlag = true
                        args.RuleResult["cacheData"] = value.CacheSdkData
                        return LittleRuleResult{am.sdkName, "true" + "" + rule.RuleWithPre, rule.Sort}
                    }else {
                        logger.Info("------------------------------持续时间条件不满足")
                        return LittleRuleResult{am.sdkName, "false" + "" + rule.RuleWithPre, rule.Sort}
                    }
                }
            }

@@ -825,11 +816,9 @@
                //TimeEleList = make(map[string]timeElement)
                TimeEleList[am.taskId+" "+am.sdkId+" "+am.areaId] = &timeEle // 定时器元素以摄像机id拼接区域id为键
                logger.Info("创建了计数器并且计数器集合为：", TimeEleList)
                return LittleRuleResult{am.sdkName, "false" + "" + rule.RuleWithPre, rule.Sort}
            }
        }
    }
    return LittleRuleResult{}
}

// 给数据库的规则表达式代参 args: 一条子规则，区域数据