Sha256: 31d614250f97bb9a96782c5f309dc0ad73c35745b71444090880808906d91148
Contents?: true
Size: 1.96 KB
Versions: 10
Compression:
Stored size: 1.96 KB
Contents
# frozen_string_literal: true
module Decidim
module Meetings
module Metrics
class MeetingsMetricManage < Decidim::MetricManage
def metric_name
"meetings"
end
def save
return @registry if @registry
@registry = []
cumulative.each do |key, cumulative_value|
next if cumulative_value.zero?
quantity_value = quantity[key] || 0
category_id, space_type, space_id = key
record = Decidim::Metric.find_or_initialize_by(day: @day.to_s, metric_type: @metric_name,
organization: @organization, decidim_category_id: category_id,
participatory_space_type: space_type, participatory_space_id: space_id)
record.assign_attributes(cumulative: cumulative_value, quantity: quantity_value)
@registry << record
end
@registry.each(&:save!)
@registry
end
private
def query
return @query if @query
spaces = Decidim.participatory_space_manifests.flat_map do |manifest|
manifest.participatory_spaces.call(@organization).public_spaces
end
components = Decidim::Component.where(participatory_space: spaces).published
@query = Decidim::Meetings::Meeting.where(component: components).joins(:component)
.left_outer_joins(:category).visible
@query = @query.where("decidim_meetings_meetings.created_at <= ?", end_time)
@query = @query.group("decidim_categorizations.decidim_category_id",
:participatory_space_type,
:participatory_space_id)
@query
end
def quantity
@quantity ||= query.where("decidim_meetings_meetings.created_at >= ?", start_time).count
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems