指针传递改为值传递

panlei

2019-06-29 2ef897766c8222b7d907ebed8a951e9a72f7877b

 ruleserver/ruleToformula.go

@@ -112,7 +112,7 @@
   IsStatic    bool       // 是否静止
   ImageWidth  int        // 摄像机拍摄的图像宽 像素
   ImageHeight int        // 摄像机拍摄的图像高 像素
   AreaMapList []*AreaMap // 本sdk提取的数据按照区域划分后的数据集合
   AreaMapList []AreaMap // 本sdk提取的数据按照区域划分后的数据集合
}

// 从算法模块儿拿来的对一帧图像各个算法提取的数据集合
@@ -177,10 +177,10 @@
}

// 把sdk从数据帧上提取的按照区域分类归置
func SdkDataFormat(cameraId string, arg *SdkData, cameraPolygons []protomsg.CameraPolygon) {
func SdkDataFormat(cameraId string, arg SdkData, cameraPolygons []protomsg.CameraPolygon) {
   for _, polygon := range cameraPolygons {
      //log.Println("++++++在这儿看一下区域啊", polygon)
      areaMap := &AreaMap{cameraId: cameraId, areaId: polygon.Id, areaJson: polygon.Polygon, triggerLine: polygon.TriggerLine, directionLine: polygon.DirectionLine}
      areaMap := AreaMap{cameraId: cameraId, areaId: polygon.Id, areaJson: polygon.Polygon, triggerLine: polygon.TriggerLine, directionLine: polygon.DirectionLine}
      // 为每个摄像机区域填充数据
      areaMap.CountAreaObjs(arg)
      log.Println("-------areaMap的内容",areaMap)
@@ -190,13 +190,13 @@
}

// 对单帧图像的判断 是舍弃（或者说对于某些需求可以放ES数据库一份）还是返回
func Judge(args *SdkDatas) {
func Judge(args SdkDatas) {
   if len(args.Sdkdata) > 0 {
      // 拿到本摄像机的区域
      cameraPolygons := GetPolygons(args.CameraId)
      // 把所有的sdk提取的数据都按所属摄像机的区域归置
      for _, arg := range args.Sdkdata {
         SdkDataFormat(args.CameraId, &arg, cameraPolygons)
         SdkDataFormat(args.CameraId, arg, cameraPolygons)
      }
      // 跑本摄像机的所有规则组 一组一组跑
      taskRuleList := GetRuleGroup(args.CameraId) // 本摄像机下所有任务组
@@ -226,17 +226,16 @@
      }
   }
}
func RunRule(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) bool {
func RunRule(args SdkDatas, groupRule *protomsg.GroupRule, taskId string) bool {
   resultSplice := []*LittleRuleResult{}
   // 先过完条件规则
   log.Println("---------------------看下这个组规则：", groupRule.Rules)
   for j := 0; j < len(groupRule.Rules); j++ {
      for _, sdkData := range args.Sdkdata {
         if sdkData.SdkId == "812b674b-2375-4589-919a-5c1c3278a975" {
            log.Println("入侵的算法数据", sdkData)
         }
         for _, areaMap := range sdkData.AreaMapList {
            ruleResult := filterRule(groupRule.Rules[j], areaMap)
            ruleResult := filterRule(groupRule.Rules[j], &areaMap)
            if ruleResult.Result != "" {
               log.Println("条件规则结果：", ruleResult.Result)
               resultSplice = append(resultSplice, &ruleResult)
@@ -249,7 +248,7 @@
   for _, sdkData := range args.Sdkdata {
      for _, areaMap := range sdkData.AreaMapList {
         for j := 0; j < len(groupRule.Rules); j++ {
            putFaceToResult(groupRule.Rules[j], areaMap, faces)
            putFaceToResult(groupRule.Rules[j], &areaMap, faces)
         }
      }
   }
@@ -258,7 +257,7 @@
   for j := 0; j < len(groupRule.Rules); j++ {
      for _, sdkData := range args.Sdkdata {
         for _, areaMap := range sdkData.AreaMapList {
            ruleResult := transferParameters(groupRule.Rules[j], areaMap)
            ruleResult := transferParameters(groupRule.Rules[j], &areaMap)
            if ruleResult.Result != "" {
               log.Println("数量规则结果：", ruleResult.Result)
               resultSplice = append(resultSplice, &ruleResult)
@@ -270,7 +269,7 @@
   for j := 0; j < len(groupRule.Rules); j++ {
      for _, sdkData := range args.Sdkdata {
         for _, areaMap := range sdkData.AreaMapList {
            ruleResult := timeRuleResult(groupRule.Rules[j], areaMap)
            ruleResult := timeRuleResult(groupRule.Rules[j], &areaMap)
            if ruleResult.Result != "" {
               log.Println("时间规则结果：", ruleResult.Result)
               resultSplice = append(resultSplice, &ruleResult)
@@ -282,7 +281,7 @@
   for j := 0; j < len(groupRule.Rules); j++ {
      for _, sdkData := range args.Sdkdata {
         for _, areaMap := range sdkData.AreaMapList {
            duration(groupRule.Rules[j], areaMap)
            duration(groupRule.Rules[j], &areaMap)
         }
      }
   }
@@ -349,7 +348,7 @@
}

// 计算区域内的目标数量以及将相似度、占比、尺寸等打包
func (a *AreaMap) CountAreaObjs(arg *SdkData) {
func (a *AreaMap) CountAreaObjs(arg SdkData) {

   a.targetNum = 0
   threshold := 0.0       // 相似度
@@ -418,7 +417,7 @@
}

// 联动任务的处理
func linkTask(args *SdkDatas, groupRule *protomsg.GroupRule, taskId string) {
func linkTask(args SdkDatas, groupRule *protomsg.GroupRule, taskId string) {
   // new一个定时器，如果以此groupId为标志的定时器不存在的话
   var flag bool = true
   var timeEle = TimeElement{N: 3, InitN: 3, GroupId: groupRule.GroupId}