diff --git a/src/main/java/io/gmss/fiscad/persistence/procedure_fonction_stocke/interface_sigibe/recuperer_declaration_propriete.sql b/src/main/java/io/gmss/fiscad/persistence/procedure_fonction_stocke/interface_sigibe/recuperer_declaration_propriete.sql index a26f886..26f099a 100644 --- a/src/main/java/io/gmss/fiscad/persistence/procedure_fonction_stocke/interface_sigibe/recuperer_declaration_propriete.sql +++ b/src/main/java/io/gmss/fiscad/persistence/procedure_fonction_stocke/interface_sigibe/recuperer_declaration_propriete.sql @@ -43,7 +43,8 @@ BEGIN valeur_batiment, personne_id, - quartier_id + quartier_id, + statut_edeclaration_propriete ) SELECT now() AS created_at, @@ -81,8 +82,8 @@ BEGIN src.valeur_batiment, p.id AS personne_id, - q.id AS quartier_id - + q.id AS quartier_id, + 'EN_ATTENTE' FROM dblink( 'host=localhost port=5432 dbname=sigibe_test user=sigibe_test_user password=1234567890', ' @@ -141,11 +142,19 @@ BEGIN valeur_batiment bigint ) left join personne p on p.ifu=src.ifu - left join quartier q on q.code=src.r_quartier; + left join quartier q on q.code=src.r_quartier + where not exists( select 1 + from edeclaration_propriete edp + where edp.id_impot=src.id_impot + ); GET DIAGNOSTICS v_inserted_count = ROW_COUNT; RAISE NOTICE 'Intégration terminée. Nombre de lignes insérées : %', v_inserted_count; END; -$$; \ No newline at end of file +$$; + + +--'host=193.181.208.4 port=5433 dbname=sigibe_test user=sigibe_test_user password=sigibe_test_pwd', +--' \ No newline at end of file diff --git a/src/main/java/io/gmss/fiscad/persistence/repositories/interface_sigibe/EdeclarationProprieteRepository.java b/src/main/java/io/gmss/fiscad/persistence/repositories/interface_sigibe/EdeclarationProprieteRepository.java index dafb8f2..7b916eb 100755 --- a/src/main/java/io/gmss/fiscad/persistence/repositories/interface_sigibe/EdeclarationProprieteRepository.java +++ b/src/main/java/io/gmss/fiscad/persistence/repositories/interface_sigibe/EdeclarationProprieteRepository.java @@ -503,11 +503,9 @@ public interface EdeclarationProprieteRepository extends JpaRepository