391 lines
14 KiB
Python
391 lines
14 KiB
Python
from pycen import con_gn
|
|
|
|
sql0 = '''
|
|
with habitats as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(lb_code) AS habitats
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.cor_zh_cb USING (id_zh)
|
|
group by 1 order by 1
|
|
), crit_delim as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(ref_nomenclatures.get_nomenclature_label(cor_lim_list.id_lim)) AS crit_delim
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.cor_lim_list USING (id_lim_list)
|
|
group by 1 order by 1
|
|
), esp_fs as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(ref_nomenclatures.get_nomenclature_label(cor_zh_lim_fs.id_lim_fs)) AS crit_esp_fs
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.cor_zh_lim_fs USING (id_zh)
|
|
group by 1 order by 1
|
|
), v_activity AS (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(ref_nomenclatures.get_nomenclature_label(cor_impact_types.id_impact)) impacts
|
|
FROM pr_zh.t_activity
|
|
LEFT JOIN pr_zh.cor_impact_list USING (id_impact_list)
|
|
LEFT JOIN pr_zh.cor_impact_types USING (id_cor_impact_types)
|
|
group by 1 order by 1
|
|
), activ_hum AS (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(CASE WHEN t_activity.id_activity IS NULL
|
|
THEN NULL
|
|
ELSE json_build_object(
|
|
'activite', ref_nomenclatures.get_nomenclature_label(t_activity.id_activity),
|
|
'position', ref_nomenclatures.get_nomenclature_label(t_activity.id_position),
|
|
'impact', v_activity.impacts,
|
|
'rmq_activ', t_activity.remark_activity
|
|
)
|
|
END) AS activ_hum
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_activity USING (id_zh)
|
|
LEFT JOIN v_activity USING (id_zh)
|
|
group by zh_uuid order by 1
|
|
--), activ_hum_test AS (
|
|
-- SELECT
|
|
-- zh_uuid,
|
|
-- CASE WHEN t_activity.id_activity IS NOT NULL
|
|
-- THEN jsonb_build_object(
|
|
-- ref_nomenclatures.get_nomenclature_label(t_activity.id_activity), v_activity.impacts
|
|
-- )
|
|
-- ELSE NULL
|
|
-- END AS activ_hum_test
|
|
-- FROM pr_zh.t_zh
|
|
-- LEFT JOIN pr_zh.t_activity USING (id_zh)
|
|
-- LEFT JOIN v_activity USING (id_zh)
|
|
-- --group by zh_uuid order by 1
|
|
), inflow as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(CASE WHEN t_inflow.id_inflow IS NULL
|
|
THEN NULL
|
|
ELSE json_build_object(
|
|
'entree_eau', ref_nomenclatures.get_nomenclature_label(t_inflow.id_inflow),
|
|
'perm', ref_nomenclatures.get_nomenclature_label(t_inflow.id_permanance),
|
|
'topo', t_inflow.topo
|
|
)
|
|
END) AS entree_eau
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_inflow USING (id_zh)
|
|
group by zh_uuid
|
|
), outflow as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(CASE WHEN t_outflow.id_outflow IS NULL
|
|
THEN NULL
|
|
ELSE json_build_object(
|
|
'sortie_eau', ref_nomenclatures.get_nomenclature_label(t_outflow.id_outflow),
|
|
'perm', ref_nomenclatures.get_nomenclature_label(t_outflow.id_permanance),
|
|
'topo', t_outflow.topo
|
|
)
|
|
END) AS sortie_eau
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_outflow USING (id_zh)
|
|
group by zh_uuid
|
|
), functions as (
|
|
WITH hydro as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(json_build_object(
|
|
'fonctions', ref_nomenclatures.get_nomenclature_label(t_functions.id_function),
|
|
'qualification', ref_nomenclatures.get_nomenclature_label(t_functions.id_qualification),
|
|
'connaissance', ref_nomenclatures.get_nomenclature_label(t_functions.id_knowledge),
|
|
'justification', t_functions.justification
|
|
)) AS hydro
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_functions USING (id_zh)
|
|
WHERE id_function IN (
|
|
SELECT
|
|
id_nomenclature
|
|
FROM ref_nomenclatures.t_nomenclatures
|
|
JOIN ref_nomenclatures.bib_nomenclatures_types bib USING (id_type)
|
|
WHERE bib.mnemonique = 'FONCTIONS_HYDRO')
|
|
group by zh_uuid
|
|
), bio as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(json_build_object(
|
|
'fonctions', ref_nomenclatures.get_nomenclature_label(t_functions.id_function),
|
|
'qualification', ref_nomenclatures.get_nomenclature_label(t_functions.id_qualification),
|
|
'connaissance', ref_nomenclatures.get_nomenclature_label(t_functions.id_knowledge),
|
|
'justification', t_functions.justification
|
|
)) AS bio
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_functions USING (id_zh)
|
|
WHERE id_function IN (
|
|
SELECT
|
|
id_nomenclature
|
|
FROM ref_nomenclatures.t_nomenclatures
|
|
JOIN ref_nomenclatures.bib_nomenclatures_types bib USING (id_type)
|
|
WHERE bib.mnemonique = 'FONCTIONS_BIO')
|
|
group by zh_uuid
|
|
), int_patrim as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(json_build_object(
|
|
'fonctions', ref_nomenclatures.get_nomenclature_label(t_functions.id_function),
|
|
'qualification', ref_nomenclatures.get_nomenclature_label(t_functions.id_qualification),
|
|
'connaissance', ref_nomenclatures.get_nomenclature_label(t_functions.id_knowledge),
|
|
'justification', t_functions.justification
|
|
)) AS int_patrim
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_functions USING (id_zh)
|
|
WHERE id_function IN (
|
|
SELECT
|
|
id_nomenclature
|
|
FROM ref_nomenclatures.t_nomenclatures
|
|
JOIN ref_nomenclatures.bib_nomenclatures_types bib USING (id_type)
|
|
WHERE bib.mnemonique = 'INTERET_PATRIM')
|
|
group by zh_uuid
|
|
), val_socio as (
|
|
SELECT
|
|
zh_uuid,
|
|
json_agg(json_build_object(
|
|
'fonctions', ref_nomenclatures.get_nomenclature_label(t_functions.id_function),
|
|
'qualification', ref_nomenclatures.get_nomenclature_label(t_functions.id_qualification),
|
|
'connaissance', ref_nomenclatures.get_nomenclature_label(t_functions.id_knowledge),
|
|
'justification', t_functions.justification
|
|
)) AS val_socio
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN pr_zh.t_functions USING (id_zh)
|
|
WHERE id_function IN (
|
|
SELECT
|
|
id_nomenclature
|
|
FROM ref_nomenclatures.t_nomenclatures
|
|
JOIN ref_nomenclatures.bib_nomenclatures_types bib USING (id_type)
|
|
WHERE bib.mnemonique = 'VAL_SOC_ECO')
|
|
group by zh_uuid
|
|
)
|
|
SELECT
|
|
zh_uuid,
|
|
hydro.hydro,
|
|
bio.bio,
|
|
int_patrim.int_patrim,
|
|
val_socio.val_socio
|
|
FROM pr_zh.t_zh
|
|
LEFT JOIN hydro USING (zh_uuid)
|
|
LEFT JOIN bio USING (zh_uuid)
|
|
LEFT JOIN int_patrim USING (zh_uuid)
|
|
LEFT JOIN val_socio USING (zh_uuid)
|
|
--group by zh_uuid
|
|
), especes as (
|
|
SELECT
|
|
zh_uuid,
|
|
(select distinct count(vm_flora.cd_nom) from pr_zh.vm_flora where id_zh = t.id_zh) nb_flora,
|
|
(select distinct count(vm_vertebrates.cd_nom) from pr_zh.vm_vertebrates where id_zh = t.id_zh) nb_vertebrates,
|
|
(select distinct count(vm_invertebrates.cd_nom) from pr_zh.vm_invertebrates where id_zh = t.id_zh) nb_invertebrates
|
|
--count(vm_vertebrates.cd_nom) nb_vertebrates,
|
|
--count(vm_invertebrates.cd_nom) nb_invertebrates
|
|
FROM pr_zh.t_zh t
|
|
--GROUP BY zh_uuid
|
|
), rb as (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(name) river_bassin
|
|
FROM pr_zh.cor_zh_rb
|
|
JOIN pr_zh.t_river_basin USING (id_rb)
|
|
GROUP BY id_zh
|
|
), instrument as (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(ref_nomenclatures.get_nomenclature_label(t_instruments.id_instrument)) instrument
|
|
FROM pr_zh.t_instruments
|
|
GROUP BY id_zh
|
|
), urba as (
|
|
WITH urban_type as (
|
|
SELECT
|
|
id_doc,
|
|
json_agg(json_build_object(
|
|
'typ_doc', ref_nomenclatures.get_nomenclature_label(cor_urban_type_range.id_doc_type),
|
|
'zone', ref_nomenclatures.get_nomenclature_label(cor_urban_type_range.id_range_type)
|
|
)) doc_range
|
|
FROM pr_zh.cor_zh_doc_range
|
|
JOIN pr_zh.cor_urban_type_range USING (id_cor)
|
|
GROUP BY id_doc
|
|
)
|
|
SELECT
|
|
id_zh,
|
|
json_agg(json_build_object(
|
|
'typ_doc', ref_nomenclatures.get_nomenclature_label(t_urban_planning_docs.id_doc_type),
|
|
'doc_range', doc_range,
|
|
'zone', l_areas.area_name,
|
|
'remarque', t_urban_planning_docs.remark
|
|
)) docs_urba
|
|
FROM pr_zh.t_urban_planning_docs
|
|
JOIN ref_geo.l_areas USING (id_area)
|
|
JOIN urban_type USING (id_doc)
|
|
GROUP BY id_zh
|
|
), actions AS (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(json_build_object(
|
|
'priorite', ref_nomenclatures.get_nomenclature_label(t_actions.id_priority_level),
|
|
'action', bib_actions.name,
|
|
'remarque', t_actions.remark
|
|
) ORDER BY id_priority_level,bib_actions.name) prio_actions
|
|
FROM pr_zh.t_actions
|
|
JOIN pr_zh.bib_actions USING (id_action)
|
|
GROUp BY id_zh
|
|
), zh_area_com AS (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(l_areas.area_name||' ('||cover||'%%)' ORDER BY l_areas.area_name) commune
|
|
FROM pr_zh.cor_zh_area
|
|
JOIN ref_geo.l_areas USING (id_area)
|
|
WHERE cover IS NOT NULL
|
|
GROUP BY id_zh
|
|
), dep AS (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(l_areas.area_name ORDER BY l_areas.area_name) departement
|
|
FROM pr_zh.cor_zh_area
|
|
JOIN ref_geo.l_areas USING (id_area)
|
|
join ref_geo.bib_areas_types bat using (id_type)
|
|
WHERE cover IS null and bat.type_code = 'DEP'
|
|
GROUP BY id_zh
|
|
), inventaire AS (
|
|
SELECT
|
|
id_zh,
|
|
json_agg(json_build_object(
|
|
'inventaire',l_areas.area_code ||' - '||l_areas.area_name,
|
|
'url', l_areas."source"
|
|
) ORDER BY l_areas.area_name) inventaire
|
|
FROM pr_zh.cor_zh_area
|
|
JOIN ref_geo.l_areas USING (id_area)
|
|
join ref_geo.bib_areas_types bat using (id_type)
|
|
WHERE cover IS null and bat.type_code not in ('DEP')
|
|
GROUP BY id_zh
|
|
)
|
|
SELECT
|
|
zh_uuid,
|
|
code,
|
|
main_name,
|
|
--concat(crea_role.nom_role, ' ', crea_role.prenom_role) AS crea_author,
|
|
--bib_org.name AS organisme,
|
|
--concat(updt_role.nom_role, ' ', updt_role.prenom_role) AS updt_author,
|
|
bib_org_user_updt.nom_organisme as org_updt,
|
|
create_date crea_date,
|
|
update_date updt_date,
|
|
--ST_TRANSFORM(geom,2154)::geometry(geometry,2154) geom,
|
|
geom,
|
|
area surface,
|
|
rb.river_bassin,
|
|
dep.departement,
|
|
zh_area_com.commune,
|
|
ref_nomenclatures.get_nomenclature_label(id_sdage) sdage,
|
|
ref_nomenclatures.get_nomenclature_label(id_sage) sage,
|
|
CASE WHEN habitats.habitats::text = '[null]'
|
|
THEN NULL
|
|
ELSE habitats.habitats
|
|
END AS habitats,
|
|
remark_pres descript,
|
|
crit_delim.crit_delim,
|
|
remark_lim rmq_delilm,
|
|
CASE WHEN esp_fs.crit_esp_fs::text = '[null]'
|
|
THEN NULL
|
|
ELSE esp_fs.crit_esp_fs
|
|
END AS crit_esp_fs,
|
|
remark_lim_fs rmq_esp_fs,
|
|
--ef_area,
|
|
--v_habref v_hab,
|
|
CASE WHEN activ_hum.activ_hum::text = '[null]'
|
|
THEN NULL
|
|
ELSE activ_hum.activ_hum::text
|
|
END AS activ_hum,
|
|
-- activ_hum_test.activ_hum_test,
|
|
ref_nomenclatures.get_nomenclature_label(id_thread) bilan_menace,
|
|
CASE WHEN inflow.entree_eau::text = '[null]'
|
|
THEN NULL
|
|
ELSE inflow.entree_eau::text
|
|
END AS entree_eau,
|
|
CASE WHEN outflow.sortie_eau::text = '[null]'
|
|
THEN NULL
|
|
ELSE outflow.sortie_eau::text
|
|
END AS sortie_eau,
|
|
ref_nomenclatures.get_nomenclature_label(id_frequency) freq_sub,
|
|
ref_nomenclatures.get_nomenclature_label(id_spread) extend_sub,
|
|
ref_nomenclatures.get_nomenclature_label(id_connexion) connex,
|
|
ref_nomenclatures.get_nomenclature_label(id_diag_hydro) diag_hydro,
|
|
ref_nomenclatures.get_nomenclature_label(id_diag_bio) diag_bio,
|
|
functions.hydro::text,
|
|
functions.bio::text,
|
|
functions.int_patrim::text,
|
|
functions.val_socio::text,
|
|
remark_eval_functions eval_fcts,
|
|
remark_eval_heritage eval_heritage,
|
|
remark_eval_thread eval_menace,
|
|
remark_eval_actions eval_actions,
|
|
ref_nomenclatures.get_nomenclature_label(id_strat_gestion) strat_gestion,
|
|
remark_diag rmq_gestion,
|
|
--is_other_inventory,
|
|
--is_carto_hab,
|
|
--nb_hab,
|
|
--total_hab_cover,
|
|
especes.nb_flora nb_flora_sp,
|
|
especes.nb_vertebrates nb_vertebrate_sp,
|
|
especes.nb_invertebrates nb_invertebrate_sp,
|
|
inventaire.inventaire::text,
|
|
actions.prio_actions::text,
|
|
instrument.instrument::text,
|
|
urba.docs_urba::text
|
|
--remark_is_other_inventory
|
|
FROM pr_zh.t_zh
|
|
JOIN utilisateurs.t_roles crea_role ON t_zh.create_author = crea_role.id_role
|
|
LEFT JOIN utilisateurs.t_roles updt_role ON t_zh.update_author = updt_role.id_role
|
|
LEFT JOIN utilisateurs.bib_organismes bib_org_user_updt on updt_role.id_organisme = bib_org_user_updt.id_organisme
|
|
LEFT JOIN pr_zh.bib_organismes bib_org USING (id_org)
|
|
LEFT JOIN habitats USING (zh_uuid)
|
|
LEFT JOIN crit_delim USING (zh_uuid)
|
|
LEFT JOIN esp_fs USING (zh_uuid)
|
|
LEFT JOIN activ_hum USING (zh_uuid)
|
|
--LEFT JOIN activ_hum_test USING (zh_uuid)
|
|
LEFT JOIN inflow USING (zh_uuid)
|
|
LEFT JOIN outflow USING (zh_uuid)
|
|
LEFT JOIN functions USING (zh_uuid)
|
|
LEFT JOIN especes USING (zh_uuid)
|
|
LEFT JOIN rb USING (id_zh)
|
|
LEFT JOIN instrument USING (id_zh)
|
|
LEFT JOIN urba USING (id_zh)
|
|
LEFT JOIN actions USING (id_zh)
|
|
LEFT JOIN zh_area_com USING (id_zh)
|
|
LEFT JOIN dep USING (id_zh)
|
|
LEFT JOIN inventaire USING (id_zh)
|
|
'''
|
|
|
|
sql_zh_all = '''
|
|
DROP VIEW IF EXISTS gn_exports.v_synthese_zones_humides;
|
|
|
|
CREATE VIEW gn_exports.v_synthese_zones_humides AS
|
|
''' + sql0 + '''
|
|
--group BY zh_uuid
|
|
WHERE code not like '38CENIS%%'
|
|
AND ref_nomenclatures.get_cd_nomenclature(id_sdage)::int > 0
|
|
--id_sdage > 0
|
|
order by code
|
|
;
|
|
'''
|
|
|
|
with con_gn.begin() as cnx:
|
|
cnx.execute(sql_zh_all)
|
|
|
|
|
|
sql_zh_38 = '''
|
|
DROP VIEW IF EXISTS gn_exports.v_synthese_zones_humides_isere;
|
|
|
|
CREATE VIEW gn_exports.v_synthese_zones_humides_isere AS
|
|
''' + sql0 + '''
|
|
--group BY zh_uuid
|
|
WHERE code not like '38CENIS%%'
|
|
AND dep.departement::jsonb @> '"Isère"'
|
|
AND ref_nomenclatures.get_cd_nomenclature(id_sdage)::int > 0
|
|
order by code
|
|
;
|
|
'''
|
|
|
|
with con_gn.begin() as cnx:
|
|
cnx.execute(sql_zh_38) |