DAVE 702 (#375)

Der-Alex-K · boal · web-flow · commit 46d3b1da2ef2 · 2025-07-29T14:03:21.000+02:00
* add method for in between check of dates * remove unused impoprt * add unit test * add unittest * add unittest * add logic to set dates in messfaehigkeit * adapt unit test * adapt unit test * add unit test * ein zwischenstand * add messfaehihkeiten to validation object for auswertung * add lgic to extract relevant messfaehigkeiten * add lgic to extract relevant messfaehigkeiten * refactor some code * not running * new code base * add extraction of tagesaggregate * add extraction of tagesaggregate * add extraction of tagesaggregate * add method to null non choosen tagesaggragate attributes * adapt unit test * remove unecassry mapper * add unit test * add unit tests * add unit test * add unit test * add unit test * add unit test * add uniot test * add unit test * add unit test * add unit test * add unit test * add unit tests * unit test * add javadoc * add partial unit test * refactor code * refactor code * reformat code * fix bug divide by 0 * add javadocs * add javadoc * add javadoc * add javadoc * fix unittest * first draft of valid days * add days to excel sheet * add unit tests * remove increment * refactor code * fix bug for radverkehr * adapt unit test * add unit test * add unit tests * add unit test * adapt unit test * Refactor Verkehrsart as Enum (#361) * detektierte Verkehrsart als enum uebermitteln * Feld verkehrsart umbenannt * DVE-699 (#372) * always update letztePlausibleMessung save highest Fahrzeugklasse instead of last one * Anmerkung umgesetzt * hotfix * fix second bug and add comment * hotfix bug * add javadoc * add searchfilter for Verkehrsart * spotless * hotfix to extract relevant kalendertage of zeitraum --------- Co-authored-by: alexander.boxhorn <alexander.boxhorn@muenchen.de>
diff --git a/src/main/java/de/muenchen/dave/controller/SucheController.java b/src/main/java/de/muenchen/dave/controller/SucheController.java
@@ -5,6 +5,7 @@
 import de.muenchen.dave.domain.dtos.suche.SucheComplexSuggestsDTO;
 import de.muenchen.dave.exceptions.ResourceNotFoundException;
 import de.muenchen.dave.services.SucheService;
+import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotNull;
 import java.util.Set;
 import lombok.extern.slf4j.Slf4j;
@@ -39,7 +40,7 @@ public SucheController(final SucheService sucheService) {
     @PostMapping(value = "/suggest-datenportal", produces = MediaType.APPLICATION_JSON_VALUE)
     @Transactional(readOnly = true)
     public ResponseEntity<SucheComplexSuggestsDTO> suggestDatenportal(@RequestParam(value = REQUEST_PARAMETER_QUERY) @NotNull final String query,
-            @RequestBody @NotNull final SearchAndFilterOptionsDTO searchAndFilterOptions) {
+            @RequestBody @NotNull @Valid final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         try {
             final SucheComplexSuggestsDTO sucheComplexSuggestsDTO = this.sucheService.getComplexSuggestSichtbarDatenportal(query, searchAndFilterOptions);
             return new ResponseEntity<>(sucheComplexSuggestsDTO, HttpStatus.OK);
@@ -55,7 +56,7 @@ public ResponseEntity<SucheComplexSuggestsDTO> suggestDatenportal(@RequestParam(
     @PostMapping(value = "/suggest", produces = MediaType.APPLICATION_JSON_VALUE)
     @Transactional(readOnly = true)
     public ResponseEntity<SucheComplexSuggestsDTO> suggest(@RequestParam(value = REQUEST_PARAMETER_QUERY) @NotNull final String query,
-            @RequestBody @NotNull final SearchAndFilterOptionsDTO searchAndFilterOptions) {
+            @RequestBody @NotNull @Valid final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         try {
             final SucheComplexSuggestsDTO sucheComplexSuggestsDTO = this.sucheService.getComplexSuggest(query, searchAndFilterOptions, true);
             return new ResponseEntity<>(sucheComplexSuggestsDTO, HttpStatus.OK);
@@ -72,7 +73,7 @@ public ResponseEntity<SucheComplexSuggestsDTO> suggest(@RequestParam(value = REQ
     @Transactional(readOnly = true)
     public ResponseEntity<Set<ErhebungsstelleKarteDTO>> searchErhebungsstelleForMapDatenportal(
             @RequestParam(value = REQUEST_PARAMETER_QUERY) @NotNull final String query,
-            @RequestBody @NotNull final SearchAndFilterOptionsDTO searchAndFilterOptions) {
+            @RequestBody @NotNull @Valid final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         try {
             final Set<ErhebungsstelleKarteDTO> erhebungsstellenForMap = this.sucheService.sucheErhebungsstelleSichtbarDatenportal(query,
                     searchAndFilterOptions);
@@ -90,7 +91,7 @@ public ResponseEntity<Set<ErhebungsstelleKarteDTO>> searchErhebungsstelleForMapD
     @Transactional(readOnly = true)
     public ResponseEntity<Set<ErhebungsstelleKarteDTO>> searchErhebungsstelleForMap(
             @RequestParam(value = REQUEST_PARAMETER_QUERY) @NotNull final String query,
-            @RequestBody @NotNull final SearchAndFilterOptionsDTO searchAndFilterOptions) {
+            @RequestBody @NotNull @Valid final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         try {
             final Set<ErhebungsstelleKarteDTO> erhebungsstellenForMap = this.sucheService.sucheErhebungsstelle(query, searchAndFilterOptions, true);
             return new ResponseEntity<>(erhebungsstellenForMap, HttpStatus.OK);
diff --git a/src/main/java/de/muenchen/dave/domain/dtos/suche/SearchAndFilterOptionsDTO.java b/src/main/java/de/muenchen/dave/domain/dtos/suche/SearchAndFilterOptionsDTO.java
@@ -1,10 +1,15 @@
 package de.muenchen.dave.domain.dtos.suche;
 
+import de.muenchen.dave.domain.enums.Verkehrsart;
+import jakarta.validation.constraints.NotNull;
+import java.util.List;
 import lombok.Data;
 
 @Data
 public class SearchAndFilterOptionsDTO {
 
     private boolean searchInMessstellen;
     private boolean searchInZaehlstellen;
+    @NotNull
+    private List<Verkehrsart> messstelleVerkehrsart;
 }
diff --git a/src/main/java/de/muenchen/dave/services/SucheService.java b/src/main/java/de/muenchen/dave/services/SucheService.java
@@ -202,7 +202,7 @@ public SucheComplexSuggestsDTO getComplexSuggest(
 
         if (searchAndFilterOptions.isSearchInMessstellen()) {
             // Messstellen
-            dto.setMessstellenSuggests(getMessstellenSuggest(q));
+            dto.setMessstellenSuggests(getMessstellenSuggest(q, searchAndFilterOptions));
         }
 
         return dto;
@@ -249,7 +249,7 @@ public Set<ErhebungsstelleKarteDTO> sucheErhebungsstelle(
         log.debug("Zugriff auf den Service #sucheErhebungsstelle");
         final Set<ErhebungsstelleKarteDTO> searchResult = new HashSet<>();
         if (searchAndFilterOptions.isSearchInMessstellen()) {
-            searchResult.addAll(sucheMessstelle(query));
+            searchResult.addAll(sucheMessstelle(query, searchAndFilterOptions));
         }
         if (searchAndFilterOptions.isSearchInZaehlstellen()) {
             searchResult.addAll(sucheZaehlstelle(query, searchAndFilterOptions, isAdminportal));
@@ -300,9 +300,11 @@ private Set<ZaehlstelleKarteDTO> sucheZaehlstelle(final String query, final Sear
      * @param query Eine Suchquery
      * @return Ein Set von befüllten SucheMessstelleSuggestDTOs
      */
-    private List<SucheMessstelleSuggestDTO> getMessstellenSuggest(final String query) {
+    private List<SucheMessstelleSuggestDTO> getMessstellenSuggest(final String query, final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         final Page<Messstelle> messstellen = this.messstelleIndex.suggestSearch(query, PageRequest.of(0, 3));
         final List<SucheMessstelleSuggestDTO> sucheMessstelleSuggestDTOS = messstellen.stream()
+                .filter(messstelle -> CollectionUtils.emptyIfNull(searchAndFilterOptions.getMessstelleVerkehrsart())
+                        .contains(messstelle.getDetektierteVerkehrsart()))
                 .map(this.messstelleMapper::bean2SucheMessstelleSuggestDto)
                 .collect(Collectors.toList());
         log.debug("Found {} messstelle(n)", sucheMessstelleSuggestDTOS.size());
@@ -315,7 +317,7 @@ private List<SucheMessstelleSuggestDTO> getMessstellenSuggest(final String query
      * @param query Eine Suchquery
      * @return Ein Set von befüllten ErhebungsstelleKarteDTOs
      */
-    private Set<MessstelleKarteDTO> sucheMessstelle(final String query) {
+    private Set<MessstelleKarteDTO> sucheMessstelle(final String query, final SearchAndFilterOptionsDTO searchAndFilterOptions) {
         final List<Messstelle> messstellen;
         final PageRequest pageable = PageRequest.of(0, 10000);
         if (StringUtils.isEmpty(query)) {
@@ -325,7 +327,10 @@ private Set<MessstelleKarteDTO> sucheMessstelle(final String query) {
             log.debug("query '{}'", q);
             messstellen = this.messstelleIndex.suggestSearch(q, pageable).toList();
         }
-        return sucheMapper.messstelleToMessstelleKarteDTO(messstellen, stadtbezirkMapper);
+        final var filteredMessstellen = messstellen.stream().filter(
+                messstelle -> CollectionUtils.emptyIfNull(searchAndFilterOptions.getMessstelleVerkehrsart()).contains(messstelle.getDetektierteVerkehrsart()))
+                .toList();
+        return sucheMapper.messstelleToMessstelleKarteDTO(filteredMessstellen, stadtbezirkMapper);
     }
 
     private boolean isDateEqualOrAfter(final LocalDate datum, final LocalDate datumAfter) {
