2019-05-02 18:17:27 -04:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
2013-02-05 14:16:51 -05:00
|
|
|
module Jobs
|
|
|
|
|
2019-10-02 00:01:53 -04:00
|
|
|
class EnqueueDigestEmails < ::Jobs::Scheduled
|
2016-03-02 15:26:27 -05:00
|
|
|
every 30.minutes
|
2013-02-05 14:16:51 -05:00
|
|
|
|
|
|
|
def execute(args)
|
2017-04-24 15:26:06 -04:00
|
|
|
return if SiteSetting.disable_digest_emails? || SiteSetting.private_email?
|
|
|
|
target_user_ids.each do |user_id|
|
2019-10-21 13:25:35 -04:00
|
|
|
::Jobs.enqueue(:user_email, type: :digest, user_id: user_id)
|
2013-02-25 11:42:20 -05:00
|
|
|
end
|
2013-02-05 14:16:51 -05:00
|
|
|
end
|
|
|
|
|
2013-08-27 20:44:13 -04:00
|
|
|
def target_user_ids
|
2016-03-02 15:26:27 -05:00
|
|
|
# Users who want to receive digest email within their chosen digest email frequency
|
2020-05-27 11:09:40 -04:00
|
|
|
query = User
|
|
|
|
.real
|
2017-03-08 13:19:11 -05:00
|
|
|
.activated
|
2020-05-27 11:09:40 -04:00
|
|
|
.not_suspended
|
2017-03-08 13:19:11 -05:00
|
|
|
.where(staged: false)
|
2020-05-27 11:09:40 -04:00
|
|
|
.joins(:user_option, :user_stat, :user_emails)
|
2017-03-08 13:19:11 -05:00
|
|
|
.where("user_options.email_digests")
|
|
|
|
.where("user_stats.bounce_score < #{SiteSetting.bounce_score_threshold}")
|
2020-05-27 11:09:40 -04:00
|
|
|
.where("user_emails.primary")
|
2016-03-02 15:26:27 -05:00
|
|
|
.where("COALESCE(last_emailed_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 MINUTE'::INTERVAL * user_options.digest_after_minutes)")
|
|
|
|
.where("COALESCE(last_seen_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 MINUTE'::INTERVAL * user_options.digest_after_minutes)")
|
2017-02-08 12:11:34 -05:00
|
|
|
.where("COALESCE(last_seen_at, '2010-01-01') >= CURRENT_TIMESTAMP - ('1 DAY'::INTERVAL * #{SiteSetting.suppress_digest_email_after_days})")
|
2013-06-06 11:45:18 -04:00
|
|
|
|
|
|
|
# If the site requires approval, make sure the user is approved
|
2017-03-08 13:19:11 -05:00
|
|
|
query = query.where("approved OR moderator OR admin") if SiteSetting.must_approve_users?
|
2013-06-06 11:45:18 -04:00
|
|
|
|
2013-08-27 20:44:13 -04:00
|
|
|
query.pluck(:id)
|
2013-02-05 14:16:51 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
2013-02-25 11:42:20 -05:00
|
|
|
end
|