panlei
2019-11-07 6e8ebf781ac457b7ec77f7e4c9ade4c3d36002bc
ruleserver/ruleToformula.go
@@ -1,6 +1,9 @@
package ruleserver
import (
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/logger.git"
   "github.com/knetic/govaluate"
   "plugin"
   "ruleprocess/cache"
   "ruleprocess/structure"
@@ -78,30 +81,6 @@
         }
      }
   }
}
func CallSo(sdkId string,rule *protomsg.Rule, am *structure.AreaMap) structure.LittleRuleResult{
   // 根据sdkId查出其对应的sdk的soName,调用相应so的Entrance方法
   var soName = ""
   if sdkId == "812b674b-2375-4589-919a-5c1c3278a97e" {
      soName = "face.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a975"{
      soName = "intrusion.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a976" {
      soName = "personUnsual.so"
   } else if sdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
      soName = "faceCompare.so"
   }
   p,err :=  plugin.Open("./algorithm/"+soName)
   if err != nil {
      panic(err)
   }
   f,err1 := p.Lookup("Entrance")
   if err1 != nil {
      panic("没有找到入口函数")
   }
   ruleResult := f.(func(rule *protomsg.Rule, am *structure.AreaMap)structure.LittleRuleResult)(rule,am)
   return ruleResult
}
func CallMiddleware(args *structure.SdkDatas,rule protomsg.GroupRule) ([]*structure.LittleRuleResult, string, string){
@@ -484,59 +463,3 @@
   return cacheId
}
func timeRuleResult(rule *protomsg.Rule, am *structure.AreaMap) structure.LittleRuleResult {
   if rule.PolygonId == am.AreaId { // 首先规则所对应的区域id要跟区域数据的id对的上
      if rule.SdkArgAlias == "time_rule" { // 判断是否符合时间规
         //logger.Info("----------当前时间规则:---------", rule)
         // 根据放值字段里存的时间规则的id去另一个表里查需要比对的时间段(比如当前时间是周三,应根据区域id查出其周三的几个布防时间段,数组)
         //logger.Info("时间规则的测试")
         now := time.Now()
         index := getIndexOfWeek(now.Weekday().String())
         timeList := GetTimeById(rule.SdkArgValue, index)
         //logger.Info("当天的时间段集合:----------", timeList)
         //logger.Info("从数据库中查出的时间规则:", timeList)
         // 判断图片数据的时间是否符合当前规则 在一个即为true,全不在为false
         if rule.Operator == "satisfy" || rule.Operator == "==" { // 满足所选的时间规则
            flag := "false"
            for _, timeSlot := range timeList {
               formula := "'" + timeSlot.Start + "'" + "<" + "'" + am.Time + "'"
               expression, _ := govaluate.NewEvaluableExpression(formula) // 得到数学公式
               result, _ := expression.Evaluate(nil)                      // 得到数学公式的结果
               formula1 := "'" + timeSlot.End + "'" + ">" + "'" + am.Time + "'"
               expression1, _ := govaluate.NewEvaluableExpression(formula1) // 得到数学公式
               result1, _ := expression1.Evaluate(nil)                      // 得到数学公式的结果
               //logger.Info("看看这两尊大神", result, result1)
               if result.(bool) && result1.(bool) {
                  flag = "true"
                  break
               }
            }
            return structure.LittleRuleResult{am.SdkName, rule.RuleWithPre + "" + flag, rule.Sort}
         }
         if rule.Operator == "unsatisfy" || rule.Operator == "!=" { // 不满足所选的时间规则
            flag := "true"
            for _, timeSlot := range timeList {
               formula := "'" + timeSlot.Start + "'" + " < " + "'" + am.Time + "'"
               //logger.Info("-----------------时间规则不满足的公式start:", formula)
               expression, _ := govaluate.NewEvaluableExpression(formula) // 得到数学公式
               result, _ := expression.Evaluate(nil)                      // 得到数学公式的结果
               formula1 := "'" + timeSlot.End + "'" + " > " + "'" + am.Time + "'"
               //logger.Info("-----------------时间规则不满足的公式end:", formula1)
               expression1, _ := govaluate.NewEvaluableExpression(formula1) // 得到数学公式
               result1, _ := expression1.Evaluate(nil)                      // 得到数学公式的结果
               if result.(bool) && result1.(bool) {
                  flag = "false"
                  break
               }
            }
            return structure.LittleRuleResult{am.SdkName, rule.RuleWithPre + "" + flag, rule.Sort}
         }
      }
   }
   return structure.LittleRuleResult{}
}