DAVE-767 (#407)

* add Cache for OptionsmenueSettings

* add new index to kalendertag

* add logging

* add cache for auffaelligetage

* update logging

* fix drop index

* add serializable

* add serializable

Author: Der-Alex-K

src/main/java/de/muenchen/dave/configuration/CachingConfiguration.java

@@ -32,6 +32,10 @@ public class CachingConfiguration {
 
     public static final String READ_ZAEHLSTELLE_DTO = "READ_ZAEHLSTELLE_DTO";
 
+    public static final String OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN = "OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN";
+
+    public static final String AUFFAELLIGETAGE_FOR_MESSSTELLE = "AUFFAELLIGETAGE_FOR_MESSSTELLE";
+
     @Value("${hazelcast.instance:data_hazl_instance}")
     public String hazelcastInstanceName;
     @Value("${hazelcast.group-name:data_hazl_group}")
@@ -108,6 +112,8 @@ private void mapConfig(final Config config) {
         config.addMapConfig(this.getMapConfig(LADE_PROCESSED_ZAEHLDATEN, this.maxIdleTimeSecondsZaehldaten));
         config.addMapConfig(this.getMapConfig(LADE_ZAEHLDATEN_ZEITREIHE_DTO, this.maxIdleTimeSecondsZaehldaten));
         config.addMapConfig(this.getMapConfig(READ_ZAEHLSTELLE_DTO, this.maxIdleTimeSecondsZaehldaten));
+        config.addMapConfig(this.getMapConfig(OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN, this.maxIdleTimeSecondsZaehldaten));
+        config.addMapConfig(this.getMapConfig(AUFFAELLIGETAGE_FOR_MESSSTELLE, this.maxIdleTimeSecondsZaehldaten));
     }
 
     private MapConfig getMapConfig(final String name, final int maxIdleTime) {

src/main/java/de/muenchen/dave/domain/Kalendertag.java

@@ -17,8 +17,8 @@
 @Table(
         indexes = {
                 @Index(
-                        name = "index_kalendertag_datum ",
-                        columnList = "datum"
+                        name = "index_combined_datum_tagestyp ",
+                        columnList = "datum, tagestyp"
                 ),
                 @Index(
                         name = "index_kalendertag_next_start_date ",

src/main/java/de/muenchen/dave/domain/dtos/OptionsmenueSettingsDTO.java

@@ -2,11 +2,12 @@
 
 import de.muenchen.dave.domain.enums.Fahrzeugklasse;
 import de.muenchen.dave.domain.enums.ZaehldatenIntervall;
+import java.io.Serializable;
 import java.util.List;
 import lombok.Data;
 
 @Data
-public class OptionsmenueSettingsDTO {
+public class OptionsmenueSettingsDTO implements Serializable {
 
     private Fahrzeugklasse fahrzeugklasse;
 

src/main/java/de/muenchen/dave/domain/dtos/messstelle/AuffaelligeTageDTO.java

@@ -1,10 +1,11 @@
 package de.muenchen.dave.domain.dtos.messstelle;
 
+import java.io.Serializable;
 import java.time.LocalDate;
 import java.util.List;
 import lombok.Data;
 
 @Data
-public class AuffaelligeTageDTO {
+public class AuffaelligeTageDTO implements Serializable {
     private List<LocalDate> auffaelligeTage;
 }

src/main/java/de/muenchen/dave/repositories/elasticsearch/MessstelleIndex.java

@@ -12,22 +12,46 @@
 
 public interface MessstelleIndex extends ElasticsearchRepository<Messstelle, String> {
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     void deleteAll();
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     void deleteAll(Iterable<? extends Messstelle> var1);
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     void deleteById(String var1);
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     void delete(Messstelle var1);
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     <S extends Messstelle> S save(S var1);
 
-    @CacheEvict(value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL }, allEntries = true)
+    @CacheEvict(
+            value = { CachingConfiguration.SUCHE_ERHEBUNGSSTELLE, CachingConfiguration.SUCHE_ERHEBUNGSSTELLE_DATENPORTAL,
+                    CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN },
+            allEntries = true
+    )
     <S extends Messstelle> Iterable<S> saveAll(Iterable<S> var1);
 
     Optional<Messstelle> findById(String var1);

src/main/java/de/muenchen/dave/repositories/relationaldb/UnauffaelligeTageRepository.java

@@ -1,15 +1,53 @@
 package de.muenchen.dave.repositories.relationaldb;
 
+import de.muenchen.dave.configuration.CachingConfiguration;
 import de.muenchen.dave.domain.UnauffaelligerTag;
 import de.muenchen.dave.domain.enums.TagesTyp;
 import java.time.LocalDate;
 import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
+import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface UnauffaelligeTageRepository extends JpaRepository<UnauffaelligerTag, UUID> {
 
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    void deleteAll();
+
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    void deleteAll(Iterable<? extends UnauffaelligerTag> var1);
+
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    void deleteById(UUID var1);
+
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    void delete(UnauffaelligerTag var1);
+
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    <S extends UnauffaelligerTag> S save(S var1);
+
+    @CacheEvict(
+            value = { CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE },
+            allEntries = true
+    )
+    <S extends UnauffaelligerTag> List<S> saveAll(Iterable<S> var1);
+
     List<UnauffaelligerTag> findByMstId(final String mstId);
 
     Optional<UnauffaelligerTag> findFirstByMstIdOrderByKalendertagDatumDesc(final String mstId);

src/main/java/de/muenchen/dave/services/OptionsmenueSettingsService.java

@@ -1,11 +1,13 @@
 package de.muenchen.dave.services;
 
+import de.muenchen.dave.configuration.CachingConfiguration;
 import de.muenchen.dave.domain.dtos.OptionsmenueSettingsDTO;
 import de.muenchen.dave.domain.mapper.OptionsmenueSettingsMapper;
 import de.muenchen.dave.repositories.relationaldb.OptionsmenueSettingsRepository;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 @Service
@@ -17,7 +19,9 @@ public class OptionsmenueSettingsService {
 
     private final OptionsmenueSettingsMapper optionsmenueSettingsMapper;
 
+    @Cacheable(value = CachingConfiguration.OPTIONSMENUE_SETTINGS_FOR_MESSSTELLEN)
     public List<OptionsmenueSettingsDTO> getAllOptionsmenueSettingsForMessstellen() {
+        log.debug("#getAllOptionsmenueSettingsForMessstellen");
         return optionsmenueSettingsRepository
                 .findAll()
                 .stream()

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

@@ -1,5 +1,6 @@
 package de.muenchen.dave.services.messstelle;
 
+import de.muenchen.dave.configuration.CachingConfiguration;
 import de.muenchen.dave.domain.Kalendertag;
 import de.muenchen.dave.domain.UnauffaelligerTag;
 import de.muenchen.dave.domain.dtos.messstelle.AuffaelligeTageDTO;
@@ -10,6 +11,7 @@
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 
 @Service
@@ -20,7 +22,9 @@ public class MessstelleOptionsmenuService {
     private final KalendertagService kalendertagService;
     private final ValidierungService validierungService;
 
+    @Cacheable(value = CachingConfiguration.AUFFAELLIGETAGE_FOR_MESSSTELLE, key = "{#p0}")
     public AuffaelligeTageDTO getAuffaelligeTageForMessstelle(final String mstId) {
+        log.debug("Zugriff auf #getAuffaelligeTageForMessstelle {}", mstId);
         final List<UnauffaelligerTag> unauffaelligeTageForMessstelle = unauffaelligeTageService.getUnauffaelligeTageForMessstelle(mstId);
         final List<LocalDate> unauffaelligeTage = unauffaelligeTageForMessstelle
                 .stream()

src/main/resources/db/migration/V10__add-index-in-kalendertag.sql

@@ -0,0 +1,2 @@
+DROP INDEX IF EXISTS index_kalendertag_datum;
+CREATE INDEX index_combined_datum_tagestyp ON kalendertag USING BTREE(datum, tagestyp);