demarches-normaliennes/app/models/procedure.rb

528 lines
16 KiB
Ruby
Raw Normal View History

require Rails.root.join('lib', 'percentile')
2018-03-06 13:44:29 +01:00
class Procedure < ApplicationRecord
self.ignored_columns = [:administrateur_id]
MAX_DUREE_CONSERVATION = 36
2018-12-20 12:00:27 +01:00
has_many :types_de_piece_justificative, -> { ordered }, dependent: :destroy
has_many :types_de_champ, -> { root.public_only.ordered }, dependent: :destroy
has_many :types_de_champ_private, -> { root.private_only.ordered }, class_name: 'TypeDeChamp', dependent: :destroy
has_many :dossiers, dependent: :restrict_with_exception
has_many :deleted_dossiers, dependent: :destroy
2017-03-07 10:25:28 +01:00
has_one :module_api_carto, dependent: :destroy
has_one :attestation_template, dependent: :destroy
2018-04-24 15:23:07 +02:00
belongs_to :parent_procedure, class_name: 'Procedure'
2018-04-17 16:11:49 +02:00
belongs_to :service
2016-06-20 17:37:04 +02:00
has_many :assign_to, dependent: :destroy
has_many :administrateurs_procedures
has_many :administrateurs, through: :administrateurs_procedures, after_remove: -> (procedure, _admin) { procedure.validate! }
has_many :gestionnaires, through: :assign_to
has_one :initiated_mail, class_name: "Mails::InitiatedMail", dependent: :destroy
has_one :received_mail, class_name: "Mails::ReceivedMail", dependent: :destroy
has_one :closed_mail, class_name: "Mails::ClosedMail", dependent: :destroy
has_one :refused_mail, class_name: "Mails::RefusedMail", dependent: :destroy
has_one :without_continuation_mail, class_name: "Mails::WithoutContinuationMail", dependent: :destroy
2018-04-11 14:35:52 +02:00
has_one_attached :notice
2018-05-31 10:59:38 +02:00
has_one_attached :deliberation
2018-04-11 14:35:52 +02:00
2018-11-14 16:24:34 +01:00
accepts_nested_attributes_for :types_de_champ, reject_if: proc { |attributes| attributes['libelle'].blank? }, allow_destroy: true
accepts_nested_attributes_for :types_de_champ_private, reject_if: proc { |attributes| attributes['libelle'].blank? }, allow_destroy: true
accepts_nested_attributes_for :types_de_piece_justificative, reject_if: proc { |attributes| attributes['libelle'].blank? }, allow_destroy: true
mount_uploader :logo, ProcedureLogoUploader
2017-06-27 14:22:43 +02:00
default_scope { where(hidden_at: nil) }
2018-05-16 17:21:12 +02:00
scope :brouillons, -> { where(aasm_state: :brouillon) }
scope :publiees, -> { where(aasm_state: :publiee) }
scope :archivees, -> { where(aasm_state: :archivee) }
scope :publiees_ou_archivees, -> { where(aasm_state: [:publiee, :archivee]) }
scope :by_libelle, -> { order(libelle: :asc) }
scope :created_during, -> (range) { where(created_at: range) }
scope :cloned_from_library, -> { where(cloned_from_library: true) }
2018-10-25 17:41:48 +02:00
scope :avec_lien, -> { where.not(path: nil) }
2017-05-26 21:30:11 +02:00
2018-11-01 14:04:32 +01:00
scope :for_api, -> {
includes(
:administrateurs,
2018-11-01 14:04:32 +01:00
:types_de_champ_private,
:types_de_champ,
:types_de_piece_justificative,
:module_api_carto
)
}
validates :libelle, presence: true, allow_blank: false, allow_nil: false
validates :description, presence: true, allow_blank: false, allow_nil: false
validates :administrateurs, presence: true
2018-05-31 10:59:38 +02:00
validate :check_juridique
2018-10-25 17:41:48 +02:00
validates :path, format: { with: /\A[a-z0-9_\-]{3,50}\z/ }, uniqueness: { scope: :aasm_state, case_sensitive: false }, presence: true, allow_blank: false, allow_nil: true
# FIXME: remove duree_conservation_required flag once all procedures are converted to the new style
validates :duree_conservation_dossiers_dans_ds, allow_nil: false, numericality: { only_integer: true, greater_than_or_equal_to: 1, less_than_or_equal_to: MAX_DUREE_CONSERVATION }, if: :durees_conservation_required
validates :duree_conservation_dossiers_hors_ds, allow_nil: false, numericality: { only_integer: true, greater_than_or_equal_to: 0 }, if: :durees_conservation_required
validates :duree_conservation_dossiers_dans_ds, allow_nil: true, numericality: { only_integer: true, greater_than_or_equal_to: 1, less_than_or_equal_to: MAX_DUREE_CONSERVATION }, unless: :durees_conservation_required
validates :duree_conservation_dossiers_hors_ds, allow_nil: true, numericality: { only_integer: true, greater_than_or_equal_to: 0 }, unless: :durees_conservation_required
before_save :update_juridique_required
before_save :update_durees_conservation_required
before_create :ensure_path_exists
2018-05-17 15:38:49 +02:00
include AASM
aasm whiny_persistence: true do
state :brouillon, initial: true
state :publiee
state :archivee
state :hidden
event :publish, after: :after_publish, guard: :can_publish? do
transitions from: :brouillon, to: :publiee
2018-09-07 18:37:44 +02:00
end
event :reopen, after: :after_reopen, guard: :can_publish? do
2018-05-17 15:38:49 +02:00
transitions from: :archivee, to: :publiee
end
event :archive, after: :after_archive do
transitions from: :publiee, to: :archivee
end
event :hide, after: :after_hide do
transitions from: :brouillon, to: :hidden
transitions from: :publiee, to: :hidden
transitions from: :archivee, to: :hidden
end
event :draft, after: :after_draft do
transitions from: :publiee, to: :brouillon
end
2018-05-17 15:38:49 +02:00
end
2018-05-17 15:39:37 +02:00
def publish_or_reopen!(administrateur, path)
if archivee? && may_reopen?(administrateur, path)
reopen!(administrateur, path)
elsif may_publish?(administrateur, path)
2018-09-07 18:42:12 +02:00
reset!
publish!(administrateur, path)
2018-09-07 18:42:12 +02:00
end
end
def reset!
if locked?
raise "Can not reset a locked procedure."
else
dossiers.destroy_all
end
end
2018-05-17 15:41:44 +02:00
def locked?
publiee_ou_archivee?
end
def accepts_new_dossiers?
!archivee?
end
2018-08-13 17:52:56 +02:00
# This method is needed for transition. Eventually this will be the same as brouillon?.
def brouillon_avec_lien?
2019-03-06 14:42:27 +01:00
brouillon? && path.present?
2018-08-13 17:52:56 +02:00
end
2018-05-17 15:41:44 +02:00
def publiee_ou_archivee?
publiee? || archivee?
end
2018-10-31 13:28:39 +01:00
def expose_legacy_carto_api?
2018-11-27 15:53:13 +01:00
module_api_carto&.use_api_carto? && module_api_carto&.migrated?
2018-10-31 13:28:39 +01:00
end
# Warning: dossier after_save build_default_champs must be removed
# to save a dossier created from this method
def new_dossier
2019-02-07 10:44:15 +01:00
Dossier.new(procedure: self, champs: build_champs, champs_private: build_champs_private)
end
def build_champs
types_de_champ.map(&:build_champ)
end
2019-02-07 10:44:15 +01:00
def build_champs_private
types_de_champ_private.map(&:build_champ)
end
2016-06-30 10:24:01 +02:00
def default_path
libelle&.parameterize&.first(50)
2016-06-30 10:24:01 +02:00
end
def organisation_name
service&.nom || organisation
end
def self.active(id)
2017-07-11 15:52:06 +02:00
publiees.find(id)
end
def switch_types_de_champ(index_of_first_element)
2018-12-20 12:00:27 +01:00
switch_list_order(types_de_champ, index_of_first_element)
end
def switch_types_de_champ_private(index_of_first_element)
2018-12-20 12:00:27 +01:00
switch_list_order(types_de_champ_private, index_of_first_element)
end
def switch_types_de_piece_justificative(index_of_first_element)
switch_list_order(types_de_piece_justificative, index_of_first_element)
end
def switch_list_order(list, index_of_first_element)
2017-05-26 21:43:44 +02:00
if index_of_first_element < 0 ||
index_of_first_element == list.count - 1 ||
list.count < 1
false
else
list[index_of_first_element].update(order_place: index_of_first_element + 1)
list[index_of_first_element + 1].update(order_place: index_of_first_element)
reload
2017-05-26 21:43:44 +02:00
true
end
end
def clone(admin, from_library)
is_different_admin = !admin.owns?(self)
populate_champ_stable_ids
2017-03-07 18:19:48 +01:00
procedure = self.deep_clone(include:
{
attestation_template: nil,
2019-02-06 10:02:05 +01:00
types_de_champ: [:drop_down_list, types_de_champ: :drop_down_list],
types_de_champ_private: [:drop_down_list, types_de_champ: :drop_down_list]
}, &method(:clone_attachments))
2018-09-18 14:31:29 +02:00
procedure.path = nil
2018-05-28 14:58:40 +02:00
procedure.aasm_state = :brouillon
procedure.test_started_at = nil
procedure.archived_at = nil
procedure.published_at = nil
2016-09-02 17:10:55 +02:00
procedure.logo_secure_token = nil
procedure.remote_logo_url = self.logo_url
procedure.lien_notice = nil
2017-03-07 18:19:48 +01:00
procedure.types_de_champ += PiecesJustificativesService.types_pj_as_types_de_champ(self)
if is_different_admin || from_library
procedure.types_de_champ.each { |tdc| tdc.options&.delete(:old_pj) }
end
if is_different_admin
procedure.administrateurs = [admin]
else
procedure.administrateurs = administrateurs
end
2018-05-30 18:45:46 +02:00
procedure.initiated_mail = initiated_mail&.dup
procedure.received_mail = received_mail&.dup
procedure.closed_mail = closed_mail&.dup
procedure.refused_mail = refused_mail&.dup
procedure.without_continuation_mail = without_continuation_mail&.dup
2017-03-07 18:19:48 +01:00
procedure.cloned_from_library = from_library
2018-04-24 15:23:07 +02:00
procedure.parent_procedure = self
if from_library
procedure.service = nil
elsif self.service.present? && is_different_admin
procedure.service = self.service.clone_and_assign_to_administrateur(admin)
end
admin.gestionnaire.assign_to_procedure(procedure)
procedure
2016-06-15 11:34:05 +02:00
end
def clone_attachments(original, kopy)
if original.is_a?(TypeDeChamp)
clone_attachment(:piece_justificative_template, original, kopy)
elsif original.is_a?(Procedure)
clone_attachment(:notice, original, kopy)
clone_attachment(:deliberation, original, kopy)
end
end
def clone_attachment(attribute, original, kopy)
original_attachment = original.send(attribute)
if original_attachment.attached?
kopy.send(attribute).attach({
io: StringIO.new(original_attachment.download),
filename: original_attachment.blob.filename,
content_type: original_attachment.blob.content_type
})
end
end
2018-01-10 17:52:43 +01:00
def whitelisted?
whitelisted_at.present?
end
def has_old_pjs?
types_de_piece_justificative.any?
end
def total_dossier
self.dossiers.state_not_brouillon.size
end
def export_filename(format)
procedure_identifier = path || "procedure-#{id}"
"dossiers_#{procedure_identifier}_#{Time.zone.now.strftime('%Y-%m-%d_%H-%M')}.#{format}"
end
def export(options = {})
ProcedureExportService.new(self, **options.to_h.symbolize_keys)
end
def to_csv(options = {})
export(options).to_csv
end
def to_xlsx(options = {})
export(options).to_xlsx
end
def to_ods(options = {})
export(options).to_ods
end
def procedure_overview(start_date)
ProcedureOverview.new(self, start_date)
end
def initiated_mail_template
initiated_mail || Mails::InitiatedMail.default_for_procedure(self)
end
def received_mail_template
received_mail || Mails::ReceivedMail.default_for_procedure(self)
end
def closed_mail_template
closed_mail || Mails::ClosedMail.default_for_procedure(self)
end
def refused_mail_template
refused_mail || Mails::RefusedMail.default_for_procedure(self)
end
def without_continuation_mail_template
without_continuation_mail || Mails::WithoutContinuationMail.default_for_procedure(self)
end
2017-09-27 15:16:07 +02:00
def self.default_sort
{
'table' => 'self',
'column' => 'id',
'order' => 'desc'
2018-09-20 17:02:28 +02:00
}
2017-09-27 15:16:07 +02:00
end
def whitelist!
2018-10-25 15:07:15 +02:00
update_attribute('whitelisted_at', Time.zone.now)
end
def closed_mail_template_attestation_inconsistency_state
# As an optimization, dont check the predefined templates (they are presumed correct)
if closed_mail.present?
tag_present = closed_mail.body.include?("--lien attestation--")
if attestation_template&.activated? && !tag_present
:missing_tag
elsif !attestation_template&.activated? && tag_present
:extraneous_tag
end
end
end
def usual_traitement_time
percentile_time(:en_construction_at, :processed_at, 90)
end
PATH_AVAILABLE = :available
PATH_AVAILABLE_PUBLIEE = :available_publiee
PATH_NOT_AVAILABLE = :not_available
PATH_NOT_AVAILABLE_BROUILLON = :not_available_brouillon
PATH_CAN_PUBLISH = [PATH_AVAILABLE, PATH_AVAILABLE_PUBLIEE]
2018-10-25 17:41:48 +02:00
def path_availability(administrateur, path)
Procedure.path_availability(administrateur, path, id)
2018-10-25 17:41:48 +02:00
end
def self.path_availability(administrateur, path, exclude_id = nil)
if exclude_id.present?
procedure = where.not(id: exclude_id).find_by(path: path)
else
procedure = find_by(path: path)
end
if procedure.blank?
PATH_AVAILABLE
elsif administrateur.owns?(procedure)
if procedure.brouillon?
PATH_NOT_AVAILABLE_BROUILLON
else
PATH_AVAILABLE_PUBLIEE
end
else
PATH_NOT_AVAILABLE
end
2018-10-25 17:41:48 +02:00
end
def self.find_with_path(path)
where.not(aasm_state: :archivee).where("path LIKE ?", "%#{path}%")
end
def populate_champ_stable_ids
TypeDeChamp.where(procedure: self, stable_id: nil).find_each do |type_de_champ|
type_de_champ.update_column(:stable_id, type_de_champ.id)
end
end
def missing_steps
result = []
if service.nil?
result << :service
end
if gestionnaires.empty?
result << :instructeurs
end
result
end
2019-03-20 14:27:30 +01:00
def move_type_de_champ(type_de_champ, new_index)
types_de_champ, collection_attribute_name = if type_de_champ.parent&.repetition?
if type_de_champ.parent.private?
[type_de_champ.parent.types_de_champ, :types_de_champ_private_attributes]
else
[type_de_champ.parent.types_de_champ, :types_de_champ_attributes]
end
elsif type_de_champ.private?
[self.types_de_champ_private, :types_de_champ_private_attributes]
else
[self.types_de_champ, :types_de_champ_attributes]
end
attributes = move_type_de_champ_attributes(types_de_champ.to_a, type_de_champ, new_index)
if type_de_champ.parent&.repetition?
attributes = [
{
id: type_de_champ.parent.id,
libelle: type_de_champ.parent.libelle,
types_de_champ_attributes: attributes
}
]
end
update!(collection_attribute_name => attributes)
end
private
2019-03-20 14:27:30 +01:00
def move_type_de_champ_attributes(types_de_champ, type_de_champ, new_index)
old_index = types_de_champ.index(type_de_champ)
types_de_champ.insert(new_index, types_de_champ.delete_at(old_index))
.map.with_index do |type_de_champ, index|
{
id: type_de_champ.id,
libelle: type_de_champ.libelle,
order_place: index
}
end
end
2018-10-25 17:41:48 +02:00
def claim_path_ownership!(path)
procedure = Procedure.joins(:administrateurs)
.where(administrateurs: { id: administrateur_ids })
.find_by(path: path)
2018-10-25 17:41:48 +02:00
if procedure&.publiee? && procedure != self
procedure.archive!
2018-09-07 18:36:31 +02:00
end
2018-10-25 17:41:48 +02:00
update!(path: path)
end
def can_publish?(administrateur, path)
path_availability(administrateur, path).in?(PATH_CAN_PUBLISH)
2018-09-07 18:36:31 +02:00
end
def can_reopen?(administrateur, path)
path_availability(administrateur, path).in?(PATH_CAN_PUBLISH)
end
def after_publish(administrateur, path)
2018-10-25 15:11:12 +02:00
update!(published_at: Time.zone.now)
2018-09-07 18:36:31 +02:00
2018-10-25 17:41:48 +02:00
claim_path_ownership!(path)
end
def after_reopen(administrateur, path)
2018-10-25 17:41:48 +02:00
update!(published_at: Time.zone.now, archived_at: nil)
claim_path_ownership!(path)
2018-09-07 18:36:31 +02:00
end
def after_archive
2018-10-25 15:11:12 +02:00
update!(archived_at: Time.zone.now, path: nil)
2018-09-07 18:36:31 +02:00
end
def after_hide
2018-10-25 15:11:12 +02:00
now = Time.zone.now
update!(hidden_at: now, path: nil)
2018-09-07 18:36:31 +02:00
dossiers.update_all(hidden_at: now)
end
def after_draft
update!(published_at: nil)
end
def update_juridique_required
self.juridique_required ||= (cadre_juridique.present? || deliberation.attached?)
true
end
2018-05-31 10:59:38 +02:00
def check_juridique
if juridique_required? && (cadre_juridique.blank? && !deliberation.attached?)
2018-05-31 10:59:38 +02:00
errors.add(:cadre_juridique, " : veuillez remplir le texte de loi ou la délibération")
end
end
def update_durees_conservation_required
self.durees_conservation_required ||= duree_conservation_dossiers_hors_ds.present? && duree_conservation_dossiers_dans_ds.present?
true
end
2018-09-19 11:02:38 +02:00
def percentile_time(start_attribute, end_attribute, p)
2018-09-19 11:02:38 +02:00
times = dossiers
.where.not(start_attribute => nil, end_attribute => nil)
2019-02-18 11:56:09 +01:00
.where(end_attribute => 1.month.ago..Time.zone.now)
2018-09-19 11:02:38 +02:00
.pluck(start_attribute, end_attribute)
2018-09-27 14:30:31 +02:00
.map { |(start_date, end_date)| end_date - start_date }
2018-09-19 11:02:38 +02:00
if times.present?
times.percentile(p).ceil
2018-09-19 11:02:38 +02:00
end
end
def ensure_path_exists
2019-03-06 14:42:27 +01:00
if self.path.nil?
self.path = SecureRandom.uuid
end
end
end