调整实名比对

zhangzengfei

2024-11-07 c06ac05c6e52dd5bf818c9add39db5eed557ccac

 cache/cache.go

@@ -7,9 +7,6 @@

   "sdkCompare/cache/shardmap"
   "sdkCompare/db"

   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/logger.git"
)

var peerSizeNum = flag.Int("peerSize", 3000, "the query number from database")
@@ -27,7 +24,6 @@

var CaptureDbMap *AreaMapItem
var RealNameDbMap = shardmap.New(uint8(*threadNum))
var KeyPersonDbMap = shardmap.New(uint8(*threadNum))

var doOnce sync.Once

@@ -45,7 +41,6 @@

   initDbTablePersonsCache()
   initRealNamePersonsCache()
   initKeyPersonsCache()
}

func ReInitDbTablePersonsCache() {
@@ -137,7 +132,7 @@
}

func initRealNamePersonsCache() {
   var dbApi db.Layouts
   var dbApi db.RealNamePerson
   dbPersons, err := dbApi.GetRealNamePersonList()
   if err != nil {
      logger.Error("init real-name persons error,", err.Error())
@@ -148,20 +143,6 @@
   }

   logger.Debugf("常住人口共有%d条记录", len(dbPersons))
}

func initKeyPersonsCache() {
   var dbApi db.Layouts
   dbPersons, err := dbApi.GetKeyPersonList()
   if err != nil {
      logger.Error("init real-name persons error,", err.Error())
   }

   for _, value := range dbPersons {
      KeyPersonDbMap.Set(value.Id, value)
   }

   logger.Debugf("重点人员共有%d条记录", len(dbPersons))
}

// UpdateDbPersonsCacheById 更新缓存中的全部人员信息