---

panlei

2019-07-31 3987da3187e398620ec1f69efe819b89bd649517

 ruleserver/ruleToformula.go

@@ -121,6 +121,20 @@
      args.RuleResult["face"] = []FaceResult{}
      //logger.Warn("传进去之前是什么德行：",args.RuleResult["yolo"])
      if taskGroup != nil && len(taskGroup.GroupRules) > 0 {
         // 先过独立，再过联动
         for _, group := range taskGroup.GroupRules {
            //logger.Println("------------------------------任务规则：",taskRule)
            taskId := taskGroup.TaskId
            //logger.Println("------------本组任务下的规则组的数量：",len(ruleList))
            temp := group.Rules // temp为一组完整规则 在此需要判断规则是否是联动规则
            label := make(map[string]interface{})
            if len(temp) > 0 {
               if group.SetType != "linkTask" {
                  // 独立任务的处理
                  RunRule(args, group, taskId, message,label)
               }
            }
         }
         for _, group := range taskGroup.GroupRules {
            //logger.Println("------------------------------任务规则：",taskRule)
            taskId := taskGroup.TaskId
@@ -131,9 +145,6 @@
               if group.SetType == "linkTask" {
                  // groupId中含有link则为联动任务
                  LinkTask(args, group, taskId, message,label)
               } else {
                  // 独立任务的处理
                  RunRule(args, group, taskId, message,label)
               }
            }
         }
@@ -399,7 +410,7 @@
            }
         }
         if flag1 {
            TimeEleList[groupRule.GroupId].RuleResults = append(TimeEleList[groupRule.GroupId].RuleResults, &RuleResult{groupRule.Rules[j].CameraId, groupRule.Rules[j].Sort, "", groupRule.Rules[j].RuleWithPre,&ResultMsg{message,args.RuleResult}})
            TimeEleList[groupRule.GroupId].RuleResults = append(TimeEleList[groupRule.GroupId].RuleResults, &RuleResult{groupRule.Rules[j].CameraId, groupRule.Rules[j].Sort, "", groupRule.Rules[j].RuleWithPre,ResultMsg{}})
         }
      }
   }
@@ -412,6 +423,7 @@
      for _, va := range timeEle.RuleResults {
         if va.CameraId == args.CameraId {
            va.Result = strconv.FormatBool(isOk)
            va.CacheData = ResultMsg{message,args.RuleResult}
            logger.Info("这个摄像机--", args.CameraId, "--被赋予了result", va.Result)
         }
      }
@@ -439,11 +451,11 @@
            if result.(bool) {
               logger.Info("___________________________________________________________________联动任务报警")
               // 把数组里缓存的数据取出来一起报警
               label["linkCache"] = []*ResultMsg{}
               label["linkCache"] = []ResultMsg{}
               for _, ruleRes := range TimeEleList[groupRule.GroupId].RuleResults {
                  label["linkCache"] = append(label["linkCache"].([]*ResultMsg),ruleRes.CacheData)
                  label["linkCache"] = append(label["linkCache"].([]ResultMsg),ruleRes.CacheData)
               }
               logger.Debug("联动任务缓存了几个数据",len(label["linkCache"].([]*ResultMsg)))
               logger.Debug("联动任务缓存了几个数据",len(label["linkCache"].([]ResultMsg)))
               //os.Exit(1)
            }
         }