# frozen_string_literal: true module Decidim module Proposals module Metrics class EndorsementsMetricManage < Decidim::MetricManage def metric_name "endorsements" 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, proposal_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, related_object_type: "Decidim::Proposals::Proposal", related_object_id: proposal_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 components = Decidim::Component.where(participatory_space: retrieve_participatory_spaces).published proposals = Decidim::Proposals::Proposal.where(component: components).except_withdrawn @query = Decidim::Proposals::ProposalEndorsement.joins(proposal: :component) .left_outer_joins(proposal: :category) .where(proposal: proposals) @query = @query.where("decidim_proposals_proposal_endorsements.created_at <= ?", end_time) @query = @query.group("decidim_categorizations.id", :participatory_space_type, :participatory_space_id, :decidim_proposal_id) @query end def quantity @quantity ||= query.where("decidim_proposals_proposal_endorsements.created_at >= ?", start_time).count end end end end end