派生自 ruleprocess
ruleserver/ruleToformula.go
@@ -222,6 +222,25 @@ } } } func (arg *Arg) fillLiker(){ bytes := bigCache.Getdbpersonmsg("", arg.Feature, true) var m map[string]float32 err1 := json.Unmarshal(bytes, &m) if err1 != nil { logger.Error("getBaseInfo解压错误", err1) } logger.Info("----------------------------------------map是", m) for key, val := range m { logger.Info("_______________________________________对比库的返回值", key, val) baseinfo, err1 := esutil.Dbpersoninfosbyid(key) if err1 != nil { logger.Error("查询底库人员信息出错", err1) } baseinfo.CompareScore = val arg.Liker = append(arg.Liker, &baseinfo) } //logger.Info("------------------第一次看args:",*arg) } func Compare(args *SdkDatas, groupRule *protomsg.GroupRule) { compareFlag := 0 tableIds := "" @@ -247,28 +266,13 @@ if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a972" { for _, sdkData := range args.Sdkdata { if sdkData.IpcId == "A8B73405-373D-4F23-CED2-A617EBD7EC55" { // 搜索到人脸检测的sdkdata 现在关于人脸的只有他一个sdk，全找他 logger.Info("============================================第一关") logger.Info("============================================第一关") for _, areaMap := range sdkData.AreaMapList { // 拿区域中每个人脸特征值去对比，填充其liker if groupRule.Rules[j].PolygonId == areaMap.areaId { for _, arg := range areaMap.args { if compareFlag == 1 { bytes := bigCache.Getdbpersonmsg("", arg.Feature, true) var m map[string]float32 err1 := json.Unmarshal(bytes, &m) if err1 != nil { logger.Error("getBaseInfo解压错误", err1) } logger.Info("----------------------------------------map是",m) for key, val := range m { logger.Info("_______________________________________对比库的返回值",key,val) baseinfo, err1 := esutil.Dbpersoninfosbyid(key) if err1 != nil { logger.Error("查询底库人员信息出错", err1) } baseinfo.CompareScore = val arg.Liker = append(arg.Liker, &baseinfo) } arg.fillLiker() } if compareFlag == 2 { array := strings.Split(tableIds, ",") @@ -289,8 +293,9 @@ } } } logger.Info("-------------------成功给liker赋值：", arg.Liker) logger.Info("-------------------成功给liker赋值,长度为：", len(arg.Liker)) } //logger.Info("=======第一次看args：",areaMap.args) } } } @@ -304,7 +309,7 @@ logger.Error("比对规则有误", err.(string)) } }() logger.Info("+++++++++++规则开始运行+++++++++++++++++当前规则--：", *groupRule) logger.Info("+++++++++++规则开始运行+++++++++++++++++当前大规则--：", *groupRule) Compare(args, groupRule) resultSplice := []*LittleRuleResult{} sdkNames := "" @@ -318,7 +323,7 @@ } ipcId := sdk.IpcId sdkName := sdk.SdkName logger.Info("规则的ipcId与sdkData的IpcId:",ipcId,"===",sdkData.IpcId) if ipcId == sdkData.IpcId { logger.Info("当前走的规则的算法是--：", sdkName, "---") for _, areaMap := range sdkData.AreaMapList { @@ -393,7 +398,8 @@ ipcId := sdk.IpcId if ipcId == sdkData.IpcId { for _, areaMap := range sdkData.AreaMapList { duration(groupRule.Rules[j], &areaMap, args) // 去开启一个定时器 duration(groupRule.Rules[j], groupRule.GroupId, &areaMap, args) } } } @@ -429,7 +435,7 @@ // 给这帧数据打上规则组标签 //args.RuleResult = append(args.RuleResult, Result{TaskId: taskId, RuleGroupId: groupRule.GroupId}) for k, timeEle := range TimeEleList { if strings.Contains(k, taskId) { if strings.Contains(k, groupRule.GroupId) { timeEle.N = timeEle.InitN // 重置定时器 } } @@ -439,8 +445,8 @@ // 判断持续时间条件，去看池子里是否有与本帧数据有关的定时器，如果有，看此时是否走到0，没有此定时器或有定时器走到0的话返回成功报警 var flag bool = true for k, timeEle := range TimeEleList { if strings.Contains(k, taskId) { if timeEle.N != 0 { // 跟这个任务有关的定时器要全部等于0 if strings.Contains(k, groupRule.GroupId) { if timeEle.N != 0 { // 这组规则的定时器要全部等于0 logger.Info("———————————-------------不冤，你是被定时器打败的：") flag = false } @@ -492,6 +498,23 @@ } else { return false } } func TimerAlarm(groupId string) (int){ var flagTime int = 0 for k, timeEle := range TimeEleList { if strings.Contains(k, groupId) { if timeEle.N == 0 && !timeEle.AlarmFlag { // 这组规则的定时器要全部等于0 暂且认为一组规则只有一个定时器 logger.Info("———————————-------------首次符合持续时间规则并报警") flagTime = 1 timeEle.AlarmFlag = true } if timeEle.N == 0 && timeEle.AlarmFlag { logger.Info("-------------------------符合持续时间规则但并不是首次，不报警") flagTime = 2 } } } return flagTime } func putFaceToResult(am *AreaMap) []Arg { @@ -664,7 +687,7 @@ if rule.PolygonId == am.areaId { // 算法和区域都得对的上 if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a972" && rule.SdkArgAlias != "time_rule" { // 只需要过滤阈值，过滤完后数组长度大于0即为报警，但要考虑如何对每一张都报警呢 // 只需要过滤阈值，过滤完后数组长度大于0即为报警 argValue, err := strconv.ParseFloat(rule.SdkArgValue, 64) if err != nil { logger.Error("规则配置的阈值非法") @@ -796,40 +819,28 @@ } } // 都过滤完条件之后看看是否满足持续时间条件 func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) LittleRuleResult{ // 如果有持续时间条件维护开启一个定时器 func duration(rule *protomsg.Rule, groupId string, am *AreaMap, args *SdkDatas) { if rule.PolygonId == am.areaId { // 首先规则所对应的区域id要跟区域数据的id对的上 配置的算法要对的上 if rule.SdkArgAlias == "duration" { // // 先看看定时器元素队列中是否有这个摄像机这个区域的定时器,如果有就不能再次创建了 var flag bool = true for k,value := range TimeEleList { if k == am.taskId+" "+am.sdkId+" "+am.areaId { for k, _ := range TimeEleList { if k == groupId+" "+rule.Id { 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} } } } if flag { timeLength, _ := strconv.Atoi(rule.SdkArgValue) timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: *args} // 扔进去一个定时器元素 timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: *args} // 扔进去一个定时器元素（并缓存当前画面帧数据） //TimeEleList = make(map[string]timeElement) TimeEleList[am.taskId+" "+am.sdkId+" "+am.areaId] = &timeEle // 定时器元素以摄像机id拼接区域id为键 TimeEleList[groupId+" "+rule.Id] = &timeEle // 定时器元素以摄像机id拼接区域id为键 logger.Info("创建了计数器并且计数器集合为：", TimeEleList) return LittleRuleResult{am.sdkName, "false" + "" + rule.RuleWithPre, rule.Sort} } } } return LittleRuleResult{} } // 给数据库的规则表达式代参 args: 一条子规则，区域数据
