houdini/lib/query/query_campaigns.rb

85 lines
2.8 KiB
Ruby
Raw Normal View History

# License: AGPL-3.0-or-later WITH Web-Template-Output-Additional-Permission-3.0-or-later
require 'qexpr'
module QueryCampaigns
def self.featured(limit, gross_more_than)
expr = Qexpr.new.select(
'campaigns.name',
'campaigns.summary',
'campaigns.gross',
Image._url('campaigns', 'main_image', 'normal') + 'AS main_image_url',
"concat('/nonprofits/', campaigns.nonprofit_id, '/campaigns/', campaigns.id) AS url"
).from(
Qexpr.new.select("campaigns.*", "SUM(donations.amount) AS gross")
.from("campaigns")
.join("donations", "donations.campaign_id=campaigns.id")
.group_by("campaigns.id"),
"campaigns"
).where("campaigns.gross > $amount AND campaigns.published='t' AND campaigns.nonprofit_id!=$id", amount: gross_more_than, id: 4182)
.order_by("campaigns.updated_at ASC")
.limit(limit)
Psql.execute(expr.parse)
end
def self.timeline(campaign_id)
ex = QueryCampaigns.payments_expression(campaign_id, true)
ex.group_by("DATE(payments.date)")
.order_by("DATE(payments.date)")
.execute
end
def self.payments_expression(campaign_id, for_timeline)
selects = [
"coalesce(SUM(payments.gross_amount), 0) AS total_cents",
"coalesce(SUM(recurring.gross_amount), 0) AS recurring_cents",
"coalesce(SUM(offsite.gross_amount), 0) AS offsite_cents",
"coalesce(SUM(onetime.gross_amount), 0) AS onetime_cents"]
for_timeline ?
selects.push("MAX(DATE(payments.date)) AS date") :
selects.push("coalesce(count(supporters.id), 0) AS supporters_count")
return Qx.select(*selects)
.from("payments")
.left_join(
["donations", "payments.donation_id=donations.id"],
["payments AS onetime", "onetime.id=payments.id AND onetime.kind='Donation'"],
["payments AS offsite", "offsite.id=payments.id AND offsite.kind='OffsitePayment'"],
["payments AS recurring", "recurring.id=payments.id AND recurring.kind='RecurringDonation'"])
.where("donations.campaign_id" => campaign_id)
end
def self.totals(campaign_id)
ex = QueryCampaigns.payments_expression(campaign_id, false)
ex.add_left_join(["supporters", "donations.supporter_id=supporters.id"])
.execute.first
end
def self.name_and_id(npo_id)
Psql.execute(
Qexpr.new.select(
"campaigns.name",
"campaigns.id")
.from("campaigns")
.where("campaigns.nonprofit_id=$id", id: npo_id)
.where("campaigns.deleted='f' OR campaigns.deleted IS NULL")
.order_by("campaigns.name ASC")
)
end
def self.get_campaign_and_children(campaign_id)
Qx.select("id")
.from('campaigns')
.where("campaigns.id = $id OR campaigns.parent_campaign_id=$id",
id: campaign_id)
end
end