2025-02-21 11:57:59 -05:00
|
|
|
class IncomeStatement::Totals
|
|
|
|
include IncomeStatement::BaseQuery
|
|
|
|
|
|
|
|
def initialize(family, transactions_scope:)
|
|
|
|
@family = family
|
|
|
|
@transactions_scope = transactions_scope
|
|
|
|
end
|
|
|
|
|
|
|
|
def call
|
|
|
|
ActiveRecord::Base.connection.select_all(query_sql).map do |row|
|
|
|
|
TotalsRow.new(
|
|
|
|
parent_category_id: row["parent_category_id"],
|
|
|
|
category_id: row["category_id"],
|
|
|
|
classification: row["classification"],
|
|
|
|
total: row["total"],
|
2025-03-11 12:37:57 -04:00
|
|
|
transactions_count: row["transactions_count"],
|
2025-02-21 11:57:59 -05:00
|
|
|
missing_exchange_rates?: row["missing_exchange_rates"]
|
|
|
|
)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
2025-03-11 12:37:57 -04:00
|
|
|
TotalsRow = Data.define(:parent_category_id, :category_id, :classification, :total, :transactions_count, :missing_exchange_rates?)
|
2025-02-21 11:57:59 -05:00
|
|
|
|
|
|
|
def query_sql
|
|
|
|
base_sql = base_query_sql(family: @family, interval: "day", transactions_scope: @transactions_scope)
|
|
|
|
|
|
|
|
<<~SQL
|
|
|
|
WITH base_totals AS (
|
|
|
|
#{base_sql}
|
|
|
|
)
|
|
|
|
SELECT
|
|
|
|
parent_category_id,
|
|
|
|
category_id,
|
|
|
|
classification,
|
|
|
|
ABS(SUM(total)) as total,
|
2025-03-11 12:37:57 -04:00
|
|
|
BOOL_OR(missing_exchange_rates) as missing_exchange_rates,
|
|
|
|
SUM(transactions_count) as transactions_count
|
2025-02-21 11:57:59 -05:00
|
|
|
FROM base_totals
|
|
|
|
GROUP BY 1, 2, 3;
|
|
|
|
SQL
|
|
|
|
end
|
|
|
|
end
|