84 lines
3 KiB
Ruby
84 lines
3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# License: AGPL-3.0-or-later WITH WTO-AP-3.0-or-later
|
|
# Full license explanation at https://github.com/houdiniproject/houdini/blob/master/LICENSE
|
|
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')
|
|
|
|
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 IN (#{QueryCampaigns.get_campaign_and_children(campaign_id).parse})")
|
|
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)
|
|
np = Nonprofit.find(npo_id)
|
|
campaigns = np.campaigns.not_deleted.includes(:profile).order('campaigns.name ASC')
|
|
output = campaigns.map do |i|
|
|
{
|
|
'name' => i.name,
|
|
'id' => i.id,
|
|
'isChildCampaign' => i.child_campaign?,
|
|
'creator' => i.profile&.name || "user ##{i.profile.id}"
|
|
}
|
|
end
|
|
output
|
|
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
|