---

panlei

2019-08-01 e3f9b39c5c0f96315d409e09d92ce704b9c6385b

 ruleserver/readyDataForRule.go

@@ -1,14 +1,13 @@
package ruleserver

import (
   "basic.com/pubsub/cache.git/esutil"
   bigCache "basic.com/pubsub/cache.git"
   "basic.com/pubsub/cache.git/esutil"
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "fmt"
   "github.com/go-yaml/yaml"
   "io/ioutil"
   "os"
   "ruleprocess/cache"
   "ruleprocess/logger"
   "strconv"
@@ -74,7 +73,7 @@
func GetPolygons(cameraId string) []protomsg.CameraPolygon {
   var cameraPolygons []protomsg.CameraPolygon
   cameraPolygons = cache.GetPolygonsByCameraId(cameraId)
   logger.Debug("------=======查看下全部区域：",cameraPolygons)
   //logger.Debug("------=======查看下全部区域：",cameraPolygons)
   return cameraPolygons
}

@@ -160,7 +159,7 @@
      ids = append(ids,key)
   }
   logger.Info("------------------------------------------------------------------------------------------------------------------------")
   logger.Info("=====================人员id的集合为：",ids)
   //logger.Info("=====================人员id的集合为：",ids)
   if len(ids) > 0 {
      baseinfos, err1 := esutil.Dbpersoninfosbyid(ids,dbTablePersons,serverIp,serverPort)
      if err1 != nil {
@@ -168,16 +167,14 @@
      }
      for _,baseinfo := range baseinfos  {
         // 根据tableId查询底库信息给liker赋值
         logger.Info("---------看看每个底库人员的信息：",baseinfo.Id,baseinfo.PersonName)
         //logger.Info("---------看看每个底库人员的信息：",baseinfo.Id,baseinfo.PersonName)
         var tableIds []string
         tableIds = append(tableIds,baseinfo.TableId) // 虽然是传入数组返回数组的接口，但我按单个的使用了
         table,err := esutil.Dbtablefosbyid(tableIds,"dbtables",serverIp,serverPort)
         if err != nil || len(table) == 0{
            logger.Error("根据id查询底库信息出错！",err,"--返回值长度为：",len(table))
         }
         logger.Warn("返回的比分",m[baseinfo.Id])
         os.Exit(0)
         base := BaseInfo{TableId:baseinfo.TableId,TableName:table[0].TableName,BwType:table[0].BwType,CompareScore:Retain(m[baseinfo.Id]),PersonId:baseinfo.Id,PersonName:baseinfo.PersonName,PersonPicUrl:baseinfo.PersonPicUrl,PhoneNum:baseinfo.PhoneNum,Sex:baseinfo.Sex,IdCard:baseinfo.IdCard,MonitorLevel:baseinfo.MonitorLevel,Content:baseinfo.Reserved}
         base := BaseInfo{TableId:baseinfo.TableId,TableName:table[0].TableName,BwType:table[0].BwType,CompareScore:Retain(m[baseinfo.Id])*100,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的对比值是多少：",base)
         //os.Exit(1)
         arg.Liker = append(arg.Liker, &base)
@@ -224,7 +221,7 @@
               for _, areaMap := range sdkData.AreaMapList {
                  // 拿区域中每个人脸特征值去对比，填充其liker
                  if groupRule.Rules[j].PolygonId == areaMap.areaId {
                     logger.Info("--------------看看compareFlag的值和tableId和areaMap.args的长度：",compareFlag,tableIds,len(areaMap.args))
                     //logger.Info("--------------看看compareFlag的值和tableId和areaMap.args的长度：",compareFlag,tableIds,len(areaMap.args))
                     for _, arg := range areaMap.args {
                        if compareFlag == 1 {
                           arg.fillLiker(nil,threshold)
@@ -232,7 +229,7 @@
                        if compareFlag == 2 {
                           arg.fillLiker(tableIds,threshold)
                        }
                        logger.Info("-------------------成功给liker赋值,长度为：", len(arg.Liker))
                        //logger.Info("-------------------成功给liker赋值,长度为：", len(arg.Liker))
                     }
                     areaMap.filterData = areaMap.args
                     //logger.Info("=======第一次看args：",(areaMap.filterData))