完善持续时间条件的判断

panlei

2019-07-10 a49dcd9e6d0cca3cecaa520c06295666de9b9630

完善持续时间条件的判断

 ruleserver/ruleToformula.go

@@ -390,9 +390,17 @@
                logger.Error("没查到sdk的信息---", err)
            }
            ipcId := sdk.IpcId
            sdkName := sdk.SdkName
            if ipcId == sdkData.IpcId {
                for _, areaMap := range sdkData.AreaMapList {
                    duration(groupRule.Rules[j], &areaMap, args)
                    ruleResult := duration(groupRule.Rules[j], &areaMap, args)
                    if ruleResult.Result != "" {
                        logger.Info("时间规则结果：", ruleResult.Result)
                        if ruleResult.Result == "true" && !strings.Contains(sdkNames, sdkName) {
                            sdkNames = sdkName + ","
                        }
                        resultSplice = append(resultSplice, &ruleResult)
                    }
                }
            }
        }
@@ -795,15 +803,22 @@
}

// 都过滤完条件之后看看是否要创建一个定时器元素 创建定时器的条件：是否有靠右行，个体静止等自带定时器含义的算法以及是否有持续时间
func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) {
func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) LittleRuleResult{
    if rule.PolygonId == am.areaId { // 首先规则所对应的区域id要跟区域数据的id对的上  配置的算法要对的上
        if rule.SdkArgAlias == "duration" { //
            // 先看看定时器元素队列中是否有这个摄像机这个区域的定时器,如果有就不能再次创建了
            var flag bool = true
            for k, _ := range TimeEleList {
            for k,value := range TimeEleList {
                if k == am.taskId+" "+am.sdkId+" "+am.areaId {
                    flag = false // 有就置为false
                    logger.Info("有这个定时器，不再创建了：")
                    // 看看定时器中的值是否为0 如果为0应该报警，如果不为0返回false，未达到持续时间的要求
                    if value.N == 0 {
                        return LittleRuleResult{am.sdkName, "true" + "" + rule.RuleWithPre, rule.Sort}
                    }else {
                        logger.Info("------------------------------持续时间条件不满足")
                        return LittleRuleResult{am.sdkName, "false" + "" + rule.RuleWithPre, rule.Sort}
                    }
                }
            }

@@ -813,9 +828,11 @@
                //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: 一条子规则，区域数据