demarches-normaliennes/app/models/export.rb

165 lines
4.3 KiB
Ruby
Raw Normal View History

2019-12-03 18:36:50 +01:00
class Export < ApplicationRecord
include TransientModelsWithPurgeableJobConcern
MAX_DUREE_CONSERVATION_EXPORT = 32.hours
MAX_DUREE_GENERATION = 16.hours
2019-12-03 18:36:50 +01:00
enum format: {
csv: 'csv',
ods: 'ods',
2022-04-08 17:12:53 +02:00
xlsx: 'xlsx',
2022-11-16 11:50:19 +01:00
zip: 'zip',
json: 'json'
2022-04-08 17:12:53 +02:00
}, _prefix: true
2019-12-03 18:36:50 +01:00
2021-06-16 11:46:25 +02:00
enum time_span_type: {
everything: 'everything',
monthly: 'monthly'
}
enum statut: {
'a-suivre': 'a-suivre',
suivis: 'suivis',
traites: 'traites',
tous: 'tous',
supprimes_recemment: 'supprimes_recemment',
archives: 'archives',
expirant: 'expirant'
}
2019-12-03 18:36:50 +01:00
has_and_belongs_to_many :groupe_instructeurs
belongs_to :procedure_presentation, optional: true
belongs_to :instructeur, optional: true
2019-12-03 18:36:50 +01:00
has_one_attached :file
validates :format, :groupe_instructeurs, :key, presence: true
2019-12-03 18:36:50 +01:00
scope :ante_chronological, -> { order(updated_at: :desc) }
2020-09-29 14:00:31 +02:00
after_create_commit :compute_async
2019-12-03 18:36:50 +01:00
FORMATS_WITH_TIME_SPAN = [:xlsx, :ods, :csv].flat_map do |format|
[{ format: format, time_span_type: 'everything' }]
2021-06-16 11:46:25 +02:00
end
2022-11-16 11:50:19 +01:00
FORMATS = [:xlsx, :ods, :csv, :zip, :json].map do |format|
{ format: format }
end
2021-06-16 11:46:25 +02:00
2019-12-03 18:36:50 +01:00
def compute_async
ExportJob.perform_later(self)
end
def compute
self.dossiers_count = dossiers_for_export.count
load_snapshot!
file.attach(blob.signed_id) # attaching a blob directly might run identify/virus scanner and wipe it
2019-12-03 18:36:50 +01:00
end
2021-06-16 11:46:25 +02:00
def since
time_span_type == Export.time_span_types.fetch(:monthly) ? 30.days.ago : nil
end
def filtered?
procedure_presentation_id.present?
end
def self.find_or_create_fresh_export(format, groupe_instructeurs, instructeur, time_span_type: time_span_types.fetch(:everything), statut: statuts.fetch(:tous), procedure_presentation: nil)
attributes = {
format:,
time_span_type:,
statut:,
key: generate_cache_key(groupe_instructeurs.map(&:id), procedure_presentation)
}
recent_export = pending
.or(generated.where(updated_at: (5.minutes.ago)..))
.includes(:procedure_presentation)
.find_by(attributes)
return recent_export if recent_export.present?
create!(**attributes, groupe_instructeurs:,
instructeur:,
procedure_presentation:,
procedure_presentation_snapshot: procedure_presentation&.snapshot)
2019-12-03 18:36:50 +01:00
end
def self.for_groupe_instructeurs(groupe_instructeurs_ids)
joins(:groupe_instructeurs).where(groupe_instructeurs: groupe_instructeurs_ids).distinct(:id)
end
def self.by_key(groupe_instructeurs_ids, procedure_presentation)
where(key: [
generate_cache_key(groupe_instructeurs_ids),
generate_cache_key(groupe_instructeurs_ids, procedure_presentation)
])
end
def self.generate_cache_key(groupe_instructeurs_ids, procedure_presentation = nil)
if procedure_presentation.present?
[
groupe_instructeurs_ids.sort.join('-'),
procedure_presentation.id,
Digest::MD5.hexdigest(procedure_presentation.snapshot.slice(:filters, :sort).to_s)
].join('--')
else
groupe_instructeurs_ids.sort.join('-')
end
end
def count
return dossiers_count if !dossiers_count.nil? # export generated
return dossiers_for_export.count if procedure_presentation_id.present?
nil
2019-12-03 18:36:50 +01:00
end
def procedure
groupe_instructeurs.first.procedure
end
2019-12-03 18:36:50 +01:00
private
def load_snapshot!
if procedure_presentation_snapshot.present?
procedure_presentation.attributes = procedure_presentation_snapshot
end
end
def dossiers_for_export
@dossiers_for_export ||= begin
dossiers = Dossier.where(groupe_instructeur: groupe_instructeurs)
if since.present?
dossiers.visible_by_administration.where('dossiers.depose_at > ?', since)
elsif procedure_presentation.present?
filtered_sorted_ids = procedure_presentation
.filtered_sorted_ids(dossiers, statut)
dossiers.where(id: filtered_sorted_ids)
else
dossiers.visible_by_administration
end
end
end
def blob
service = ProcedureExportService.new(procedure, dossiers_for_export)
2019-12-03 18:36:50 +01:00
case format.to_sym
when :csv
service.to_csv
2019-12-03 18:36:50 +01:00
when :xlsx
service.to_xlsx
2019-12-03 18:36:50 +01:00
when :ods
service.to_ods
2022-04-08 17:12:53 +02:00
when :zip
service.to_zip
2022-11-16 11:50:19 +01:00
when :json
service.to_geo_json
2019-12-03 18:36:50 +01:00
end
end
end