mirror of
https://github.com/openfoodfoundation/openfoodnetwork
synced 2026-03-09 03:20:21 +00:00
b98552003c
13220 Fixes affiliate sales spec 13220 Use before_create to update product name 13220 Fixes rubocop warnings 13220 Update product_name in line_item in specs 13220 Fix before_create lint 13220 Add spec for checking product_name is not set in reports 13220 Fixes rubocop issue 13220 Add migrations for updating the existing line items 13220 Fixing lint issues 13220 Set product_name in line_item before doing validation 13220 Fix linter issues 13220 Fixes spec 13220 Fixes linter issues 13220 Review comments 13220 Review comments 13220 Add default product name 13220 Use product_name instead of variant product name when using line item 13220 Fix specs 13220 Revert change in affiliate_sales_data_spec CL-13220 Store variant name in line_item 13220 Default variant name to original variant's full name for line_items 13220 Add missing frozen string literal 13220 Add spec for full_variant_name 13220 Remove UpdateProductNameInLineItems and AddNotNullToProductNameInLineItems migrations 13220 Remove presence validation for product_name 13220 Use full_product_name which defaults to variant product name if empty
93 lines
2.7 KiB
Ruby
93 lines
2.7 KiB
Ruby
# frozen_string_literal: false
|
|
|
|
# Responsible for keeping line items on initialised orders for a subscription in sync with
|
|
# the subscription line items on that subscription.
|
|
|
|
class LineItemSyncer
|
|
def initialize(subscription, order_update_issues)
|
|
@subscription = subscription
|
|
@order_update_issues = order_update_issues
|
|
end
|
|
|
|
def sync!(order)
|
|
update_item_quantities(order)
|
|
create_new_items(order)
|
|
destroy_obsolete_items(order)
|
|
end
|
|
|
|
private
|
|
|
|
delegate :subscription_line_items, to: :subscription
|
|
|
|
attr_reader :subscription, :order_update_issues
|
|
|
|
def update_item_quantities(order)
|
|
changed_subscription_line_items.each do |sli|
|
|
line_item = order.line_items.find_by(variant_id: sli.variant_id)
|
|
|
|
if line_item.blank?
|
|
order_update_issues.add(order, sli.variant.product_and_full_name)
|
|
next
|
|
end
|
|
|
|
unless update_quantity(line_item, sli)
|
|
add_order_update_issue(order, line_item)
|
|
end
|
|
end
|
|
end
|
|
|
|
def create_new_items(order)
|
|
new_subscription_line_items.each do |sli|
|
|
new_line_item = order.line_items.create(variant_id: sli.variant_id,
|
|
quantity: sli.quantity,
|
|
skip_stock_check: skip_stock_check?(order))
|
|
next if skip_stock_check?(order) || new_line_item.sufficient_stock?
|
|
|
|
order.line_items.delete(new_line_item)
|
|
add_order_update_issue(order, new_line_item)
|
|
end
|
|
end
|
|
|
|
def destroy_obsolete_items(order)
|
|
order.line_items.
|
|
where(variant_id: subscription_line_items.
|
|
select(&:marked_for_destruction?).
|
|
map(&:variant_id)).
|
|
destroy_all
|
|
end
|
|
|
|
def changed_subscription_line_items
|
|
subscription_line_items.select{ |sli| sli.changed? && sli.persisted? }
|
|
end
|
|
|
|
def new_subscription_line_items
|
|
subscription_line_items.select(&:new_record?)
|
|
end
|
|
|
|
def update_quantity(line_item, sli)
|
|
if line_item.quantity == sli.quantity_was
|
|
return line_item.update(quantity: sli.quantity,
|
|
skip_stock_check: skip_stock_check?(line_item.order))
|
|
end
|
|
line_item.quantity == sli.quantity
|
|
end
|
|
|
|
def skip_stock_check?(order)
|
|
!order.complete?
|
|
end
|
|
|
|
def add_order_update_issue(order, line_item)
|
|
issue_description = "#{line_item.product.name} - #{line_item.full_variant_name}"
|
|
issue_description << " - #{stock_issue_description(line_item)}" if line_item.insufficient_stock?
|
|
order_update_issues.add(order, issue_description)
|
|
end
|
|
|
|
def stock_issue_description(line_item)
|
|
if line_item.variant.in_stock?
|
|
I18n.t("admin.subscriptions.stock.insufficient_stock")
|
|
else
|
|
I18n.t("admin.subscriptions.stock.out_of_stock")
|
|
end
|
|
end
|
|
end
|