demarches-normaliennes/app/services/expired_dossiers_deletion_service.rb

class ExpiredDossiersDeletionService
  def self.process_expired_dossiers_brouillon
    send_brouillon_expiration_notices
    delete_expired_brouillons_and_notify
  end

  def self.process_expired_dossiers_en_construction
    send_en_construction_expiration_notices
    delete_expired_en_construction_and_notify
  end

  def self.process_expired_dossiers_termine
    send_termine_expiration_notices
    delete_expired_termine_and_notify
  end

  def self.send_brouillon_expiration_notices
    dossiers_close_to_expiration = Dossier
      .brouillon_close_to_expiration
      .without_brouillon_expiration_notice_sent

    dossiers_close_to_expiration
      .with_notifiable_procedure
      .includes(:user, :procedure)
      .group_by(&:user)
      .each do |(user, dossiers)|
        DossierMailer.notify_brouillon_near_deletion(
          dossiers,
          user.email
        ).deliver_later

        # mark as sent dossiers from current notification
        Dossier.where(id: dossiers).update_all(brouillon_close_to_expiration_notice_sent_at: Time.zone.now)
      end

    # mark as sent dossiers without notification
    dossiers_close_to_expiration.update_all(brouillon_close_to_expiration_notice_sent_at: Time.zone.now)
  end

  def self.send_en_construction_expiration_notices
    send_expiration_notices(
      Dossier.en_construction_close_to_expiration.without_en_construction_expiration_notice_sent,
      :en_construction_close_to_expiration_notice_sent_at
    )
  end

  def self.send_termine_expiration_notices
    send_expiration_notices(
      Dossier.termine_close_to_expiration.without_termine_expiration_notice_sent,
      :termine_close_to_expiration_notice_sent_at
    )
  end

  def self.delete_expired_brouillons_and_notify
    dossiers_to_remove = Dossier.brouillon_expired

    dossiers_to_remove
      .with_notifiable_procedure
      .includes(:user, :procedure)
      .group_by(&:user)
      .each do |(user, dossiers)|
        DossierMailer.notify_brouillon_deletion(
          dossiers.map(&:hash_for_deletion_mail),
          user.email
        ).deliver_later

        # destroy dossiers from current notification
        Dossier.where(id: dossiers).destroy_all
      end

    # destroy dossiers without notification
    dossiers_to_remove.destroy_all
  end

  def self.delete_expired_en_construction_and_notify
    delete_expired_and_notify(Dossier.en_construction_expired)
  end

  def self.delete_expired_termine_and_notify
    delete_expired_and_notify(Dossier.termine_expired)
  end

  private

  def self.send_expiration_notices(dossiers_close_to_expiration, close_to_expiration_flag)
    dossiers_close_to_expiration
      .with_notifiable_procedure
      .includes(:user)
      .group_by(&:user)
      .each do |(user, dossiers)|
        DossierMailer.notify_near_deletion_to_user(
          dossiers,
          user.email
        ).deliver_later
      end

    group_by_fonctionnaire_email(dossiers_close_to_expiration).each do |(email, dossiers)|
      DossierMailer.notify_near_deletion_to_administration(
        dossiers.to_a,
        email
      ).deliver_later

      # mark as sent dossiers from current notification
      Dossier.where(id: dossiers.to_a).update_all(close_to_expiration_flag => Time.zone.now)
    end

    # mark as sent dossiers without notification
    dossiers_close_to_expiration.update_all(close_to_expiration_flag => Time.zone.now)
  end

  def self.delete_expired_and_notify(dossiers_to_remove)
    dossiers_to_remove.each(&:expired_keep_track!)

    dossiers_to_remove
      .with_notifiable_procedure
      .includes(:user)
      .group_by(&:user)
      .each do |(user, dossiers)|
        DossierMailer.notify_automatic_deletion_to_user(
          DeletedDossier.where(dossier_id: dossiers.map(&:id)).to_a,
          user.email
        ).deliver_later
      end

    self.group_by_fonctionnaire_email(dossiers_to_remove).each do |(email, dossiers)|
      DossierMailer.notify_automatic_deletion_to_administration(
        DeletedDossier.where(dossier_id: dossiers.map(&:id)).to_a,
        email
      ).deliver_later

      # destroy dossiers from current notification
      Dossier.where(id: dossiers.to_a).destroy_all
    end

    # destroy dossiers without notification
    dossiers_to_remove.destroy_all
  end

  def self.group_by_fonctionnaire_email(dossiers)
    dossiers
      .with_notifiable_procedure
      .includes(:followers_instructeurs, procedure: [:administrateurs])
      .each_with_object(Hash.new { |h, k| h[k] = Set.new }) do |dossier, h|
        (dossier.followers_instructeurs + dossier.procedure.administrateurs).each { |destinataire| h[destinataire.email] << dossier }
      end
  end
end