defmodule MvWeb.StatisticsLive do @moduledoc """ LiveView for the statistics page at /statistics. Displays aggregated member and membership fee cycle statistics. """ use MvWeb, :live_view require Logger import MvWeb.LiveHelpers, only: [current_actor: 1] alias Mv.Statistics alias Mv.MembershipFees.MembershipFeeType alias MvWeb.Helpers.MembershipFeeHelpers @impl true def mount(_params, _session, socket) do socket = socket |> assign(:page_title, gettext("Statistics")) |> assign(:selected_fee_type_id, nil) |> load_fee_types() |> load_statistics() {:ok, socket} end @impl true def handle_params(params, uri, socket) do # Query params: after push_patch, params may not include query string in some cases; # always derive from URI as well so fee_type_id is reliable. uri_query = if uri, do: URI.decode_query(URI.parse(uri).query || ""), else: %{} fee_type_id = params["fee_type_id"] || uri_query["fee_type_id"] fee_type_id = normalize_fee_type_id(fee_type_id) socket = socket |> assign(:selected_fee_type_id, fee_type_id) |> load_statistics() {:noreply, socket} end defp normalize_fee_type_id(nil), do: nil defp normalize_fee_type_id(""), do: nil defp normalize_fee_type_id(id) when is_binary(id) do case String.trim(id) do "" -> nil trimmed -> trimmed end end defp normalize_fee_type_id(_), do: nil @impl true def render(assigns) do ~H""" <.header> {gettext("Statistics")} <:subtitle>{gettext("Overview from first membership to today")}

{gettext("Members")}

{gettext("Active members")}

": " <> to_string(@active_count)} > {@active_count}

{gettext("Inactive members")}

": " <> to_string(@inactive_count)} > {@inactive_count}

{gettext("Member numbers by year")}

{gettext("From %{first} to %{last} (relevant years with membership data)", first: @years |> List.last() |> to_string(), last: @years |> List.first() |> to_string() )}

<.member_numbers_table joins_exits_by_year={@joins_exits_by_year} />

{gettext("Contributions")}

{gettext("Contributions by year")}

<.contributions_bars_by_year contributions_by_year={@contributions_by_year} totals_over_all_years={@totals_over_all_years} />

{gettext("All years combined (pie)")}

<.contributions_pie cycle_totals={@totals_over_all_years} />

{gettext("Paid")} {gettext("Unpaid")} {gettext("Suspended")}

""" end @impl true def handle_event("change_fee_type", %{"fee_type_id" => ""}, socket) do {:noreply, push_patch(socket, to: ~p"/statistics")} end def handle_event("change_fee_type", %{"fee_type_id" => id}, socket) when is_binary(id) do trimmed = String.trim(id) to = if trimmed == "", do: ~p"/statistics", else: ~p"/statistics" <> "?" <> URI.encode_query(%{"fee_type_id" => trimmed}) {:noreply, push_patch(socket, to: to)} end attr :joins_exits_by_year, :list, required: true defp member_numbers_table(assigns) do rows = assigns.joins_exits_by_year total_activity = Enum.map(rows, fn r -> r.joins + r.exits end) max_total = (total_activity != [] && Enum.max(total_activity)) || 1 rows_with_pct = Enum.map(rows, fn row -> sum = row.joins + row.exits bar_pct = if max_total > 0 and sum > 0 do min(100.0, Float.round(sum / max_total * 100, 1)) else 0 end seg_scale = max(sum, 1) joins_pct = min(100.0, row.joins / seg_scale * 100) exits_pct = min(100.0, row.exits / seg_scale * 100) %{ year: row.year, joins: row.joins, exits: row.exits, bar_pct: bar_pct, joins_pct: Float.round(joins_pct, 1), exits_pct: Float.round(exits_pct, 1) } end) assigns = assign(assigns, :rows, rows_with_pct) ~H""" """ end attr :contributions_by_year, :list, required: true attr :totals_over_all_years, :map, required: true defp contributions_bars_by_year(assigns) do rows = assigns.contributions_by_year totals = assigns.totals_over_all_years all_rows_with_decimals = Enum.map(rows, fn row -> %{ year: row.year, summary: false, total: row.total, paid: row.paid, unpaid: row.unpaid, suspended: row.suspended } end) ++ [ %{ year: nil, summary: true, total: totals.total, paid: totals.paid, unpaid: totals.unpaid, suspended: totals.suspended } ] max_total = max_decimal(all_rows_with_decimals, :total) rows_with_pct = Enum.map(all_rows_with_decimals, fn row -> bar_pct = bar_pct(row.total, max_total) sum_positive = Decimal.add(Decimal.add(row.paid, row.unpaid), row.suspended) seg_scale = if Decimal.compare(sum_positive, 0) == :gt, do: sum_positive, else: Decimal.new(1) paid_pct = row.paid |> Decimal.div(seg_scale) |> Decimal.mult(100) |> Decimal.to_float() |> min(100.0) unpaid_pct = row.unpaid |> Decimal.div(seg_scale) |> Decimal.mult(100) |> Decimal.to_float() |> min(100.0) suspended_pct = row.suspended |> Decimal.div(seg_scale) |> Decimal.mult(100) |> Decimal.to_float() |> min(100.0) %{ year: row.year, summary: row.summary, total_formatted: MembershipFeeHelpers.format_currency(row.total), paid_formatted: MembershipFeeHelpers.format_currency(row.paid), unpaid_formatted: MembershipFeeHelpers.format_currency(row.unpaid), suspended_formatted: MembershipFeeHelpers.format_currency(row.suspended), bar_pct: bar_pct, paid_pct: paid_pct, unpaid_pct: unpaid_pct, suspended_pct: suspended_pct } end) assigns = assign(assigns, :rows, rows_with_pct) ~H""" """ end defp max_decimal(rows, key) do Enum.reduce(rows, Decimal.new(0), fn row, acc -> val = Map.get(row, key) if Decimal.compare(val, acc) == :gt, do: val, else: acc end) end defp bar_pct(value, max) do scale = if Decimal.compare(max, 0) == :gt, do: max, else: Decimal.new(1) pct = value |> Decimal.div(scale) |> Decimal.mult(100) |> Decimal.to_float() min(100.0, pct) end attr :cycle_totals, :map, required: true defp contributions_pie(assigns) do paid = assigns.cycle_totals.paid unpaid = assigns.cycle_totals.unpaid suspended = assigns.cycle_totals.suspended sum_positive = Decimal.add(Decimal.add(paid, unpaid), suspended) scale = if Decimal.compare(sum_positive, 0) == :gt, do: sum_positive, else: Decimal.new(1) paid_pct = Decimal.div(paid, scale) |> Decimal.mult(100) |> Decimal.to_float() unpaid_pct = Decimal.div(unpaid, scale) |> Decimal.mult(100) |> Decimal.to_float() suspended_pct = Decimal.div(suspended, scale) |> Decimal.mult(100) |> Decimal.to_float() # Conic gradient: 0deg = top, clockwise. Success (paid), warning (unpaid), base-300 (suspended) # Use theme CSS variables (--color-*) so the pie renders in all themes paid_deg = paid_pct * 3.6 unpaid_deg = unpaid_pct * 3.6 gradient_stops = "var(--color-success) 0deg, var(--color-success) #{paid_deg}deg, var(--color-warning) #{paid_deg}deg, var(--color-warning) #{paid_deg + unpaid_deg}deg, var(--color-base-300) #{paid_deg + unpaid_deg}deg, var(--color-base-300) 360deg" assigns = assigns |> assign(:paid_pct, paid_pct) |> assign(:unpaid_pct, unpaid_pct) |> assign(:suspended_pct, suspended_pct) |> assign(:gradient_stops, gradient_stops) ~H""" """ end defp load_fee_types(socket) do actor = current_actor(socket) case MembershipFeeType |> Ash.Query.sort(name: :asc) |> Ash.read(domain: Mv.MembershipFees, actor: actor) do {:ok, fee_types} -> assign(socket, :membership_fee_types, fee_types) {:error, reason} -> Logger.warning("StatisticsLive: failed to load fee types: #{inspect(reason)}") socket |> put_flash(:error, gettext("Fee types could not be loaded.")) |> assign(:membership_fee_types, []) end end defp load_statistics(socket) do actor = current_actor(socket) fee_type_id = socket.assigns[:selected_fee_type_id] # Member stats must never depend on fee type (only contributions do) opts_member = [actor: actor] opts_contributions = [actor: actor] ++ if fee_type_id, do: [fee_type_id: fee_type_id], else: [] current_year = Date.utc_today().year first_year = Statistics.first_join_year(opts_member) || current_year years = first_year..current_year |> Enum.to_list() |> Enum.reverse() active_count = Statistics.active_member_count(opts_member) inactive_count = Statistics.inactive_member_count(opts_member) joins_exits_by_year = build_joins_exits_by_year(years, opts_member) contributions_by_year = build_contributions_by_year(years, opts_contributions) totals_over_all_years = sum_cycle_totals(contributions_by_year) assign(socket, years: years, active_count: active_count, inactive_count: inactive_count, joins_exits_by_year: joins_exits_by_year, contributions_by_year: contributions_by_year, totals_over_all_years: totals_over_all_years ) end defp build_joins_exits_by_year(years, opts) do Enum.map(years, fn y -> %{ year: y, joins: Statistics.joins_by_year(y, opts), exits: Statistics.exits_by_year(y, opts) } end) end defp build_contributions_by_year(years, opts) do Enum.map(years, fn y -> totals = Statistics.cycle_totals_by_year(y, opts) %{ year: y, total: totals.total, paid: totals.paid, unpaid: totals.unpaid, suspended: totals.suspended } end) end defp sum_cycle_totals(contributions_by_year) do Enum.reduce( contributions_by_year, %{ total: Decimal.new(0), paid: Decimal.new(0), unpaid: Decimal.new(0), suspended: Decimal.new(0) }, fn row, acc -> %{ total: Decimal.add(acc.total, row.total), paid: Decimal.add(acc.paid, row.paid), unpaid: Decimal.add(acc.unpaid, row.unpaid), suspended: Decimal.add(acc.suspended, row.suspended) } end ) end end