Skip to content

Commit

Permalink
Optimise la vue fiches_action
Browse files Browse the repository at this point in the history
  • Loading branch information
@amandinejacquelin @derfurth
amandinejacquelin authored and derfurth committed Jan 29, 2023
1 parent 9fa0f7d commit 210fa3a
Show file tree
Hide file tree
Showing 7 changed files with 2,089 additions and 1,832 deletions.
1,468 changes: 63 additions & 1,405 deletions data_layer/sqitch/deploy/plan_action/plan_action.sql
View file

Large diffs are not rendered by default.

1,443 changes: 1,443 additions & 0 deletions data_layer/sqitch/deploy/plan_action/[email protected]
View file

Large diffs are not rendered by default.

380 changes: 107 additions & 273 deletions data_layer/sqitch/revert/plan_action/plan_action.sql
View file
Original file line number Diff line number Diff line change
@@ -1,280 +1,114 @@
-- Deploy tet:plan_action to pg

BEGIN;
drop function upsert_axe(nom text, collectivite_id integer, parent integer);
drop table fiche_action_import_csv cascade;
drop function import_plan_action_csv() cascade;
drop function plan_action(pa_id integer);
drop function delete_fiche_action() cascade;
drop function upsert_fiche_action() cascade;
drop view fiches_action;
drop function enlever_annexe(fiche_id integer, annexe annexe, supprimer boolean);
drop function ajouter_annexe(fiche_id integer, annexe annexe);
drop table fiche_action_annexe;
drop table annexe cascade;
drop view indicateurs_collectivite;
drop function enlever_indicateur(fiche_id integer, indicateur indicateur_generique);
drop function ajouter_indicateur(fiche_id integer, indicateur indicateur_generique);
drop type indicateur_generique;
drop table fiche_action_indicateur;
drop function enlever_action(fiche_id integer, action_id action_id);
drop function ajouter_action(fiche_id integer, action_id action_id);
drop table fiche_action_action;
drop function enlever_referent(fiche_id integer, referent personne);
drop function ajouter_referent(fiche_id integer, referent personne);
drop table fiche_action_referent;
drop function enlever_pilote(fiche_id integer, pilote personne);
drop function ajouter_pilote(fiche_id integer, pilote personne);
drop view fiche_action_personne_pilote;
drop table fiche_action_pilote;
drop function personnes_collectivite(collectivite_id integer);
drop type personne;
drop table personne_tag cascade;
drop function enlever_structure(fiche_id integer, structure structure_tag);
drop function ajouter_structure(fiche_id integer, structure structure_tag);
drop table fiche_action_structure_tag;
drop table structure_tag cascade;
drop function enlever_partenaire(fiche_id integer, partenaire partenaire_tag);
drop function ajouter_partenaire(fiche_id integer, partenaire partenaire_tag);
drop table fiche_action_partenaire_tag;
drop table partenaire_tag cascade;
drop function plans_action_collectivite(id_collectivite integer);
drop function enlever_fiche_action_d_un_axe(fiche_id integer, axe_id integer);
drop function ajouter_fiche_action_dans_un_axe(fiche_id integer, axe_id integer);
drop table fiche_action_axe;
drop table axe cascade;
drop function enlever_thematique(fiche_id integer, thematique text);
drop function ajouter_thematique(fiche_id integer, thematique text);
drop table fiche_action_sous_thematique;
drop table sous_thematique;
drop function enlever_sous_thematique(fiche_id integer, thematique_id integer);
drop function ajouter_sous_thematique(fiche_id integer, thematique_id integer);
drop table fiche_action_thematique;
drop table thematique;
drop function peut_modifier_la_fiche(fiche_id integer);
drop table fiche_action cascade;
drop table private.tag;
drop type fiche_action_niveaux_priorite cascade;
drop type fiche_action_statuts cascade;
drop type fiche_action_cibles cascade;
drop type fiche_action_resultats_attendus cascade;
drop type fiche_action_piliers_eci cascade;

create type fiche_action_avancement as enum ('pas_fait', 'fait', 'en_cours', 'non_renseigne');

-- fiche action
create table public.fiche_action as select * from migration.fiche_action;
alter table fiche_action drop column avancement;
alter table fiche_action add column avancement fiche_action_avancement;
update fiche_action p set avancement = (select m.avancement::text::fiche_action_avancement
from migration.fiche_action m
where m.uid = p.uid);

create trigger set_modified_at_before_fiche_action_update
before update
on
fiche_action
for each row
execute procedure update_modified_at();

alter table fiche_action
enable row level security;

create policy allow_read
on fiche_action
for select
using (is_authenticated());

create policy allow_insert
on fiche_action
with check (have_edition_acces(collectivite_id));

create policy allow_update
on fiche_action
using (have_edition_acces(collectivite_id));


create table fiche_action_action as select * from migration.fiche_action_action;
comment on table fiche_action_action is
'Many-to-many relationship between fiche action and referentiel action';
alter table fiche_action_action
enable row level security;

create policy allow_read
on fiche_action_action
for select
using (is_authenticated());


create table fiche_action_indicateur as select * from migration.fiche_action_indicateur;
comment on table fiche_action_indicateur is
'Many-to-many relationship between fiche action and referentiel indicateur';
alter table fiche_action_indicateur
enable row level security;
create policy allow_read
on fiche_action_indicateur
for select
using (is_authenticated());

create table fiche_action_indicateur_personnalise as select * from migration.fiche_action_indicateur_personnalise;
comment on table fiche_action_indicateur_personnalise is
'Many-to-many relationship between fiche action and indicateur personnalisé';
alter table fiche_action_indicateur_personnalise
enable row level security;
create policy allow_read
on fiche_action_indicateur_personnalise
for select
using (is_authenticated());


create or replace function update_fiche_relationships(
fiche_action_uid uuid,
action_ids action_id[],
indicateur_ids indicateur_id[],
indicateur_personnalise_ids integer[]
) returns void as
$$
declare
uid uuid;
i action_id;
j indicateur_id;
k integer;
begin
-- the name fiche_action_id is ambiguous as it can refer to a column.
select update_fiche_relationships.fiche_action_uid into uid;

-- clear previous relationships
delete from fiche_action_action where fiche_action_action.fiche_action_uid = uid;
delete from fiche_action_indicateur where fiche_action_indicateur.fiche_action_uid = uid;
delete from fiche_action_indicateur_personnalise where fiche_action_indicateur_personnalise.fiche_action_uid = uid;

-- write relationships
foreach i in array action_ids
loop
insert into fiche_action_action (fiche_action_uid, action_id)
values (uid, i);
end loop;

foreach j in array indicateur_ids
loop
insert into fiche_action_indicateur (fiche_action_uid, indicateur_id)
values (uid, j);
end loop;

foreach k in array indicateur_personnalise_ids
loop
insert into fiche_action_indicateur_personnalise (fiche_action_uid, indicateur_personnalise_id)
values (uid, k);
end loop;
end;
$$
language plpgsql security definer ;
comment on function update_fiche_relationships is
'Update fiche action relationships with actions, indicateurs and indicateurs personnalisés';


create or replace function after_fiche_action_write_save_relationships() returns trigger as
$$
begin
perform update_fiche_relationships(
new.uid,
new.action_ids,
new.indicateur_ids,
new.indicateur_personnalise_ids
);
return new;
end;
$$ language plpgsql;

create trigger after_fiche_action_write
after insert or update
on fiche_action
for each row
execute procedure after_fiche_action_write_save_relationships();

comment on function after_fiche_action_write_save_relationships is
'Save relationships with actions, indicateurs and indicateurs personnalisés '
'from fiche action data on insert or update to ensure they are correct';

-- plan d'action
create table public.plan_action as select * from migration.plan_action;

create trigger set_modified_at_before_plan_action_update
before update
on
plan_action
for each row
execute procedure update_modified_at();


alter table plan_action
enable row level security;

create policy allow_read
on plan_action
for select
using (is_authenticated());


create policy allow_insert
on plan_action
with check (have_edition_acces(collectivite_id));

create policy allow_update
on plan_action
using (have_edition_acces(collectivite_id));



-- plan d'action par défaut
create or replace function after_collectivite_insert_default_plan() returns trigger as
$$
begin
insert into plan_action
(collectivite_id,
uid,
nom,
categories,
fiches_by_category)
values (new.id,
gen_random_uuid(),
'Plan d''action de la collectivité',
'[]',
'[]');
return new;
end;
$$ language plpgsql;

create trigger after_collectivite_insert
after insert
on collectivite
for each row
execute procedure after_collectivite_insert_default_plan();

drop table migration.plan_action;
drop table migration.fiche_action_indicateur_personnalise;
drop table migration.fiche_action_indicateur;
drop table migration.fiche_action_action;
drop table migration.fiche_action;
drop type migration.fiche_action_avancement;

create materialized view stats.collectivite_plan_action
as
with fa as (select collectivite_id,
count(*) as count
from fiche_action f
group by f.collectivite_id),
pa as (select collectivite_id,
count(*) as count
from plan_action p
group by p.collectivite_id)
select c.*,
coalesce(fa.count, 0) as fiches,
coalesce(pa.count, 0) as plans
from stats.collectivite c
left join pa on pa.collectivite_id = c.collectivite_id
left join fa on pa.collectivite_id = fa.collectivite_id
order by fiches desc;
create or replace view fiches_action as
select fa.*,
t.thematiques,
st.sous_thematiques,
p.partenaires,
s.structures,
pi.pilotes,
re.referents,
anne.annexes,
pla.axes,
act.actions,
ind.indicateurs
from fiche_action fa
-- thematiques
left join lateral (
select array_agg(th.*::thematique) as thematiques
from thematique th
join fiche_action_thematique fath on fath.thematique = th.thematique
where fath.fiche_id = fa.id
) as t on true
-- sous-thematiques
left join lateral (
select array_agg(sth.*::sous_thematique) as sous_thematiques
from sous_thematique sth
join fiche_action_sous_thematique fasth on fasth.thematique_id = sth.id
where fasth.fiche_id = fa.id
) as st on true
-- partenaires
left join lateral (
select array_agg(pt.*::partenaire_tag) as partenaires
from partenaire_tag pt
join fiche_action_partenaire_tag fapt on fapt.partenaire_tag_id = pt.id
where fapt.fiche_id = fa.id
) as p on true
-- structures
left join lateral (
select array_agg(st.*::structure_tag) as structures
from structure_tag st
join fiche_action_structure_tag fast on fast.structure_tag_id = st.id
where fast.fiche_id = fa.id
) as s on true
-- pilotes
left join lateral (
select array_agg(pil.*::personne) as pilotes
from (
select coalesce(pt.nom, concat(dcp.prenom, ' ', dcp.nom)) as nom,
pt.collectivite_id,
fap.tag_id,
fap.user_id
from fiche_action_pilote fap
left join personne_tag pt on fap.tag_id = pt.id
left join dcp on fap.user_id = dcp.user_id
where fap.fiche_id = fa.id
) pil
) as pi on true
-- referents
left join lateral (
select array_agg(ref.*::personne) as referents
from (
select coalesce(pt.nom, concat(dcp.prenom, ' ', dcp.nom)) as nom,
pt.collectivite_id,
far.tag_id,
far.user_id
from fiche_action_referent far
left join personne_tag pt on far.tag_id = pt.id
left join dcp on far.user_id = dcp.user_id
where far.fiche_id = fa.id
) ref
) as re on true
-- annexes
left join lateral (
select array_agg(a.*::annexe) as annexes
from annexe a
join fiche_action_annexe faa on faa.annexe_id = a.id
where faa.fiche_id = fa.id
) as anne on true
-- axes
left join lateral (
select array_agg(pa.*::axe) as axes
from axe pa
join fiche_action_axe fapa on fapa.axe_id = pa.id
where fapa.fiche_id = fa.id
) as pla on true
-- actions
left join lateral (
select array_agg(ar.*::action_relation) as actions
from action_relation ar
join fiche_action_action faa on faa.action_id = ar.id
where faa.fiche_id = fa.id
) as act on true
-- indicateurs
left join lateral (
select array_agg(indi.*::indicateur_generique) as indicateurs
from (
select fai.indicateur_id,
fai.indicateur_personnalise_id,
coalesce(id.nom, ipd.titre) as nom,
coalesce(id.description, ipd.description) as description,
coalesce(id.unite, ipd.unite) as unite
from fiche_action_indicateur fai
left join indicateur_definition id on fai.indicateur_id = id.id
left join indicateur_personnalise_definition ipd on fai.indicateur_personnalise_id = ipd.id
where fai.fiche_id = fa.id
) indi
) as ind on true
-- TODO fiches liées (à calculer dans la vue selon action et indicateurs?)
;


COMMIT;
Loading

0 comments on commit 210fa3a

Please sign in to comment.