更新实名比对

zhangzengfei

2024-12-09 366e2ff546092d9be26411fb698b3ddd8e834a11

 cache/cache.go

@@ -1,6 +1,7 @@
package cache

import (
   "basic.com/pubsub/protomsg.git"
   "flag"
   "sync"
   "time"
@@ -8,7 +9,6 @@
   "sdkCompare/cache/shardmap"
   "sdkCompare/db"

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

@@ -27,7 +27,6 @@

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

var doOnce sync.Once

@@ -45,7 +44,6 @@

   initDbTablePersonsCache()
   initRealNamePersonsCache()
   initKeyPersonsCache()
}

func ReInitDbTablePersonsCache() {
@@ -137,7 +135,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 +146,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 更新缓存中的全部人员信息