kevinsivic/dawarich
1
0
Fork 0
mirror of https://github.com/Freika/dawarich.git synced 2026-01-14 03:01:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix Google Records import

Browse source
This commit is contained in:
Eugene Burmakin 2025-01-21 16:03:52 +01:00
parent 049812823f
commit 0ff47f3ac7
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
app/services/tasks/imports/google_records.rb
View file

@ -39,22 +39,22 @@ class Tasks::Imports::GoogleRecords
batch << prepare_location_data(location, import_id)
if batch.size >= BATCH_SIZE
bulk_insert_locations(batch)
bulk_insert_points(batch)
batch = []
end
end
end
# Process any remaining records
bulk_insert_locations(batch) if batch.any?
bulk_insert_points(batch) if batch.any?
end
def prepare_location_data(location, import_id)
{
import_id: import_id,
latitude: location['latitudeE7']&.to_f&. / 1e7,
longitude: location['longitudeE7']&.to_f&. / 1e7,
timestamp: Time.at(location['timestampMs'].to_i / 1000),
latitude: location['latitudeE7']&.to_f&.div(1e7),
longitude: location['longitudeE7']&.to_f&.div(1e7),
timestamp: Time.zone.at(location['timestampMs'].to_i / 1000),
accuracy: location['accuracy'],
source_data: location.to_json,
created_at: Time.current,
@ -62,8 +62,8 @@ class Tasks::Imports::GoogleRecords
}
end
def bulk_insert_locations(batch)
Location.upsert_all(
def bulk_insert_points(batch)
Point.upsert_all(
batch,
unique_by: %i[import_id timestamp],
returning: false