address cal scheduler (#2890)

Author: u2

app/workers/calculate_address_info_worker.rb

@@ -16,11 +16,12 @@ def perform()
     end
     Rails.cache.write(key, local_tip_block.id)
 
-    Address.where(id: contained_address_ids).find_in_batches do |group|
-      sleep(50) # Make sure it doesn't get too crowded in there!
+    Address.where(id: contained_address_ids).find_in_batches(batch_size: 100).with_index do |group, batch|
+      puts "Processing group ##{batch}"
       address_attributes = []
 
       group.each do |addr|
+        # puts addr.id
         balance, balance_occupied = addr.cal_balance
         address_attributes << {
           id: addr.id,

lib/scheduler.rb

@@ -115,6 +115,10 @@ def call_worker(clz)
   call_worker ContractStatisticWorker
 end
 
+s.every "10h" overlap: false do
+  call_worker CalculateAddressInfoWorker
+end
+
 s.cron "0,30 * * * *" do
   BitcoinStatistic.refresh
 end