Merge pull request #70 from Purple-Stock/fix/68-under-count-pendings

refactor bling_order_item.rb: task 68

Author: Pauloparakleto

app/jobs/bling_order_job_updater.rb

@@ -6,6 +6,11 @@ def perform(record, account_id)
     result = Services::Bling::FindOrder.call(id: record.bling_order_id, order_command: 'find_order', tenant: account_id)
     raise StandardError if result['error'].present?
 
-    record.update({ value: result['data']['total'], situation_id: result['data']['situacao']['id'] })
+    record.situation_id = result['data']['situacao']['id']
+    record.value = result['data']['total']
+    record.alteration_date = Time.zone.today
+    return unless record.situation_id_changed?
+
+    record.save!
   end
 end

app/models/bling_order_item.rb

@@ -119,8 +119,13 @@ def self.group_order_items(base_query)
   def self.update_yourself(self_collection)
     account_id = self_collection.first.account_id
 
-    self_collection.each do |record|
-      BlingOrderJobUpdater.perform_later(record, account_id)
+    self_collection.find_in_batches(batch_size: 100) do |sub_collection|
+      GoodJob::Bulk.enqueue do
+        sub_collection.each do |record|
+          BlingOrderJobUpdater.perform_later(record, account_id)
+        end
+      end
+      sleep 10 if Rails.env.eql?('production') || Rails.env.eql?('staging')
     end
   end
 

spec/models/bling_order_item_spec.rb

@@ -243,6 +243,20 @@
             expect(collection.first.reload.value.to_f).to eq(69.9)
           end
         end
+
+        it 'updates status situation' do
+          VCR.use_cassette('find_checked_order', erb: true) do
+            described_class.update_yourself(collection)
+            expect(collection.first.reload.situation_id.to_i).to eq(BlingOrderItem::Status::IN_PROGRESS)
+          end
+        end
+
+        it 'updates alteration date' do
+          VCR.use_cassette('find_checked_order', erb: true) do
+            described_class.update_yourself(collection)
+            expect(collection.first.reload.alteration_date.strftime('%Y-%m-%d')).to eq(Time.zone.today.strftime)
+          end
+        end
       end
 
       context 'when there are too many requests error in the response' do