OK-420 Add rough implementation to form siirtotiedostos for kk-hakus

Opetushallitus · May 7, 2024 · 0b5b2b7 · 0b5b2b7
1 parent 6df4ccc
commit 0b5b2b7
Show file tree

Hide file tree

Showing 3 changed files with 38 additions and 0 deletions.
diff --git a/src/main/scala/ScalatraBootstrap.scala b/src/main/scala/ScalatraBootstrap.scala
@@ -161,6 +161,7 @@ class ScalatraBootstrap extends LifeCycle {
         registers.ovaraDbRepository,
         new SiirtotiedostoClient(config.siirtotiedostoClientConfig),
         koosteet.ensikertalainen,
+        integrations.haut,
         config.siirtotiedostoPageSize
       )
     ),

diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/ovara/OvaraResource.scala b/src/main/scala/fi/vm/sade/hakurekisteri/ovara/OvaraResource.scala
@@ -61,7 +61,19 @@ class OvaraResource(ovaraService: OvaraService)(implicit val security: Security)
     } else {
       Forbidden("Ei tarvittavia oikeuksia ovara-siirtotiedoston muodostamiseen")
     }
+  }
 
+  get("/muodosta/ensikertalaisuudet/kkhaut") {
+    if (currentUser.exists(_.isAdmin)) {
+      val vainAktiiviset: Boolean = params.get("vainAktiiviset").exists(_.toBoolean)
+      logger.info(
+        s"Muodostetaan ensikertalaisten siirtotiedosto kk-hauille. Vain aktiiviset: $vainAktiiviset"
+      )
+      val result = ovaraService.triggerEnsikertalaiset(vainAktiiviset)
+      Ok(s"Valmista - $result")
+    } else {
+      Forbidden("Ei tarvittavia oikeuksia ovara-siirtotiedoston muodostamiseen")
+    }
   }
 
   override protected implicit def jsonFormats: Formats = HakurekisteriJsonSupport.format

diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/ovara/OvaraService.scala b/src/main/scala/fi/vm/sade/hakurekisteri/ovara/OvaraService.scala
@@ -9,6 +9,15 @@ import fi.vm.sade.hakurekisteri.ensikertalainen.{
   MenettamisenPeruste
 }
 import fi.vm.sade.hakurekisteri.integration.ExecutorUtil
+import fi.vm.sade.hakurekisteri.integration.haku.{
+  AllHaut,
+  GetHautQuery,
+  Haku,
+  HakuRequest,
+  RestHaku,
+  RestHakuResult
+}
+import fi.vm.sade.hakurekisteri.integration.kouta.KoutaInternalActorRef
 import fi.vm.sade.hakurekisteri.rest.support.HakurekisteriJsonSupport
 import fi.vm.sade.utils.slf4j.Logging
 
@@ -27,6 +36,7 @@ class OvaraService(
   db: OvaraDbRepository,
   s3Client: SiirtotiedostoClient,
   ensikertalainenActor: ActorRef,
+  hakuActor: ActorRef,
   pageSize: Int
 ) extends IOvaraService
     with Logging {
@@ -81,6 +91,21 @@ class OvaraService(
     menettamisenPeruste: Option[MenettamisenPeruste]
   )
 
+  //Haetaan hakujen oidit ja synkataan ensikertalaiset näille
+  def triggerEnsikertalaiset(vainAktiiviset: Boolean) = {
+    implicit val to: Timeout = Timeout(5.minutes)
+    val allHaut: Future[AllHaut] =
+      (hakuActor ? HakuRequest)
+        .mapTo[AllHaut] //fixme, tää on ongelma koska palautuu 0 hakua jos kaikkia hakuja ei oo vielä haettu actorin päässä.
+    val hakuResult = Await.result(allHaut, 5.minutes)
+    val kiinnostavat =
+      hakuResult.haut.filter(haku => (!vainAktiiviset || haku.isActive) && haku.kkHaku).map(_.oid)
+    logger.info(
+      s"Löydettiin ${kiinnostavat.size} kiinnostavaa hakua yhteensä ${hakuResult.haut.size} hausta. Vain aktiiviset: $vainAktiiviset"
+    )
+    formEnsikertalainenSiirtotiedostoForHakus(kiinnostavat)
+  }
+
   //Ensivaiheessa ajetaan tämä kaikille kk-hauille kerran, myöhemmin riittää synkata kerran päivässä aktiivisten kk-hakujen tiedot
   def formEnsikertalainenSiirtotiedostoForHakus(hakuOids: Seq[String]) = {
     def formSiirtotiedostoForHaku(hakuOid: String) = {