mirror of
https://github.com/Freika/dawarich.git
synced 2026-01-11 17:51:39 -05:00
80 lines
2.1 KiB
Ruby
80 lines
2.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class CreateStats
|
|
attr_reader :years, :months, :users
|
|
|
|
def initialize(user_ids)
|
|
@users = User.where(id: user_ids)
|
|
@years = (1970..Time.current.year).to_a
|
|
@months = (1..12).to_a
|
|
end
|
|
|
|
def call
|
|
users.each do |user|
|
|
years.each do |year|
|
|
months.each { |month| update_month_stats(user, year, month) }
|
|
end
|
|
|
|
create_stats_updated_notification(user)
|
|
rescue StandardError => e
|
|
create_stats_update_failed_notification(user, e)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def points(user, beginning_of_month_timestamp, end_of_month_timestamp)
|
|
user
|
|
.tracked_points
|
|
.without_raw_data
|
|
.where(timestamp: beginning_of_month_timestamp..end_of_month_timestamp)
|
|
.order(:timestamp)
|
|
.select(:latitude, :longitude, :timestamp, :city, :country)
|
|
end
|
|
|
|
def update_month_stats(user, year, month)
|
|
beginning_of_month_timestamp = DateTime.new(year, month).beginning_of_month.to_i
|
|
end_of_month_timestamp = DateTime.new(year, month).end_of_month.to_i
|
|
|
|
points = points(user, beginning_of_month_timestamp, end_of_month_timestamp)
|
|
|
|
return if points.empty?
|
|
|
|
stat = Stat.find_or_initialize_by(year:, month:, user:)
|
|
stat.distance = distance(points)
|
|
stat.toponyms = toponyms(points)
|
|
stat.daily_distance = stat.distance_by_day
|
|
stat.save
|
|
end
|
|
|
|
def distance(points)
|
|
distance = 0
|
|
|
|
points.each_cons(2) do
|
|
distance += Geocoder::Calculations.distance_between(
|
|
[_1.latitude, _1.longitude], [_2.latitude, _2.longitude], units: DISTANCE_UNIT.to_sym
|
|
)
|
|
end
|
|
|
|
distance
|
|
end
|
|
|
|
def toponyms(points)
|
|
CountriesAndCities.new(points).call
|
|
end
|
|
|
|
def create_stats_updated_notification(user)
|
|
Notifications::Create.new(
|
|
user:, kind: :info, title: 'Stats updated', content: 'Stats updated'
|
|
).call
|
|
end
|
|
|
|
def create_stats_update_failed_notification(user, error)
|
|
Notifications::Create.new(
|
|
user:,
|
|
kind: :error,
|
|
title: 'Stats update failed',
|
|
content: "#{error.message}, stacktrace: #{error.backtrace.join("\n")}"
|
|
).call
|
|
end
|
|
end
|