减少日志量外加放开标签过滤器

panlei

2019-10-24 c165dbb634d3c8f3446d499c25894e8d61945c2d

 ruleserver/ruleToformula.go

@@ -244,7 +244,7 @@
                  }
               }
            }
            logger.Info("face标签的长度：",len(faces))
            //logger.Info("face标签的长度：",len(faces))
            //for _,face := range faces  {
            //   //logger.Debug("————————————————________________看看人脸的坐标:",face.Location)
            //}
@@ -339,20 +339,20 @@
         timeEle = *timeEle1
      }
   }
   for _,ruleRe := range timeEle.RuleResults {
      logger.Info("联动数组里的数据----",ruleRe.CameraId,ruleRe.Sort)
   }
   //for _,ruleRe := range timeEle.RuleResults {
   //   logger.Info("联动数组里的数据----",ruleRe.CameraId,ruleRe.Sort)
   //}
   if flag { // 如果还没有这个定时器元素就新增一个
      //timeEle := TimeElement{N: 2, InitN: 2, GroupId: groupRule.GroupId} // 扔进去一个定时器元素
      //TimeEleList = make(map[string]timeElement)
      TimeEleList[groupRule.GroupId] = &timeEle // 定时器元素以规则组id为键
      logger.Info("---------------------------------------------联动任务创建了计数器并且计数器集合为：", TimeEleList)
      //logger.Info("---------------------------------------------联动任务创建了计数器并且计数器集合为：", TimeEleList)
      // 得出这组完整规则里涉及到几个摄像机，决定着数组里有几个结构体,去重添加方式
      for j := 0; j < len(groupRule.Rules); j++ {
         var flag1 bool = true
         logger.Info("规则组信息：",groupRule.Rules[j].CameraId)
         //logger.Info("规则组信息：",groupRule.Rules[j].CameraId)
         for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
            logger.Info("联动数组里的数据：",ruleRes.CameraId,ruleRes.Sort)
            //logger.Info("联动数组里的数据：",ruleRes.CameraId,ruleRes.Sort)
            if groupRule.Rules[j].CameraId == ruleRes.CameraId {
               flag1 = false
            }
@@ -421,7 +421,7 @@
                  for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
                     label.LinkCache = append(label.LinkCache, ruleRes.CacheData)
                  }
                  logger.Debug("联动任务缓存了几个数据", len(label.LinkCache))
                  //logger.Debug("联动任务缓存了几个数据", len(label.LinkCache))
                  for i := 0; i < len(args.RuleResult["yolo"].([]structure.Result)); i++ {
                     if args.RuleResult["yolo"].([]structure.Result)[i].RuleGroupId == groupRule.GroupId { // 把联动数据追加上
                        args.RuleResult["yolo"].([]structure.Result)[i].Others.LinkCache = label.LinkCache
@@ -492,7 +492,7 @@
               // 把没有相似者的人脸从filterData中删除
               for index := 0; index < len(am.FilterData); {
                  // 将达不到阈值的相似者从相似者数组中删除
                  logger.Info("看看相似者人数：",len(am.FilterData[index].Liker))
                  //logger.Info("看看相似者人数：",len(am.FilterData[index].Liker))
                  if len(am.FilterData[index].Liker) == 0 {
                     // Go 语言中切片删除元素的本质是：以被删除元素为分界点，将前后两个部分的内存重新连接起来。不用怀疑，数组删除元素就这么坑爹
                     am.FilterData = append(am.FilterData[:index], am.FilterData[index+1:]...)
@@ -503,7 +503,7 @@
               if len(am.FilterData) > 0 {
                  flag = "true"
               }
               logger.Info("---------人脸比对符合条件的数量为：",len(am.FilterData))
               //logger.Info("---------人脸比对符合条件的数量为：",len(am.FilterData))
               return structure.LittleRuleResult{am.SdkName, rule.RuleWithPre + "" + flag, rule.Sort}
            }
         }
@@ -512,7 +512,7 @@
            if rule.Operator == "==" || rule.Operator == ">=" || rule.Operator == "<=" || rule.Operator == "<" || rule.Operator == ">" || rule.Operator == "!=" {
               // 如果是不规矩的连接符统统返回false 规则也只能判断人脸的相似度，所以不存在别的连接符
               if rule.SdkArgAlias == "score" || rule.SdkArgAlias == "proportion" || rule.SdkArgAlias == "size" { // 判断的是相似值，占比，尺寸等过滤条件，如果再有，还可以再加
                  logger.Info("-----------------------过规则之前区域内的人脸数量为：",am.TargetNum)
                  //logger.Info("-----------------------过规则之前区域内的人脸数量为：",am.TargetNum)
                  var args []*structure.Arg
                  if rule.RuleWithPre == "&&" {
                     args = am.FilterData
@@ -544,7 +544,7 @@
                     }
                  }
                  am.TargetNum = len(am.FilterData) // 把符合条件的目标数量更新到targetNum字段
                  logger.Info("过完条件后的目标数量为：",am.TargetNum)
                  //logger.Info("过完条件后的目标数量为：",am.TargetNum)
                  if am.TargetNum > 0 {
                     logger.Info("！！！！！！！！！人脸检测成功")
                     return structure.LittleRuleResult{am.SdkName, rule.RuleWithPre + "" + "true", rule.Sort}
@@ -615,14 +615,14 @@
func duration(rule *protomsg.Rule, groupId string, am *structure.AreaMap, args *structure.SdkDatas, message *protomsg.SdkMessage) {
   if rule.PolygonId == am.AreaId { // 首先规则所对应的区域id要跟区域数据的id对的上  配置的算法要对的上
      if rule.SdkArgAlias == "duration" { //
         logger.Info("当前小规则是：---------", rule)
         //logger.Info("当前小规则是：---------", rule)
         // 先看看定时器元素队列中是否有这条规则的定时器,如果有就不能再次创建了
         rw.Lock()
         var flag bool = true
         for k, _ := range TimeEleList {
            if k == groupId+"+"+rule.Id {
               flag = false // 有就置为false
               logger.Info("有这个定时器，不再创建了：")
               //logger.Info("有这个定时器，不再创建了：")
            }
         }

@@ -631,7 +631,7 @@
            timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, args.RuleResult}} // 扔进去一个定时器元素（并缓存当前画面帧数据）
            //TimeEleList = make(map[string]timeElement)
            TimeEleList[groupId+"+"+rule.Id] = &timeEle // 定时器元素以当前持续时间小规则id为键
            logger.Info("创建了计数器")
            //logger.Info("创建了计数器")
         }
         rw.Unlock()
      }