panlei
2019-07-13 ac8aa9785bc3c31afb7eb5a430efdf45cf9dccc3
修改定时器的缓存结果标签
2个文件已修改
10 ■■■■ 已修改文件
ruleserver/ruleToformula.go 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/timeTicker.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
ruleserver/ruleToformula.go
@@ -489,6 +489,12 @@
            if args.RuleResult["face"] != nil {
                logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]Arg)))
            }
            // 给定时器里缓存的那帧数据赋结果标签
            for k, timeEle := range TimeEleList {
                if strings.Contains(k, groupRule.GroupId) {
                    timeEle.CacheSdkData.RuleResult = args.RuleResult
                }
            }
            return true
        } else {
            return false
@@ -873,7 +879,7 @@
            if flag {
                timeLength, _ := strconv.Atoi(rule.SdkArgValue)
                timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: &ResultMsg{message,args.RuleResult}} // 扔进去一个定时器元素(并缓存当前画面帧数据)
                timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: ResultMsg{message,nil}} // 扔进去一个定时器元素(并缓存当前画面帧数据)
                //TimeEleList = make(map[string]timeElement)
                TimeEleList[groupId+" "+rule.Id] = &timeEle // 定时器元素以摄像机id拼接区域id为键
                logger.Info("创建了计数器并且计数器集合为:", TimeEleList)
ruleserver/timeTicker.go
@@ -17,7 +17,7 @@
    InitN        int                  // 赋值后就不变的初始值
    BufferFlag   int                  // 缓冲容错位 连续帧false才为false
    AlarmFlag    bool                 // 报警标志位 定时器开启后第一次报警时会被置为true 往后再来报警也不会插进ES
    CacheSdkData *ResultMsg // 定时器的缓存数据 持续时间类的开启定时器时要缓存一帧
    CacheSdkData ResultMsg // 定时器的缓存数据 持续时间类的开启定时器时要缓存一帧
    GroupId      string               // 联动规则需要记录下此时的规则组id
    RuleResults  []*RuleResult
}