把插入es的so放进中间件

panlei

2019-12-11 4243a710f702b601b1d5a7dc2c765191c191201d

 algorithm/middleware/middleware.go

@@ -2,7 +2,7 @@

import (
   "basic.com/pubsub/protomsg.git"
   logger "github.com/alecthomas/log4go"
   "basic.com/valib/logger.git"
   "encoding/json"
   "github.com/knetic/govaluate"
   "plugin"
@@ -207,7 +207,7 @@
            // 根据规则的sdkId查出其对应的ipcId，用ipcId去找该比对的数据
            sdk, err := cache.GetSdkById(groupRule.Rules[j].SdkId)
            if err != nil {
               _ = logger.Error("没查到sdk的信息---", err)
               logger.Error("没查到sdk的信息---", err)
            }
            ipcId := sdk.IpcId
            sdkName := sdk.SdkName
@@ -362,19 +362,23 @@
func CallSo(sdkId string,rule *protomsg.Rule, am *structure.AreaMap,lable *structure.Others,args *structure.SdkDatas,message *protomsg.SdkMessage) structure.LittleRuleResult{
   // 根据sdkId查出其对应的sdk的soName，调用相应so的Entrance方法
   var soName = ""
   if sdkId == "812b674b-2375-4589-919a-5c1c3278a97e" {

   switch sdkId {
   case "812b674b-2375-4589-919a-5c1c3278a97e":
      soName = "face.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a975"{
   case "812b674b-2375-4589-919a-5c1c3278a975":
      soName = "intrusion.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a976" || sdkId == "812b674b-2375-4589-919a-5c1c3278a973" {
   case "812b674b-2375-4589-919a-5c1c3278a976":
      soName = "personUnsual.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
   case "812b674b-2375-4589-919a-5c1c3278a973":
      soName = "personUnsual.so"
   case "812b674b-2375-4589-919a-5c1c3278a972":
      soName = "faceCompare.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a977" {
   case "812b674b-2375-4589-919a-5c1c3278a977":
      soName = "static.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a978" {
   case "812b674b-2375-4589-919a-5c1c3278a978":
      soName = "plate.so"
   } else if sdkId == "人体跟踪" {
   case "人体跟踪":
      soName = "personTrack.so"
   }
   //soInfo,err := cache.GetSoInfoById(sdkId)