缩短睡眠时间

panlei

2019-12-05 bcf4b98ea7f6a37a0664ff1fe3c97fd8cdc0e699

 ruleserver/readyDataForRule.go

@@ -6,6 +6,7 @@
   "encoding/json"
   "errors"
   "fmt"
   logger "github.com/alecthomas/log4go"
   "github.com/golang/protobuf/proto"
   "math"
   "nanomsg.org/go-mangos"
@@ -13,7 +14,7 @@
   "nanomsg.org/go-mangos/transport/tcp"
   "net"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "ruleprocess/structure"
   "strconv"
   "time"
)
@@ -30,8 +31,6 @@
}

func Init() {
   //logger.Debug("本机信息和server信息：", localConfig, serverIp, serverPort)
   //bigCache.Init(dbTablePersons, serverIp, serverPort, localConfig.ServerId)
   go Push1()
}

@@ -62,7 +61,6 @@
         taskGroup = task
      }
   }
   logger.Debug("当前数据帧要匹配的规则组：-------------------------","摄像机id:",cameraId,"任务id",taskId)
   if taskGroup == nil  {
      return nil
   } else {
@@ -77,7 +75,7 @@
func GetPolygons(cameraId string) []protomsg.CameraPolygon {
   var cameraPolygons []protomsg.CameraPolygon
   cameraPolygons = cache.GetPolygonsByCameraId(cameraId)
   logger.Debug("------=======查看下全部区域：",cameraPolygons)
   //logger.Debug("------=======查看下全部区域：",cameraPolygons)
   return cameraPolygons
}

@@ -88,58 +86,22 @@
}
func Decimal(value float32) float64 {
   value1, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", float64(value)), 64)
   logger.Info("初步保留两位成str:",value1)
   //logger.Info("初步保留两位成str:",value1)
   n10 := math.Pow10(4)
   value2 := math.Trunc((value1+0.5/n10)*n10) / n10
   logger.Info("初步保留两位成str::::",value2)
   //logger.Info("初步保留两位成str::::",value2)
   return value2
}
// 取出某个时间规则的第几天的规则段集合
func GetTimeById(id string, index int) []TimeRange {
   _, cameraTimeRule := cache.GetTimeRuleById(id)
   var timeRangeList []day
   err := json.Unmarshal([]byte(cameraTimeRule.TimeRule), &timeRangeList)
   if err != nil {
      logger.Error("取时间规则时反序列化错误！")
   }
   for _, timerange := range timeRangeList {
      if timerange.Day == index {
         //logger.Println("取到的时间规则：", timerange.TimeRange)
         return timerange.TimeRange
      }
   }
   return nil
}

// 根据传入的字符串得到其在一周内的索引 周一到周日分别对应1到7
func getIndexOfWeek(weekday string) int {
   var weekdays = [7]string{"Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday", "Sunday"}
   for k, value := range weekdays {
      if value == weekday {
         return k + 1 // 因为数据库中存的是1-7代表的周一到周日
      }
   }
   return 0
}

type TimeRange struct {
   Start string `json:"start"`
   End   string `json:"end"`
}
type day struct {
   Day       int         `json:"day"`        // 标示当前星期几
   TimeRange []TimeRange `json:"time_range"` // 当天的几个时间段
}

// 将字符串格式的坐标序列化为Point格式
func Json2points(areaPoints string) []Point {
   var pts []Point
func Json2points(areaPoints string) []structure.Point {
   var pts []structure.Point
   if areaPoints == "[]" || areaPoints == "" {
      logger.Error("=====================此区域为全部区域")
      pts = append(pts, Point{0, 0})
      pts = append(pts, Point{0, 540})
      pts = append(pts, Point{960, 540})
      pts = append(pts, Point{960, 0})
      pts = append(pts, structure.Point{0, 0})
      pts = append(pts, structure.Point{0, 540})
      pts = append(pts, structure.Point{960, 540})
      pts = append(pts, structure.Point{960, 0})
   } else {
      err := json.Unmarshal([]byte(areaPoints), &pts)
      if err != nil {
@@ -151,7 +113,7 @@
}

// 给目标填充liker
func (arg *Arg) fillLiker(tableId []string, compareThreshold float32) {
func fillLiker(tableId []string, compareThreshold float32,arg *structure.Arg) {
   //bytes := bigCache.GetComparePersonBaseInfo(tableId, arg.Feature, compareThreshold)
   comArg := &protomsg.CompareArgs{
      TableIds:tableId,
@@ -161,7 +123,6 @@
   }

   bytes := getCompareMsg(comArg)
   //bytes := []byte{}
   var scResult protomsg.SdkCompareResult
   err1 := proto.Unmarshal(bytes, &scResult)
   if err1 != nil {
@@ -195,8 +156,8 @@
         if err != nil || len(table) == 0 {
            logger.Error("根据id查询底库信息出错！", err, "--返回值长度为：", len(table))
         }
         logger.Debug("看看这个base的对比值是多少：", Decimal(m[baseinfo.Id].CompareScore))
         base := BaseInfo{TableId: baseinfo.TableId, TableName: table[0].TableName, BwType: table[0].BwType, CompareScore: Decimal(m[baseinfo.Id].CompareScore), PersonId: baseinfo.Id, PersonName: baseinfo.PersonName, PersonPicUrl: baseinfo.PersonPicUrl, PhoneNum: baseinfo.PhoneNum, Sex: baseinfo.Sex, IdCard: baseinfo.IdCard, MonitorLevel: baseinfo.MonitorLevel, Content: baseinfo.Reserved}
         //logger.Debug("看看这个base的对比值是多少：", Decimal(m[baseinfo.Id].CompareScore))
         base := structure.BaseInfo{TableId: baseinfo.TableId, TableName: table[0].TableName, BwType: table[0].BwType, CompareScore: Decimal(m[baseinfo.Id].CompareScore), TargetId: baseinfo.Id, TargetName: baseinfo.PersonName, TargetPicUrl: baseinfo.PersonPicUrl, MonitorLevel: baseinfo.MonitorLevel, Content: baseinfo.Reserved,DbLabel: baseinfo.PhoneNum+"/"+baseinfo.Sex+"/"+baseinfo.IdCard,}
         //os.Exit(1)
         arg.Liker = append(arg.Liker, &base)
      }
@@ -205,7 +166,7 @@
}

// 人脸比对
func Compare(args *SdkDatas, groupRule *protomsg.GroupRule) {
func Compare(args *structure.SdkDatas, groupRule *protomsg.GroupRule) {
   compareFlag := 0
   var tableIds []string
   var threshold float32 = 50 // 默认阈值为50
@@ -222,7 +183,7 @@
         if groupRule.Rules[j].SdkArgAlias == "cmpThreshold" {
            v2, err := strconv.ParseFloat(groupRule.Rules[j].SdkArgValue, 32)
            if err != nil {
               logger.Error("string转float32失败！")
               //logger.Error("string转float32失败！")
            }
            threshold = float32(v2)
         }
@@ -231,38 +192,30 @@
   // 为了测试作下弊，直接让其比对全部底库
   //compareFlag = 1
   if compareFlag == 0 {
      logger.Info("没有配置对比底库参数")
      //logger.Info("没有配置对比底库参数")
      return
   }
   logger.Debug("=====配置的阈值为：", threshold)
   //logger.Debug("=====配置的阈值为：", threshold)
   for j := 0; j < len(groupRule.Rules); j++ {
      if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
         for _, sdkData := range args.Sdkdata {
            if sdkData.IpcId == "A8B73405-373D-4F23-CED2-A617EBD7EC55" { // 搜索到人脸检测的sdkdata 现在关于人脸的只有他一个sdk，全找他
               logger.Info("============================================进行人脸对比")
               //logger.Info("============================================进行人脸对比")
               for _, areaMap := range sdkData.AreaMapList {
                  // 拿区域中每个人脸特征值去对比，填充其liker
                  if groupRule.Rules[j].PolygonId == areaMap.areaId {
                  if groupRule.Rules[j].PolygonId == areaMap.AreaId {
                     //logger.Info("--------------看看compareFlag的值和tableId和areaMap.args的长度：",compareFlag,tableIds,len(areaMap.args))
                     for _, arg := range areaMap.args {
                     for _, arg := range areaMap.Args {
                        arg.Liker = arg.Liker[0:0]
                        //logger.Info("清空之后看看之前打的人脸标签变了没：")
                        //if args.RuleResult["face"] != nil && len(args.RuleResult["face"].([]FaceResult)) > 0 {
                        //   for _, faceResult := range args.RuleResult["face"].([]FaceResult) {
                        //      for _,arg := range faceResult.Args {
                        //         logger.Info("人员分值是：",arg.Score,"liker的数量为",arg.Liker)
                        //      }
                        //   }
                        //}
                        if compareFlag == 1 {
                           arg.fillLiker(nil, threshold)
                           fillLiker(nil, threshold, arg)
                        }
                        if compareFlag == 2 {
                           arg.fillLiker(tableIds, threshold)
                           fillLiker(tableIds, threshold, arg)
                        }
                        //logger.Info("-------------------成功给liker赋值,长度为：", len(arg.Liker))
                     }
                     areaMap.filterData = areaMap.args
                     areaMap.FilterData = areaMap.Args
                     //logger.Info("=======第一次看args：",(areaMap.filterData))
                  }
                  //logger.Info("-------------------------------人脸对比之后的目标数量",len(areaMap.args))
@@ -275,48 +228,48 @@
}

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

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

   areaPoints := Json2points(a.areaJson)
   widthScale := float64(arg.ImageWidth / 960)
   heigthScale := float64(arg.ImageHeight / 540)
   for _, obj := range arg.Photo {
      //logger.Info("------------------看看sdkData:", arg.SdkName, "的Photo数据----------------", obj, "----顺便看看占比-----：", PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale))
      if threshold <= obj.Score && size <= float64(obj.Rects.Width*obj.Rects.Height) && intersectionper <= PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale) {
         // 这步要备齐表达式里所需要的所有参数
         a.targetNum++
         arg1 := Arg{obj.Id,obj.Score, PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale), float64(obj.Rects.Width * obj.Rects.Height), obj.IsYolo, obj.Rects, obj.Feature, obj.ThftRes, []*BaseInfo{}}
         //logger.Println("放进去的arg：-------", arg1)
         a.args = append(a.args, &arg1)
         a.filterData = append(a.filterData, &arg1)
      }
   }
   logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.targetNum,"---",len(a.filterData))
   a.time = time.Unix(time.Now().Unix(), 0).String()[11:16]
   a.keepRight = arg.KeepRight
   a.isStatic = arg.IsStatic
   //logger.Println("--------------------看看区域数据：",*a)
}

// 把sdk从数据帧上提取的按照区域分类归置
func SdkDataFormat(cameraId string, arg *SdkData, cameraPolygons []protomsg.CameraPolygon) {
   logger.Info("==================================本sdkData中解出来的目标数据=======================================")
   for _, photo := range arg.Photo {
      logger.Info("--------解析出来的数据---", cameraId, arg.IpcId, photo.Rects, photo.Score)
   }
   for _, polygon := range cameraPolygons {
      //logger.Println("++++++在这儿看一下区域啊:", polygon.Polygon)
      areaMap := AreaMap{cameraId: cameraId, areaId: polygon.Id, areaJson: polygon.Polygon, triggerLine: polygon.TriggerLine, directionLine: polygon.DirectionLine}
      // 为每个摄像机区域填充数据
      areaMap.CountAreaObjs(arg)
      arg.AreaMapList = append(arg.AreaMapList, &areaMap)
   }
}
//func CountAreaObjs(a *structure.AreaMap,arg *structure.SdkData) {
//
//   a.TargetNum = 0
//   threshold := 80.0       // 相似度
//   intersectionper := 20.0 // 占比
//   size := 0.0            // 尺寸
//
//   areaPoints := Json2points(a.AreaJson)
//   logger.Info("看看图片的width和height:",arg.ImageWidth,arg.ImageHeight)
//   widthScale := float64(arg.ImageWidth) / 960
//   heigthScale := float64(arg.ImageHeight) / 540
//   for _, obj := range arg.Photo {
//      //logger.Info("------------------看看sdkData:", arg.SdkName, "的Photo数据----------------", obj, "----顺便看看占比-----：", PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale))
//      if  obj.Score >= threshold && float64(obj.Rects.Width*obj.Rects.Height) >= size && PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale) >= intersectionper {
//         // 这步要备齐表达式里所需要的所有参数
//         a.TargetNum++
//         uuid := uuid.NewV4().String()
//         arg1 := structure.Arg{obj.Id,uuid,obj.Score, PgsInterPercent(areaPoints, obj.Rects, widthScale, heigthScale), float64(obj.Rects.Width * obj.Rects.Height), a.AreaJson,obj.Type, obj.Rects, obj.Car,obj.Feature, obj.ThftRes, []*structure.BaseInfo{},"",structure.ResultMsg{}}
//         //logger.Println("放进去的arg：-------", arg1)
//         a.Args = append(a.Args, &arg1)
//         a.FilterData = append(a.FilterData, &arg1)
//      }
//   }
//   //logger.Info("区域是：",areaPoints,"区域内目标数量为：",a.TargetNum,"---",len(a.FilterData))
//   a.Time = time.Unix(time.Now().Unix(), 0).String()[11:16]
//   //logger.Println("--------------------看看区域数据：",*a)
//}
//
//// 把sdk从数据帧上提取的按照区域分类归置
//func SdkDataFormat(cameraId string, arg *structure.SdkData, cameraPolygons []protomsg.CameraPolygon) {
//   logger.Info("==================================本sdkData中解出来的目标数据=======================================")
//   for _, photo := range arg.Photo {
//      logger.Info("--------解析出来的数据---", cameraId, arg.IpcId, photo.Rects, photo.Score)
//   }
//   for _, polygon := range cameraPolygons {
//      //logger.Println("++++++在这儿看一下区域啊:", polygon.Polygon)
//      areaMap := structure.AreaMap{CameraId: cameraId, AreaId: polygon.Id, AreaJson: polygon.Polygon, TriggerLine: polygon.TriggerLine, DirectionLine: polygon.DirectionLine}
//      // 为每个摄像机区域填充数据
//      CountAreaObjs(&areaMap,arg)
//      arg.AreaMapList = append(arg.AreaMapList, &areaMap)
//   }
//}

func Push(data *protomsg.CompareArgs,sock mangos.Socket) []byte{
   //var sock mangos.Socket
@@ -328,12 +281,12 @@
   //}
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   if errSize != nil {
      logger.Error("Failed set MaxRecvSize: %v", err)
      _ = logger.Error("Failed set MaxRecvSize: %v", err)
      return nil
   }
   serverIP, _ := GetLocalIP()
   if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
      logger.Error("请求socket拨号失败: %s", err.Error())
      _ = logger.Error("请求socket拨号失败: %s", err.Error())
   }
   //sock.AddTransport(ipc.NewTransport())
   sock.AddTransport(tcp.NewTransport())
@@ -347,17 +300,16 @@
   logger.Debug("推送数据")
   //bytes := []byte("ndfasojdfaidsos")
   if err = sock.Send(bytes); err != nil {
      logger.Error("推送socket发送数据失败: %s", err.Error())
      _ = logger.Error("推送socket发送数据失败: %s", err.Error())
      //os.Exit(1)
   }
   if msg, err = sock.Recv(); err != nil {
      logger.Error("接收响应失败: %s", err.Error())
      _ = logger.Error("接收响应失败: %s", err.Error())
      //os.Exit(1)
   }
   logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
   return msg
}


func Push1(){
   //var sock mangos.Socket
@@ -365,17 +317,17 @@
   var msg []byte

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

@@ -391,19 +343,16 @@
            logger.Info("序列化失败：",err1)
         }
         logger.Debug("推送数据")
         //bytes := []byte("ndfasojdfaidsos")
         if err = sock.Send(bytes); err != nil {
            logger.Error("推送socket发送数据失败: %s", err.Error())
            //os.Exit(1)
            _ = logger.Error("推送socket发送数据失败: %s", err.Error())
         }
         if msg, err = sock.Recv(); err != nil {
            logger.Error("接收响应失败: %s", err.Error())
            //os.Exit(1)
            _ = logger.Error("接收响应失败: %s", err.Error())
         }
         logger.Debug("数据推送成功！收到响应,数据长度为：",len(msg))
         receiver <- msg
      default:

         time.Sleep(time.Millisecond * 10)
      }
   }
}