2020-04-28 18:03:23 +08:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
module Repositories
|
|
|
|
class SnapshotProvisioningService
|
|
|
|
extend Service
|
|
|
|
|
|
|
|
attr_reader :repository_snapshot, :errors
|
|
|
|
|
|
|
|
def initialize(repository_snapshot:)
|
|
|
|
@repository_snapshot = repository_snapshot
|
|
|
|
@errors = {}
|
|
|
|
end
|
|
|
|
|
|
|
|
def call
|
|
|
|
return self unless valid?
|
|
|
|
|
2021-11-29 17:51:49 +08:00
|
|
|
ActiveRecord::Base.transaction(requires_new: true) do
|
2020-04-28 18:03:23 +08:00
|
|
|
repository = @repository_snapshot.original_repository
|
2022-01-26 00:48:45 +08:00
|
|
|
has_stock_management = repository.has_stock_management?
|
2020-04-28 18:03:23 +08:00
|
|
|
|
|
|
|
repository.repository_columns.each do |column|
|
|
|
|
column.snapshot!(@repository_snapshot)
|
|
|
|
end
|
|
|
|
|
|
|
|
repository_rows = repository.repository_rows
|
|
|
|
.joins(:my_module_repository_rows)
|
|
|
|
.where(my_module_repository_rows: { my_module: @repository_snapshot.my_module })
|
|
|
|
|
|
|
|
repository_rows.find_each do |original_row|
|
2022-01-26 00:48:45 +08:00
|
|
|
row_snapshot = original_row.snapshot!(@repository_snapshot)
|
|
|
|
create_stock_consumption_cell_snapshot!(original_row, row_snapshot) if has_stock_management
|
2020-04-28 18:03:23 +08:00
|
|
|
end
|
|
|
|
|
|
|
|
@repository_snapshot.ready!
|
2021-11-29 17:51:49 +08:00
|
|
|
rescue StandardError => e
|
|
|
|
if e.is_a?(ActiveRecord::RecordInvalid)
|
|
|
|
@errors[e.record.class.name.underscore] = e.record.errors.full_messages
|
|
|
|
else
|
|
|
|
@errors[:general] = e.message
|
|
|
|
end
|
2020-04-28 18:03:23 +08:00
|
|
|
Rails.logger.error e.message
|
|
|
|
raise ActiveRecord::Rollback
|
|
|
|
end
|
|
|
|
|
|
|
|
self
|
|
|
|
end
|
|
|
|
|
|
|
|
def succeed?
|
|
|
|
@errors.none?
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def valid?
|
|
|
|
unless @repository_snapshot
|
|
|
|
@errors[:invalid_arguments] =
|
|
|
|
{ 'repository_snapshot': @repository_snapshot }
|
|
|
|
.map do |key, value|
|
|
|
|
if value.nil?
|
|
|
|
I18n.t('repositories.my_module_assigned_snapshot_service.invalid_arguments', key: key.capitalize)
|
|
|
|
end
|
|
|
|
end.compact
|
|
|
|
return false
|
|
|
|
end
|
|
|
|
true
|
|
|
|
end
|
2022-01-26 00:48:45 +08:00
|
|
|
|
|
|
|
def create_stock_consumption_cell_snapshot!(repository_row, row_snapshot)
|
|
|
|
my_module_repository_row =
|
|
|
|
repository_row.my_module_repository_rows.find { |mrr| mrr.my_module_id == @repository_snapshot.my_module_id }
|
|
|
|
return if my_module_repository_row.stock_consumption.blank?
|
|
|
|
|
|
|
|
stock_unit_item =
|
|
|
|
@repository_snapshot.repository_stock_consumption_column
|
|
|
|
.repository_stock_unit_items
|
|
|
|
.find { |item| item.data == my_module_repository_row.repository_stock_unit_item&.data }
|
|
|
|
RepositoryStockConsumptionValue.create!(
|
|
|
|
repository_cell_attributes: {
|
|
|
|
repository_column: @repository_snapshot.repository_stock_consumption_column,
|
|
|
|
repository_row: row_snapshot
|
|
|
|
},
|
|
|
|
amount: my_module_repository_row.stock_consumption,
|
|
|
|
repository_stock_unit_item: stock_unit_item
|
|
|
|
)
|
|
|
|
end
|
2020-04-28 18:03:23 +08:00
|
|
|
end
|
|
|
|
end
|