| | |
| | | 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 { |
| | |
| | | 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() |
| | |
| | | } |
| | | wg.Wait() |
| | | logger.Debug("抓拍档案库人员缓存完成用时:", time.Since(temptime)) |
| | | |
| | | for k, v := range CaptureDbMap.Area { |
| | | logger.Debugf("Cache area %s item len %d ", k, v.GetLen()) |
| | | } |
| | | } |
| | | } |
| | | |