读公共的配置文件

panlei

2019-09-16 716810adb573f7e6b40ab52887b5b158d9824817

 ruleserver/readyDataForRule.go

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

import (
   "basic.com/dbapi.git"
   bigCache "basic.com/pubsub/cache.git"
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "errors"
@@ -49,14 +48,13 @@
   if err1 != nil {
      logger.Error("查询本机信息失败！")
   }
   logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   sock, err = req.NewSocket();
   if err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   //logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   //bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   go Push1()
}

var sender chan *protomsg.CompareArgs = make(chan *protomsg.CompareArgs)
var receiver chan []byte = make(chan []byte)
type BaseInfo struct {
   TableId      string  `json:"tableId"`
   TableName    string  `json:"tableName"`
@@ -83,17 +81,21 @@
      }
   }
   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拿到摄像机所有区域
func GetPolygons(cameraId string) []protomsg.CameraPolygon {
   var cameraPolygons []protomsg.CameraPolygon
   cameraPolygons = cache.GetPolygonsByCameraId(cameraId)
   //logger.Debug("------=======查看下全部区域：",cameraPolygons)
   logger.Debug("------=======查看下全部区域：",cameraPolygons)
   return cameraPolygons
}

@@ -175,12 +177,14 @@
      CompareThreshold:compareThreshold,
      Source:false,
   }
   serverIp, _ := GetLocalIP()
   bytes := Push("tcp://"+serverIp+":4010",comArg,sock)

   bytes := getCompareMsg(comArg)
   //bytes := []byte{}
   var scResult protomsg.SdkCompareResult
   err1 := proto.Unmarshal(bytes, &scResult)
   if err1 != nil {
      logger.Error("getBaseInfo解压错误", err1)
      return
   }
   //logger.Info("----------------------------------------map是", m)
   ids := []string{}
@@ -292,7 +296,7 @@
func (a *AreaMap) CountAreaObjs(arg *SdkData) {

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

@@ -332,7 +336,7 @@
   }
}

func Push(url string,data *protomsg.CompareArgs,sock mangos.Socket) []byte{
func Push(data *protomsg.CompareArgs,sock mangos.Socket) []byte{
   //var sock mangos.Socket
   var err error
   var msg []byte
@@ -345,11 +349,13 @@
      logger.Error("Failed set MaxRecvSize: %v", err)
      return nil
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
   if err = sock.Dial(url); err != nil {
   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("序列化数据")
   bytes,err1 := proto.Marshal(data)
   logger.Info("数据长度为：",len(bytes))
@@ -370,6 +376,58 @@
   return msg
}


func Push1(){
   //var sock mangos.Socket
   var err error
   var msg []byte

   if sock, err = req.NewSocket(); err != nil {
      logger.Error("创建请求socket失败: %s", err.Error())
   }
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   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())
   }
   logger.Info("序列化数据")

   for {
      select {
      // case <-ctx.Done():
      //    return
      case data := <- sender:
         bytes,err1 := proto.Marshal(data)
         logger.Info("数据长度为：",len(bytes))
         if err1 != nil {
            logger.Info("序列化失败：",err1)
         }
         logger.Debug("推送数据")
         //bytes := []byte("ndfasojdfaidsos")
         if err = sock.Send(bytes); err != nil {
            logger.Error("推送socket发送数据失败: %s", err.Error())
            //os.Exit(1)
         }
         if msg, err = sock.Recv(); err != nil {
            logger.Error("接收响应失败: %s", err.Error())
            //os.Exit(1)
         }
         logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
         receiver <- msg
      default:

      }
   }
}
func getCompareMsg(data *protomsg.CompareArgs) []byte{
   sender <- data
   return <-receiver
}
// 获取本机ip
func GetLocalIP() (ipv4 string, err error) {
   var (