EP-4401-2

Opetushallitus · Nov 11, 2024 · a578983 · a578983
1 parent e787155
commit a578983
Show file tree

Hide file tree

Showing 11 changed files with 60 additions and 20 deletions.
diff --git a/...e/src/main/java/fi/vm/sade/eperusteet/repository/JulkaistuPerusteDataStoreRepository.java b/...e/src/main/java/fi/vm/sade/eperusteet/repository/JulkaistuPerusteDataStoreRepository.java
@@ -1,5 +1,6 @@
 package fi.vm.sade.eperusteet.repository;
 
+import fi.vm.sade.eperusteet.domain.KoulutusTyyppi;
 import org.springframework.security.access.prepost.PreAuthorize;
 
 import java.util.List;
@@ -9,6 +10,6 @@ public interface JulkaistuPerusteDataStoreRepository {
     @PreAuthorize("hasPermission(#perusteId, 'peruste', 'MUOKKAUS') or hasPermission(#perusteId, 'peruste', 'TILANVAIHTO')")
     void syncPeruste(Long perusteId);
 
-    List<Long> findPerusteIds();
+    List<Long> findPerusteIdsByKoulutustyypit(List<String> koulutustyypit);
 
 }
diff --git a/...java/fi/vm/sade/eperusteet/repository/custom/JulkaistuPerusteDataStoreRepositoryImpl.java b/...java/fi/vm/sade/eperusteet/repository/custom/JulkaistuPerusteDataStoreRepositoryImpl.java
@@ -1,5 +1,6 @@
 package fi.vm.sade.eperusteet.repository.custom;
 
+import fi.vm.sade.eperusteet.domain.KoulutusTyyppi;
 import fi.vm.sade.eperusteet.dto.util.CacheArvot;
 import fi.vm.sade.eperusteet.repository.JulkaistuPerusteDataStoreRepository;
 import fi.vm.sade.eperusteet.repository.PerusteRepository;
@@ -39,9 +40,11 @@ public void syncPeruste(Long perusteId) {
     }
 
     @Override
-    public List<Long> findPerusteIds() {
-        String sql = "SELECT DISTINCT perusteid FROM julkaistu_peruste_data_store";
+    public List<Long> findPerusteIdsByKoulutustyypit(List<String> koulutustyypit) {
+        String sql = "SELECT DISTINCT perusteid FROM julkaistu_peruste_data_store WHERE koulutustyyppi IN (:koulutustyypit)";
+
         return (List<Long>) entityManager.createNativeQuery(sql)
+                .setParameter("koulutustyypit", koulutustyypit)
                 .getResultList()
                 .stream()
                 .map(o -> Long.parseLong(o.toString()))

diff --git a/...perusteet-service/src/main/java/fi/vm/sade/eperusteet/service/ScheduledConfiguration.java b/...perusteet-service/src/main/java/fi/vm/sade/eperusteet/service/ScheduledConfiguration.java
@@ -55,9 +55,7 @@ public class ScheduledConfiguration implements SchedulingConfigurer {
     public void sortTasks() {
         // Järjestetään tehtävät prioriteetin mukaan
         tasks = tasks.stream()
-                .sorted(Comparator.comparing(ScheduledTask::getPriority)
-                        .thenComparing(ScheduledTask::getName)
-                        .reversed())
+                .sorted(Comparator.comparing(ScheduledTask::getPriority).reversed())
                 .collect(Collectors.toList());
     }
 

diff --git a/...teet-service/src/main/java/fi/vm/sade/eperusteet/service/impl/MaintenanceServiceImpl.java b/...teet-service/src/main/java/fi/vm/sade/eperusteet/service/impl/MaintenanceServiceImpl.java
@@ -44,6 +44,7 @@
 import fi.vm.sade.eperusteet.service.mapping.Dto;
 import fi.vm.sade.eperusteet.service.mapping.DtoMapper;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.CacheManager;
 import org.springframework.cache.annotation.Cacheable;
@@ -54,9 +55,9 @@
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.support.TransactionTemplate;
-import org.springframework.util.CollectionUtils;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Comparator;
 import java.util.Date;
 import java.util.HashSet;
@@ -287,7 +288,10 @@ public void teeMaarayksetPerusteille() {
     @Override
     @IgnorePerusteUpdateCheck
     public void cacheJulkisetPerusteNavigoinnit() {
-        julkaistuPerusteDataStoreRepository.findPerusteIds()
+        List<String> koulutustyypit = Arrays.stream(KoulutusTyyppi.values()).map(KoulutusTyyppi::toString).collect(Collectors.toList());
+        koulutustyypit.removeAll(List.of(KoulutusTyyppi.VALMA.toString(), KoulutusTyyppi.TELMA.toString()));
+        koulutustyypit.removeAll(KoulutusTyyppi.ammatilliset());
+        julkaistuPerusteDataStoreRepository.findPerusteIdsByKoulutustyypit(koulutustyypit)
                 .forEach(perusteId -> perusteRepository.findOne(perusteId).getKielet()
                         .forEach(kieli -> {
                             try {
@@ -301,7 +305,10 @@ public void cacheJulkisetPerusteNavigoinnit() {
     @Override
     @IgnorePerusteUpdateCheck
     public void cacheJulkaistutPerusteet() {
-        julkaistuPerusteDataStoreRepository.findPerusteIds()
+        List<String> koulutustyypit = Arrays.stream(KoulutusTyyppi.values()).map(KoulutusTyyppi::toString).collect(Collectors.toList());
+        koulutustyypit.removeAll(List.of(KoulutusTyyppi.VALMA.toString(), KoulutusTyyppi.TELMA.toString()));
+        koulutustyypit.removeAll(KoulutusTyyppi.ammatilliset());
+        julkaistuPerusteDataStoreRepository.findPerusteIdsByKoulutustyypit(koulutustyypit)
                 .forEach(perusteId -> {
                     try {
                         perusteService.getJulkaistuSisalto(perusteId);

diff --git a/...rusteet-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/AmosaaTilastotTask.java b/...rusteet-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/AmosaaTilastotTask.java
@@ -20,7 +20,7 @@ public class AmosaaTilastotTask extends AbstractScheduledTask {
 
     @Override
     public int getPriority() {
-        return 500;
+        return 70;
     }
 
     @Override

diff --git a/...rvice/src/main/java/fi/vm/sade/eperusteet/service/tasks/JulkinenEtusivuHakuCacheTask.java b/...rvice/src/main/java/fi/vm/sade/eperusteet/service/tasks/JulkinenEtusivuHakuCacheTask.java
@@ -21,7 +21,7 @@ public class JulkinenEtusivuHakuCacheTask extends AbstractScheduledTask {
 
     @Override
     public int getPriority() {
-        return 100;
+        return 80;
     }
 
     @Override

diff --git a/...-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/PerusteJulkaisutCacheTask.java b/...-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/PerusteJulkaisutCacheTask.java
@@ -25,15 +25,12 @@ public class PerusteJulkaisutCacheTask extends AbstractScheduledTask {
 
     @Override
     public int getPriority() {
-        return 200;
+        return 100;
     }
 
     @Override
     public void executeTask(Date viimeisinajoaika) {
-        maintenanceService.clearCache(CacheArvot.JULKINEN_PERUSTE_NAVIGOINTI);
         maintenanceService.clearCache(CacheArvot.PERUSTE_JULKAISU);
-
-        maintenanceService.cacheJulkisetPerusteNavigoinnit();
         maintenanceService.cacheJulkaistutPerusteet();
     }
 }
diff --git a/...ervice/src/main/java/fi/vm/sade/eperusteet/service/tasks/PerusteNavigoinnitCacheTask.java b/...ervice/src/main/java/fi/vm/sade/eperusteet/service/tasks/PerusteNavigoinnitCacheTask.java
@@ -0,0 +1,36 @@
+package fi.vm.sade.eperusteet.service.tasks;
+
+import fi.vm.sade.eperusteet.dto.util.CacheArvot;
+import fi.vm.sade.eperusteet.repository.JulkaistuPerusteDataStoreRepository;
+import fi.vm.sade.eperusteet.service.MaintenanceService;
+import fi.vm.sade.eperusteet.service.PerusteService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Component
+public class PerusteNavigoinnitCacheTask extends AbstractScheduledTask {
+
+    @Lazy
+    @Autowired
+    private MaintenanceService maintenanceService;
+
+    @Autowired
+    private JulkaistuPerusteDataStoreRepository julkaistuPerusteDataStoreRepository;
+
+    @Autowired
+    private PerusteService perusteService;
+
+    @Override
+    public int getPriority() {
+        return 90;
+    }
+
+    @Override
+    public void executeTask(Date viimeisinajoaika) {
+        maintenanceService.clearCache(CacheArvot.JULKINEN_PERUSTE_NAVIGOINTI);
+        maintenanceService.cacheJulkisetPerusteNavigoinnit();
+    }
+}
diff --git a/...java/fi/vm/sade/eperusteet/service/tasks/TutkinnonosienAmmattiaitovaatimusKooditTask.java b/...java/fi/vm/sade/eperusteet/service/tasks/TutkinnonosienAmmattiaitovaatimusKooditTask.java
@@ -28,16 +28,14 @@ public class TutkinnonosienAmmattiaitovaatimusKooditTask extends AbstractSchedul
 
     @Override
     public int getPriority() {
-        return 4000;
+        return 50;
     }
 
     @Override
     public void executeTask(Date viimeisinajoaika) {
-
         koodistoClient.addKoodistoRelaatio(KoodistoUriArvo.TUTKINTONIMIKKEET, KoodistoUriArvo.TUTKINNONOSAT, KoodiRelaatioTyyppi.SISALTYY);
         koodistoClient.addKoodistoRelaatio(KoodistoUriArvo.KOULUTUS, KoodistoUriArvo.TUTKINNONOSAT, KoodiRelaatioTyyppi.SISALTYY);
         koodistoClient.addKoodistoRelaatio(KoodistoUriArvo.TUTKINNONOSAT, KoodistoUriArvo.AMMATTITAITOVAATIMUKSET, KoodiRelaatioTyyppi.SISALTYY);
         ammattitaitovaatimusService.lisaaAmmattitaitovaatimusTutkinnonosaKoodistoon(viimeisinajoaika);
-
     }
 }
diff --git a/...erusteet-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/YlopsTilastotTask.java b/...erusteet-service/src/main/java/fi/vm/sade/eperusteet/service/tasks/YlopsTilastotTask.java
@@ -18,7 +18,7 @@ public class YlopsTilastotTask extends AbstractScheduledTask {
 
     @Override
     public int getPriority() {
-        return 550;
+        return 60;
     }
 
     @Override

diff --git a/...test/java/fi/vm/sade/eperusteet/service/util/JulkaistuPerusteDataStoreRepositoryMock.java b/...test/java/fi/vm/sade/eperusteet/service/util/JulkaistuPerusteDataStoreRepositoryMock.java
@@ -16,7 +16,7 @@ public void syncPeruste(Long perusteId) {
     }
 
     @Override
-    public List<Long> findPerusteIds() {
+    public List<Long> findPerusteIdsByKoulutustyypit(List<String> koulutustyypit) {
         return List.of();
     }
 }