联动任务---

panlei

2019-09-12 8c8cda516514867b0840207066a34d3a1bec3858

 ruleserver/readyDataForRule.go

@@ -51,7 +51,7 @@
   }
   logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   Push1()
   go Push1()
}

var sender chan *protomsg.CompareArgs = make(chan *protomsg.CompareArgs)
@@ -82,10 +82,14 @@
      }
   }
   logger.Debug("当前数据帧要匹配的规则组：-------------------------","摄像机id:",cameraId,"任务id",taskId)
   for _,ruleGroup := range taskGroup.GroupRules{
      logger.Info(ruleGroup.GroupText)
   if taskGroup == nil  {
      return nil
   } else {
      for _,ruleGroup := range taskGroup.GroupRules{
         logger.Info(ruleGroup.GroupText)
      }
      return taskGroup
   }
   return taskGroup
}

// 根据摄像机id拿到摄像机所有区域
@@ -293,7 +297,7 @@
func (a *AreaMap) CountAreaObjs(arg *SdkData) {

   a.targetNum = 0
   threshold := 0.0       // 相似度
   threshold := 0.5       // 相似度
   intersectionper := 0.2 // 占比
   size := 0.0            // 尺寸

@@ -386,13 +390,12 @@
   if errSize != nil {
      logger.Error("Failed set MaxRecvSize: %v", err)
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())

   logger.Info("序列化数据")

   for {