|
|
@ -18,10 +18,10 @@ module Exports |
|
|
|
def export_case_logs(full_update: false) |
|
|
|
def export_case_logs(full_update: false) |
|
|
|
start_time = Time.zone.now |
|
|
|
start_time = Time.zone.now |
|
|
|
case_logs = retrieve_case_logs(start_time, full_update) |
|
|
|
case_logs = retrieve_case_logs(start_time, full_update) |
|
|
|
empty_export = case_logs.empty? |
|
|
|
export = build_export_run(start_time, full_update) |
|
|
|
export = build_export_run(start_time, full_update, empty_export) |
|
|
|
|
|
|
|
daily_run = get_daily_run_number |
|
|
|
daily_run = get_daily_run_number |
|
|
|
archive_datetimes = write_export_archive(export, case_logs) |
|
|
|
archive_datetimes = write_export_archive(export, case_logs) |
|
|
|
|
|
|
|
export.empty_export = archive_datetimes.empty? |
|
|
|
write_master_manifest(daily_run, archive_datetimes) |
|
|
|
write_master_manifest(daily_run, archive_datetimes) |
|
|
|
export.save! |
|
|
|
export.save! |
|
|
|
end |
|
|
|
end |
|
|
@ -39,11 +39,11 @@ module Exports |
|
|
|
LogsExport.where(created_at: today.beginning_of_day..today.end_of_day).count + 1 |
|
|
|
LogsExport.where(created_at: today.beginning_of_day..today.end_of_day).count + 1 |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
def build_export_run(current_time, full_update, empty_export) |
|
|
|
def build_export_run(current_time, full_update) |
|
|
|
previous_exports_with_data = LogsExport.where(empty_export: false) |
|
|
|
previous_exports_with_data = LogsExport.where(empty_export: false) |
|
|
|
|
|
|
|
|
|
|
|
if previous_exports_with_data.empty? |
|
|
|
if previous_exports_with_data.empty? |
|
|
|
return LogsExport.new(started_at: current_time, empty_export:) |
|
|
|
return LogsExport.new(started_at: current_time) |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
base_number = previous_exports_with_data.maximum(:base_number) |
|
|
|
base_number = previous_exports_with_data.maximum(:base_number) |
|
|
@ -56,7 +56,7 @@ module Exports |
|
|
|
increment_number += 1 |
|
|
|
increment_number += 1 |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
LogsExport.new(started_at: current_time, base_number:, increment_number:, empty_export:) |
|
|
|
LogsExport.new(started_at: current_time, base_number:, increment_number:) |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
def write_master_manifest(daily_run, archive_datetimes) |
|
|
|
def write_master_manifest(daily_run, archive_datetimes) |
|
|
|