DVE-699 (#372)

* always update letztePlausibleMessung
save highest Fahrzeugklasse instead of last one

* Anmerkung umgesetzt

Author: Der-Alex-K

src/main/java/de/muenchen/dave/domain/mapper/detektor/MessstelleReceiverMapper.java

@@ -5,6 +5,7 @@
 import de.muenchen.dave.domain.elasticsearch.detektor.Messfaehigkeit;
 import de.muenchen.dave.domain.elasticsearch.detektor.Messquerschnitt;
 import de.muenchen.dave.domain.elasticsearch.detektor.Messstelle;
+import de.muenchen.dave.domain.enums.Fahrzeugklasse;
 import de.muenchen.dave.domain.enums.ZaehldatenIntervall;
 import de.muenchen.dave.domain.mapper.FahrzeugklassenMapper;
 import de.muenchen.dave.domain.mapper.StadtbezirkMapper;
@@ -17,6 +18,7 @@
 import java.util.List;
 import java.util.Set;
 import java.util.UUID;
+import java.util.stream.Collectors;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -45,7 +47,7 @@ public interface MessstelleReceiverMapper {
     List<Messfaehigkeit> createMessfaehigkeit(List<MessfaehigkeitDto> dto);
 
     @AfterMapping
-    default void createMessstelleAfterMapping(@MappingTarget Messstelle bean, MessstelleDto dto, @Context StadtbezirkMapper stadtbezirkMapper) {
+    default void dto2EntityAfterMapping(@MappingTarget Messstelle bean, MessstelleDto dto, @Context StadtbezirkMapper stadtbezirkMapper) {
         if (StringUtils.isEmpty(bean.getId())) {
             bean.setId(UUID.randomUUID().toString());
         }
@@ -54,6 +56,18 @@ default void createMessstelleAfterMapping(@MappingTarget Messstelle bean, Messst
             bean.setPunkt(new GeoPoint(dto.getLatitude(), dto.getLongitude()));
         }
 
+        final Set<Fahrzeugklasse> distinctFahrzeugklassenOfMessfaehigkeiten = bean.getMessfaehigkeiten().stream().map(Messfaehigkeit::getFahrzeugklasse)
+                .collect(Collectors.toSet());
+        if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ACHT_PLUS_EINS)) {
+            bean.setFahrzeugklasse(Fahrzeugklasse.ACHT_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ZWEI_PLUS_EINS)) {
+            bean.setFahrzeugklasse(Fahrzeugklasse.ZWEI_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.SUMME_KFZ)) {
+            bean.setFahrzeugklasse(Fahrzeugklasse.SUMME_KFZ);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.RAD)) {
+            bean.setFahrzeugklasse(Fahrzeugklasse.RAD);
+        }
+
         // Suchworte setzen
         final Set<String> generatedSuchwoerter = SuchwortUtil.generateSuchworteOfMessstelle(bean, stadtbezirkMapper);
 
@@ -91,6 +105,7 @@ default void createMessquerschnittAfterMapping(@MappingTarget Messquerschnitt be
     @Mapping(target = "messquerschnitte", ignore = true)
     @Mapping(target = "lageplanVorhanden", ignore = true)
     @Mapping(target = "datumLetztePlausibleMessung", ignore = true)
+    @Mapping(target = "fahrzeugklasse", ignore = true)
     Messstelle updateMessstelle(@MappingTarget Messstelle existing, MessstelleDto dto, @Context StadtbezirkMapper stadtbezirkMapper);
 
     @Mapping(target = "id", ignore = true)

src/main/java/de/muenchen/dave/services/messstelle/MessstelleReceiver.java

@@ -21,7 +21,6 @@
 import net.javacrumbs.shedlock.core.LockAssert;
 import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
 import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.context.annotation.Profile;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
@@ -124,10 +123,8 @@ protected void updateMessstelle(final Messstelle existingMessstelle, final Messs
         final var updatedMessquerschnitte = updateMessquerschnitteOfMessstelle(toSave.getMessquerschnitte(), dto.getMessquerschnitte());
         toSave.setMessquerschnitte(updatedMessquerschnitte);
         customSuggestIndexService.updateSuggestionsForMessstelle(toSave);
-        if (ObjectUtils.isEmpty(dto.getDatumLetztePlausibleMessung())) {
-            unauffaelligeTageService.findFirstByMstIdOrderByKalendertagDatumDesc(toSave.getMstId())
-                    .ifPresent(unauffaelligerTag -> toSave.setDatumLetztePlausibleMessung(unauffaelligerTag.getKalendertag().getDatum()));
-        }
+        unauffaelligeTageService.findFirstByMstIdOrderByKalendertagDatumDesc(toSave.getMstId())
+                .ifPresent(unauffaelligerTag -> toSave.setDatumLetztePlausibleMessung(unauffaelligerTag.getKalendertag().getDatum()));
         final Messstelle updated = messstelleIndexService.saveMessstelle(toSave);
         final var statusMessstelleNeu = updated.getStatus();
         if (statusMessstelleAlt != statusMessstelleNeu) {

src/test/java/de/muenchen/dave/domain/mapper/MessstelleReceiverMapperTests.java

@@ -6,8 +6,10 @@
 import com.google.common.base.Splitter;
 import de.muenchen.dave.domain.elasticsearch.MessquerschnittRandomFactory;
 import de.muenchen.dave.domain.elasticsearch.MessstelleRandomFactory;
+import de.muenchen.dave.domain.elasticsearch.detektor.Messfaehigkeit;
 import de.muenchen.dave.domain.elasticsearch.detektor.Messquerschnitt;
 import de.muenchen.dave.domain.elasticsearch.detektor.Messstelle;
+import de.muenchen.dave.domain.enums.Fahrzeugklasse;
 import de.muenchen.dave.domain.enums.MessstelleStatus;
 import de.muenchen.dave.domain.mapper.detektor.MessstelleReceiverMapper;
 import de.muenchen.dave.domain.mapper.detektor.MessstelleReceiverMapperImpl;
@@ -16,6 +18,7 @@
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.Set;
+import java.util.stream.Collectors;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.reflect.FieldUtils;
@@ -70,6 +73,18 @@ void testCreateMessstelle() {
         expected.setMessquerschnitte(mapper.createMessquerschnitte(dto.getMessquerschnitte()));
         expected.setMessfaehigkeiten(mapper.createMessfaehigkeit(dto.getMessfaehigkeiten()));
 
+        final Set<Fahrzeugklasse> distinctFahrzeugklassenOfMessfaehigkeiten = expected.getMessfaehigkeiten().stream().map(Messfaehigkeit::getFahrzeugklasse)
+                .collect(Collectors.toSet());
+        if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ACHT_PLUS_EINS)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.ACHT_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ZWEI_PLUS_EINS)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.ZWEI_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.SUMME_KFZ)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.SUMME_KFZ);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.RAD)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.RAD);
+        }
+
         final Messstelle messstelle = this.mapper.createMessstelle(dto, stadtbezirkMapper);
         Assertions.assertThat(messstelle)
                 .isNotNull()
@@ -124,7 +139,6 @@ void testUpdateMessstelle() {
         expected.setRealisierungsdatum(updatedData.getRealisierungsdatum());
         expected.setAbbaudatum(updatedData.getAbbaudatum());
         expected.setHersteller(updatedData.getHersteller());
-        expected.setFahrzeugklasse(new FahrzeugklassenMapperImpl().map(updatedData.getFahrzeugklasse()));
         expected.setDetektierteVerkehrsarten(updatedData.getDetektierteVerkehrsarten());
         expected.setSuchwoerter(new ArrayList<>());
         expected.getSuchwoerter().addAll(bean.getCustomSuchwoerter());
@@ -150,6 +164,18 @@ void testUpdateMessstelle() {
         expected.setMessquerschnitte(bean.getMessquerschnitte());
         expected.setDatumLetztePlausibleMessung(bean.getDatumLetztePlausibleMessung());
 
+        final Set<Fahrzeugklasse> distinctFahrzeugklassenOfMessfaehigkeiten = expected.getMessfaehigkeiten().stream().map(Messfaehigkeit::getFahrzeugklasse)
+                .collect(Collectors.toSet());
+        if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ACHT_PLUS_EINS)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.ACHT_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.ZWEI_PLUS_EINS)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.ZWEI_PLUS_EINS);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.SUMME_KFZ)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.SUMME_KFZ);
+        } else if (distinctFahrzeugklassenOfMessfaehigkeiten.contains(Fahrzeugklasse.RAD)) {
+            expected.setFahrzeugklasse(Fahrzeugklasse.RAD);
+        }
+
         final StadtbezirkMapper stadtbezirkMapper = Mockito.mock(StadtbezirkMapper.class);
         when(stadtbezirkMapper.bezeichnungOf(any())).thenReturn("Schwabing-West");
         final Messstelle actual = this.mapper.updateMessstelle(bean, updatedData, stadtbezirkMapper);