新增删除人员缓存的处理

zhangzengfei

2024-05-08 a2c0678e8d34d1bd5afa26c6a2b34ec97b411777

 cache/cache.go

@@ -90,7 +90,7 @@
               logger.Error(err)
               return
            }
            logger.Debugf("获取%d条人员信息", len(dbPersons))
            logger.Debugf(" eachNum:%d, 获取%d条人员信息", queryEachNum, len(dbPersons))
            CacheMap.Lock()

            areaId := ""
@@ -130,7 +130,7 @@
      logger.Error(err)
      return
   }
   if info.AreaId != "" {
   if info != nil && info.AreaId != "" {
      CacheMap.Lock()
      defer CacheMap.Unlock()
      if _, ok := CacheMap.Area[info.AreaId]; !ok {
@@ -141,6 +141,15 @@
   }
}

func DeleteDbPersonsCacheById(id string) {
   CacheMap.Lock()
   defer CacheMap.Unlock()

   for key, _ := range CacheMap.Area {
      CacheMap.Area[key].Del(id)
   }
}

func RealTimeAddPersonInfoToCache(tableId string, id string, faceFeature string, enable int32, carNo string) {
   CacheMap.Lock()
   defer CacheMap.Unlock()