11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
# File 'app/interactors/ntq_excelsior_engine/imports/import_lines.rb', line 11
def call
import = context.import
importer = context.importer.new
importer.options ||= {}
importer.options.merge!({
import_id: import.id,
creator: import.created_by
})
begin
import.update(state: 'importing')
importer.class.before.call(importer.context, importer.options) if importer.class.before.is_a?(Proc)
import.import_lines.find_each(batch_size: 1000) do |line|
result = importer.import_line(line.line, save: true)
line.update(status: result[:status], line_errors: result[:errors], action: result[:action])
end
importer.class.after.call(importer.context, importer.options) if importer.class.after.is_a?(Proc)
sleep 2 if NtqExcelsiorEngine.debug
stats = {
count: import.import_lines.count,
errors: import.import_lines.in_error.count,
success: import.import_lines.successes.count,
create: import.import_lines.successes.is_create.count,
update: import.import_lines.successes.is_update.count
}
import.update(state: import.import_lines.in_error.any? ? 'error' : 'imported', stats: stats)
import.import_lines.delete_all unless NtqExcelsiorEngine.keep_import_lines
rescue => e
p e.inspect
Appsignal.send_error(e)
import.update(state: 'error', backtrace: e.backtrace.join('\n'))
end
end
|