diff --git a/app/assets/images/budgets/stats/gender.png b/app/assets/images/budgets/stats/gender.png new file mode 100644 index 000000000..e4179354c Binary files /dev/null and b/app/assets/images/budgets/stats/gender.png differ diff --git a/app/controllers/budgets/results_controller.rb b/app/controllers/budgets/results_controller.rb index 40586ed96..e8e80a234 100644 --- a/app/controllers/budgets/results_controller.rb +++ b/app/controllers/budgets/results_controller.rb @@ -8,6 +8,7 @@ module Budgets def show authorize! :read_results, @budget @investments = Budget::Result.new(@budget, @heading).investments + @headings = @budget.headings.sort_by_name end private diff --git a/app/controllers/budgets/stats_controller.rb b/app/controllers/budgets/stats_controller.rb new file mode 100644 index 000000000..080bf0ef9 --- /dev/null +++ b/app/controllers/budgets/stats_controller.rb @@ -0,0 +1,24 @@ +module Budgets + class StatsController < ApplicationController + + before_action :load_budget + load_and_authorize_resource :budget + + def show + authorize! :read_stats, @budget + @stats = load_stats + @headings = @budget.headings.sort_by_name + end + + private + + def load_stats + Budget::Stats.new(@budget).generate + end + + def load_budget + @budget = Budget.find_by(slug: params[:budget_id]) || Budget.find_by(id: params[:budget_id]) + end + + end +end diff --git a/app/models/abilities/administrator.rb b/app/models/abilities/administrator.rb index a72997dbf..9f8c7e965 100644 --- a/app/models/abilities/administrator.rb +++ b/app/models/abilities/administrator.rb @@ -66,6 +66,7 @@ module Abilities can [:hide, :update, :toggle_selection], Budget::Investment can [:valuate, :comment_valuation], Budget::Investment can :create, Budget::ValuatorAssignment + can :read_stats, Budget, phase: "reviewing_ballots" can [:search, :edit, :update, :create, :index, :destroy], Banner diff --git a/app/models/abilities/everyone.rb b/app/models/abilities/everyone.rb index a20a119fe..626be1c0a 100644 --- a/app/models/abilities/everyone.rb +++ b/app/models/abilities/everyone.rb @@ -21,6 +21,7 @@ module Abilities can [:read], Budget::Group can [:read, :print, :json_data], Budget::Investment can [:read_results, :read_executions], Budget, phase: "finished" + can :read_stats, Budget, phase: "finished" can :new, DirectMessage can [:read, :debate, :draft_publication, :allegations, :result_publication, :proposals, :milestones], Legislation::Process, published: true diff --git a/app/models/budget/ballot/line.rb b/app/models/budget/ballot/line.rb index 54b26f4b4..c64ed39c0 100644 --- a/app/models/budget/ballot/line.rb +++ b/app/models/budget/ballot/line.rb @@ -1,7 +1,7 @@ class Budget class Ballot class Line < ApplicationRecord - belongs_to :ballot + belongs_to :ballot, counter_cache: :ballot_lines_count belongs_to :investment, counter_cache: :ballot_lines_count belongs_to :heading belongs_to :group diff --git a/app/models/budget/stats.rb b/app/models/budget/stats.rb new file mode 100644 index 000000000..c7e162c81 --- /dev/null +++ b/app/models/budget/stats.rb @@ -0,0 +1,220 @@ +class Budget + class Stats + + def initialize(budget) + @budget = budget + end + + def generate + stats = %w[total_participants total_participants_support_phase total_participants_vote_phase + total_budget_investments total_votes total_selected_investments + total_unfeasible_investments total_male_participants total_female_participants + total_supports total_unknown_gender_or_age age_groups male_percentage + female_percentage headings total_participants_web total_participants_booths] + stats.map { |stat_name| [stat_name.to_sym, send(stat_name)] }.to_h + end + + private + + def total_participants + stats_cache("total_participants") { participants.distinct.count } + end + + def total_participants_support_phase + stats_cache("total_participants_support_phase") { voters.uniq.count } + end + + def total_participants_web + stats_cache("total_participants_web") do + (balloters - poll_ballot_voters).uniq.compact.count + end + end + + def total_participants_booths + stats_cache("total_participants_booths") { poll_ballot_voters.uniq.count } + end + + def total_participants_vote_phase + stats_cache("total_participants_vote_phase") { balloters.uniq.count } + end + + def total_budget_investments + stats_cache("total_budget_investments") { @budget.investments.count } + end + + def total_votes + stats_cache("total_votes") { @budget.ballots.pluck(:ballot_lines_count).inject(0) { |sum, x| sum + x } } + end + + def total_selected_investments + stats_cache("total_selected_investments") { @budget.investments.selected.count } + end + + def total_unfeasible_investments + stats_cache("total_unfeasible_investments") { @budget.investments.unfeasible.count } + end + + def total_male_participants + stats_cache("total_male_participants") { participants.where(gender: "male").count } + end + + def total_female_participants + stats_cache("total_female_participants") { participants.where(gender: "female").count } + end + + def total_supports + stats_cache("total_supports") { supports(@budget).count } + end + + def total_unknown_gender_or_age + stats_cache("total_unknown_gender_or_age") do + participants.where("gender IS NULL OR date_of_birth is NULL").uniq.count + end + end + + def age_groups + stats_cache("age_groups") do + groups = Hash.new(0) + ["16 - 19", + "20 - 24", + "25 - 29", + "30 - 34", + "35 - 39", + "40 - 44", + "45 - 49", + "50 - 54", + "55 - 59", + "60 - 64", + "65 - 69", + "70 - 140"].each do |group| + start, finish = group.split(" - ") + group_name = (group == "70 - 140" ? "+ 70" : group) + groups[group_name] = User.where(id: participants) + .where("date_of_birth > ? AND date_of_birth < ?", + finish.to_i.years.ago.beginning_of_year, + start.to_i.years.ago.end_of_year).count + end + groups + end + end + + def male_percentage + stats_cache("male_percentage") { total_male_participants / total_participants_with_gender.to_f * 100 } + end + + def female_percentage + stats_cache("female_percentage") { total_female_participants / total_participants_with_gender.to_f * 100 } + end + + def participants + stats_cache("participants") do + User.where(id: (authors + voters + balloters + poll_ballot_voters).uniq.compact) + end + end + + def authors + stats_cache("authors") { @budget.investments.pluck(:author_id) } + end + + def voters + stats_cache("voters") { supports(@budget).pluck(:voter_id) } + end + + def balloters + stats_cache("balloters") { @budget.ballots.where("ballot_lines_count > ?", 0).pluck(:user_id) } + end + + def poll_ballot_voters + stats_cache("poll_ballot_voters") do + @budget&.poll ? @budget.poll.voters.pluck(:user_id) : [] + end + end + + def total_participants_with_gender + stats_cache("total_participants_with_gender") { participants.where.not(gender: nil).distinct.count } + end + + def balloters_by_heading(heading_id) + stats_cache("balloters_by_heading_#{heading_id}") do + @budget.ballots.joins(:lines).where(budget_ballot_lines: {heading_id: heading_id}).pluck(:user_id) + end + end + + def voters_by_heading(heading) + stats_cache("voters_by_heading_#{heading.id}") do + supports(heading).pluck(:voter_id) + end + end + + def headings + stats_cache("headings") do + groups = Hash.new(0) + @budget.headings.order("id ASC").each do |heading| + groups[heading.id] = Hash.new(0).merge(calculate_heading_totals(heading)) + end + + groups[:total] = Hash.new(0) + groups[:total][:total_investments_count] = groups.collect {|_k, v| v[:total_investments_count]}.sum + groups[:total][:total_participants_support_phase] = groups.collect {|_k, v| v[:total_participants_support_phase]}.sum + groups[:total][:total_participants_vote_phase] = groups.collect {|_k, v| v[:total_participants_vote_phase]}.sum + groups[:total][:total_participants_all_phase] = groups.collect {|_k, v| v[:total_participants_all_phase]}.sum + + @budget.headings.each do |heading| + groups[heading.id].merge!(calculate_heading_stats_with_totals(groups[heading.id], groups[:total], heading.population)) + end + + groups[:total][:percentage_participants_support_phase] = groups.collect {|_k, v| v[:percentage_participants_support_phase]}.sum + groups[:total][:percentage_participants_vote_phase] = groups.collect {|_k, v| v[:percentage_participants_vote_phase]}.sum + groups[:total][:percentage_participants_all_phase] = groups.collect {|_k, v| v[:percentage_participants_all_phase]}.sum + + groups + end + end + + def calculate_heading_totals(heading) + { + total_investments_count: heading.investments.count, + total_participants_support_phase: voters_by_heading(heading).uniq.count, + total_participants_vote_phase: balloters_by_heading(heading.id).uniq.count, + total_participants_all_phase: voters_and_balloters_by_heading(heading) + } + end + + def calculate_heading_stats_with_totals(heading_totals, groups_totals, population) + { + percentage_participants_support_phase: participants_percent(heading_totals, groups_totals, :total_participants_support_phase), + percentage_district_population_support_phase: population_percent(population, heading_totals[:total_participants_support_phase]), + percentage_participants_vote_phase: participants_percent(heading_totals, groups_totals, :total_participants_vote_phase), + percentage_district_population_vote_phase: population_percent(population, heading_totals[:total_participants_vote_phase]), + percentage_participants_all_phase: participants_percent(heading_totals, groups_totals, :total_participants_all_phase), + percentage_district_population_all_phase: population_percent(population, heading_totals[:total_participants_all_phase]) + } + end + + def voters_and_balloters_by_heading(heading) + (voters_by_heading(heading) + balloters_by_heading(heading.id)).uniq.count + end + + def participants_percent(heading_totals, groups_totals, phase) + calculate_percentage(heading_totals[phase], groups_totals[phase]) + end + + def population_percent(population, participants) + return "N/A" unless population.to_f.positive? + calculate_percentage(participants, population) + end + + def calculate_percentage(fraction, total) + percent = fraction / total.to_f + percent.nan? ? 0.0 : (percent * 100).round(3) + end + + def supports(supportable) + ActsAsVotable::Vote.where(votable_type: "Budget::Investment", votable_id: supportable.investments.pluck(:id)) + end + + def stats_cache(key, &block) + Rails.cache.fetch("budgets_stats/#{@budget.id}/#{key}/v10", &block) + end + end +end diff --git a/app/views/budgets/executions/show.html.erb b/app/views/budgets/executions/show.html.erb index c1abd1e5c..aa107e3b6 100644 --- a/app/views/budgets/executions/show.html.erb +++ b/app/views/budgets/executions/show.html.erb @@ -31,6 +31,9 @@
  • <%= link_to t("budgets.results.link"), budget_results_path(@budget) %>
    • +
  • + <%= link_to t("budgets.stats.link"), budget_stats_path(@budget) %> +
  • <%= link_to t("budgets.executions.link"), budget_executions_path(@budget), class: "is-active" %>
    • diff --git a/app/views/budgets/results/show.html.erb b/app/views/budgets/results/show.html.erb index b8b3e9de8..43e403090 100644 --- a/app/views/budgets/results/show.html.erb +++ b/app/views/budgets/results/show.html.erb @@ -31,6 +31,9 @@ <%= t("shared.you_are_in") %> <%= link_to t("budgets.results.link"), budget_results_path(@budget), class: "is-active" %> +
  • + <%= link_to t("budgets.stats.link"), budget_stats_path(@budget) %> +
  • <%= link_to t("budgets.executions.link"), budget_executions_path(@budget) %>
    • @@ -43,10 +46,8 @@

    <%= t("budgets.results.heading_selection_title") %>

    -