panlei
2019-11-16 01556f81c04191f640bccc6f83f42c03dc008614
ruleserver/ruleToformula.go
@@ -102,18 +102,10 @@
   result := false
   sdkNames := ""
   polygonId := ""
   targets := []*structure.Arg{} // 符合条件的目标
   // 把一帧数据和一组规则发给算法部分,得出判断结果
   result,sdkNames,polygonId = CallMiddleware(args,*groupRule,&label,message)
   for _, sdkData := range args.Sdkdata {
      for _, areaMap := range sdkData.AreaMapList {
         targets = append(targets,areaMap.AlarmObj...)
         for _,obj := range areaMap.AlarmObj {
            logger.Info("个体静止的目标",obj.Id, obj.Location, obj.CacheData.Cid, len(obj.CacheData.Data))
         }
      }
   }
   //logger.Info("符合条件的目标数据:",targets)
   if result {
      // 最后过持续时间等时间维度的条件   把时间规则位置调整到这个位置是为了缓存数据         !!!!!ps: 对画面中单个目标做定时器的不用再过画面定时器
      cacheId := ""
@@ -238,6 +230,7 @@
      // 结果为假时也要走,有杀死定时器的操作
      TimerAlarm(&label, groupRule.GroupId, result)
      //fmt.Println(timeFlag)
      logger.Info("不符合规则")
      return false,[]int{}
   }
}
@@ -429,7 +422,10 @@
func duration(rule *protomsg.Rule, groupId string, am *structure.AreaMap, args *structure.SdkDatas, message *protomsg.SdkMessage) string{
   cacheId := ""
   if rule.PolygonId == am.AreaId { // 首先规则所对应的区域id要跟区域数据的id对的上  配置的算法要对的上
      if rule.SdkArgAlias == "duration" && rule.SdkId != "812b674b-2375-4589-919a-5c1c3278a977"{ // 排除对画面中单个目标的算法,个体静止以及靠右行这种
      if rule.SdkId == "812b674b-2375-4589-919a-5c1c3278a977" {  // 排除对画面中单个目标的算法,个体静止以及靠右行这种
         return ""
      }
      if rule.SdkArgAlias == "duration" {
         //logger.Info("当前小规则是:---------", rule)
         // 先看看定时器元素队列中是否有这条规则的定时器,如果有就不能再次创建了
         rw.Lock()
@@ -442,6 +438,9 @@
         }
         if flag {
            //m := make(map[string]interface{})
            //m["yolo"] = []structure.Result{}
            //m["yolo"] = append(m["yolo"].([]structure.Result), structure.Result{args.TaskId, "", "", true, 0, "", am.FilterData, am.AreaJson, false,*lable})
            timeLength, _ := strconv.Atoi(rule.SdkArgValue)
            timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, nil}} // 扔进去一个定时器元素(并缓存当前画面帧数据)
            //TimeEleList = make(map[string]timeElement)