修改缓存更新的数据结构

zhangzengfei

2024-03-30 7e7a2baab4c5ccb9dd8dc5104041c9efe718ed9a

 cache/cache.go

@@ -130,14 +130,14 @@
      logger.Error(err)
      return
   }
   if info.Tableid != "" {
   if info.AreaId != "" {
      CacheMap.Lock()
      defer CacheMap.Unlock()
      if _, ok := CacheMap.Area[info.Tableid]; !ok {
         CacheMap.Area[info.Tableid] = shardmap.New(uint8(*threadnum))
      if _, ok := CacheMap.Area[info.AreaId]; !ok {
         CacheMap.Area[info.AreaId] = shardmap.New(uint8(*threadnum))
      }
      CacheMap.Area[info.Tableid].Set(info.Id, info)
      CacheMap.Area[info.Tableid].Settime()
      CacheMap.Area[info.AreaId].Set(info.Id, info)
      CacheMap.Area[info.AreaId].Settime()
   }
}