code format

zhangzengfei

2024-09-26 88b1f1d1d14a8fe9e3dde2f363a89d821fc0e641

 cache/cache.go

@@ -68,8 +68,9 @@
   var dbpApi db.DbPersons
   total, e := dbpApi.GetPersonTotal("")

   var psApi db.PersonStatus
   accessAreas, _ := psApi.GetPersonAccessedAreas()
   // 暂时去掉到访小区过滤
   //var psApi db.PersonStatus
   //accessAreas, _ := psApi.GetPersonAccessedAreas()

   logger.Debugf("抓拍档案库共有%d条记录", total)
   if e == nil && total > 0 {
@@ -95,7 +96,7 @@
               logger.Error(err)
               return
            }
            logger.Debugf(" eachNum:%d, 获取%d条人员信息", queryEachNum, len(dbPersons))
            logger.Debugf("eachNum:%d, 获取%d条人员信息", queryEachNum, len(dbPersons))
            CaptureDbMap.Lock()

            areaId := ""
@@ -108,14 +109,14 @@
                  continue
               }

               for _, areaId := range accessAreas[value.Id] {
                  if _, ok := CaptureDbMap.Area[areaId]; !ok {
                     CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
                  }

                  CaptureDbMap.Area[areaId].Set(value.Id, value)
                  CaptureDbMap.Area[areaId].Settime()
               //for _, areaId := range accessAreas[value.Id] {
               if _, ok := CaptureDbMap.Area[areaId]; !ok {
                  CaptureDbMap.Area[areaId] = shardmap.New(uint8(*threadnum))
               }

               CaptureDbMap.Area[areaId].Set(value.Id, value)
               CaptureDbMap.Area[areaId].Settime()
               //}
            }

            CaptureDbMap.Unlock()
@@ -124,6 +125,10 @@
      }
      wg.Wait()
      logger.Debug("抓拍档案库人员缓存完成用时:", time.Since(temptime))

      for k, v := range CaptureDbMap.Area {
         logger.Debugf("Cache area %s item len %d ", k, v.GetLen())
      }
   }
}