mirror of
https://github.com/Freika/dawarich.git
synced 2026-01-11 01:31:39 -05:00
113 lines
3.6 KiB
Ruby
113 lines
3.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# This class uses Komoot's Photon API
|
|
class ReverseGeocoding::Places::FetchData
|
|
attr_reader :place
|
|
|
|
IGNORED_OSM_VALUES = %w[house residential yes detached].freeze
|
|
IGNORED_OSM_KEYS = %w[highway railway].freeze
|
|
|
|
def initialize(place_id)
|
|
@place = Place.find(place_id)
|
|
end
|
|
|
|
def call
|
|
unless DawarichSettings.reverse_geocoding_enabled?
|
|
Rails.logger.warn('Reverse geocoding is not enabled')
|
|
return
|
|
end
|
|
|
|
places = reverse_geocoded_places
|
|
first_place = places.shift
|
|
update_place(first_place)
|
|
|
|
# Extract all osm_ids for preloading
|
|
osm_ids = places.map { |place| place.data['properties']['osm_id'].to_s }
|
|
|
|
# Preload all existing places with these osm_ids in a single query
|
|
existing_places = Place.where("geodata->'properties'->>'osm_id' IN (?)", osm_ids)
|
|
.index_by { |p| p.geodata.dig('properties', 'osm_id').to_s }
|
|
|
|
# Process with preloaded data
|
|
places.each { |reverse_geocoded_place| fetch_and_create_place(reverse_geocoded_place, existing_places) }
|
|
end
|
|
|
|
private
|
|
|
|
def update_place(reverse_geocoded_place)
|
|
return if reverse_geocoded_place.nil?
|
|
|
|
data = reverse_geocoded_place.data
|
|
|
|
place.update!(
|
|
name: place_name(data),
|
|
lonlat: "POINT(#{data['geometry']['coordinates'][0]} #{data['geometry']['coordinates'][1]})",
|
|
city: data['properties']['city'],
|
|
country: data['properties']['country'],
|
|
geodata: data,
|
|
source: Place.sources[:photon],
|
|
reverse_geocoded_at: Time.current
|
|
)
|
|
end
|
|
|
|
def fetch_and_create_place(reverse_geocoded_place, existing_places = nil)
|
|
data = reverse_geocoded_place.data
|
|
new_place = find_place(data, existing_places)
|
|
|
|
new_place.name = place_name(data)
|
|
new_place.city = data['properties']['city']
|
|
new_place.country = data['properties']['country'] # TODO: Use country id
|
|
new_place.geodata = data
|
|
new_place.source = :photon
|
|
if new_place.lonlat.blank?
|
|
new_place.lonlat = "POINT(#{data['geometry']['coordinates'][0]} #{data['geometry']['coordinates'][1]})"
|
|
end
|
|
|
|
new_place.save!
|
|
end
|
|
|
|
def find_place(place_data, existing_places = nil)
|
|
osm_id = place_data['properties']['osm_id'].to_s
|
|
|
|
# Use the preloaded data if available
|
|
if existing_places
|
|
return existing_places[osm_id] if existing_places[osm_id].present?
|
|
else
|
|
# Fall back to individual query if no preloaded data
|
|
found_place = Place.where("geodata->'properties'->>'osm_id' = ?", osm_id).first
|
|
return found_place if found_place.present?
|
|
end
|
|
|
|
Place.find_or_initialize_by(
|
|
lonlat: "POINT(#{place_data['geometry']['coordinates'][0].to_f.round(5)} #{place_data['geometry']['coordinates'][1].to_f.round(5)})",
|
|
latitude: place_data['geometry']['coordinates'][1].to_f.round(5),
|
|
longitude: place_data['geometry']['coordinates'][0].to_f.round(5)
|
|
)
|
|
end
|
|
|
|
def place_name(data)
|
|
name = data.dig('properties', 'name')
|
|
type = data.dig('properties', 'osm_value')&.capitalize&.gsub('_', ' ')
|
|
address = "#{data.dig('properties', 'postcode')} #{data.dig('properties', 'street')}"
|
|
address += " #{data.dig('properties', 'housenumber')}" if data.dig('properties', 'housenumber').present?
|
|
|
|
name ||= address
|
|
|
|
"#{name} (#{type})"
|
|
end
|
|
|
|
def reverse_geocoded_places
|
|
data = Geocoder.search(
|
|
[place.lat, place.lon],
|
|
limit: 10,
|
|
distance_sort: true,
|
|
radius: 1,
|
|
units: ::DISTANCE_UNIT
|
|
)
|
|
|
|
data.reject do |place|
|
|
place.data['properties']['osm_value'].in?(IGNORED_OSM_VALUES) ||
|
|
place.data['properties']['osm_key'].in?(IGNORED_OSM_KEYS)
|
|
end
|
|
end
|
|
end
|