gestion de profil, secteur, section et arbre decoupage

src/main/java/io/gmss/fiscad/implementations/decoupage/SecteurServiceImpl.java

@@ -3,40 +3,44 @@ package io.gmss.fiscad.implementations.decoupage;
 import io.gmss.fiscad.entities.decoupage.Secteur;
 import io.gmss.fiscad.entities.decoupage.SecteurDecoupage;
 import io.gmss.fiscad.entities.infocad.parametre.Structure;
+import io.gmss.fiscad.entities.user.AvoirFonction;
 import io.gmss.fiscad.entities.user.User;
 import io.gmss.fiscad.exceptions.BadRequestException;
 import io.gmss.fiscad.exceptions.NotFoundException;
 import io.gmss.fiscad.interfaces.decoupage.SecteurService;
 import io.gmss.fiscad.paylaods.request.synchronisation.SecteurDecoupagePayload;
 import io.gmss.fiscad.paylaods.request.synchronisation.SecteurPayload;
+import io.gmss.fiscad.paylaods.response.restoration.ParcelleStatsProjectionUnSecteur;
 import io.gmss.fiscad.repositories.decoupage.ArrondissementRepository;
 import io.gmss.fiscad.repositories.decoupage.QuartierRepository;
 import io.gmss.fiscad.repositories.decoupage.SecteurRepository;
+import io.gmss.fiscad.repositories.infocad.metier.ParcelleRepository;
 import io.gmss.fiscad.repositories.infocad.parametre.StructureRepository;
+import io.gmss.fiscad.repositories.user.AvoirFonctionRepository;
 import io.gmss.fiscad.repositories.user.UserRepository;
+import lombok.AllArgsConstructor;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
+import java.util.concurrent.atomic.AtomicReference;
 
+@AllArgsConstructor
 @Service
 public class SecteurServiceImpl implements SecteurService {
     private final SecteurRepository secteurRepository;
+    private final ParcelleRepository parcelleRepository;
     private final UserRepository userRepository;
     private final ArrondissementRepository arrondissementRepository;
     private final QuartierRepository quartierRepository;
     private final StructureRepository structureRepository;
+    private final AvoirFonctionRepository avoirFonctionRepository;
+
 
-    public SecteurServiceImpl(SecteurRepository secteurRepository, UserRepository userRepository, ArrondissementRepository arrondissementRepository, QuartierRepository quartierRepository, StructureRepository structureRepository) {
-        this.secteurRepository = secteurRepository;
-        this.userRepository = userRepository;
-        this.arrondissementRepository = arrondissementRepository;
-        this.quartierRepository = quartierRepository;
-        this.structureRepository = structureRepository;
-    }
 
 
     @Override
@@ -56,7 +60,7 @@ public class SecteurServiceImpl implements SecteurService {
     private Secteur getSecteurFromPayload(SecteurPayload secteurPayload) {
         Secteur secteur = new Secteur();
         Optional<User> optionalUser = userRepository.findById(secteurPayload.getChefSecteurId());
-        secteur.setChefSecteur(optionalUser.orElse(null));
+        //secteur.setChefSecteur(optionalUser.orElse(null));
         Optional<Structure> optionalStructure = structureRepository.findById(secteurPayload.getStructureId());
         secteur.setStructure(optionalStructure.orElse(null));
         List<SecteurDecoupage> secteurDecoupageList = new ArrayList<>();
@@ -134,4 +138,40 @@ public class SecteurServiceImpl implements SecteurService {
     public Optional<Secteur> getSecteurById(Long id) {
         return secteurRepository.findById(id);
     }
+
+    @Override
+    public List<ParcelleStatsProjectionUnSecteur> getStatParcelleDecoupageUnSecteur(Long secteurId) {
+        return parcelleRepository.findStatsBySecteurs(List.of(secteurId));
+    }
+
+    @Override
+    public List<ParcelleStatsProjectionUnSecteur> getStatParcelleDecoupageByUserId(Long userId) {
+        List<AvoirFonction> avoirFonctions= avoirFonctionRepository.findAvoirFonctionByUser_Id(userId);
+        AtomicReference<List<ParcelleStatsProjectionUnSecteur>> parcelleStatsProjectionUnSecteurs = new AtomicReference<>(new ArrayList<>());
+
+        avoirFonctions.stream()
+                .filter(af -> af.getDateFin() == null || af.getDateFin().isAfter(LocalDate.now()))
+                .forEach(avoirFonction -> {
+                    if(avoirFonction.getFonction().getSecteur()!=null){
+                        parcelleStatsProjectionUnSecteurs.set(parcelleRepository.findStatsBySecteurs(List.of(avoirFonction.getFonction().getSecteur().getId())));
+                    }else
+                        if (avoirFonction.getFonction().getSection()!=null){
+                            List<Secteur> secteurs= secteurRepository.findDistinctBySection_Id(avoirFonction.getFonction().getSection().getId());
+                            List<Long> secteurIds = secteurs.stream()
+                                    .map(Secteur::getId)
+                                    .toList();
+                            parcelleStatsProjectionUnSecteurs.set(parcelleRepository.findStatsBySecteurs(secteurIds));
+                        }else if(avoirFonction.getFonction().getStructure()!=null){
+                            List<Secteur> secteurs= secteurRepository.findDistinctBySection_Structure_Id(avoirFonction.getFonction().getStructure().getId());
+                            List<Long> secteurIds = secteurs.stream()
+                                    .map(Secteur::getId)
+                                    .toList();
+                            parcelleStatsProjectionUnSecteurs.set(parcelleRepository.findStatsBySecteurs(secteurIds));
+                        }
+
+                });
+
+
+    return parcelleStatsProjectionUnSecteurs.get();
+    }
 }