CEN38/Python_scripts
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

adapt requete for not use source table infraction_rnn

Browse Source
This commit is contained in:
Colas Geier 2025-10-09 12:05:36 +02:00
parent 9ce2809804
commit ccf224418b
1 changed files with 68 additions and 66 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

134
15_POLICE/v_infraction_rnn.py
View File

@ -7,74 +7,76 @@ sql = '''
DROP VIEW IF EXISTS police.v_infraction_rnn;
CREATE VIEW police.v_infraction_rnn AS
WITH photos as (
SELECT
json_data->>'__Submissions-id'::text "__Submissions-id",
json_agg('https://odk2.cen-isere.fr/v1/projects/6/forms/infraction_rnn/submissions/'||(json_data->>'__Submissions-id'::text)||'/attachments/'||(json_data->>'photos')::text) photos
FROM police.infraction_rnn
WHERE tablename = 'photos_repeat'
group by json_data->>'__Submissions-id'::text
), strip_infra as (
SELECT
inf.json_data->>'__Submissions-id' "__Submissions-id",
json_data->>'__id' "__id",
json_strip_nulls(inf.json_data) json_data
FROM police.infraction_rnn inf
WHERE inf.tablename = 'multiple_infract'
), key_infra as (
select
json_data->>'__Submissions-id' "__Submissions-id",
json_data->>'__id' "__id",
json_object_keys(json_data::json) data_keys
from strip_infra
), key_infra_agg as (
select
"__Submissions-id","__id", array_agg(data_keys) data_keys
from key_infra
group by 2,1
WITH photos AS (
SELECT infraction_rnn.json_data ->> '__Submissions-id'::text AS "__Submissions-id",
json_agg((('https://odk2.cen-isere.fr/v1/projects/6/forms/infraction_rnn/submissions/'::text || (infraction_rnn.json_data ->> '__Submissions-id'::text)) || '/attachments/'::text) || (infraction_rnn.json_data ->> 'photos'::text)) AS photos
FROM (
select row_to_json(t.*) json_data
from police.infraction_rnn_photos_repeat_data t
) infraction_rnn
GROUP BY (infraction_rnn.json_data ->> '__Submissions-id'::text)
), strip_infra AS (
SELECT inf_1.json_data ->> '__Submissions-id'::text AS "__Submissions-id",
inf_1.json_data ->> '__id'::text AS __id,
json_strip_nulls(inf_1.json_data) AS json_data
FROM (
select row_to_json(t.*) json_data
from police.infraction_rnn_multiple_infract_data t
) inf_1
), key_infra AS (
SELECT strip_infra.json_data ->> '__Submissions-id'::text AS "__Submissions-id",
strip_infra.json_data ->> '__id'::text AS __id,
json_object_keys(strip_infra.json_data) AS data_keys
FROM strip_infra
), key_infra_agg AS (
SELECT key_infra."__Submissions-id",
key_infra.__id,
array_agg(key_infra.data_keys) AS data_keys
FROM key_infra
GROUP BY key_infra.__id, key_infra."__Submissions-id"
)
SELECT
inf.json_data->>'__id'::text id_infraction,
split_part(sub.data_id,':',2)::uuid id_submission,
"submitterName" digitiser,
catego_controle,
catego_sensibil,
autre_catego_sensi,
autre_type_sanct,
inf.json_data->>'catego_infract'::text catego_infract,
inf.json_data->>key_infra_agg.data_keys[1] nature_infra,
case when SPLIT_PART(key_infra_agg.data_keys[3],'_',1) = 'natinf'
then inf.json_data->>key_infra_agg.data_keys[2]
else null
end code_catego,
case when SPLIT_PART(key_infra_agg.data_keys[3],'_',1) = 'natinf'
then inf.json_data->>key_infra_agg.data_keys[3]
else inf.json_data->>key_infra_agg.data_keys[2]
end code_infra,
inf.json_data->>'descrpt_infract'::text descrpt_infract,
"Commentaire_remarque_nombre_de_tentes",
"Conformit_du_contr_le",
"day" "date",
"heure",
infract_nb,
nat_operation,
nature_pers,
nb_pers_control,
nb_pers_sensibil,
nb_verb,
nom_agent,
type_sanct,
ph.photos,
"submissionDate" date_saisie,
"updatedAt" date_maj,
st_force2d(st_geomfromgeojson(replace(COALESCE(geom,point_carte),'\\','')))::geometry(geometry, 4326) AS geom
FROM police.infraction_rnn_submissions_data AS sub
JOIN strip_infra inf ON sub.data_id::text = inf."__Submissions-id"::text
join key_infra_agg on inf.__id = key_infra_agg.__id
JOIN photos ph ON sub.data_id::text = ph."__Submissions-id"::text
ORDER BY 2,1 ;
SELECT inf.json_data ->> '__id'::text AS id_infraction,
split_part(sub.data_id, ':'::text, 2)::uuid AS id_submission,
sub."submitterName" AS digitiser,
sub.catego_controle,
sub.catego_sensibil,
sub.autre_catego_sensi,
sub.autre_type_sanct,
inf.json_data ->> 'catego_infract'::text AS catego_infract,
inf.json_data ->> key_infra_agg.data_keys[1] AS nature_infra,
CASE
WHEN split_part(key_infra_agg.data_keys[3], '_'::text, 1) = 'natinf'::text THEN inf.json_data ->> key_infra_agg.data_keys[2]
ELSE NULL::text
END AS code_catego,
CASE
WHEN split_part(key_infra_agg.data_keys[3], '_'::text, 1) = 'natinf'::text THEN inf.json_data ->> key_infra_agg.data_keys[3]
ELSE inf.json_data ->> key_infra_agg.data_keys[2]
END AS code_infra,
inf.json_data ->> 'descrpt_infract'::text AS descrpt_infract,
sub."Commentaire_remarque_nombre_de_tentes",
sub."Conformit_du_contr_le",
sub.day AS date,
sub.heure,
sub.infract_nb,
sub.nat_operation,
sub.nature_pers,
sub.nb_pers_control,
sub.nb_pers_sensibil,
sub.nb_verb,
sub.nom_agent,
sub.type_sanct,
ph.photos,
sub."submissionDate" AS date_saisie,
sub."updatedAt" AS date_maj,
st_force2d(st_geomfromgeojson(replace(COALESCE(sub.geom, sub.point_carte), '\\'::text, ''::text)))::geometry(Geometry,4326) AS geom
FROM police.infraction_rnn_submissions_data sub
JOIN strip_infra inf ON sub.data_id = inf."__Submissions-id"
JOIN key_infra_agg ON inf.__id = key_infra_agg.__id
JOIN photos ph ON sub.data_id = ph."__Submissions-id"
ORDER BY (split_part(sub.data_id, ':'::text, 2)::uuid), (inf.json_data ->> '__id'::text)
;
GRANT SELECT ON TABLE police.infraction_rnn TO grp_police;
GRANT SELECT ON TABLE police.v_infraction_rnn TO grp_police;
'''
with con_odk.begin() as cnx: