112 lines
2.9 KiB
Ruby
112 lines
2.9 KiB
Ruby
module JamRuby
|
|
class EmailBatch < ActiveRecord::Base
|
|
self.table_name = "email_batches"
|
|
|
|
attr_accessible :lock_version
|
|
|
|
VAR_FIRST_NAME = '@FIRSTNAME'
|
|
VAR_LAST_NAME = '@LASTNAME'
|
|
|
|
DEFAULT_SENDER = "support@jamkazam.com"
|
|
|
|
include AASM
|
|
aasm do
|
|
state :pending, :initial => true
|
|
state :testing
|
|
state :tested
|
|
state :batching
|
|
state :batched
|
|
state :disabled
|
|
|
|
event :enable do
|
|
transitions :from => :disabled, :to => :pending
|
|
end
|
|
event :do_test_run, :after => :running_tests do
|
|
transitions :from => [:pending, :tested, :batched], :to => :testing
|
|
end
|
|
event :did_test_run do
|
|
transitions :from => :testing, :to => :tested
|
|
end
|
|
event :do_batch_run, :after => Proc.new { running_batch } do
|
|
transitions :from => [:tested, :pending, :batched], :to => :batching
|
|
end
|
|
event :did_batch_run do
|
|
transitions :from => :batching, :to => :batched
|
|
end
|
|
event :disable do
|
|
transitions :from => [:pending, :tested, :batched], :to => :disabled
|
|
end
|
|
end
|
|
|
|
# has_many :email_batch_results, :class_name => 'JamRuby::EmailBatchResult'
|
|
|
|
def self.qualified_users
|
|
User.select(:email)
|
|
.where(:opt_out_email_batch => false)
|
|
end
|
|
|
|
def deliver
|
|
self.do_batch_run!
|
|
self.class.qualified_users.pluck(:id).find_in_batches(batch_size: 100) do |user_ids|
|
|
BatchMailer.send_batch_email(self.id, user_ids).deliver
|
|
end
|
|
end
|
|
|
|
def test_users
|
|
self.test_emails.split(',').collect do |ee|
|
|
ee.strip!
|
|
uu = User.new
|
|
uu.email = ee
|
|
uu.first_name = ee.match(/^(.*)@/)[1].to_s
|
|
uu.last_name = 'Test'
|
|
uu
|
|
end
|
|
end
|
|
|
|
def send_test_batch
|
|
self.do_test_run!
|
|
BatchMailer.send_batch_email_test(self.id).deliver
|
|
end
|
|
|
|
def merged_body(user)
|
|
body.gsub(VAR_FIRST_NAME, user.first_name).gsub(VAR_LAST_NAME, user.last_name)
|
|
end
|
|
|
|
def did_send(emails)
|
|
self.update_with_conflict_validation({ :sent_count => self.sent_count + emails.size })
|
|
|
|
if self.sent_count >= self.qualified_count
|
|
if batching?
|
|
self.did_batch_run!
|
|
elsif testing?
|
|
self.did_test_run!
|
|
end
|
|
end
|
|
end
|
|
|
|
def update_with_conflict_validation(*args)
|
|
num_try = 0
|
|
update_attributes(*args)
|
|
rescue ActiveRecord::StaleObjectError
|
|
num_try += 1
|
|
if 5 > num_try
|
|
self.reload
|
|
retry
|
|
end
|
|
end
|
|
|
|
def running_batch
|
|
self.update_attributes({:qualified_count => self.class.qualified_users.count,
|
|
:sent_count => 0
|
|
})
|
|
end
|
|
|
|
def running_tests
|
|
self.update_attributes({:qualified_count => self.class.qualified_users.count,
|
|
:sent_count => 0
|
|
})
|
|
end
|
|
|
|
end
|
|
end
|