把插入es的so放进中间件

panlei

2019-12-11 4243a710f702b601b1d5a7dc2c765191c191201d

 ruleserver/ruleToformula.go

@@ -5,7 +5,7 @@
   "github.com/knetic/govaluate"
   "plugin"
   "ruleprocess/cache"
   logger "github.com/alecthomas/log4go"
   "basic.com/valib/logger.git"
   "ruleprocess/structure"
   "sort"
   "strconv"
@@ -119,6 +119,7 @@
   result,sdkNames,polygonId = CallMiddleware(args,*groupRule,&label,message)

   if result {

      // 最后过持续时间等时间维度的条件   把时间规则位置调整到这个位置是为了缓存数据         ！！！！！ps: 对画面中单个目标做定时器的不用再过画面定时器
      for j := 0; j < len(groupRule.Rules); j++ {
         for _, sdkData := range args.Sdkdata {
@@ -355,7 +356,7 @@
         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,label})
            m["yolo"] = append(m["yolo"].([]structure.Result), structure.Result{args.TaskId, "", "", true, 0, "", am.FilterData, true,am.AreaJson, false,label})
            timeLength, _ := strconv.Atoi(rule.SdkArgValue)
            timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, BufferFlag: 10, CacheSdkData: structure.ResultMsg{message, m}} // 扔进去一个定时器元素（并缓存当前画面帧数据）
            //TimeEleList = make(map[string]timeElement)
@@ -370,6 +371,7 @@
}

func AssembResultLabel(args *structure.SdkDatas, groupRule *protomsg.GroupRule,sdkNames string,taskId string,polygonId string,label structure.Others) []int{

   faces := []*structure.Arg{}
   yolos := []*structure.Arg{}
   targets := []*structure.Arg{}
@@ -427,27 +429,27 @@
   //logger.Info("触发的区域id：",polygonId)
   var labelTypes []int // 0为yolo标签，1为face标签 2为两者标签
   if sdkNames != "" && len(targets) == 0 {
      args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, yolos, polygonId, islink,label})
      args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, yolos, true,polygonId, islink,label})
      labelTypes = append(labelTypes,0)
      //logger.Info("-------------------yolo结果标签长度", len(args.RuleResult["yolo"].([]Result)))
   }
   if faceFlag {
      args.RuleResult["face"] = append(args.RuleResult["face"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, faces, polygonId, islink,label})
      args.RuleResult["face"] = append(args.RuleResult["face"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, faces, false,polygonId, islink,label})
      //logger.Info("-------------------face结果标签", len(args.RuleResult["face"].([]structure.Result)))
      labelTypes = append(labelTypes,1)
   }
   if len(targets) > 0 {
      args.RuleResult["target"] = append(args.RuleResult["target"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, targets, polygonId, islink,label})
      args.RuleResult["target"] = append(args.RuleResult["target"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, targets, false,polygonId, islink,label})
      //logger.Info("-------------------目标持续结果标签", len(args.RuleResult["target"].([]structure.Result)))
      labelTypes = append(labelTypes,2)
   }
   if len(cars) > 0 {
      args.RuleResult["plate"] = append(args.RuleResult["plate"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, cars, polygonId, islink,label})
      args.RuleResult["plate"] = append(args.RuleResult["plate"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, cars, false,polygonId, islink,label})
      //logger.Info("-------------------车牌结果标签", len(args.RuleResult["plate"].([]structure.Result)))
      labelTypes = append(labelTypes,3)
   }
   if len(personTrack) > 0 {
      args.RuleResult["track"] = append(args.RuleResult["track"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, personTrack, polygonId, islink,label})
      args.RuleResult["track"] = append(args.RuleResult["track"].([]structure.Result), structure.Result{taskId, sdkNames, groupRule.GroupId, groupRule.DefenceState, groupRule.AlarmLevel, groupRule.GroupText, personTrack, false,polygonId, islink,label})
      //logger.Info("-------------------车牌结果标签", len(args.RuleResult["plate"].([]structure.Result)))
      labelTypes = append(labelTypes,4)
   }