module Instructeurs class ProceduresController < InstructeurController before_action :ensure_ownership!, except: [:index] before_action :redirect_to_avis_if_needed, only: [:index] ITEMS_PER_PAGE = 25 def index @procedures = current_instructeur .procedures .with_attached_logo .includes(:defaut_groupe_instructeur) .order(closed_at: :desc, unpublished_at: :desc, published_at: :desc, created_at: :desc) dossiers = current_instructeur.dossiers.joins(:groupe_instructeur) @dossiers_count_per_procedure = dossiers.all_state.group('groupe_instructeurs.procedure_id').reorder(nil).count @dossiers_a_suivre_count_per_procedure = dossiers.without_followers.en_cours.group('groupe_instructeurs.procedure_id').reorder(nil).count @dossiers_archived_count_per_procedure = dossiers.archived.group('groupe_instructeurs.procedure_id').count @dossiers_termines_count_per_procedure = dossiers.termine.group('groupe_instructeurs.procedure_id').reorder(nil).count groupe_ids = current_instructeur.groupe_instructeurs.pluck(:id) @followed_dossiers_count_per_procedure = current_instructeur .followed_dossiers .joins(:groupe_instructeur) .en_cours .where(groupe_instructeur_id: groupe_ids) .group('groupe_instructeurs.procedure_id') .reorder(nil) .count end def show @procedure = procedure @current_filters = current_filters @available_fields_to_filters = available_fields_to_filters # Technically, procedure_presentation already sets the attribute. # Setting it here to make clear that it is used by the view @procedure_presentation = procedure_presentation @displayed_fields_values = displayed_fields_values @a_suivre_dossiers = current_instructeur .dossiers .for_procedure(procedure) .without_followers .en_cours @followed_dossiers = current_instructeur .followed_dossiers .where(groupe_instructeur: current_instructeur.groupe_instructeurs) .for_procedure(procedure) .en_cours @followed_dossiers_id = current_instructeur .followed_dossiers .where(groupe_instructeur: current_instructeur.groupe_instructeurs) .for_procedure(procedure) .pluck(:id) @termines_dossiers = current_instructeur .dossiers .for_procedure(procedure) .termine @all_state_dossiers = current_instructeur .dossiers .for_procedure(procedure) .all_state @archived_dossiers = current_instructeur .dossiers .for_procedure(procedure) .archived @dossiers = case statut when 'a-suivre' @a_suivre_dossiers when 'suivis' @followed_dossiers when 'traites' @termines_dossiers when 'tous' @all_state_dossiers when 'archives' @archived_dossiers end sorted_ids = procedure_presentation.sorted_ids(@dossiers, current_instructeur) if @current_filters.count > 0 filtered_ids = procedure_presentation.filtered_ids(@dossiers, statut) filtered_sorted_ids = sorted_ids.filter { |id| filtered_ids.include?(id) } else filtered_sorted_ids = sorted_ids end page = params[:page].presence || 1 filtered_sorted_paginated_ids = Kaminari .paginate_array(filtered_sorted_ids) .page(page) .per(ITEMS_PER_PAGE) @dossiers = @dossiers.where(id: filtered_sorted_paginated_ids) @dossiers = procedure_presentation.eager_load_displayed_fields(@dossiers) @dossiers = @dossiers.sort_by { |d| filtered_sorted_paginated_ids.index(d.id) } kaminarize(page, filtered_sorted_ids.count) assign_exports end def update_displayed_fields values = params[:values] if values.nil? values = [] end fields = values.map do |value| find_field(*value.split('/')) end procedure_presentation.update(displayed_fields: fields) current_sort = procedure_presentation.sort if !values.include?(field_id(current_sort)) procedure_presentation.update(sort: Procedure.default_sort) end redirect_back(fallback_location: instructeur_procedure_url(procedure)) end def update_sort current_sort = procedure_presentation.sort table = params[:table] column = params[:column] if table == current_sort['table'] && column == current_sort['column'] order = current_sort['order'] == 'asc' ? 'desc' : 'asc' else order = 'asc' end sort = { 'table' => table, 'column' => column, 'order' => order } procedure_presentation.update(sort: sort) redirect_back(fallback_location: instructeur_procedure_url(procedure)) end def add_filter if params[:value].present? filters = procedure_presentation.filters table, column = params[:field].split('/') label = find_field(table, column)['label'] filters[statut] << { 'label' => label, 'table' => table, 'column' => column, 'value' => params[:value] } procedure_presentation.update(filters: filters) end redirect_back(fallback_location: instructeur_procedure_url(procedure)) end def remove_filter filters = procedure_presentation.filters to_remove = params.values_at(:table, :column, :value) filters[statut].reject! { |filter| filter.values_at('table', 'column', 'value') == to_remove } procedure_presentation.update(filters: filters) redirect_back(fallback_location: instructeur_procedure_url(procedure)) end def download_export export_format = params[:export_format] groupe_instructeurs = current_instructeur .groupe_instructeurs .where(procedure: procedure) export = Export.find_or_create_export(export_format, groupe_instructeurs) if export.ready? respond_to do |format| format.js do @procedure = procedure assign_exports flash.notice = "L’export au format \"#{export_format}\" est prêt." end format.html do redirect_to export.file.service_url end end else respond_to do |format| notice_message = "Nous générons cet export. Veuillez revenir dans quelques minutes pour le télécharger." format.js do @procedure = procedure assign_exports if !params[:no_progress_notification] flash.notice = notice_message end end format.html do redirect_to instructeur_procedure_url(procedure), notice: notice_message end end end end def email_notifications @procedure = procedure @assign_to = assign_to end def update_email_notifications assign_to.update!(assign_to_params) flash.notice = 'Vos notifications sont enregistrées.' redirect_to instructeur_procedure_path(procedure) end def stats @procedure = procedure @usual_traitement_time = @procedure.stats_usual_traitement_time @dossiers_funnel = @procedure.stats_dossiers_funnel @termines_states = @procedure.stats_termines_states end private def assign_to_params params.require(:assign_to).permit(:email_notifications_enabled, :weekly_email_notifications_enabled) end def assign_exports groupe_instructeurs_for_procedure = current_instructeur.groupe_instructeurs.where(procedure: procedure) @xlsx_export = Export.find_for_format_and_groupe_instructeurs(:xlsx, groupe_instructeurs_for_procedure) @csv_export = Export.find_for_format_and_groupe_instructeurs(:csv, groupe_instructeurs_for_procedure) @ods_export = Export.find_for_format_and_groupe_instructeurs(:ods, groupe_instructeurs_for_procedure) end def find_field(table, column) procedure_presentation.fields.find { |c| c['table'] == table && c['column'] == column } end def field_id(field) field.values_at('table', 'column').join('/') end def assign_to current_instructeur.assign_to.joins(:groupe_instructeur).find_by(groupe_instructeurs: { procedure: procedure }) end def statut @statut ||= (params[:statut].presence || 'a-suivre') end def procedure Procedure.find(params[:procedure_id]) end def ensure_ownership! if !current_instructeur.procedures.include?(procedure) flash[:alert] = "Vous n’avez pas accès à cette démarche" redirect_to root_path end end def redirect_to_avis_if_needed if current_instructeur.procedures.count == 0 && current_instructeur.avis.count > 0 redirect_to instructeur_avis_index_path end end def procedure_presentation @procedure_presentation ||= get_procedure_presentation end def get_procedure_presentation procedure_presentation, errors = current_instructeur.procedure_presentation_and_errors_for_procedure_id(params[:procedure_id]) if errors.present? flash[:alert] = "Votre affichage a dû être réinitialisé en raison du problème suivant : " + errors.full_messages.join(', ') end procedure_presentation end def displayed_fields_values procedure_presentation.displayed_fields.map { |field| field_id(field) } end def current_filters @current_filters ||= procedure_presentation.filters[statut] end def available_fields_to_filters procedure_presentation.fields_for_select end def kaminarize(current_page, total) @dossiers.instance_eval <<-EVAL def current_page #{current_page} end def total_pages (#{total} / #{ITEMS_PER_PAGE}.to_f).ceil end def limit_value #{ITEMS_PER_PAGE} end def first_page? current_page == 1 end def last_page? current_page == total_pages end EVAL end end end