Contents

class Counter::ReconciliationJob
  # include Sidekiq::Worker

  def perform counter_id
    counter = Counter::Value.find(counter_id)
    changes = Counter::Change.where(counter: counter).pending
    changes.with_lock do
      counter.increment! changes.sum(increment)
      changes.update_all processed: Time.now
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
counterwise-0.1.5	app/jobs/counter/reconciliation_job.rb
counterwise-0.1.4	app/jobs/counter/reconciliation_job.rb
counterwise-0.1.3	app/jobs/counter/reconciliation_job.rb
counterwise-0.1.2	app/jobs/counter/reconciliation_job.rb
counterwise-0.1.1	app/jobs/counter/reconciliation_job.rb
counterwise-0.1.0	app/jobs/counter/reconciliation_job.rb