Sha256: 519be4d4ba21d3d3db200b6e6db688f3e38fc7ddc6352282d52880d1452c2da8
Contents?: true
Size: 1.89 KB
Versions: 21
Compression:
Stored size: 1.89 KB
Contents
namespace :exchanges do
desc %q{Takes unreturned exchanged items and creates a new order to charge
the customer for not returning them}
task charge_unreturned_items: :environment do
unreturned_return_items = Spree::ReturnItem.expecting_return.exchange_processed.includes(:exchange_inventory_unit).where([
"spree_inventory_units.created_at < :days_ago AND spree_inventory_units.state = :iu_state",
days_ago: Spree::Config[:expedited_exchanges_days_window].days.ago, iu_state: "shipped"
]).references(:exchange_inventory_units).to_a
# Determine that a return item has already been deemed unreturned and therefore charged
# by the fact that its exchange inventory unit has popped off to a different order
unreturned_return_items.select! { |ri| ri.inventory_unit.order_id == ri.exchange_inventory_unit.order_id }
failures = []
unreturned_return_items.group_by(&:exchange_shipment).each do |shipment, return_items|
item_charger = Spree::UnreturnedItemCharger.new(shipment, return_items)
begin
item_charger.charge_for_items
rescue Spree::UnreturnedItemCharger::ChargeFailure => e
failure = {message: e.message, new_order: e.new_order.try(:number)}
rescue Exception => e
failure = {message: "#{e.class}: #{e.message}"}
end
if failure
failures << failure.merge({
order: item_charger.original_order.number,
shipment: shipment.number,
return_items: return_items.map(&:id),
order_errors: item_charger.original_order.errors.full_messages,
})
end
end
if failures.any?
if Spree::UnreturnedItemCharger.failure_handler
Spree::UnreturnedItemCharger.failure_handler.call(failures)
else
raise Spree::ChargeUnreturnedItemsFailures.new(failures.to_json)
end
end
end
end
class Spree::ChargeUnreturnedItemsFailures < StandardError; end
Version data entries
21 entries across 21 versions & 1 rubygems