---

panlei

2019-07-13 a31474f8d650dd5fba2d4c8bbe737c6ba6b17891

 ruleserver/ruleToformula.go

@@ -129,7 +129,7 @@
//protomsg.SdkMessage.TaskLabel.SdkmsgWithTask.sdkdata

type ResultMsg struct {
   protomsg.SdkMessage
   *protomsg.SdkMessage
   RuleResult map[string]interface{} // 过完规则后打的标签
}

@@ -186,7 +186,7 @@
}

// 对单帧图像的判断 thisSdkDatas  当前传入的这帧数据，cacheSdkData 定时器里缓存的一帧数据 没有就返回nil  (thisSdkDatas SdkDatas, cacheSdkDatas SdkDatas)
func Judge(args *SdkDatas) {
func Judge(args *SdkDatas,message *protomsg.SdkMessage) {
   if len(args.Sdkdata) > 0 {
      // 拿到本摄像机的区域
      cameraPolygons := GetPolygons(args.CameraId)
@@ -212,10 +212,10 @@
               if len(temp) > 0 {
                  if ruleList[i].SetType == "linkTask" {
                     // groupId中含有link则为联动任务
                     LinkTask(args, ruleList[i], taskId)
                     LinkTask(args, ruleList[i], taskId,message)
                  } else {
                     // 独立任务的处理
                     RunRule(args, ruleList[i], taskId)
                     RunRule(args, ruleList[i], taskId,message)
                  }
               }
            }
@@ -306,7 +306,7 @@
      }
   }
}
func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) bool {
func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string,message *protomsg.SdkMessage) bool {
   defer func() {
      if err := recover(); err != nil {
         logger.Error("比对规则有误", err.(string))
@@ -417,7 +417,7 @@
         if ipcId == sdkData.IpcId {
            for _, areaMap := range sdkData.AreaMapList {
               // 去开启一个定时器
               duration(groupRule.Rules[j], groupRule.GroupId, areaMap, args)
               duration(groupRule.Rules[j], groupRule.GroupId, areaMap, args,message)
            }
         }
      }
@@ -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
@@ -533,10 +539,14 @@
      } else { // 结果为假
         for k, timeEle := range TimeEleList {
            if strings.Contains(k, groupId) {
               logger.Debug("------------------------------重置定时器，此时的计数器的值为",timeEle.N)
               timeEle.N = timeEle.InitN // 重置定时器
               timeEle.CacheSdkData = SdkDatas{} // 把缓存数据扔了
               flagTime = "12"
               if timeEle.AlarmFlag {
                  logger.Debug("------------------------------杀死定时器，报警此帧状态改变的数据，此时的计数器的值为",timeEle.N)
                  flagTime = "12"
                  args.RuleResult["timeLabel"] = flagTime
                  delete(TimeEleList,k)
               } else {
                  delete(TimeEleList,k)
               }
            }
         }

@@ -544,6 +554,7 @@
   } else { // 无定时器
      if result {
         flagTime = "01"
         args.RuleResult["timeLabel"] = flagTime
      } else {
         flagTime = "00"
      }
@@ -628,7 +639,7 @@
}

// 联动任务的处理
func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) {
func LinkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string,message *protomsg.SdkMessage) {
   // new一个定时器，如果以此groupId为标志的定时器不存在的话
   logger.Info("------------------------------------------当前是联动任务，规则是：", groupRule.GroupText)
   var flag bool = true
@@ -658,7 +669,7 @@
      }
   }
   // 往数组里赋值
   isOk := RunRule(args, groupRule, taskId)
   isOk := RunRule(args, groupRule, taskId,message)
   if isOk {
      logger.Info("这帧图像在任务下的一整条规则下（联动任务下就是跟本摄像机像相关的小规则）的判断结果为true")
      // 根据cameraId去更新或者插入结果,然后判断是否数组是否可以得出报警的结论
@@ -854,7 +865,7 @@
}

// 如果有持续时间条件维护开启一个定时器
func duration(rule *protomsg.Rule, groupId string, am *AreaMap, args *SdkDatas) {
func duration(rule *protomsg.Rule, groupId string, am *AreaMap, args *SdkDatas,message *protomsg.SdkMessage) {
   if rule.PolygonId == am.areaId { // 首先规则所对应的区域id要跟区域数据的id对的上  配置的算法要对的上
      if rule.SdkArgAlias == "duration" { //
         // 先看看定时器元素队列中是否有这个摄像机这个区域的定时器,如果有就不能再次创建了
@@ -868,7 +879,7 @@

         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: ResultMsg{message,nil}} // 扔进去一个定时器元素（并缓存当前画面帧数据）
            //TimeEleList = make(map[string]timeElement)
            TimeEleList[groupId+" "+rule.Id] = &timeEle // 定时器元素以摄像机id拼接区域id为键
            logger.Info("创建了计数器并且计数器集合为：", TimeEleList)