Merge pull request 'develop' (#5) from develop into main

Reviewed-on: #5

.gitea/workflows/cd-main.yml

@@ -0,0 +1,118 @@
+name: CD - Deploy on main
+
+on:
+  pull_request:
+    branches:
+      - main
+
+jobs:
+  deploy:
+    runs-on: self-hosted
+
+    steps:
+      # 1) S'assurer que Node.js est installé
+      - name: Ensure Node.js is installed
+        shell: sh
+        run: |
+          if command -v node >/dev/null 2>&1; then
+            echo "Node.js already installed: $(node -v)"
+          else
+            echo "Node.js not found, installing..."
+            apk update && apk add --no-cache nodejs
+            echo "Node.js installed: $(node -v)"
+          fi
+
+      # 2) S'assurer que Java & Maven sont installés
+      - name: Ensure Java & Maven are installed
+        shell: sh
+        run: |
+          if command -v java >/dev/null 2>&1; then
+            echo "Java already installed:"
+            java -version
+          else
+            echo "Java not found, installing OpenJDK 17..."
+            apk update && apk add --no-cache openjdk17-jdk
+            echo "Java installed:"
+            java -version
+          fi
+
+          if command -v mvn >/dev/null 2>&1; then
+            echo "Maven already installed:"
+            mvn -version
+          else
+            echo "Maven not found, installing Maven..."
+            apk update && apk add --no-cache maven
+            echo "Maven installed:"
+            mvn -version
+          fi
+
+      # 3) Détecter JAVA_HOME dynamiquement et le propager
+      - name: Detect JAVA_HOME dynamically
+        shell: sh
+        run: |
+          JAVA_BIN=$(readlink -f "$(command -v java)")
+          JAVA_HOME=$(dirname "$(dirname "$JAVA_BIN")")
+          echo "Detected JAVA_HOME=$JAVA_HOME"
+          echo "JAVA_HOME=$JAVA_HOME" >> "$GITHUB_ENV"
+
+      # 4) Checkout du dépôt
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      # 5) Afficher quelques infos utiles
+      - name: Show current commit and tools
+        shell: sh
+        run: |
+          echo "Current commit:"
+          git rev-parse HEAD
+          echo "JAVA_HOME is: $JAVA_HOME"
+          java -version
+          mvn -version
+
+      # 6) S'assurer que le client Docker + docker-compose sont installés
+      - name: Ensure Docker CLI is installed
+        shell: sh
+        run: |
+          if command -v docker >/dev/null 2>&1; then
+            echo "Docker CLI already installed:"
+            docker version || true
+          else
+            echo "Docker CLI not found, installing..."
+            apk update && apk add --no-cache docker docker-compose
+            echo "Docker CLI installed:"
+            docker version || true
+          fi
+
+      # 7) Générer le .env utilisé par docker-compose-prod.yml
+      - name: Generate .env from Gitea secrets
+        shell: sh
+        run: |
+          cat > .env <<EOF
+          POSTGRES_DB_FISCAD=${{ secrets.POSTGRES_DB_FISCAD }}
+          POSTGRES_USER_FISCAD=${{ secrets.POSTGRES_USER_FISCAD }}
+          POSTGRES_PASSWORD_FISCAD=${{ secrets.POSTGRES_PASSWORD_FISCAD }}
+          EOF
+          echo "Generated .env:"
+          cat .env
+
+      # 8) Build Maven pour générer le jar dans target/
+      - name: Build backend with Maven
+        shell: sh
+        run: mvn -B clean package
+
+      # 9) Déploiement en prod avec docker-compose-prod.yml
+      - name: Deploy using docker-compose (prod)
+        shell: sh
+        run: |
+          # IMPORTANT : on fixe le nom du projet compose
+          export COMPOSE_PROJECT_NAME=fiscad
+          
+          # Puis on déploie avec un nom de projet fixe
+          docker-compose -f docker-compose-prod.yml pull || true
+          docker-compose -f docker-compose-prod.yml down --remove-orphans
+          docker-compose -f docker-compose-prod.yml up -d --build
+
+      # 10) Nettoyage des images non utilisées
+      - name: Cleanup unused images
+        shell: sh
+        run: docker image prune -f || true

.gitea/workflows/ci-develop.yml

@@ -0,0 +1,73 @@
+name: CI - Build & Test (develop)
+
+on:
+  pull_request:
+    branches:
+      - develop
+
+jobs:
+  build-and-test:
+    runs-on: self-hosted
+
+    steps:
+      # 1) S'assurer que Node.js est installé (utile pour les actions JS comme actions/checkout)
+      - name: Ensure Node.js is installed
+        shell: sh
+        run: |
+          if command -v node >/dev/null 2>&1; then
+            echo "Node.js already installed: $(node -v)"
+          else
+            echo "Node.js not found, installing..."
+            apk update && apk add --no-cache nodejs
+            echo "Node.js installed: $(node -v)"
+          fi
+
+      # 2) S'assurer que Java + Maven sont installés
+      - name: Ensure Java & Maven are installed
+        shell: sh
+        run: |
+          if command -v java >/dev/null 2>&1; then
+            echo "Java already installed:"
+            java -version
+          else
+            echo "Java not found, installing OpenJDK 17..."
+            apk update && apk add --no-cache openjdk17-jdk
+            echo "Java installed:"
+            java -version
+          fi
+
+          if command -v mvn >/dev/null 2>&1; then
+            echo "Maven already installed:"
+            mvn -version
+          else
+            echo "Maven not found, installing Maven..."
+            apk update && apk add --no-cache maven
+            echo "Maven installed:"
+            mvn -version
+          fi
+
+      # 3) Détecter automatiquement JAVA_HOME et le propager au reste du job
+      - name: Detect JAVA_HOME dynamically
+        shell: sh
+        run: |
+          JAVA_BIN=$(readlink -f "$(command -v java)")
+          JAVA_HOME=$(dirname "$(dirname "$JAVA_BIN")")
+          echo "Detected JAVA_HOME=$JAVA_HOME"
+          echo "JAVA_HOME=$JAVA_HOME" >> "$GITHUB_ENV"
+
+      # 4) Checkout du dépôt (Node est déjà garanti à ce stade)
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      # 5) Vérification des versions (pour les logs)
+      - name: Show Java & Maven versions
+        shell: sh
+        run: |
+          echo "JAVA_HOME is: $JAVA_HOME"
+          java -version
+          mvn -version
+
+      # 6) Build Maven
+      - name: Build with Maven
+        shell: sh
+        run: mvn -B clean verify

Dockerfile

@@ -1,5 +1,5 @@
 # Étape 1 : Build avec Maven et Java 17
-FROM openjdk:17-jdk-slim
+FROM eclipse-temurin:17-jdk-jammy
 
 
 WORKDIR /app

docker-compose-prod.yml

@@ -0,0 +1,46 @@
+version: '3.9'
+
+services:
+
+  db:
+    image: postgres:15
+    container_name: fiscad-db
+    restart: always
+    environment:
+      POSTGRES_DB: ${POSTGRES_DB_FISCAD}
+      POSTGRES_USER: ${POSTGRES_USER_FISCAD}
+      POSTGRES_PASSWORD: ${POSTGRES_PASSWORD_FISCAD}
+    ports:
+      - "5432:5432"
+    volumes:
+      - db-data-fiscad:/var/lib/postgresql/data
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -U ${POSTGRES_USER_FISCAD}"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+
+  app:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    container_name: fiscad-app
+    depends_on:
+      - db
+    environment:
+      SPRING_DATASOURCE_URL: jdbc:postgresql://db:5432/${POSTGRES_DB_FISCAD}
+      SPRING_DATASOURCE_USERNAME: ${POSTGRES_USER_FISCAD}
+      SPRING_DATASOURCE_PASSWORD: ${POSTGRES_PASSWORD_FISCAD}
+      SERVER_PORT: 8282
+      IO_GMSS_FISCAD_PROFILE: abomey
+      SPRING_PROFILES_ACTIVE: abomey
+    ports:
+      - "8282:8282"
+    volumes:
+      - /fiscad/uploads:/app/uploads
+      - /fiscad/jasperReport:/app/jasperReport
+      - /fiscad/logs:/app/logs
+    restart: on-failure
+
+volumes:
+  db-data-fiscad:

secrets/postgresPassword.txt

@@ -1 +0,0 @@
-W5fwD({9*q53

src/main/java/io/gmss/fiscad/controllers/infocad/metier/TpeController.java

@@ -26,7 +26,7 @@ import org.springframework.web.client.HttpClientErrorException;
 @SecurityRequirement(name = "bearer")
 @Tag(name = "Tpe")
 @CrossOrigin(origins = "*")
-//@PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
+@PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
 public class TpeController {
 
     private final TpeService tpeService;

src/main/java/io/gmss/fiscad/controllers/synchronisation/RestaurationController.java

@@ -14,8 +14,6 @@ import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.HttpClientErrorException;
 
-import java.util.List;
-
 @RestController
 @RequestMapping(value = "api/restauration", produces = MediaType.APPLICATION_JSON_VALUE)
 @SecurityRequirement(name = "bearer")
@@ -31,11 +29,11 @@ public class RestaurationController {
         this.restaurationService = restaurationService;
     }
 
-    @GetMapping(path = "/enquete")
-    public ResponseEntity<?> getEnquetes(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/enquete/{terminalId}")
+    public ResponseEntity<?> getEnquetes(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getEnquete(terminalId,limit,offset), "liste des enquetes avec succès."),
+                    new ApiResponse<>(true, restaurationService.getEnquete(terminalId), "liste des enquetes avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -54,11 +52,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/acteur-concerne")
-    public ResponseEntity<?> getActeurConcerne(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/acteur-concerne/{terminalId}")
+    public ResponseEntity<?> getActeurConcerne(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getActeurConcernes(terminalId,limit,offset), "liste des acteurs concernés avec succès."),
+                    new ApiResponse<>(true, restaurationService.getActeurConcernes(terminalId), "liste des acteurs concernés avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -77,11 +75,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/personne") // ok
-    public ResponseEntity<?> getPersonnes(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/personne/{terminalId}") // ok
+    public ResponseEntity<?> getPersonnes(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getPersonne(terminalId,limit,offset), "liste des personnes avec succès."),
+                    new ApiResponse<>(true, restaurationService.getPersonne(terminalId), "liste des personnes avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -100,11 +98,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/membre-groupe")
-    public ResponseEntity<?> getMembrePersonnes(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/membre-groupe/{terminalId}")
+    public ResponseEntity<?> getMembrePersonnes(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getMembreGroupe(terminalId,limit,offset), "liste des membres groupe avec succès."),
+                    new ApiResponse<>(true, restaurationService.getMembreGroupe(terminalId), "liste des membres groupe avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -123,11 +121,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/parcelle")
-    public ResponseEntity<?> getParcelle(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/parcelle/{terminalId}")
+    public ResponseEntity<?> getParcelle(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getParcelle(terminalId,limit,offset), "liste des parcelle avec succès."),
+                    new ApiResponse<>(true, restaurationService.getParcelle(terminalId), "liste des parcelle avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -146,11 +144,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/caracteristique-parcelle")
-    public ResponseEntity<?> getCaracteristiqueParcelle(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/piece/{terminalId}")
+    public ResponseEntity<?> getPieces(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getCaracateristiqueParcelle(terminalId,limit,offset), "liste des caractéristiques des unités de logement avec succès."),
+                    new ApiResponse<>(true, restaurationService.getPieces(terminalId), "liste des enquetes avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -169,34 +167,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/piece")
-    public ResponseEntity<?> getPieces(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/upload/{terminalId}")
+    public ResponseEntity<?> getUpload(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getPieces(terminalId,limit,offset), "liste des enquetes avec succès."),
-                    HttpStatus.OK
-            );
-        } catch (HttpClientErrorException.MethodNotAllowed e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Method POST/GET is required."), HttpStatus.OK);
-        } catch (NotFoundException | BadRequestException | MyFileNotFoundException | ResourceNotFoundException |
-                 FileStorageException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, e.getMessage()), HttpStatus.OK);
-        } catch (NullPointerException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Null value has been detected {" + e.getMessage() + "}."), HttpStatus.OK);
-        } catch (Exception e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "An error has been occur and the content is {" + e.getMessage() + "}."), HttpStatus.OK);
-        }
-    }
-
-    @GetMapping(path = "/upload")
-    public ResponseEntity<?> getUpload(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
-        try {
-            return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getUploads(terminalId,limit,offset), "liste des enquetes avec succès."),
+                    new ApiResponse<>(true, restaurationService.getUpload(terminalId), "liste des enquetes avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -238,18 +213,12 @@ public class RestaurationController {
         }
     }
 
-    @PostMapping(path = "/files/{terminalId}")
-    public ResponseEntity<?> getCurrentUserTpe(@RequestBody List<Long> ids, @PathVariable Long terminalId) {
-        return new ResponseEntity<>(
-                new ApiResponse<>(true, restaurationService.getFiles(terminalId, ids), "liste des enquetes avec succès."),
-                HttpStatus.OK
-        );
-    }
-    @GetMapping(path = "/batiment")
-    public ResponseEntity<?> getBatiments(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+
+    @GetMapping(path = "/batiment/{terminalId}")
+    public ResponseEntity<?> getBatiments(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getBatiment(terminalId,limit,offset), "liste des batiments avec succès."),
+                    new ApiResponse<>(true, restaurationService.getBatiment(terminalId), "liste des batiments avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -269,11 +238,11 @@ public class RestaurationController {
     }
 
 
-    @GetMapping(path = "/enquete-batiment")
-    public ResponseEntity<?> getEnqueteBatiment(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/enquete-batiment/{terminalId}")
+    public ResponseEntity<?> getEnqueteBatiment(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getEnqueteBatiment(terminalId,limit,offset), "liste des enquetes batiments avec succès."),
+                    new ApiResponse<>(true, restaurationService.getEnqueteBatiment(terminalId), "liste des enquetes batiments avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -293,11 +262,11 @@ public class RestaurationController {
     }
 
 
-    @GetMapping(path = "/caracteristique-batiment")
-    public ResponseEntity<?> getCaracteristiqueBatiment(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/caracteristique-batiment/{terminalId}")
+    public ResponseEntity<?> getCaracteristiqueBatiment(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getCaracateristiqueBatiment(terminalId,limit,offset), "liste des caractéristiques batiments avec succès."),
+                    new ApiResponse<>(true, restaurationService.getCaracateristiqueBatiment(terminalId), "liste des caractéristiques batiments avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -316,82 +285,11 @@ public class RestaurationController {
         }
     }
 
-    @GetMapping(path = "/unite-logement")
-    public ResponseEntity<?> getUniteLogement(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
+    @GetMapping(path = "/caracteristique-unite-logement/{terminalId}")
+    public ResponseEntity<?> getCaracteristiqueUniteLogement(@PathVariable Long terminalId) {
         try {
             return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getUniteLogement(terminalId, limit, offset), "liste des unités de logement avec succès."),
-                    HttpStatus.OK
-            );
-        } catch (HttpClientErrorException.MethodNotAllowed e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Method POST/GET is required."), HttpStatus.OK);
-        } catch (NotFoundException | BadRequestException | MyFileNotFoundException | ResourceNotFoundException |
-                 FileStorageException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, e.getMessage()), HttpStatus.OK);
-        } catch (NullPointerException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Null value has been detected {" + e.getMessage() + "}."), HttpStatus.OK);
-        } catch (Exception e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "An error has been occur and the content is {" + e.getMessage() + "}."), HttpStatus.OK);
-        }
-    }
-
-    @GetMapping(path = "/enquete-unite-logement")
-    public ResponseEntity<?> getEnqueteEnqueteUniteLogement(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
-        try {
-            return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getEnqueteUniteLogement(terminalId,limit,offset), "liste des enquetes d'unité de logement chargée avec succès."),
-                    HttpStatus.OK
-            );
-        } catch (HttpClientErrorException.MethodNotAllowed e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Method POST/GET is required."), HttpStatus.OK);
-        } catch (NotFoundException | BadRequestException | MyFileNotFoundException | ResourceNotFoundException |
-                 FileStorageException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, e.getMessage()), HttpStatus.OK);
-        } catch (NullPointerException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Null value has been detected {" + e.getMessage() + "}."), HttpStatus.OK);
-        } catch (Exception e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "An error has been occur and the content is {" + e.getMessage() + "}."), HttpStatus.OK);
-        }
-    }
-
-    @GetMapping(path = "/caracteristique-unite-logement")
-    public ResponseEntity<?> getCaracteristiqueUniteLogement(@RequestParam Long terminalId,@RequestParam Long limit, @RequestParam Long offset) {
-        try {
-            return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getCaracateristiqueUniteLogement(terminalId,limit,offset), "liste des caractéristiques des unités de logement avec succès."),
-                    HttpStatus.OK
-            );
-        } catch (HttpClientErrorException.MethodNotAllowed e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Method POST/GET is required."), HttpStatus.OK);
-        } catch (NotFoundException | BadRequestException | MyFileNotFoundException | ResourceNotFoundException |
-                 FileStorageException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, e.getMessage()), HttpStatus.OK);
-        } catch (NullPointerException e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "Null value has been detected {" + e.getMessage() + "}."), HttpStatus.OK);
-        } catch (Exception e) {
-            logger.error(e.getLocalizedMessage());
-            return new ResponseEntity<>(new ApiResponse(false, null, "An error has been occur and the content is {" + e.getMessage() + "}."), HttpStatus.OK);
-        }
-    }
-
-
-
-    @GetMapping(path = "/taille-objet")
-    public ResponseEntity<?> getTailleObjet(@RequestParam Long terminalId) {
-        try {
-            return new ResponseEntity<>(
-                    new ApiResponse<>(true, restaurationService.getTailleObjetByTerminalId(terminalId), "liste des tailles des objets chargée avec succès."),
+                    new ApiResponse<>(true, restaurationService.getCaracateristiqueUniteLogement(terminalId), "liste des caractéristiques des unités de logement avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {

src/main/java/io/gmss/fiscad/controllers/synchronisation/SynchronisationController.java

@@ -18,6 +18,7 @@ import org.springframework.http.ResponseEntity;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
@@ -442,11 +443,11 @@ public class SynchronisationController {
 
     @PostMapping(path = "/unite-logement")
     @PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
-    public ResponseEntity<?> syncUniteLogement(@RequestBody List<UniteLogementPayload> uniteLogementPayloads) {
+    public ResponseEntity<?> syncUniteLogement(@RequestBody List<UniteLogementPaylaod> uniteLogementPaylaods) {
         try {
             return new ResponseEntity<>(
                     //new ApiResponse<>(true,null, "Liste des unités de logement synchronisées avec succès."),
-                    new ApiResponse<>(true, synchronisationService.syncUniteLogement(uniteLogementPayloads), "Liste des unités de logement synchronisées avec succès."),
+                    new ApiResponse<>(true, synchronisationService.syncUniteLogement(uniteLogementPaylaods), "Liste des unités de logement synchronisées avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -467,11 +468,11 @@ public class SynchronisationController {
 
     @PostMapping(path = "/caracteristique-batiment")
     @PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
-    public ResponseEntity<?> syncCaracteristiqueBatiment(@RequestBody List<CaracteristiqueBatimentPayload> caracteristiqueBatimentPayloads) {
+    public ResponseEntity<?> syncCaracteristiqueBatiment(@RequestBody List<CaracteristiqueBatimentPaylod> caracteristiqueBatimentPaylods) {
         try {
             return new ResponseEntity<>(
                     //new ApiResponse<>(true, null, "Liste des caractéristiques des bâtiments synchronisée avec succès."),
-                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueBatiment(caracteristiqueBatimentPayloads), "Liste des caractéristiques des bâtiments synchronisée avec succès."),
+                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueBatiment(caracteristiqueBatimentPaylods), "Liste des caractéristiques des bâtiments synchronisée avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -492,11 +493,11 @@ public class SynchronisationController {
 
     @PostMapping(path = "/caracteristique-parcelle")
     @PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
-    public ResponseEntity<?> syncCaracteristiqueParcelle(@RequestBody List<CaracteristiqueParcellePayload> caracteristiqueParcellePayloads) {
+    public ResponseEntity<?> syncCaracteristiqueParcelle(@RequestBody List<CaracteristiqueParcellePaylod> caracteristiqueParcellePaylods) {
         try {
             return new ResponseEntity<>(
                     //new ApiResponse<>(true, null, "Liste des caractéristiques des parcelles synchronisée avec succès."),
-                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueParcelle(caracteristiqueParcellePayloads), "Liste des caractéristiques des parcelles synchronisée avec succès."),
+                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueParcelle(caracteristiqueParcellePaylods), "Liste des caractéristiques des parcelles synchronisée avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {
@@ -517,11 +518,11 @@ public class SynchronisationController {
 
     @PostMapping(path = "/caracteristique-unite-logement")
     @PreAuthorize("hasRole('ADMIN') or hasRole('SUPERVISEUR') or hasRole('ENQUETEUR')")
-    public ResponseEntity<?> syncCaracteristiqueUniteLogement(@RequestBody List<CaracteristiqueUniteLogementPayload> caracteristiqueUniteLogementPayloads) {
+    public ResponseEntity<?> syncCaracteristiqueUniteLogement(@RequestBody List<CaracteristiqueUniteLogementPaylod> caracteristiqueUniteLogementPaylods) {
         try {
             return new ResponseEntity<>(
                     //new ApiResponse<>(true, null, "Liste des caractéristiques des unités de logement synchronisée avec succès."),
-                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueUniteLogement(caracteristiqueUniteLogementPayloads), "Liste des caractéristiques des unités de logement synchronisée avec succès."),
+                    new ApiResponse<>(true, synchronisationService.syncCaracteristiqueUniteLogement(caracteristiqueUniteLogementPaylods), "Liste des caractéristiques des unités de logement synchronisée avec succès."),
                     HttpStatus.OK
             );
         } catch (HttpClientErrorException.MethodNotAllowed e) {

src/main/java/io/gmss/fiscad/entities/infocad/metier/Enquete.java

@@ -86,9 +86,7 @@ public class Enquete extends BaseEntity implements Serializable {
     @ManyToOne
     private ZoneRfu zoneRfu;
     private String autreNumeroTitreFoncier;
-
-   // private Long personneId;
-
+    private Long personneId;
     @Enumerated(EnumType.STRING)
     private StatusEnquete statusEnquete;
     @JsonFormat(pattern = "dd-MM-yyyy")
@@ -152,14 +150,14 @@ public class Enquete extends BaseEntity implements Serializable {
     private String numRue;
     private String nomRue;
     private String emplacement;
-    private Float altitude;
-    private Float precision;
-    private Integer nbreCoProprietaire;
-    private Integer nbreIndivisiaire;
+    private float altitude;
+    private float precision;
+    private int nbreCoProprietaire;
+    private int nbreIndivisiaire;
     private String autreAdresse;
     private String surface;
-    private Integer nbreBatiment;
-    private Integer nbrePiscine;
+    private int nbreBatiment;
+    private int nbrePiscine;
     @JsonFormat(pattern = "dd-MM-yyyy")
     @JsonDeserialize(using = LocalDateDeserializer.class)
     private LocalDate dateDebutExcemption;

src/main/java/io/gmss/fiscad/entities/infocad/metier/Parcelle.java

@@ -54,7 +54,7 @@ public class Parcelle extends BaseEntity implements Serializable {
     private String autreNumeroTitreFoncier;
 
     private Long typeDomaineId;
-    private String numeroProvisoire;
+    private Long numeroProvisoire;
     private Long blocId;
     @ColumnDefault("false")
     private boolean synchronise;

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataCaracteristiqueBatiment.java

@@ -2,7 +2,7 @@ package io.gmss.fiscad.entities.metadata;
 
 import com.vladmihalcea.hibernate.type.json.JsonBinaryType;
 import io.gmss.fiscad.entities.BaseEntity;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueBatimentPayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueBatimentPaylod;
 import jakarta.persistence.*;
 import lombok.Getter;
 import lombok.Setter;
@@ -26,7 +26,7 @@ public class MobileDataCaracteristiqueBatiment extends BaseEntity implements Ser
     private Long externalKey;
     @Type(JsonBinaryType.class)
     @Column(columnDefinition = "jsonb")
-    private CaracteristiqueBatimentPayload caracteristiqueBatimentPayload ;
+    private CaracteristiqueBatimentPaylod caracteristiqueBatimentPaylod ;
     @Column(columnDefinition = "boolean default false")
     private boolean traiter;
 }

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataCaracteristiqueParcelle.java

@@ -2,7 +2,7 @@ package io.gmss.fiscad.entities.metadata;
 
 import com.vladmihalcea.hibernate.type.json.JsonBinaryType;
 import io.gmss.fiscad.entities.BaseEntity;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueParcellePayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueParcellePaylod;
 import jakarta.persistence.*;
 import lombok.Getter;
 import lombok.Setter;
@@ -26,7 +26,7 @@ public class MobileDataCaracteristiqueParcelle extends BaseEntity implements Ser
     private Long externalKey;
     @Type(JsonBinaryType.class)
     @Column(columnDefinition = "jsonb")
-    private CaracteristiqueParcellePayload caracteristiqueParcellePayload;
+    private CaracteristiqueParcellePaylod caracteristiqueParcellePaylod ;
     @Column(columnDefinition = "boolean default false")
     private boolean traiter;
 }

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataCaracteristiqueUniteLogement.java

@@ -2,7 +2,7 @@ package io.gmss.fiscad.entities.metadata;
 
 import com.vladmihalcea.hibernate.type.json.JsonBinaryType;
 import io.gmss.fiscad.entities.BaseEntity;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueUniteLogementPayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueUniteLogementPaylod;
 import jakarta.persistence.*;
 import lombok.Getter;
 import lombok.Setter;
@@ -26,7 +26,7 @@ public class MobileDataCaracteristiqueUniteLogement extends BaseEntity implement
     private Long externalKey;
     @Type(JsonBinaryType.class)
     @Column(columnDefinition = "jsonb")
-    private CaracteristiqueUniteLogementPayload caracteristiqueUniteLogementPayload;
+    private CaracteristiqueUniteLogementPaylod caracteristiqueUniteLogementPaylod ;
     @Column(columnDefinition = "boolean default false")
     private boolean traiter;
 }

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataDeclarationNc.java

@@ -15,7 +15,7 @@ import java.io.Serializable;
 @Setter
 @Table(
         indexes = {
-                @Index(name = "idx_terminal_external_declarationNc", columnList = "terminalId, externalKey")
+                @Index(name = "idx_terminal_external_bat", columnList = "terminalId, externalKey")
         }
 )
 public class MobileDataDeclarationNc extends BaseEntity implements Serializable {

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataEnqueteActivite.java

@@ -16,7 +16,7 @@ import java.io.Serializable;
 @Setter
 @Table(
         indexes = {
-                @Index(name = "idx_terminal_external_EnqActivite", columnList = "terminalId, externalKey")
+                @Index(name = "idx_terminal_external_bat", columnList = "terminalId, externalKey")
         }
 )
 public class MobileDataEnqueteActivite extends BaseEntity implements Serializable {

src/main/java/io/gmss/fiscad/entities/metadata/MobileDataUniteLogement.java

@@ -2,7 +2,8 @@ package io.gmss.fiscad.entities.metadata;
 
 import com.vladmihalcea.hibernate.type.json.JsonBinaryType;
 import io.gmss.fiscad.entities.BaseEntity;
-import io.gmss.fiscad.paylaods.request.UniteLogementPayload;
+import io.gmss.fiscad.paylaods.request.ParcellePayLoad;
+import io.gmss.fiscad.paylaods.request.UniteLogementPaylaod;
 import jakarta.persistence.*;
 import lombok.Getter;
 import lombok.Setter;
@@ -26,7 +27,7 @@ public class MobileDataUniteLogement extends BaseEntity implements Serializable
     private Long externalKey;
     @Type(JsonBinaryType.class)
     @Column(columnDefinition = "jsonb")
-    private UniteLogementPayload uniteLogementPayload ;
+    private UniteLogementPaylaod uniteLogementPaylaod ;
     @Column(columnDefinition = "boolean default false")
     private boolean traiter;
 }

src/main/java/io/gmss/fiscad/entities/rfu/metier/EnqueteActivite.java

@@ -49,8 +49,8 @@ public class EnqueteActivite extends BaseEntity implements Serializable {
     @JsonDeserialize(using = LocalDateDeserializer.class)
     private LocalDate dateEnquete;
 
-    //@Column(columnDefinition = "false")
-    private Boolean estDeclarer;
+    @Column(columnDefinition = "false")
+    private boolean estDeclarer;
     private String nc;
     private Long ChiffreAffaire;
     private String NumeroRccm;

src/main/java/io/gmss/fiscad/entities/rfu/metier/EnqueteBatiment.java

@@ -41,20 +41,20 @@ public class EnqueteBatiment extends BaseEntity implements Serializable {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
-    private Float surfaceAuSol;
+    private float surfaceAuSol;
     private String autreMenuisierie;
     private String autreMur;
-    private Boolean sbee;
+    private boolean sbee;
     private String numCompteurSbee;
-    private Boolean soneb;
+    private boolean soneb;
     private String numCompteurSoneb;
-    private Integer nbreLotUnite;
-    private Integer nbreUniteLocation;
-    private Float surfaceLouee;
-    private Integer nbreMenage;
-    private Integer nbreHabitant;
-    private Float valeurMensuelleLocation;
-    private Integer nbreMoisLocation;
+    private int nbreLotUnite;
+    private int nbreUniteLocation;
+    private float surfaceLouee;
+    private int nbreMenage;
+    private int nbreHabitant;
+    private float valeurMensuelleLocation;
+    private int nbreMoisLocation;
     private String autreCaracteristiquePhysique;
     @JsonFormat(pattern = "dd-MM-yyyy")
     @JsonDeserialize(using = LocalDateDeserializer.class)

src/main/java/io/gmss/fiscad/entities/rfu/metier/EnqueteUniteLogement.java

@@ -40,17 +40,17 @@ public class EnqueteUniteLogement extends BaseEntity implements Serializable {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
-    private Float surface;
-    private Integer nbrePiece;
-    private Integer nbreHabitant;
-    private Integer nbreMenage;
+    private float surface;
+    private int nbrePiece;
+    private int nbreHabitant;
+    private int nbreMenage;
     private boolean enLocation;
-    private Float montantMensuelLoyer;
-    private Integer nbreMoisEnLocation;
-    private Float montantLocatifAnnuelDeclare;
-    private Float surfaceLouee;
-    private Boolean sbee;
-    private Boolean soneb;
+    private float montantMensuelLoyer;
+    private int nbreMoisEnLocation;
+    private float montantLocatifAnnuelDeclare;
+    private float surfaceLouee;
+    private boolean sbee;
+    private boolean soneb;
     private String numCompteurSbee;
     private String numCompteurSoneb;
     @JsonFormat(pattern = "dd-MM-yyyy")

src/main/java/io/gmss/fiscad/implementations/infocad/metier/TpeServiceImpl.java

@@ -127,7 +127,6 @@ public class TpeServiceImpl implements TpeService {
     public List<Tpe> getTpeListByUserId(Long userId) {
         return tpeRepository.getTpeByUserId(userId);
     }
-
     @Override
     public Tpe reCreateExistTpe(Tpe tpe) throws BadRequestException {
 

src/main/java/io/gmss/fiscad/implementations/synchronisation/RestaurationServiceImpl.java

@@ -1,15 +1,10 @@
 package io.gmss.fiscad.implementations.synchronisation;
 
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
-import io.gmss.fiscad.entities.metadata.*;
 import io.gmss.fiscad.entities.user.User;
-import io.gmss.fiscad.paylaods.request.*;
-//import io.gmss.fiscad.paylaods.response.restoration.BatimentPayload;
-import io.gmss.fiscad.paylaods.response.restoration.TailleObjet;
-import io.gmss.fiscad.repositories.metadata.*;
 import io.gmss.fiscad.interfaces.synchronisation.RestaurationService;
 import io.gmss.fiscad.interfaces.user.UserService;
-//import io.gmss.fiscad.paylaods.response.restoration.*;
+import io.gmss.fiscad.paylaods.response.restoration.*;
 import io.gmss.fiscad.repositories.infocad.metier.*;
 import io.gmss.fiscad.repositories.infocad.parametre.PersonneRepository;
 import io.gmss.fiscad.repositories.rfu.metier.*;
@@ -20,8 +15,9 @@ import org.springframework.security.core.Authentication;
 import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.stereotype.Service;
 
-import java.util.*;
-import java.util.stream.Collectors;
+import java.util.ArrayList;
+import java.util.Base64;
+import java.util.List;
 
 @Service
 @RequiredArgsConstructor
@@ -36,7 +32,6 @@ public class RestaurationServiceImpl implements RestaurationService {
     private final FileStorageService fileStorageService;
     private final TpeRepository tpeRepository;
     private final UserService userService;
-    private final MobileDataEnqueteRepository mobileDataEnqueteRepository;
     private Authentication authentication;
     private final BatimentRepository batimentRepository;
     private final EnqueteBatimentRepository enqueteBatimentRepository;
@@ -45,223 +40,109 @@ public class RestaurationServiceImpl implements RestaurationService {
     private final CaracteristiqueParcelleRepository caracteristiqueParcelleRepository;
     private final EnqueteUniteLogementRepository enqueteUniteLogementRepository;
     private final UniteLogementRepository uniteLogementRepository;
-    private final MobileDataActeurConcerneRepository mobileDataActeurConcerneRepository;
-    private final MobileDataPersonneRepository mobileDataPersonneRepository;
-    private final MobileDataMembreGroupeRepository mobileDataMembreGroupeRepository;
-    private final MobileDataParcelleRepository mobileDataParcelleRepository;
-    private final MobileDataPieceRepository mobileDataPieceRepository;
-    private final MobileDataUploadRepository mobileDataUploadRepository;
-    private final MobileDataBatimentRepository mobileDataBatimentRepository;
-    private final MobileDataEnqueteBatimentRepository mobileDataEnqueteBatimentRepository;
-    private final MobileDataCaracteristiqueParcelleRepository mobileDataCaracteristiqueParcelleRepository;
-    private final MobileDataCaracteristiqueBatimentRepository mobileDataCaracteristiqueBatimentRepository;
-    private final MobileDataEnqueteUniteLogementRepository mobileDataEnqueteUniteLogementRepository;
-    private final MobileDataCaracteristiqueUniteLogementRepository mobileDataCaracteristiqueUniteLogementRepository;
-    private final MobileDataUniteLogementRepository mobileDataUniteLogementRepository;
-
-
-
-//    @Override
-//    public List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId) {
-//        return acteurConcerneRepository.getActeurConcerneByTerminalId(terminaleId);
-//    }
-
-//    @Override
-//    public List<EnquetePayLoad> getEnquete(Long terminaleId) {
-//        return enqueteRepository.getEnqueteByTerminalId(terminaleId);
-//    }
-
-    @Override
-    public List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId, Long limit, Long offset) {
-        return mobileDataActeurConcerneRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataActeurConcerne::getActeurConcernePayLoad)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
-    }
-
 
 
     @Override
-    public List<EnquetePayLoad> getEnquete(Long terminaleId, Long limit, Long offset) {
-
-        return mobileDataEnqueteRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataEnquete::getEnquetePayLoad)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
-    }
-
-//    @Override
-//    public List<PersonnePayLoad> getPersonne(Long terminaleId) {
-//        return personneRepository.getPersonnesByTerminalId(terminaleId);
-//    }
-
-    @Override
-    public List<PersonnePayLoad> getPersonne(Long terminaleId, Long limit, Long offset) {
-        return mobileDataPersonneRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataPersonne::getPersonnePayLoad)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+    public List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId) {
+        return acteurConcerneRepository.getActeurConcerneByTerminalId(terminaleId);
     }
 
     @Override
-    public List<MembreGroupePayLoad> getMembreGroupe(Long terminaleId, Long limit, Long offset) {
+    public List<EnquetePayLoad> getEnquete(Long terminaleId) {
 
-        return mobileDataMembreGroupeRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataMembreGroupe::getMembreGroupePayLoad)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
-    }
-
-
-//    @Override
-//    public List<ParcellePayLoad> getParcelle(Long terminaleId) {
-//
-//        return parcelleRepository.getParcellesByTerminalId(terminaleId);
-//    }
-@Override
-public List<ParcellePayLoad> getParcelle(Long terminaleId, Long limit, Long offset) {
-    return mobileDataParcelleRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-            .stream()
-            .map(MobileDataParcelle::getParcellePayLoad)
-            .filter(Objects::nonNull)
-            .collect(Collectors.toList());
-}
-
-//    @Override
-//    public List<PiecePayLoad> getPieces(Long terminaleId) {
-//        return pieceRepository.getPiecesByTerminalId(terminaleId);
-//    }
-
-    @Override
-    public List<PiecePayLoad> getPieces(Long terminaleId, Long limit, Long offset) {
-
-        return mobileDataPieceRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataPiece::getPiecePayLoad)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+        return enqueteRepository.getEnqueteByTerminalId(terminaleId);
     }
 
     @Override
-    public List<UploadPayLoad> getUploads(Long terminaleId, Long limit, Long offset) {
-        List<MobileDataUpload> mobileDataUploads = mobileDataUploadRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset);
-        return getUploadPayLoads(mobileDataUploads);
+    public List<PersonnePayLoad> getPersonne(Long terminaleId) {
+        return personneRepository.getPersonnesByTerminalId(terminaleId);
     }
 
-//    @Override
-//    public List<BatimentPaylaod> getBatiment(Long terminalId) {
-//        return batimentRepository.getBatimentByTerminalId(terminalId);
-//    }
-
     @Override
-    public List<io.gmss.fiscad.paylaods.request.BatimentPaylaod> getBatiment(Long terminaleId, Long limit, Long offset) {
+    public List<ParcellePayLoad> getParcelle(Long terminaleId) {
 
-        return mobileDataBatimentRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataBatiment::getBatimentPaylaod)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+        return parcelleRepository.getParcellesByTerminalId(terminaleId);
     }
 
-//    @Override
-//    public List<EnqueteBatimentPayLoad> getEnqueteBatiment(Long terminalId) {
-//        return enqueteBatimentRepository.getEnqueteBatimentByTerminalId(terminalId);
-//    }
-
-
     @Override
-    public List<EnqueteBatimentPayload> getEnqueteBatiment(Long terminaleId, Long limit, Long offset) {
+    public List<PiecePayLoad> getPieces(Long terminaleId) {
 
-        return mobileDataEnqueteBatimentRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataEnqueteBatiment::getEnqueteBatimentPayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+        return pieceRepository.getPiecesByTerminalId(terminaleId);
     }
 
-//    @Override
-//    public List<CaracateristiqueParcellePayLoads> getCaracateristiqueParcelle(Long terminalId) {
-//        return caracteristiqueParcelleRepository.getCaracteristiqueParcelleByTerminalId(terminalId);
-//    }
-
     @Override
-    public List<CaracteristiqueParcellePayload> getCaracateristiqueParcelle(Long terminaleId, Long limit, Long offset) {
+    public List<MembreGroupePayLoad> getMembreGroupe(Long terminaleId) {
 
-        return mobileDataCaracteristiqueParcelleRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataCaracteristiqueParcelle::getCaracteristiqueParcellePayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+        return membreGroupeRepository.getMembreGroupeByTerminalId(terminaleId);
     }
 
-
-//    @Override
-//    public List<CaracateristiqueBatimentPayLoads> getCaracateristiqueBatiment(Long terminalId) {
-//        return caracteristiqueBatimentRepository.getCaracteristiqueBatimentByTerminalId(terminalId);
-//    }
-
     @Override
-    public List<CaracteristiqueBatimentPayload> getCaracateristiqueBatiment(Long terminaleId, Long limit, Long offset) {
+    public List<io.gmss.fiscad.paylaods.request.UploadPayLoad> getUpload(Long terminaleId) {
+        List<UploadPayLoad> uploadPayLoads = uploadRepository.getUploadByTerminalId(terminaleId);
 
-        return mobileDataCaracteristiqueBatimentRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataCaracteristiqueBatiment::getCaracteristiqueBatimentPayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+        List<io.gmss.fiscad.paylaods.request.UploadPayLoad> uploadPayLoadsOut = new ArrayList<>();
+        uploadPayLoads.forEach(uploadPayLoad -> {
+            io.gmss.fiscad.paylaods.request.UploadPayLoad uploadPayLoadLocal = new io.gmss.fiscad.paylaods.request.UploadPayLoad();
+            uploadPayLoadLocal.setTerminalId(uploadPayLoad.getTerminalId());
+            String inputStream = getUploadFile(uploadPayLoad);
+            uploadPayLoadLocal.setFileBase64(inputStream);
+            uploadPayLoadLocal.setIdBackend(uploadPayLoad.getIdBackend());
+            uploadPayLoadLocal.setPieceId(uploadPayLoad.getPieceId());
+            uploadPayLoadLocal.setSynchronise(uploadPayLoad.getSynchronise());
+            uploadPayLoadLocal.setMembreGroupeId(uploadPayLoad.getMembreGroupeId());
+            uploadPayLoadLocal.setExternalKey(uploadPayLoad.getExternalKey());
+            uploadPayLoadLocal.setBlocId(uploadPayLoad.getBlocId());
+            uploadPayLoadLocal.setFilePath(uploadPayLoad.getFilePath());
+            uploadPayLoadLocal.setEnqueteId(uploadPayLoad.getEnqueteId());
+            uploadPayLoadLocal.setMax_numero_acteur_concerne_id(uploadPayLoad.getMax_numero_acteur_concerne_id());
+            uploadPayLoadLocal.setMax_numero_piece_id(uploadPayLoad.getMax_numero_piece_id());
+            uploadPayLoadLocal.setMax_numero_upload_id(uploadPayLoad.getMax_numero_upload_id());
+            uploadPayLoadLocal.setName(uploadPayLoad.getName());
+            uploadPayLoadLocal.setObservation(uploadPayLoad.getObservation());
+            uploadPayLoadsOut.add(uploadPayLoadLocal);
+        });
+        return uploadPayLoadsOut;
     }
 
-//    @Override
-//    public List<CaracteristiqueUniteLogementPayLoad> getCaracateristiqueUniteLogement(Long terminalId) {
-//        return caracteristiqueUniteLogementRepository.getCaracteristiqueUniteLogementByTerminalId(terminalId);
-//    }
-
     @Override
-    public List<CaracteristiqueUniteLogementPayload> getCaracateristiqueUniteLogement(Long terminaleId, Long limit, Long offset) {
-
-        return mobileDataCaracteristiqueUniteLogementRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataCaracteristiqueUniteLogement::getCaracteristiqueUniteLogementPayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+    public List<BatimentPayload> getBatiment(Long terminalId) {
+        return batimentRepository.getBatimentByTerminalId(terminalId);
     }
 
-//    @Override
-//    public List<EnqueteUniteLogementPayLoad> getEnqueteUniteLogement(Long terminalId) {
-//        return enqueteUniteLogementRepository.getEnqueteUniteLogementByTerminalId(terminalId);
-//    }
-
     @Override
-    public List<EnqueteUniteLogementPayload> getEnqueteUniteLogement(Long terminaleId, Long limit, Long offset) {
-
-        return mobileDataEnqueteUniteLogementRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataEnqueteUniteLogement::getEnqueteUniteLogementPayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+    public List<EnqueteBatimentPayLoad> getEnqueteBatiment(Long terminalId) {
+        return enqueteBatimentRepository.getEnqueteBatimentByTerminalId(terminalId);
     }
 
-//    @Override
-//    public List<UniteLogementPayLoad> getUniteLogement(Long terminalId) {
-//        return uniteLogementRepository.getUniteLogementByTerminalId(terminalId);
-//    }
+    @Override
+    public List<CaracateristiqueParcellePayLoads> getCaracateristiqueParcelle(Long terminalId) {
+        return caracteristiqueParcelleRepository.getCaracteristiqueParcelleByTerminalId(terminalId);
+    }
 
     @Override
-    public List<UniteLogementPayload> getUniteLogement(Long terminaleId, Long limit, Long offset) {
+    public List<CaracateristiqueBatimentPayLoads> getCaracateristiqueBatiment(Long terminalId) {
+        return caracteristiqueBatimentRepository.getCaracteristiqueBatimentByTerminalId(terminalId);
+    }
 
-        return mobileDataUniteLogementRepository.findAllByTerminalIdIgnoreIfTreatedPaged(terminaleId, limit, offset)
-                .stream()
-                .map(MobileDataUniteLogement::getUniteLogementPayload)
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
+    @Override
+    public List<CaracteristiqueUniteLogementPayLoad> getCaracateristiqueUniteLogement(Long terminalId) {
+        return caracteristiqueUniteLogementRepository.getCaracteristiqueUniteLogementByTerminalId(terminalId);
+    }
+
+    @Override
+    public List<EnqueteUniteLogementPayLoad> getEnqueteUniteLogement(Long terminalId) {
+        return enqueteUniteLogementRepository.getEnqueteUniteLogementByTerminalId(terminalId);
+    }
+
+    @Override
+    public List<UniteLogementPayLoad> getUniteLogement(Long terminalId) {
+        return uniteLogementRepository.getUniteLogementByTerminalId(terminalId);
     }
 
     private String getUploadFile(UploadPayLoad uploadPayLoad) {
+
         try {
-            Resource resource = fileStorageService.loadFileAsResource("",uploadPayLoad.getRename());
+            Resource resource = fileStorageService.loadFileAsResource(uploadPayLoad.getFileBackendName());
             final var bytes = resource.getInputStream().readAllBytes();
             return Base64.getEncoder().encodeToString(bytes);
         } catch (Exception e) {
@@ -272,7 +153,6 @@ public List<ParcellePayLoad> getParcelle(Long terminaleId, Long limit, Long offs
     }
 
 
-
     public List<Tpe> getTpeListByCurrentUser() {
         try {
             authentication = SecurityContextHolder.getContext().getAuthentication();
@@ -284,49 +164,4 @@ public List<ParcellePayLoad> getParcelle(Long terminaleId, Long limit, Long offs
         }
 
     }
-
-    @Override
-    public TailleObjet getTailleObjetByTerminalId(Long terminalId) {
-        return mobileDataEnqueteRepository.calculateTailleEnqueteData(terminalId);
-    }
-
-
-    private List<UploadPayLoad> getUploadPayLoads(List<MobileDataUpload> mobileDataUploads) {
-        return mobileDataUploads
-                .stream()
-                .map(mobileDataUpload -> {
-                    UploadPayLoad uploadPayLoad = mobileDataUpload.getUploadPayLoad();
-                    String fileData = getUploadFile(uploadPayLoad);
-                    uploadPayLoad.setFileBase64(fileData);
-                    return uploadPayLoad;
-                })
-                .filter(Objects::nonNull)
-                .collect(Collectors.toList());
-    }
-
-
-    @Override
-    public List<UploadPayLoad> getFiles(Long terminaleId, List<Long> ids) {
-        List<UploadPayLoad> uploadPayLoads = new ArrayList<>();
-        if(ids == null || ids.isEmpty()){
-            for(Long id : ids){
-                uploadPayLoads.add(getUpload(terminaleId, id));
-            }
-        }
-        return uploadPayLoads;
-    }
-
-    @Override
-    public UploadPayLoad getUpload(Long terminaleId, Long externalKey) {
-        Optional<MobileDataUpload> optionalMobileDataUpload = mobileDataUploadRepository.findOneByTerminalIdAndExternalKey(terminaleId, externalKey);
-        if(optionalMobileDataUpload.isPresent()){
-            MobileDataUpload mobileDataUpload = optionalMobileDataUpload.get();
-            UploadPayLoad uploadPayLoad = mobileDataUpload.getUploadPayLoad();
-            String fileData = getUploadFile(uploadPayLoad);
-            uploadPayLoad.setFileBase64(fileData);
-            return uploadPayLoad;
-        }else{
-            return null;
-        }
-    }
 }

src/main/java/io/gmss/fiscad/implementations/synchronisation/SynchronisationServiceImpl.java

@@ -1,13 +1,18 @@
 package io.gmss.fiscad.implementations.synchronisation;
 
+import io.gmss.fiscad.entities.decoupage.Commune;
 import io.gmss.fiscad.entities.decoupage.Nationalite;
+import io.gmss.fiscad.entities.decoupage.Quartier;
 import io.gmss.fiscad.entities.infocad.metier.*;
 import io.gmss.fiscad.entities.infocad.parametre.*;
 import io.gmss.fiscad.entities.metadata.*;
+import io.gmss.fiscad.entities.rfu.metier.*;
 import io.gmss.fiscad.entities.rfu.parametre.Caracteristique;
 import io.gmss.fiscad.entities.rfu.parametre.TypeCaracteristique;
+import io.gmss.fiscad.entities.rfu.parametre.ZoneRfu;
 import io.gmss.fiscad.entities.user.User;
 import io.gmss.fiscad.enums.*;
+import io.gmss.fiscad.interfaces.infocad.metier.ParcelleGeomService;
 import io.gmss.fiscad.interfaces.synchronisation.SynchronisationService;
 import io.gmss.fiscad.interfaces.user.UserService;
 import io.gmss.fiscad.paylaods.request.*;
@@ -16,24 +21,30 @@ import io.gmss.fiscad.repositories.decoupage.*;
 import io.gmss.fiscad.repositories.infocad.metier.*;
 import io.gmss.fiscad.repositories.infocad.parametre.*;
 import io.gmss.fiscad.repositories.metadata.*;
+import io.gmss.fiscad.repositories.rfu.metier.*;
 import io.gmss.fiscad.repositories.rfu.parametre.CaracteristiqueRepository;
 import io.gmss.fiscad.repositories.rfu.parametre.TypeCaracteristiqueRepository;
 import io.gmss.fiscad.repositories.rfu.parametre.ZoneRfuRepository;
+import io.gmss.fiscad.repositories.user.UserRepository;
 import io.gmss.fiscad.service.FileStorageService;
 import io.gmss.fiscad.service.worker.*;
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.security.core.Authentication;
 import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.Optional;
+import java.util.function.ToDoubleBiFunction;
 
 @Service
 @RequiredArgsConstructor
@@ -404,53 +415,53 @@ public class SynchronisationServiceImpl implements SynchronisationService {
         return syncResponses;
     }
     @Override
-    public List<SyncResponse> syncUniteLogement(List<UniteLogementPayload> uniteLogementPayloads) {
+    public List<SyncResponse> syncUniteLogement(List<UniteLogementPaylaod> uniteLogementPaylaods) {
 
         List<SyncResponse> syncResponses = new ArrayList<>();
-        if (uniteLogementPayloads == null) {
+        if (uniteLogementPaylaods == null) {
             SyncResponse syncResponse = new SyncResponse(null,
                     null, false, "Aucune unité de logement à synchroniser");
             syncResponses.add(syncResponse);
             return syncResponses;
         }
-        syncResponses = saveMobileData(uniteLogementPayloads, TypeObjet.UNITELOGEMENT);
+        syncResponses = saveMobileData(uniteLogementPaylaods, TypeObjet.UNITELOGEMENT);
         return syncResponses;
     }
 
     @Override
-    public List<SyncResponse> syncCaracteristiqueBatiment(List<CaracteristiqueBatimentPayload> caracteristiqueBatimentPayloads) {
+    public List<SyncResponse> syncCaracteristiqueBatiment(List<CaracteristiqueBatimentPaylod> caracteristiqueBatimentPaylods) {
         List<SyncResponse> syncResponses = new ArrayList<>();
-        if (caracteristiqueBatimentPayloads == null) {
+        if (caracteristiqueBatimentPaylods == null) {
             SyncResponse syncResponse = new SyncResponse(null,
                     null, false, "Aucune caracteristique de bâtiment à synchroniser");
             syncResponses.add(syncResponse);
             return syncResponses;
         }
-        syncResponses = saveMobileData(caracteristiqueBatimentPayloads, TypeObjet.CARACTERISTIQUEBATIMENT);
+        syncResponses = saveMobileData(caracteristiqueBatimentPaylods, TypeObjet.CARACTERISTIQUEBATIMENT);
         return syncResponses;
     }
     @Override
-    public List<SyncResponse> syncCaracteristiqueUniteLogement(List<CaracteristiqueUniteLogementPayload> caracteristiqueUniteLogementPayloads) {
+    public List<SyncResponse> syncCaracteristiqueUniteLogement(List<CaracteristiqueUniteLogementPaylod> caracteristiqueUniteLogementPaylods) {
         List<SyncResponse> syncResponses = new ArrayList<>();
-        if (caracteristiqueUniteLogementPayloads == null) {
+        if (caracteristiqueUniteLogementPaylods == null) {
             SyncResponse syncResponse = new SyncResponse(null,
                     null, false, "Aucune caracteristique d'unité de logement à synchroniser");
             syncResponses.add(syncResponse);
             return syncResponses;
         }
-        syncResponses = saveMobileData(caracteristiqueUniteLogementPayloads, TypeObjet.CARACTERISTIQUEUNITELOGEMENT);
+        syncResponses = saveMobileData(caracteristiqueUniteLogementPaylods, TypeObjet.CARACTERISTIQUEUNITELOGEMENT);
         return syncResponses;
     }
     @Override
-    public List<SyncResponse> syncCaracteristiqueParcelle(List<CaracteristiqueParcellePayload> caracteristiqueParcellePayloads) {
+    public List<SyncResponse> syncCaracteristiqueParcelle(List<CaracteristiqueParcellePaylod> caracteristiqueParcellePaylods) {
         List<SyncResponse> syncResponses = new ArrayList<>();
-        if (caracteristiqueParcellePayloads == null) {
+        if (caracteristiqueParcellePaylods == null) {
             SyncResponse syncResponse = new SyncResponse(null,
                     null, false, "Aucune caracteristique de parcelle à synchroniser");
             syncResponses.add(syncResponse);
             return syncResponses;
         }
-        syncResponses = saveMobileData(caracteristiqueParcellePayloads, TypeObjet.CARACTERISTIQUEPARCELLE);
+        syncResponses = saveMobileData(caracteristiqueParcellePaylods, TypeObjet.CARACTERISTIQUEPARCELLE);
         return syncResponses;
     }
     @Override
@@ -748,32 +759,32 @@ public class SynchronisationServiceImpl implements SynchronisationService {
             }
             case UNITELOGEMENT -> {
                 payloads.forEach(payLoad -> {
-                    UniteLogementPayload uniteLogementPayload = (UniteLogementPayload) payLoad;
-                    //uniteLogementPayload.setIdBackend(null);
+                    UniteLogementPaylaod uniteLogementPaylaod = (UniteLogementPaylaod) payLoad;
+                    //uniteLogementPaylaod.setIdBackend(null);
                     try {
                         MobileDataUniteLogement mobileDataUniteLogement = new MobileDataUniteLogement();
 
                         Optional<MobileDataUniteLogement> optionalMobileDataUniteLogement = Optional.empty();
 
-                        if (uniteLogementPayload.getIdBackend() != null) {
-                            optionalMobileDataUniteLogement = mobileDataUniteLogementRepository.findById(uniteLogementPayload.getIdBackend());
+                        if (uniteLogementPaylaod.getIdBackend() != null) {
+                            optionalMobileDataUniteLogement = mobileDataUniteLogementRepository.findById(uniteLogementPaylaod.getIdBackend());
                             if (optionalMobileDataUniteLogement.isPresent()) {
                                 mobileDataUniteLogement = optionalMobileDataUniteLogement.get();
                             }
                         } else {
-                            optionalMobileDataUniteLogement = mobileDataUniteLogementRepository.findFirstByTerminalIdAndExternalKey(uniteLogementPayload.getTerminalId(), uniteLogementPayload.getExternalKey());
+                            optionalMobileDataUniteLogement = mobileDataUniteLogementRepository.findFirstByTerminalIdAndExternalKey(uniteLogementPaylaod.getTerminalId(), uniteLogementPaylaod.getExternalKey());
                             if (optionalMobileDataUniteLogement.isPresent()) {
                                 mobileDataUniteLogement = optionalMobileDataUniteLogement.get();
                             }
                         }
-                        mobileDataUniteLogement.setTerminalId(uniteLogementPayload.getTerminalId());
-                        mobileDataUniteLogement.setExternalKey(uniteLogementPayload.getExternalKey());
+                        mobileDataUniteLogement.setTerminalId(uniteLogementPaylaod.getTerminalId());
+                        mobileDataUniteLogement.setExternalKey(uniteLogementPaylaod.getExternalKey());
                         mobileDataUniteLogement.setTraiter(false);
-                        mobileDataUniteLogement.setUniteLogementPayload(uniteLogementPayload);
+                        mobileDataUniteLogement.setUniteLogementPaylaod(uniteLogementPaylaod);
                         mobileDataUniteLogement = mobileDataUniteLogementRepository.save(mobileDataUniteLogement);
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation effectuée avec succès pour " + TypeObjet.UNITELOGEMENT.toString());
-                        syncResponse.setExternalKey(uniteLogementPayload.getExternalKey());
+                        syncResponse.setExternalKey(uniteLogementPaylaod.getExternalKey());
                         syncResponse.setSynchronise(true);
                         syncResponse.setIdBackend(mobileDataUniteLogement.getId());
                         syncResponses.add(syncResponse);
@@ -781,9 +792,9 @@ public class SynchronisationServiceImpl implements SynchronisationService {
                         e.printStackTrace();
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation échouée pour " + TypeObjet.PIECE.toString());
-                        syncResponse.setExternalKey(uniteLogementPayload.getExternalKey());
+                        syncResponse.setExternalKey(uniteLogementPaylaod.getExternalKey());
                         syncResponse.setSynchronise(false);
-                        syncResponse.setIdBackend(uniteLogementPayload.getIdBackend());
+                        syncResponse.setIdBackend(uniteLogementPaylaod.getIdBackend());
                         syncResponses.add(syncResponse);
                     }
                 });
@@ -874,32 +885,32 @@ public class SynchronisationServiceImpl implements SynchronisationService {
             }
             case CARACTERISTIQUEPARCELLE -> {
                 payloads.forEach(payLoad -> {
-                    CaracteristiqueParcellePayload caracteristiqueParcellePayload = (CaracteristiqueParcellePayload) payLoad;
-                    //caracteristiqueParcellePayload.setIdBackend(null);
+                    CaracteristiqueParcellePaylod caracteristiqueParcellePaylod = (CaracteristiqueParcellePaylod) payLoad;
+                    //caracteristiqueParcellePaylod.setIdBackend(null);
                     try {
                         MobileDataCaracteristiqueParcelle mobileDataCaracteristiqueParcelle = new MobileDataCaracteristiqueParcelle();
 
                         Optional<MobileDataCaracteristiqueParcelle> optionalMobileDataCaracteristiqueParcelle = Optional.empty();
 
-                        if (caracteristiqueParcellePayload.getIdBackend() != null) {
-                            optionalMobileDataCaracteristiqueParcelle = mobileDataCaracteristiqueParcelleRepository.findById(caracteristiqueParcellePayload.getIdBackend());
+                        if (caracteristiqueParcellePaylod.getIdBackend() != null) {
+                            optionalMobileDataCaracteristiqueParcelle = mobileDataCaracteristiqueParcelleRepository.findById(caracteristiqueParcellePaylod.getIdBackend());
                             if (optionalMobileDataCaracteristiqueParcelle.isPresent()) {
                                 mobileDataCaracteristiqueParcelle = optionalMobileDataCaracteristiqueParcelle.get();
                             }
                         } else {
-                            optionalMobileDataCaracteristiqueParcelle = mobileDataCaracteristiqueParcelleRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueParcellePayload.getTerminalId(), caracteristiqueParcellePayload.getExternalKey());
+                            optionalMobileDataCaracteristiqueParcelle = mobileDataCaracteristiqueParcelleRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueParcellePaylod.getTerminalId(), caracteristiqueParcellePaylod.getExternalKey());
                             if (optionalMobileDataCaracteristiqueParcelle.isPresent()) {
                                 mobileDataCaracteristiqueParcelle = optionalMobileDataCaracteristiqueParcelle.get();
                             }
                         }
-                        mobileDataCaracteristiqueParcelle.setTerminalId(caracteristiqueParcellePayload.getTerminalId());
-                        mobileDataCaracteristiqueParcelle.setExternalKey(caracteristiqueParcellePayload.getExternalKey());
+                        mobileDataCaracteristiqueParcelle.setTerminalId(caracteristiqueParcellePaylod.getTerminalId());
+                        mobileDataCaracteristiqueParcelle.setExternalKey(caracteristiqueParcellePaylod.getExternalKey());
                         mobileDataCaracteristiqueParcelle.setTraiter(false);
-                        mobileDataCaracteristiqueParcelle.setCaracteristiqueParcellePayload(caracteristiqueParcellePayload);
+                        mobileDataCaracteristiqueParcelle.setCaracteristiqueParcellePaylod(caracteristiqueParcellePaylod);
                         mobileDataCaracteristiqueParcelle = mobileDataCaracteristiqueParcelleRepository.save(mobileDataCaracteristiqueParcelle);
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation effectuée avec succès pour " + TypeObjet.CARACTERISTIQUEPARCELLE.toString());
-                        syncResponse.setExternalKey(caracteristiqueParcellePayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueParcellePaylod.getExternalKey());
                         syncResponse.setSynchronise(true);
                         syncResponse.setIdBackend(mobileDataCaracteristiqueParcelle.getId());
                         syncResponses.add(syncResponse);
@@ -907,9 +918,9 @@ public class SynchronisationServiceImpl implements SynchronisationService {
                         e.printStackTrace();
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation échouée pour " + TypeObjet.CARACTERISTIQUEPARCELLE.toString());
-                        syncResponse.setExternalKey(caracteristiqueParcellePayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueParcellePaylod.getExternalKey());
                         syncResponse.setSynchronise(false);
-                        syncResponse.setIdBackend(caracteristiqueParcellePayload.getIdBackend());
+                        syncResponse.setIdBackend(caracteristiqueParcellePaylod.getIdBackend());
                         syncResponses.add(syncResponse);
                     }
                 });
@@ -917,33 +928,33 @@ public class SynchronisationServiceImpl implements SynchronisationService {
 
             case CARACTERISTIQUEBATIMENT -> {
                 payloads.forEach(payLoad -> {
-                    CaracteristiqueBatimentPayload caracteristiqueBatimentPayload = (CaracteristiqueBatimentPayload) payLoad;
-                    //caracteristiqueBatimentPayload.setIdBackend(null);
+                    CaracteristiqueBatimentPaylod caracteristiqueBatimentPaylod = (CaracteristiqueBatimentPaylod) payLoad;
+                    //caracteristiqueBatimentPaylod.setIdBackend(null);
                     try {
                         MobileDataCaracteristiqueBatiment mobileDataCaracteristiqueBatiment = new MobileDataCaracteristiqueBatiment();
 
                         Optional<MobileDataCaracteristiqueBatiment> optionalMobileDataCaracteristiqueBatiment = Optional.empty();
 
-                        if (caracteristiqueBatimentPayload.getIdBackend() != null) {
-                            optionalMobileDataCaracteristiqueBatiment = mobileDataCaracteristiqueBatimentRepository.findById(caracteristiqueBatimentPayload.getIdBackend());
+                        if (caracteristiqueBatimentPaylod.getIdBackend() != null) {
+                            optionalMobileDataCaracteristiqueBatiment = mobileDataCaracteristiqueBatimentRepository.findById(caracteristiqueBatimentPaylod.getIdBackend());
                             if (optionalMobileDataCaracteristiqueBatiment.isPresent()) {
                                 mobileDataCaracteristiqueBatiment = optionalMobileDataCaracteristiqueBatiment.get();
                             }
                         } else {
-                            optionalMobileDataCaracteristiqueBatiment = mobileDataCaracteristiqueBatimentRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueBatimentPayload.getTerminalId(), caracteristiqueBatimentPayload.getExternalKey());
+                            optionalMobileDataCaracteristiqueBatiment = mobileDataCaracteristiqueBatimentRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueBatimentPaylod.getTerminalId(), caracteristiqueBatimentPaylod.getExternalKey());
                             if (optionalMobileDataCaracteristiqueBatiment.isPresent()) {
                                 mobileDataCaracteristiqueBatiment = optionalMobileDataCaracteristiqueBatiment.get();
                             }
                         }
 
-                        mobileDataCaracteristiqueBatiment.setTerminalId(caracteristiqueBatimentPayload.getTerminalId());
-                        mobileDataCaracteristiqueBatiment.setExternalKey(caracteristiqueBatimentPayload.getExternalKey());
+                        mobileDataCaracteristiqueBatiment.setTerminalId(caracteristiqueBatimentPaylod.getTerminalId());
+                        mobileDataCaracteristiqueBatiment.setExternalKey(caracteristiqueBatimentPaylod.getExternalKey());
                         mobileDataCaracteristiqueBatiment.setTraiter(false);
-                        mobileDataCaracteristiqueBatiment.setCaracteristiqueBatimentPayload(caracteristiqueBatimentPayload);
+                        mobileDataCaracteristiqueBatiment.setCaracteristiqueBatimentPaylod(caracteristiqueBatimentPaylod);
                         mobileDataCaracteristiqueBatiment = mobileDataCaracteristiqueBatimentRepository.save(mobileDataCaracteristiqueBatiment);
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation effectuée avec succès pour " + TypeObjet.CARACTERISTIQUEBATIMENT.toString());
-                        syncResponse.setExternalKey(caracteristiqueBatimentPayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueBatimentPaylod.getExternalKey());
                         syncResponse.setSynchronise(true);
                         syncResponse.setIdBackend(mobileDataCaracteristiqueBatiment.getId());
                         syncResponses.add(syncResponse);
@@ -951,41 +962,41 @@ public class SynchronisationServiceImpl implements SynchronisationService {
                         e.printStackTrace();
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation échouée pour " + TypeObjet.CARACTERISTIQUEBATIMENT.toString());
-                        syncResponse.setExternalKey(caracteristiqueBatimentPayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueBatimentPaylod.getExternalKey());
                         syncResponse.setSynchronise(false);
-                        syncResponse.setIdBackend(caracteristiqueBatimentPayload.getIdBackend());
+                        syncResponse.setIdBackend(caracteristiqueBatimentPaylod.getIdBackend());
                         syncResponses.add(syncResponse);
                     }
                 });
             }
             case CARACTERISTIQUEUNITELOGEMENT -> {
                 payloads.forEach(payLoad -> {
-                    CaracteristiqueUniteLogementPayload caracteristiqueUniteLogementPayload = (CaracteristiqueUniteLogementPayload) payLoad;
-                    //caracteristiqueUniteLogementPayload.setIdBackend(null);
+                    CaracteristiqueUniteLogementPaylod caracteristiqueUniteLogementPaylod = (CaracteristiqueUniteLogementPaylod) payLoad;
+                    //caracteristiqueUniteLogementPaylod.setIdBackend(null);
                     try {
                         MobileDataCaracteristiqueUniteLogement mobileDataCaracteristiqueUniteLogement = new MobileDataCaracteristiqueUniteLogement();
 
                         Optional<MobileDataCaracteristiqueUniteLogement> optionalMobileDataCaracteristiqueUniteLogement = Optional.empty();
 
-                        if (caracteristiqueUniteLogementPayload.getIdBackend() != null) {
-                            optionalMobileDataCaracteristiqueUniteLogement = mobileDataCaracteristiqueUniteLogementRepository.findById(caracteristiqueUniteLogementPayload.getIdBackend());
+                        if (caracteristiqueUniteLogementPaylod.getIdBackend() != null) {
+                            optionalMobileDataCaracteristiqueUniteLogement = mobileDataCaracteristiqueUniteLogementRepository.findById(caracteristiqueUniteLogementPaylod.getIdBackend());
                             if (optionalMobileDataCaracteristiqueUniteLogement.isPresent()) {
                                 mobileDataCaracteristiqueUniteLogement = optionalMobileDataCaracteristiqueUniteLogement.get();
                             }
                         } else {
-                            optionalMobileDataCaracteristiqueUniteLogement = mobileDataCaracteristiqueUniteLogementRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueUniteLogementPayload.getTerminalId(), caracteristiqueUniteLogementPayload.getExternalKey());
+                            optionalMobileDataCaracteristiqueUniteLogement = mobileDataCaracteristiqueUniteLogementRepository.findFirstByTerminalIdAndExternalKey(caracteristiqueUniteLogementPaylod.getTerminalId(), caracteristiqueUniteLogementPaylod.getExternalKey());
                             if (optionalMobileDataCaracteristiqueUniteLogement.isPresent()) {
                                 mobileDataCaracteristiqueUniteLogement = optionalMobileDataCaracteristiqueUniteLogement.get();
                             }
                         }
-                        mobileDataCaracteristiqueUniteLogement.setTerminalId(caracteristiqueUniteLogementPayload.getTerminalId());
-                        mobileDataCaracteristiqueUniteLogement.setExternalKey(caracteristiqueUniteLogementPayload.getExternalKey());
+                        mobileDataCaracteristiqueUniteLogement.setTerminalId(caracteristiqueUniteLogementPaylod.getTerminalId());
+                        mobileDataCaracteristiqueUniteLogement.setExternalKey(caracteristiqueUniteLogementPaylod.getExternalKey());
                         mobileDataCaracteristiqueUniteLogement.setTraiter(false);
-                        mobileDataCaracteristiqueUniteLogement.setCaracteristiqueUniteLogementPayload(caracteristiqueUniteLogementPayload);
+                        mobileDataCaracteristiqueUniteLogement.setCaracteristiqueUniteLogementPaylod(caracteristiqueUniteLogementPaylod);
                         mobileDataCaracteristiqueUniteLogement = mobileDataCaracteristiqueUniteLogementRepository.save(mobileDataCaracteristiqueUniteLogement);
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation effectuée avec succès pour " + TypeObjet.CARACTERISTIQUEUNITELOGEMENT.toString());
-                        syncResponse.setExternalKey(caracteristiqueUniteLogementPayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueUniteLogementPaylod.getExternalKey());
                         syncResponse.setSynchronise(true);
                         syncResponse.setIdBackend(mobileDataCaracteristiqueUniteLogement.getId());
                         syncResponses.add(syncResponse);
@@ -993,9 +1004,9 @@ public class SynchronisationServiceImpl implements SynchronisationService {
                         e.printStackTrace();
                         SyncResponse syncResponse = new SyncResponse();
                         syncResponse.setObservation("Synchronisation échouée pour " + TypeObjet.CARACTERISTIQUEUNITELOGEMENT.toString());
-                        syncResponse.setExternalKey(caracteristiqueUniteLogementPayload.getExternalKey());
+                        syncResponse.setExternalKey(caracteristiqueUniteLogementPaylod.getExternalKey());
                         syncResponse.setSynchronise(false);
-                        syncResponse.setIdBackend(caracteristiqueUniteLogementPayload.getIdBackend());
+                        syncResponse.setIdBackend(caracteristiqueUniteLogementPaylod.getIdBackend());
                         syncResponses.add(syncResponse);
                     }
                 });

src/main/java/io/gmss/fiscad/interfaces/synchronisation/RestaurationService.java

@@ -1,74 +1,40 @@
 package io.gmss.fiscad.interfaces.synchronisation;
 
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
-import io.gmss.fiscad.paylaods.request.*;
-import io.gmss.fiscad.paylaods.response.restoration.TailleObjet;
-//import io.gmss.fiscad.paylaods.response.restoration.*;
+import io.gmss.fiscad.paylaods.response.restoration.*;
 
 import java.util.List;
 
 public interface RestaurationService {
 
-    //List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId);
-    List<EnquetePayLoad> getEnquete(Long terminaleId, Long limit, Long offset) ;
+    List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId);
 
-    List<ActeurConcernePayLoad> getActeurConcernes(Long terminaleId, Long limit, Long offset) ;
+    List<EnquetePayLoad> getEnquete(Long terminaleId);
 
-    //List<EnquetePayLoad> getEnquete(Long terminaleId);
-    List<PersonnePayLoad> getPersonne(Long terminaleId, Long limit, Long offset) ;
+    List<PersonnePayLoad> getPersonne(Long terminaleId);
 
-    List<MembreGroupePayLoad> getMembreGroupe(Long terminaleId, Long limit, Long offset) ;
+    List<ParcellePayLoad> getParcelle(Long terminaleId);
 
+    List<PiecePayLoad> getPieces(Long terminaleId);
 
-    //List<PersonnePayLoad> getPersonne(Long terminaleId);
+    List<MembreGroupePayLoad> getMembreGroupe(Long terminaleId);
 
-    //List<ParcellePayLoad> getParcelle(Long terminaleId);
-    List<ParcellePayLoad> getParcelle(Long terminaleId, Long limit, Long offset) ;
+    List<io.gmss.fiscad.paylaods.request.UploadPayLoad> getUpload(Long terminaleId);
 
+    List<BatimentPayload> getBatiment(Long terminalId);
 
-    //List<PiecePayLoad> getPieces(Long terminaleId);
-    List<PiecePayLoad> getPieces(Long terminaleId, Long limit, Long offset) ;
+    List<EnqueteBatimentPayLoad> getEnqueteBatiment(Long terminalId);
 
+    List<CaracateristiqueParcellePayLoads> getCaracateristiqueParcelle(Long terminalId);
 
+    List<CaracateristiqueBatimentPayLoads> getCaracateristiqueBatiment(Long terminalId);
 
-    //List<MembreGroupePayLoad> getMembreGroupe(Long terminaleId);
+    List<CaracteristiqueUniteLogementPayLoad> getCaracateristiqueUniteLogement(Long terminalId);
 
-   // List<io.gmss.fiscad.paylaods.request.UploadPayLoad> getUpload(Long terminaleId);
-    List<UploadPayLoad> getUploads(Long terminaleId, Long limit, Long offset) ;
-
-    //List<BatimentPayload> getBatiment(Long terminalId);
-    public List<BatimentPaylaod> getBatiment(Long terminaleId, Long limit, Long offset);
-
-    //List<EnqueteBatimentPayLoad> getEnqueteBatiment(Long terminalId);
-    public List<EnqueteBatimentPayload> getEnqueteBatiment(Long terminaleId, Long limit, Long offset);
-
-    //List<CaracateristiqueParcellePayLoads> getCaracateristiqueParcelle(Long terminalId);
-    public List<CaracteristiqueParcellePayload> getCaracateristiqueParcelle(Long terminaleId, Long limit, Long offset);
-
-
-    //List<CaracateristiqueBatimentPayLoads> getCaracateristiqueBatiment(Long terminalId);
-    public List<CaracteristiqueBatimentPayload> getCaracateristiqueBatiment(Long terminaleId, Long limit, Long offset);
-
-
-    //List<CaracteristiqueUniteLogementPayLoad> getCaracateristiqueUniteLogement(Long terminalId);
-
-    public List<CaracteristiqueUniteLogementPayload> getCaracateristiqueUniteLogement(Long terminaleId, Long limit, Long offset);
-
-    //List<EnqueteUniteLogementPayLoad> getEnqueteUniteLogement(Long terminalId);
-    public List<EnqueteUniteLogementPayload> getEnqueteUniteLogement(Long terminaleId, Long limit, Long offset);
-
-
-    //List<UniteLogementPayLoad> getUniteLogement(Long terminalId);
-
-    public List<UniteLogementPayload> getUniteLogement(Long terminaleId, Long limit, Long offset);
+    List<EnqueteUniteLogementPayLoad> getEnqueteUniteLogement(Long terminalId);
 
+    List<UniteLogementPayLoad> getUniteLogement(Long terminalId);
 
     public List<Tpe> getTpeListByCurrentUser();
 
-    TailleObjet getTailleObjetByTerminalId(Long terminalId);
-
-
-    List<UploadPayLoad> getFiles(Long terminaleId, List<Long> ids);
-    UploadPayLoad getUpload(Long terminaleId, Long externalKey);
-
 }

src/main/java/io/gmss/fiscad/interfaces/synchronisation/SynchronisationService.java

@@ -1,5 +1,7 @@
 package io.gmss.fiscad.interfaces.synchronisation;
 
+import io.gmss.fiscad.entities.infocad.metier.Upload;
+import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import io.gmss.fiscad.paylaods.request.*;
 import io.gmss.fiscad.paylaods.response.ReferencesSyncResponses;
 import io.gmss.fiscad.paylaods.response.SyncEnqueteAllDataResponse;
@@ -21,13 +23,13 @@ public interface SynchronisationService {
 
     public List<SyncResponse> syncBatiment(List<BatimentPaylaod> batimentPaylaods);
 
-    public List<SyncResponse> syncUniteLogement(List<UniteLogementPayload> uniteLogementPayloads);
+    public List<SyncResponse> syncUniteLogement(List<UniteLogementPaylaod> uniteLogementPaylaods);
 
-    public List<SyncResponse> syncCaracteristiqueBatiment(List<CaracteristiqueBatimentPayload> caracteristiqueBatimentPayloads);
+    public List<SyncResponse> syncCaracteristiqueBatiment(List<CaracteristiqueBatimentPaylod> caracteristiqueBatimentPaylods);
 
-    public List<SyncResponse> syncCaracteristiqueParcelle(List<CaracteristiqueParcellePayload> caracteristiqueParcellePayloads);
+    public List<SyncResponse> syncCaracteristiqueParcelle(List<CaracteristiqueParcellePaylod> caracteristiqueParcellePaylods);
 
-    public List<SyncResponse> syncCaracteristiqueUniteLogement(List<CaracteristiqueUniteLogementPayload> caracteristiqueUniteLogementPayloads);
+    public List<SyncResponse> syncCaracteristiqueUniteLogement(List<CaracteristiqueUniteLogementPaylod> caracteristiqueUniteLogementPaylods);
 
     public List<SyncResponse> syncMembreGroupe(List<MembreGroupePayLoad> membreGroupePayLoads);
 

src/main/java/io/gmss/fiscad/paylaods/request/CaracteristiqueBatimentPaylod.java

@@ -3,7 +3,7 @@ package io.gmss.fiscad.paylaods.request;
 import lombok.Data;
 
 @Data
-public class CaracteristiqueBatimentPayload {
+public class CaracteristiqueBatimentPaylod {
     private Long idBackend;
     private Long externalKey;
     private boolean synchronise;
@@ -18,7 +18,7 @@ public class CaracteristiqueBatimentPayload {
 
     @Override
     public String toString() {
-        return "CaracteristiqueBatimentPayload{" +
+        return "CaracteristiqueBatimentPaylod{" +
                 "idBackend=" + idBackend +
                 ", externalKey=" + externalKey +
                 ", synchronise=" + synchronise +

src/main/java/io/gmss/fiscad/paylaods/request/CaracteristiqueParcellePaylod.java

@@ -3,7 +3,7 @@ package io.gmss.fiscad.paylaods.request;
 import lombok.Data;
 
 @Data
-public class CaracteristiqueParcellePayload {
+public class CaracteristiqueParcellePaylod {
     private Long idBackend;
     private Long externalKey;
     private Long terminalId;

src/main/java/io/gmss/fiscad/paylaods/request/CaracteristiqueUniteLogementPaylod.java

@@ -3,7 +3,7 @@ package io.gmss.fiscad.paylaods.request;
 import lombok.Data;
 
 @Data
-public class CaracteristiqueUniteLogementPayload {
+public class CaracteristiqueUniteLogementPaylod {
     private Long idBackend;
     private Long externalKey;
     private Long terminalId;

src/main/java/io/gmss/fiscad/paylaods/request/ParcellePayLoad.java

@@ -25,7 +25,7 @@ public class ParcellePayLoad {
 
     /////////////////////////////////
     private Long typeDomaineId;
-    private String numeroProvisoire;
+    private Long numeroProvisoire;
     private Long blocId;
     private String situationGeographique;
     private String autreNumeroTitreFoncier;

src/main/java/io/gmss/fiscad/paylaods/request/UniteLogementPaylaod.java

@@ -3,7 +3,7 @@ package io.gmss.fiscad.paylaods.request;
 import lombok.Data;
 
 @Data
-public class UniteLogementPayload {
+public class UniteLogementPaylaod {
     private Long idBackend;
     private Long externalKey;
     private Long terminalId;

src/main/java/io/gmss/fiscad/paylaods/response/restoration/TailleObjet.java

@@ -1,19 +0,0 @@
-package io.gmss.fiscad.paylaods.response.restoration;
-
-public interface TailleObjet {
-    public int getParcelle();
-    public int getEnquete();
-    public int getPiece();
-    public int getPersonne();
-    public int getMembregroupe();
-    public int getActeurconcerne();
-    public int getEnquetebatiment();
-    public int getBatiment();
-    public int getUnitelogement();
-    public int getEnqueteunitelogement();
-    public int getCaracteristiqueparcelle();
-    public int getCaracteristiquebatiment();
-    public int getCaracteristiqueunitelogement();
-    public int getUpload();
-}
-

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataActeurConcerneRepository.java

@@ -4,8 +4,6 @@ import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
 import io.gmss.fiscad.entities.metadata.MobileDataPersonne;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -14,7 +12,4 @@ public interface MobileDataActeurConcerneRepository extends JpaRepository<Mobile
     //Optional<MobileDataActeurConcerne> findByActeurConcernePayLoad_TerminalIdAndActeurConcernePayLoad_ExternalKey(Long terminalId,Long ExternalKey);
     Optional<MobileDataActeurConcerne> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
     List<MobileDataActeurConcerne> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-
-    @Query(value = "SELECT * FROM mobile_data_acteur_concerne WHERE CAST(acteur_concerne_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataActeurConcerne> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataBatimentRepository.java

@@ -2,10 +2,7 @@ package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
 import io.gmss.fiscad.entities.metadata.MobileDataBatiment;
-import io.gmss.fiscad.entities.metadata.MobileDataPiece;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -14,8 +11,4 @@ public interface MobileDataBatimentRepository extends JpaRepository<MobileDataBa
     //Optional<MobileDataBatiment>  findMobileDataBatimentByBatimentPaylaod_TerminalIdAndBatimentPaylaod_ExternalKey(Long terminalId, Long externalKey);
     Optional<MobileDataBatiment> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
     List<MobileDataBatiment> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-
-    @Query(value = "SELECT * FROM mobile_data_batiment WHERE CAST(batiment_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataBatiment> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataCaracteristiqueBatimentRepository.java

@@ -2,11 +2,8 @@ package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueBatiment;
-import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueParcelle;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,8 +13,4 @@ public interface MobileDataCaracteristiqueBatimentRepository extends JpaReposito
     Optional<MobileDataCaracteristiqueBatiment> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataCaracteristiqueBatiment> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-
-    @Query(value = "SELECT * FROM mobile_data_caracteristique_batiment WHERE CAST(caracteristique_batiment_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataCaracteristiqueBatiment> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataCaracteristiqueParcelleRepository.java

@@ -2,11 +2,8 @@ package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueParcelle;
-import io.gmss.fiscad.entities.metadata.MobileDataEnqueteBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,7 +13,4 @@ public interface MobileDataCaracteristiqueParcelleRepository extends JpaReposito
     Optional<MobileDataCaracteristiqueParcelle> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataCaracteristiqueParcelle> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-    @Query(value = "SELECT * FROM mobile_data_caracteristique_parcelle WHERE CAST(caracteristique_parcelle_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataCaracteristiqueParcelle> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataCaracteristiqueUniteLogementRepository.java

@@ -1,12 +1,9 @@
 package io.gmss.fiscad.repositories.metadata;
 
-import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueParcelle;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,7 +13,4 @@ public interface MobileDataCaracteristiqueUniteLogementRepository extends JpaRep
     Optional<MobileDataCaracteristiqueUniteLogement> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataCaracteristiqueUniteLogement> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-    @Query(value = "SELECT * FROM mobile_data_caracteristique_unite_logement WHERE CAST(caracteristique_unite_logement_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataCaracteristiqueUniteLogement> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataEnqueteBatimentRepository.java

@@ -1,12 +1,9 @@
 package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
-import io.gmss.fiscad.entities.metadata.MobileDataBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataEnqueteBatiment;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,7 +13,4 @@ public interface MobileDataEnqueteBatimentRepository extends JpaRepository<Mobil
     Optional<MobileDataEnqueteBatiment> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataEnqueteBatiment> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-    @Query(value = "SELECT * FROM mobile_data_enquete_batiment WHERE CAST(enquete_batiment_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataEnqueteBatiment> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataEnqueteRepository.java

@@ -1,14 +1,9 @@
 package io.gmss.fiscad.repositories.metadata;
 
-import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
 import io.gmss.fiscad.entities.metadata.MobileDataEnquete;
 import io.gmss.fiscad.entities.metadata.MobileDataEnqueteBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
-import io.gmss.fiscad.paylaods.response.restoration.EnquetePayLoad;
-import io.gmss.fiscad.paylaods.response.restoration.TailleObjet;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -18,26 +13,4 @@ public interface MobileDataEnqueteRepository extends JpaRepository<MobileDataEnq
     Optional<MobileDataEnquete> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataEnquete> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-
-    @Query(value = "SELECT * FROM mobile_data_enquete WHERE CAST(enquete_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataEnquete> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
-    @Query(value = "SELECT" +
-            "    (SELECT count(*) FROM mobile_data_enquete WHERE CAST(enquete_pay_load->>'terminalId' AS BIGINT) = :terminalId) as enquete," +
-            "    (SELECT count(*) FROM mobile_data_parcelle WHERE CAST(parcelle_pay_load->>'terminalId' AS BIGINT) = :terminalId) as parcelle," +
-            "    (SELECT count(*) FROM mobile_data_personne WHERE CAST(personne_pay_load->>'terminalId' AS BIGINT) = :terminalId) as personne," +
-            "    (SELECT count(*) FROM mobile_data_acteur_concerne WHERE CAST(acteur_concerne_pay_load->>'terminalId' AS BIGINT) = :terminalId) as acteurconcerne," +
-            "    (SELECT count(*) FROM mobile_data_membre_groupe WHERE CAST(membre_groupe_pay_load->>'terminalId' AS BIGINT) = :terminalId) as membregroupe," +
-            "    (SELECT count(*) FROM mobile_data_piece WHERE CAST(piece_pay_load->>'terminalId' AS BIGINT) = :terminalId) as piece," +
-
-            "    (SELECT count(*) FROM mobile_data_batiment WHERE CAST(batiment_payload->>'terminalId' AS BIGINT) = :terminalId) as batiment," +
-            "    (SELECT count(*) FROM mobile_data_enquete_batiment WHERE CAST(enquete_batiment_payload->>'terminalId' AS BIGINT) = :terminalId) as enquetebatiment," +
-            "    (SELECT count(*) FROM mobile_data_enquete_unite_logement WHERE CAST(enquete_unite_logement_payload->>'terminalId' AS BIGINT) = :terminalId) as enqueteunitelogement," +
-            "    (SELECT count(*) FROM mobile_data_unite_logement WHERE CAST(unite_logement_payload->>'terminalId' AS BIGINT) = :terminalId) as unitelogement," +
-            "    (SELECT count(*) FROM mobile_data_caracteristique_unite_logement WHERE CAST(caracteristique_unite_logement_payload->>'terminalId' AS BIGINT) = :terminalId) as caracteristiqueunitelogement," +
-            "    (SELECT count(*) FROM mobile_data_caracteristique_batiment WHERE CAST(caracteristique_batiment_payload->>'terminalId' AS BIGINT) = :terminalId) as caracteristiquebatiment," +
-            "    (SELECT count(*) FROM mobile_data_caracteristique_parcelle WHERE CAST(caracteristique_parcelle_payload->>'terminalId' AS BIGINT) = :terminalId) as caracteristiqueparcelle," +
-
-            "    (SELECT count(*) FROM mobile_data_upload WHERE CAST(upload_pay_load->>'terminalId' AS BIGINT) = :terminalId) as upload", nativeQuery = true)
-    TailleObjet calculateTailleEnqueteData(@Param("terminalId") Long terminalId);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataEnqueteUniteLogementRepository.java

@@ -1,12 +1,9 @@
 package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
-import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataEnquete;
 import io.gmss.fiscad.entities.metadata.MobileDataEnqueteUniteLogement;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,7 +13,4 @@ public interface MobileDataEnqueteUniteLogementRepository extends JpaRepository<
     Optional<MobileDataEnqueteUniteLogement> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataEnqueteUniteLogement> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-    @Query(value = "SELECT * FROM public.mobile_data_enquete_unite_logement WHERE CAST(enquete_unite_logement_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataEnqueteUniteLogement> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataMembreGroupeRepository.java

@@ -4,8 +4,6 @@ import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
 import io.gmss.fiscad.entities.metadata.MobileDataEnqueteUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataMembreGroupe;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -15,6 +13,4 @@ public interface MobileDataMembreGroupeRepository extends JpaRepository<MobileDa
     Optional<MobileDataMembreGroupe> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataMembreGroupe> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-    @Query(value = "SELECT * FROM mobile_data_membre_groupe WHERE CAST(membre_groupe_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataMembreGroupe> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataParcelleRepository.java

@@ -5,8 +5,6 @@ import io.gmss.fiscad.entities.metadata.MobileDataParcelle;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.modelmapper.internal.bytebuddy.dynamic.DynamicType;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,7 +14,4 @@ public interface MobileDataParcelleRepository extends JpaRepository<MobileDataPa
     Optional<MobileDataParcelle> findFirstByTerminalIdAndExternalKey(Long terminalId,Long ExternalKey);
 
     List<MobileDataParcelle> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
-
-    @Query(value = "SELECT * FROM mobile_data_parcelle WHERE CAST(parcelle_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataParcelle> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataPersonneRepository.java

@@ -5,8 +5,6 @@ import io.gmss.fiscad.entities.metadata.MobileDataParcelle;
 import io.gmss.fiscad.entities.metadata.MobileDataPersonne;
 import org.modelmapper.internal.bytebuddy.dynamic.DynamicType;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,6 +14,4 @@ public interface MobileDataPersonneRepository extends JpaRepository<MobileDataPe
     List<MobileDataPersonne> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
     Optional<MobileDataPersonne> findFirstByTerminalIdAndExternalKey(Long terminalId, Long ExternalKey);
 
-    @Query(value = "SELECT * FROM mobile_data_personne WHERE CAST(personne_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataPersonne> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataPieceRepository.java

@@ -5,8 +5,6 @@ import io.gmss.fiscad.entities.metadata.MobileDataParcelle;
 import io.gmss.fiscad.entities.metadata.MobileDataPersonne;
 import io.gmss.fiscad.entities.metadata.MobileDataPiece;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -16,6 +14,4 @@ public interface MobileDataPieceRepository extends JpaRepository<MobileDataPiece
     List<MobileDataPiece> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
     Optional<MobileDataPiece> findFirstByTerminalIdAndExternalKey(Long terminalId, Long ExternalKey);
 
-    @Query(value = "SELECT * FROM mobile_data_piece WHERE CAST(piece_pay_load->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataPiece> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataUniteLogementRepository.java

@@ -1,12 +1,9 @@
 package io.gmss.fiscad.repositories.metadata;
 
 import io.gmss.fiscad.entities.metadata.MobileDataActeurConcerne;
-import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataPiece;
 import io.gmss.fiscad.entities.metadata.MobileDataUniteLogement;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -15,7 +12,5 @@ public interface MobileDataUniteLogementRepository extends JpaRepository<MobileD
     //Optional<MobileDataUniteLogement> findByUniteLogementPaylaod_TerminalIdAndUniteLogementPaylaod_ExternalKey(Long terminalId,Long externalKey);
     List<MobileDataUniteLogement> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
     Optional<MobileDataUniteLogement> findFirstByTerminalIdAndExternalKey(Long terminalId, Long ExternalKey);
-    @Query(value = "SELECT * FROM mobile_data_unite_logement WHERE CAST(unite_logement_payload ->>'terminalId' AS BIGINT) = :terminalId limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataUniteLogement> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
 
 }

src/main/java/io/gmss/fiscad/repositories/metadata/MobileDataUploadRepository.java

@@ -3,8 +3,6 @@ package io.gmss.fiscad.repositories.metadata;
 import io.gmss.fiscad.entities.metadata.MobileDataUniteLogement;
 import io.gmss.fiscad.entities.metadata.MobileDataUpload;
 import org.springframework.data.jpa.repository.JpaRepository;
-import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 import java.util.Optional;
@@ -14,8 +12,4 @@ public interface MobileDataUploadRepository extends JpaRepository<MobileDataUplo
     List<MobileDataUpload> findAllByTraiterIsFalseAndTerminalId(Long TerminalId);
     Optional<MobileDataUpload> findFirstByTerminalIdAndExternalKey(Long terminalId, Long ExternalKey);
 
-    @Query(value = "SELECT * FROM mobile_data_upload WHERE CAST(upload_pay_load->>'terminalId' AS BIGINT) = :terminalId order by id limit :limit offset :offset", nativeQuery = true)
-    List<MobileDataUpload> findAllByTerminalIdIgnoreIfTreatedPaged(@Param("terminalId") Long terminalId, @Param("limit") Long limit, @Param("offset") Long offset);
-
-    Optional<MobileDataUpload> findOneByTerminalIdAndExternalKey(Long terminaleId, Long externalKey);
 }

src/main/java/io/gmss/fiscad/service/FileStorageService.java

@@ -100,26 +100,4 @@ public class FileStorageService {
         }
     }
 
-
-    public Resource loadFileAsResource(String subDir, String fileName) {
-        try {
-            Path targetDir = this.fileStorageLocation.resolve(subDir).normalize();
-            Path filePath = targetDir.resolve(fileName).normalize();
-
-            // 🔐 Sécurité : interdit les accès en dehors du dossier cible
-            if (!filePath.startsWith(targetDir)) {
-                throw new SecurityException("Tentative d'accès non autorisée : " + fileName);
-            }
-
-            Resource resource = new UrlResource(filePath.toUri());
-            if (resource.exists() && resource.isReadable()) {
-                return resource;
-            } else {
-                throw new MyFileNotFoundException("Fichier introuvable : " + fileName);
-            }
-        } catch (MalformedURLException e) {
-            throw new MyFileNotFoundException("Fichier introuvable : " + fileName, e);
-        }
-    }
-
 }

src/main/java/io/gmss/fiscad/service/worker/CaracteristiqueBatimentAsyncWorker.java

@@ -1,19 +1,30 @@
 package io.gmss.fiscad.service.worker;
 
 import io.gmss.fiscad.entities.infocad.metier.Enquete;
+import io.gmss.fiscad.entities.infocad.metier.Parcelle;
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
+import io.gmss.fiscad.entities.infocad.parametre.Bloc;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueBatiment;
+import io.gmss.fiscad.entities.metadata.MobileDataEnquete;
 import io.gmss.fiscad.entities.rfu.metier.CaracteristiqueBatiment;
 import io.gmss.fiscad.entities.rfu.metier.EnqueteBatiment;
 import io.gmss.fiscad.entities.rfu.parametre.Caracteristique;
+import io.gmss.fiscad.entities.rfu.parametre.ZoneRfu;
+import io.gmss.fiscad.entities.user.User;
 import io.gmss.fiscad.enums.TypeObjet;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueBatimentPayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueBatimentPaylod;
+import io.gmss.fiscad.paylaods.request.EnquetePayLoad;
 import io.gmss.fiscad.repositories.infocad.metier.*;
+import io.gmss.fiscad.repositories.infocad.parametre.BlocRepository;
 import io.gmss.fiscad.repositories.metadata.MobileDataCaracteristiqueBatimentRepository;
+import io.gmss.fiscad.repositories.metadata.MobileDataEnqueteRepository;
 import io.gmss.fiscad.repositories.rfu.metier.*;
 import io.gmss.fiscad.repositories.rfu.parametre.CaracteristiqueRepository;
+import io.gmss.fiscad.repositories.rfu.parametre.ZoneRfuRepository;
+import io.gmss.fiscad.repositories.user.UserRepository;
 import io.gmss.fiscad.service.LogService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.Optional;
@@ -30,24 +41,24 @@ public class CaracteristiqueBatimentAsyncWorker {
     private final LogService logService;
    // @Async("caracteristiqueBatimentExecutor")
     public void traitementAsyncCaracteristiqueBatiment(MobileDataCaracteristiqueBatiment mobileDataCaracteristiqueBatiment) {
-        CaracteristiqueBatimentPayload caracteristiqueBatimentPayload = mobileDataCaracteristiqueBatiment.getCaracteristiqueBatimentPayload();
+        CaracteristiqueBatimentPaylod caracteristiqueBatimentPaylod = mobileDataCaracteristiqueBatiment.getCaracteristiqueBatimentPaylod();
         try {
-            if (caracteristiqueBatimentPayload.getTerminalId() == null) {
+            if (caracteristiqueBatimentPaylod.getTerminalId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEBATIMENT, "Problème de terminal", "terminal non fourni : ", mobileDataCaracteristiqueBatiment.getId());
                 return;
             } else {
-                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueBatimentPayload.getTerminalId());
+                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueBatimentPaylod.getTerminalId());
                 if (optionalTpe.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEBATIMENT, "Problème de terminal", "terminal inexistant : ", mobileDataCaracteristiqueBatiment.getId());
                     return;
                 }
             }
 
-            if (caracteristiqueBatimentPayload.getEnqueteBatimentId() == null) {
+            if (caracteristiqueBatimentPaylod.getEnqueteBatimentId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEBATIMENT, "Problème de enquete batiment", "enquete non fourni : ", mobileDataCaracteristiqueBatiment.getId());
                 return;
             } else {
-                Optional<EnqueteBatiment> optionalEnqueteBatiment = enqueteBatimentRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPayload.getEnqueteBatimentId(), caracteristiqueBatimentPayload.getTerminalId());
+                Optional<EnqueteBatiment> optionalEnqueteBatiment = enqueteBatimentRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPaylod.getEnqueteBatimentId(), caracteristiqueBatimentPaylod.getTerminalId());
                 if (optionalEnqueteBatiment.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEBATIMENT, "Problème de enquete batiment", "L'enquete précisée n'existe pas : ", mobileDataCaracteristiqueBatiment.getId());
                     return;
@@ -55,7 +66,7 @@ public class CaracteristiqueBatimentAsyncWorker {
             }
             CaracteristiqueBatiment caracteristiqueBatiment = new CaracteristiqueBatiment();
             caracteristiqueBatiment.setMobileDataId(mobileDataCaracteristiqueBatiment.getId());
-            caracteristiqueBatiment = getCaracteristiqueBatimentFromCaracteristiqueBatimentPayLoad(caracteristiqueBatiment, caracteristiqueBatimentPayload);
+            caracteristiqueBatiment = getCaracteristiqueBatimentFromCaracteristiqueBatimentPayLoad(caracteristiqueBatiment, caracteristiqueBatimentPaylod);
             caracteristiqueBatimentRepository.save(caracteristiqueBatiment);
             mobileDataCaracteristiqueBatiment.setTraiter(true);
             mobileDataCaracteristiqueBatimentRepository.save(mobileDataCaracteristiqueBatiment);
@@ -64,35 +75,35 @@ public class CaracteristiqueBatimentAsyncWorker {
         }
     }
 
-    private CaracteristiqueBatiment getCaracteristiqueBatimentFromCaracteristiqueBatimentPayLoad(CaracteristiqueBatiment caracteristiqueBatiment, CaracteristiqueBatimentPayload caracteristiqueBatimentPayload) {
+    private CaracteristiqueBatiment getCaracteristiqueBatimentFromCaracteristiqueBatimentPayLoad(CaracteristiqueBatiment caracteristiqueBatiment, CaracteristiqueBatimentPaylod caracteristiqueBatimentPaylod) {
 
 
-        if (caracteristiqueBatimentPayload.getEnqueteBatimentId() != null) {
-            Optional<EnqueteBatiment> optionalEnqueteBatiment = enqueteBatimentRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPayload.getEnqueteBatimentId(), caracteristiqueBatimentPayload.getTerminalId());
+        if (caracteristiqueBatimentPaylod.getEnqueteBatimentId() != null) {
+            Optional<EnqueteBatiment> optionalEnqueteBatiment = enqueteBatimentRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPaylod.getEnqueteBatimentId(), caracteristiqueBatimentPaylod.getTerminalId());
             caracteristiqueBatiment.setEnqueteBatiment(optionalEnqueteBatiment.orElse(null));
         }
 
-        if (caracteristiqueBatimentPayload.getCaracteristiqueId() != null) {
-            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueBatimentPayload.getCaracteristiqueId());
+        if (caracteristiqueBatimentPaylod.getCaracteristiqueId() != null) {
+            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueBatimentPaylod.getCaracteristiqueId());
             caracteristiqueBatiment.setCaracteristique(optionalCaracteristique.orElse(null));
         }
 
-        if (caracteristiqueBatimentPayload.getTerminalId() != null) {
-            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueBatimentPayload.getTerminalId());
+        if (caracteristiqueBatimentPaylod.getTerminalId() != null) {
+            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueBatimentPaylod.getTerminalId());
             caracteristiqueBatiment.setTerminal(optionalTpe.orElse(null));
         }
 
 
-        if (caracteristiqueBatimentPayload.getTerminalId() != null && caracteristiqueBatimentPayload.getEnqueteId() != null) {
-            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPayload.getEnqueteId(), caracteristiqueBatimentPayload.getTerminalId());
+        if (caracteristiqueBatimentPaylod.getTerminalId() != null && caracteristiqueBatimentPaylod.getEnqueteId() != null) {
+            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueBatimentPaylod.getEnqueteId(), caracteristiqueBatimentPaylod.getTerminalId());
             if (optionalEnquete.isPresent()) {
                 caracteristiqueBatiment.setEnqueteId(optionalEnquete.get().getId());
             }
         }
-        caracteristiqueBatiment.setEnqueteBatimentExternalKey(caracteristiqueBatimentPayload.getEnqueteBatimentId());
-        caracteristiqueBatiment.setEnqueteExternalKey(caracteristiqueBatimentPayload.getEnqueteId());
-        caracteristiqueBatiment.setValeur(caracteristiqueBatimentPayload.getValeur());
-        caracteristiqueBatiment.setExternalKey(caracteristiqueBatimentPayload.getExternalKey());
+        caracteristiqueBatiment.setEnqueteBatimentExternalKey(caracteristiqueBatimentPaylod.getEnqueteBatimentId());
+        caracteristiqueBatiment.setEnqueteExternalKey(caracteristiqueBatimentPaylod.getEnqueteId());
+        caracteristiqueBatiment.setValeur(caracteristiqueBatimentPaylod.getValeur());
+        caracteristiqueBatiment.setExternalKey(caracteristiqueBatimentPaylod.getExternalKey());
         return caracteristiqueBatiment;
 
     }

src/main/java/io/gmss/fiscad/service/worker/CaracteristiqueParcelleAsyncWorker.java

@@ -1,18 +1,29 @@
 package io.gmss.fiscad.service.worker;
 
 import io.gmss.fiscad.entities.infocad.metier.Enquete;
+import io.gmss.fiscad.entities.infocad.metier.Parcelle;
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
+import io.gmss.fiscad.entities.infocad.parametre.Bloc;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueParcelle;
+import io.gmss.fiscad.entities.metadata.MobileDataEnquete;
 import io.gmss.fiscad.entities.rfu.metier.CaracteristiqueParcelle;
 import io.gmss.fiscad.entities.rfu.parametre.Caracteristique;
+import io.gmss.fiscad.entities.rfu.parametre.ZoneRfu;
+import io.gmss.fiscad.entities.user.User;
 import io.gmss.fiscad.enums.TypeObjet;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueParcellePayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueParcellePaylod;
+import io.gmss.fiscad.paylaods.request.EnquetePayLoad;
 import io.gmss.fiscad.repositories.infocad.metier.*;
+import io.gmss.fiscad.repositories.infocad.parametre.BlocRepository;
 import io.gmss.fiscad.repositories.metadata.MobileDataCaracteristiqueParcelleRepository;
+import io.gmss.fiscad.repositories.metadata.MobileDataEnqueteRepository;
 import io.gmss.fiscad.repositories.rfu.metier.*;
 import io.gmss.fiscad.repositories.rfu.parametre.CaracteristiqueRepository;
+import io.gmss.fiscad.repositories.rfu.parametre.ZoneRfuRepository;
+import io.gmss.fiscad.repositories.user.UserRepository;
 import io.gmss.fiscad.service.LogService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.Optional;
@@ -28,25 +39,25 @@ public class CaracteristiqueParcelleAsyncWorker {
     private final LogService logService;
     //@Async("caracteristiqueParcelleExecutor")
     public void traitementAsyncCaracteristiqueParcelle(MobileDataCaracteristiqueParcelle mobileDataCaracteristiqueParcelle) {
-        CaracteristiqueParcellePayload caracteristiqueParcellePayload = mobileDataCaracteristiqueParcelle.getCaracteristiqueParcellePayload();
+        CaracteristiqueParcellePaylod caracteristiqueParcellePaylod = mobileDataCaracteristiqueParcelle.getCaracteristiqueParcellePaylod();
 
         try {
-            if (caracteristiqueParcellePayload.getTerminalId() == null) {
+            if (caracteristiqueParcellePaylod.getTerminalId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEPARCELLE, "Problème de terminal", "terminal non fourni : ", mobileDataCaracteristiqueParcelle.getId());
                 return;
             } else {
-                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueParcellePayload.getTerminalId());
+                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueParcellePaylod.getTerminalId());
                 if (optionalTpe.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEPARCELLE, "Problème de terminal", "terminal inexistant : ", mobileDataCaracteristiqueParcelle.getId());
                     return;
                 }
             }
 
-            if (caracteristiqueParcellePayload.getEnqueteId() == null) {
+            if (caracteristiqueParcellePaylod.getEnqueteId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEPARCELLE, "Problème de enquete", "enquete non fourni : ", mobileDataCaracteristiqueParcelle.getId());
                 return;
             } else {
-                Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueParcellePayload.getEnqueteId(), caracteristiqueParcellePayload.getTerminalId());
+                Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueParcellePaylod.getEnqueteId(), caracteristiqueParcellePaylod.getTerminalId());
                 if (optionalEnquete.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEPARCELLE, "Problème de enquete", "L'enquete précisée n'existe pas : ", mobileDataCaracteristiqueParcelle.getId());
                     return;
@@ -54,7 +65,7 @@ public class CaracteristiqueParcelleAsyncWorker {
             }
             CaracteristiqueParcelle caracteristiqueParcelle = new CaracteristiqueParcelle();
             caracteristiqueParcelle.setMobileDataId(mobileDataCaracteristiqueParcelle.getId());
-            caracteristiqueParcelle = getCaracteristiqueParcelleFromCaracteristiqueParcellePayLoad(caracteristiqueParcelle, caracteristiqueParcellePayload);
+            caracteristiqueParcelle = getCaracteristiqueParcelleFromCaracteristiqueParcellePayLoad(caracteristiqueParcelle, caracteristiqueParcellePaylod);
             caracteristiqueParcelleRepository.save(caracteristiqueParcelle);
             mobileDataCaracteristiqueParcelle.setTraiter(true);
             mobileDataCaracteristiqueParcelleRepository.save(mobileDataCaracteristiqueParcelle);
@@ -63,27 +74,27 @@ public class CaracteristiqueParcelleAsyncWorker {
         }
     }
 
-    private CaracteristiqueParcelle getCaracteristiqueParcelleFromCaracteristiqueParcellePayLoad(CaracteristiqueParcelle caracteristiqueParcelle, CaracteristiqueParcellePayload caracteristiqueParcellePayload) {
+    private CaracteristiqueParcelle getCaracteristiqueParcelleFromCaracteristiqueParcellePayLoad(CaracteristiqueParcelle caracteristiqueParcelle, CaracteristiqueParcellePaylod caracteristiqueParcellePaylod) {
 
-        if (caracteristiqueParcellePayload.getEnqueteId() != null) {
-            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueParcellePayload.getEnqueteId(), caracteristiqueParcellePayload.getTerminalId());
+        if (caracteristiqueParcellePaylod.getEnqueteId() != null) {
+            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueParcellePaylod.getEnqueteId(), caracteristiqueParcellePaylod.getTerminalId());
 
             caracteristiqueParcelle.setEnquete(optionalEnquete.orElse(null));
         }
 
-        if (caracteristiqueParcellePayload.getCaracteristiqueId() != null) {
-            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueParcellePayload.getCaracteristiqueId());
+        if (caracteristiqueParcellePaylod.getCaracteristiqueId() != null) {
+            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueParcellePaylod.getCaracteristiqueId());
             caracteristiqueParcelle.setCaracteristique(optionalCaracteristique.orElse(null));
         }
 
-        if (caracteristiqueParcellePayload.getTerminalId() != null) {
-            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueParcellePayload.getTerminalId());
+        if (caracteristiqueParcellePaylod.getTerminalId() != null) {
+            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueParcellePaylod.getTerminalId());
             caracteristiqueParcelle.setTerminal(optionalTpe.orElse(null));
         }
 
-        caracteristiqueParcelle.setEnqueteExternalKey(caracteristiqueParcellePayload.getEnqueteId());
-        caracteristiqueParcelle.setValeur(caracteristiqueParcellePayload.getValeur());
-        caracteristiqueParcelle.setExternalKey(caracteristiqueParcellePayload.getExternalKey());
+        caracteristiqueParcelle.setEnqueteExternalKey(caracteristiqueParcellePaylod.getEnqueteId());
+        caracteristiqueParcelle.setValeur(caracteristiqueParcellePaylod.getValeur());
+        caracteristiqueParcelle.setExternalKey(caracteristiqueParcellePaylod.getExternalKey());
         return caracteristiqueParcelle;
 
     }

src/main/java/io/gmss/fiscad/service/worker/CaracteristiqueUniteLogementAsyncWorker.java

@@ -2,21 +2,28 @@ package io.gmss.fiscad.service.worker;
 
 import io.gmss.fiscad.entities.infocad.metier.Enquete;
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
+import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueBatiment;
 import io.gmss.fiscad.entities.metadata.MobileDataCaracteristiqueUniteLogement;
+import io.gmss.fiscad.entities.rfu.metier.CaracteristiqueBatiment;
 import io.gmss.fiscad.entities.rfu.metier.CaracteristiqueUniteLogement;
+import io.gmss.fiscad.entities.rfu.metier.EnqueteBatiment;
 import io.gmss.fiscad.entities.rfu.metier.EnqueteUniteLogement;
 import io.gmss.fiscad.entities.rfu.parametre.Caracteristique;
 import io.gmss.fiscad.enums.TypeObjet;
-import io.gmss.fiscad.paylaods.request.CaracteristiqueUniteLogementPayload;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueBatimentPaylod;
+import io.gmss.fiscad.paylaods.request.CaracteristiqueUniteLogementPaylod;
 import io.gmss.fiscad.repositories.infocad.metier.EnqueteRepository;
 import io.gmss.fiscad.repositories.infocad.metier.TpeRepository;
 import io.gmss.fiscad.repositories.metadata.MobileDataCaracteristiqueBatimentRepository;
 import io.gmss.fiscad.repositories.metadata.MobileDataCaracteristiqueUniteLogementRepository;
+import io.gmss.fiscad.repositories.rfu.metier.CaracteristiqueBatimentRepository;
 import io.gmss.fiscad.repositories.rfu.metier.CaracteristiqueUniteLogementRepository;
+import io.gmss.fiscad.repositories.rfu.metier.EnqueteBatimentRepository;
 import io.gmss.fiscad.repositories.rfu.metier.EnqueteUniteLogementRepository;
 import io.gmss.fiscad.repositories.rfu.parametre.CaracteristiqueRepository;
 import io.gmss.fiscad.service.LogService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.Optional;
@@ -34,24 +41,24 @@ public class CaracteristiqueUniteLogementAsyncWorker {
     private final LogService logService;
     //@Async("caracteristiqueUniteLogementExecutor")
     public void traitementAsyncCaracteristiqueUniteLogement(MobileDataCaracteristiqueUniteLogement mobileDataCaracteristiqueUniteLogement) {
-        CaracteristiqueUniteLogementPayload caracteristiqueUniteLogementPayload = mobileDataCaracteristiqueUniteLogement.getCaracteristiqueUniteLogementPayload();
+        CaracteristiqueUniteLogementPaylod caracteristiqueUniteLogementPaylod = mobileDataCaracteristiqueUniteLogement.getCaracteristiqueUniteLogementPaylod();
         try {
-            if (caracteristiqueUniteLogementPayload.getTerminalId() == null) {
+            if (caracteristiqueUniteLogementPaylod.getTerminalId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEUNITELOGEMENT, "Problème de terminal", "terminal non fourni : ", mobileDataCaracteristiqueUniteLogement.getId());
                 return;
             } else {
-                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueUniteLogementPayload.getTerminalId());
+                Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueUniteLogementPaylod.getTerminalId());
                 if (optionalTpe.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEUNITELOGEMENT, "Problème de terminal", "terminal inexistant : ", mobileDataCaracteristiqueUniteLogement.getId());
                     return;
                 }
             }
 
-            if (caracteristiqueUniteLogementPayload.getEnqueteUniteLogementId() == null) {
+            if (caracteristiqueUniteLogementPaylod.getEnqueteUniteLogementId() == null) {
                 logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEUNITELOGEMENT, "Problème de enquete unite logement", "enquete non fourni : ", mobileDataCaracteristiqueUniteLogement.getId());
                 return;
             } else {
-                Optional<EnqueteUniteLogement> optionalEnqueteUniteLogement = enqueteUniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPayload.getEnqueteUniteLogementId(), caracteristiqueUniteLogementPayload.getTerminalId());
+                Optional<EnqueteUniteLogement> optionalEnqueteUniteLogement = enqueteUniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPaylod.getEnqueteUniteLogementId(), caracteristiqueUniteLogementPaylod.getTerminalId());
                 if (optionalEnqueteUniteLogement.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.CARACTERISTIQUEUNITELOGEMENT, "Problème de enquete unite logement", "L'enquete précisée n'existe pas : ", mobileDataCaracteristiqueUniteLogement.getId());
                     return;
@@ -59,7 +66,7 @@ public class CaracteristiqueUniteLogementAsyncWorker {
             }
             CaracteristiqueUniteLogement caracteristiqueUniteLogement = new CaracteristiqueUniteLogement();
             caracteristiqueUniteLogement.setMobileDataId(mobileDataCaracteristiqueUniteLogement.getId());
-            caracteristiqueUniteLogement = getCaracteristiqueUniteLogementFromCaracteristiqueUniteLogementPayLoad(caracteristiqueUniteLogement, caracteristiqueUniteLogementPayload);
+            caracteristiqueUniteLogement = getCaracteristiqueUniteLogementFromCaracteristiqueUniteLogementPayLoad(caracteristiqueUniteLogement, caracteristiqueUniteLogementPaylod);
             caracteristiqueUniteLogementRepository.save(caracteristiqueUniteLogement);
             mobileDataCaracteristiqueUniteLogement.setTraiter(true);
             mobileDataCaracteristiqueUniteLogementRepository.save(mobileDataCaracteristiqueUniteLogement);
@@ -68,32 +75,32 @@ public class CaracteristiqueUniteLogementAsyncWorker {
         }
     }
 
-    private CaracteristiqueUniteLogement getCaracteristiqueUniteLogementFromCaracteristiqueUniteLogementPayLoad(CaracteristiqueUniteLogement caracteristiqueUniteLogement, CaracteristiqueUniteLogementPayload caracteristiqueUniteLogementPayload) {
+    private CaracteristiqueUniteLogement getCaracteristiqueUniteLogementFromCaracteristiqueUniteLogementPayLoad(CaracteristiqueUniteLogement caracteristiqueUniteLogement, CaracteristiqueUniteLogementPaylod caracteristiqueUniteLogementPaylod) {
 
-        if (caracteristiqueUniteLogementPayload.getEnqueteUniteLogementId() != null) {
-            Optional<EnqueteUniteLogement> optionalEnqueteUniteLogement = enqueteUniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPayload.getEnqueteUniteLogementId(), caracteristiqueUniteLogementPayload.getTerminalId());
+        if (caracteristiqueUniteLogementPaylod.getEnqueteUniteLogementId() != null) {
+            Optional<EnqueteUniteLogement> optionalEnqueteUniteLogement = enqueteUniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPaylod.getEnqueteUniteLogementId(), caracteristiqueUniteLogementPaylod.getTerminalId());
             caracteristiqueUniteLogement.setEnqueteUniteLogement(optionalEnqueteUniteLogement.orElse(null));
         }
 
-        if (caracteristiqueUniteLogementPayload.getCaracteristiqueId() != null) {
-            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueUniteLogementPayload.getCaracteristiqueId());
+        if (caracteristiqueUniteLogementPaylod.getCaracteristiqueId() != null) {
+            Optional<Caracteristique> optionalCaracteristique = caracteristiqueRepository.findById(caracteristiqueUniteLogementPaylod.getCaracteristiqueId());
             caracteristiqueUniteLogement.setCaracteristique(optionalCaracteristique.orElse(null));
         }
 
-        if (caracteristiqueUniteLogementPayload.getTerminalId() != null) {
-            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueUniteLogementPayload.getTerminalId());
+        if (caracteristiqueUniteLogementPaylod.getTerminalId() != null) {
+            Optional<Tpe> optionalTpe = tpeRepository.findById(caracteristiqueUniteLogementPaylod.getTerminalId());
             caracteristiqueUniteLogement.setTerminal(optionalTpe.orElse(null));
         }
-        if (caracteristiqueUniteLogementPayload.getTerminalId() != null && caracteristiqueUniteLogementPayload.getEnqueteId() != null) {
-            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPayload.getEnqueteId(), caracteristiqueUniteLogementPayload.getTerminalId());
+        if (caracteristiqueUniteLogementPaylod.getTerminalId() != null && caracteristiqueUniteLogementPaylod.getEnqueteId() != null) {
+            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(caracteristiqueUniteLogementPaylod.getEnqueteId(), caracteristiqueUniteLogementPaylod.getTerminalId());
             if (optionalEnquete.isPresent()) {
                 caracteristiqueUniteLogement.setEnqueteId(optionalEnquete.get().getId());
             }
         }
-        caracteristiqueUniteLogement.setEnqueteExternalKey(caracteristiqueUniteLogementPayload.getEnqueteId());
-        caracteristiqueUniteLogement.setEnqueteUniteLogementExternalKey(caracteristiqueUniteLogementPayload.getEnqueteUniteLogementId());
-        caracteristiqueUniteLogement.setValeur(caracteristiqueUniteLogementPayload.getValeur());
-        caracteristiqueUniteLogement.setExternalKey(caracteristiqueUniteLogementPayload.getExternalKey());
+        caracteristiqueUniteLogement.setEnqueteExternalKey(caracteristiqueUniteLogementPaylod.getEnqueteId());
+        caracteristiqueUniteLogement.setEnqueteUniteLogementExternalKey(caracteristiqueUniteLogementPaylod.getEnqueteUniteLogementId());
+        caracteristiqueUniteLogement.setValeur(caracteristiqueUniteLogementPaylod.getValeur());
+        caracteristiqueUniteLogement.setExternalKey(caracteristiqueUniteLogementPaylod.getExternalKey());
         return caracteristiqueUniteLogement;
     }
 }

src/main/java/io/gmss/fiscad/service/worker/EnqueteAsyncWorker.java

@@ -200,7 +200,7 @@ public class EnqueteAsyncWorker {
         enquete.setNbrePiscine(enquetePayLoad.getNbrePiscine());
         enquete.setDateDebutExcemption(enquetePayLoad.getDateDebutExcemption());
         enquete.setDateFinExcemption(enquetePayLoad.getDateFinExcemption());
-        //enquete.setPersonneId(enquetePayLoad.getPersonneId());
+        enquete.setPersonneId(enquetePayLoad.getPersonneId());
         enquete.setAutreNumeroTitreFoncier(enquete.getAutreNumeroTitreFoncier());
         return enquete;
     }

src/main/java/io/gmss/fiscad/service/worker/UniteLogementAsyncWorker.java

@@ -1,12 +1,18 @@
 package io.gmss.fiscad.service.worker;
 
 import io.gmss.fiscad.entities.infocad.metier.Enquete;
+import io.gmss.fiscad.entities.infocad.metier.Parcelle;
 import io.gmss.fiscad.entities.infocad.metier.Tpe;
+import io.gmss.fiscad.entities.infocad.parametre.Bloc;
+import io.gmss.fiscad.entities.metadata.MobileDataEnquete;
 import io.gmss.fiscad.entities.metadata.MobileDataUniteLogement;
 import io.gmss.fiscad.entities.rfu.metier.Batiment;
 import io.gmss.fiscad.entities.rfu.metier.UniteLogement;
+import io.gmss.fiscad.entities.rfu.parametre.ZoneRfu;
+import io.gmss.fiscad.entities.user.User;
 import io.gmss.fiscad.enums.TypeObjet;
-import io.gmss.fiscad.paylaods.request.UniteLogementPayload;
+import io.gmss.fiscad.paylaods.request.EnquetePayLoad;
+import io.gmss.fiscad.paylaods.request.UniteLogementPaylaod;
 import io.gmss.fiscad.repositories.infocad.metier.*;
 import io.gmss.fiscad.repositories.infocad.parametre.BlocRepository;
 import io.gmss.fiscad.repositories.metadata.MobileDataEnqueteRepository;
@@ -16,6 +22,7 @@ import io.gmss.fiscad.repositories.rfu.parametre.ZoneRfuRepository;
 import io.gmss.fiscad.repositories.user.UserRepository;
 import io.gmss.fiscad.service.LogService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.util.Optional;
@@ -43,25 +50,25 @@ public class UniteLogementAsyncWorker {
     private final LogService logService;
     //@Async("uniteLogementExecutor")
     public void traitementAsyncUniteLogement(MobileDataUniteLogement mobileDataUniteLogement) {
-        UniteLogementPayload uniteLogementPayload = mobileDataUniteLogement.getUniteLogementPayload();
+        UniteLogementPaylaod uniteLogementPaylaod = mobileDataUniteLogement.getUniteLogementPaylaod();
 
         try {
-            if (uniteLogementPayload.getTerminalId() == null) {
+            if (uniteLogementPaylaod.getTerminalId() == null) {
                 logService.logTraiementAsync(TypeObjet.UNITELOGEMENT, "Problème de terminal", "terminal non fourni : ", mobileDataUniteLogement.getId());
                 return;
             } else {
-                Optional<Tpe> optionalTpe = tpeRepository.findById(uniteLogementPayload.getTerminalId());
+                Optional<Tpe> optionalTpe = tpeRepository.findById(uniteLogementPaylaod.getTerminalId());
                 if (optionalTpe.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.UNITELOGEMENT, "Problème de terminal", "terminal inexistant : ", mobileDataUniteLogement.getId());
                     return;
                 }
             }
 
-            if (uniteLogementPayload.getBatimentId() == null) {
+            if (uniteLogementPaylaod.getBatimentId() == null) {
                 logService.logTraiementAsync(TypeObjet.UNITELOGEMENT, "Problème de batiment", "batiment non fourni : ", mobileDataUniteLogement.getId());
                 return;
             } else {
-                Optional<Batiment> optionalBatiment = batimentRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPayload.getBatimentId(), uniteLogementPayload.getTerminalId());
+                Optional<Batiment> optionalBatiment = batimentRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPaylaod.getBatimentId(), uniteLogementPaylaod.getTerminalId());
                 if (optionalBatiment.isEmpty()) {
                     logService.logTraiementAsync(TypeObjet.UNITELOGEMENT, "Problème de batiment", "Le batiment précisée n'existe pas : ", mobileDataUniteLogement.getId());
                     return;
@@ -74,13 +81,13 @@ public class UniteLogementAsyncWorker {
             if (optionalUniteLogement.isPresent()) {
                 uniteLogement = optionalUniteLogement.get();
             }else {
-                optionalUniteLogement = uniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPayload.getExternalKey(), uniteLogementPayload.getTerminalId());
+                optionalUniteLogement = uniteLogementRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPaylaod.getExternalKey(),uniteLogementPaylaod.getTerminalId());
                 if (optionalUniteLogement.isPresent()) {
                     uniteLogement = optionalUniteLogement.get();
                 }
             }
             uniteLogement.setMobileDataId(mobileDataUniteLogement.getId());
-            uniteLogement = getUniteLogementFromUniteLogementPayLoad(uniteLogement, uniteLogementPayload);
+            uniteLogement = getUniteLogementFromUniteLogementPayLoad(uniteLogement, uniteLogementPaylaod);
             uniteLogementRepository.save(uniteLogement);
             mobileDataUniteLogement.setTraiter(true);
             mobileDataUniteLogementRepository.save(mobileDataUniteLogement);
@@ -90,29 +97,29 @@ public class UniteLogementAsyncWorker {
     }
 
 
-    private UniteLogement getUniteLogementFromUniteLogementPayLoad(UniteLogement uniteLogement, UniteLogementPayload uniteLogementPayload) {
+    private UniteLogement getUniteLogementFromUniteLogementPayLoad(UniteLogement uniteLogement, UniteLogementPaylaod uniteLogementPaylaod) {
 
-        if (uniteLogementPayload.getBatimentId() != null) {
-            Optional<Batiment> optionalBatiment = batimentRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPayload.getBatimentId(), uniteLogementPayload.getTerminalId());
+        if (uniteLogementPaylaod.getBatimentId() != null) {
+            Optional<Batiment> optionalBatiment = batimentRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPaylaod.getBatimentId(), uniteLogementPaylaod.getTerminalId());
             uniteLogement.setBatiment(optionalBatiment.orElse(null));
         }
 
-        if (uniteLogementPayload.getTerminalId() != null) {
-            Optional<Tpe> optionalTpe = tpeRepository.findById(uniteLogementPayload.getTerminalId());
+        if (uniteLogementPaylaod.getTerminalId() != null) {
+            Optional<Tpe> optionalTpe = tpeRepository.findById(uniteLogementPaylaod.getTerminalId());
             uniteLogement.setTerminal(optionalTpe.orElse(null));
         }
-        if (uniteLogementPayload.getTerminalId() != null && uniteLogementPayload.getEnqueteId() != null) {
-            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPayload.getEnqueteId(), uniteLogementPayload.getTerminalId());
+        if (uniteLogementPaylaod.getTerminalId() != null && uniteLogementPaylaod.getEnqueteId() != null) {
+            Optional<Enquete> optionalEnquete = enqueteRepository.findFirstByExternalKeyAndTerminal_Id(uniteLogementPaylaod.getEnqueteId(), uniteLogementPaylaod.getTerminalId());
             if (optionalEnquete.isPresent()) {
                 uniteLogement.setEnqueteId(optionalEnquete.get().getId());
             }
         }
-        uniteLogement.setEnqueteExternalKey(uniteLogementPayload.getEnqueteId());
-        uniteLogement.setNul(uniteLogementPayload.getNul());
-        uniteLogement.setNumeroEtage(uniteLogementPayload.getNumeroEtage());
-        uniteLogement.setCode(uniteLogementPayload.getCode());
-        uniteLogement.setExternalKey(uniteLogementPayload.getExternalKey());
-        uniteLogement.setBatimentExternalKey(uniteLogementPayload.getBatimentId());
+        uniteLogement.setEnqueteExternalKey(uniteLogementPaylaod.getEnqueteId());
+        uniteLogement.setNul(uniteLogementPaylaod.getNul());
+        uniteLogement.setNumeroEtage(uniteLogementPaylaod.getNumeroEtage());
+        uniteLogement.setCode(uniteLogementPaylaod.getCode());
+        uniteLogement.setExternalKey(uniteLogementPaylaod.getExternalKey());
+        uniteLogement.setBatimentExternalKey(uniteLogementPaylaod.getBatimentId());
         return uniteLogement;
     }
 }

src/main/resources/application.properties

@@ -1,6 +1,6 @@
-spring.profiles.active=${SPRING_PROFILES_ACTIVE}
+#spring.profiles.active=${SPRING_PROFILES_ACTIVE}
 #spring.profiles.active=abomey
-#spring.profiles.active=dgi
+spring.profiles.active=dgi
 spring.jpa.properties.hibernate.id.new_generator_mappings=false
 spring.jpa.properties.hibernate.enable_lazy_load_no_trans=true
 spring.jpa.open-in-view=false