Haetaan Koskesta öisin kaikkien aktiivisten kk-hakujen hakijoiden amm…

…atilliset suoritukset
Opetushallitus · May 22, 2024 · 794bd65 · 794bd65
1 parent 8fffcf3
commit 794bd65
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 8 deletions.
diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/integration/haku/HakuActor.scala b/src/main/scala/fi/vm/sade/hakurekisteri/integration/haku/HakuActor.scala
@@ -73,13 +73,13 @@ class HakuActor(
     case sq: Seq[_] =>
       storedHakus = sq.collect { case h: Haku => h }
       val activeHakus: Seq[Haku] = storedHakus.filter(_.isActive)
-      val ytlHakus = activeHakus.filter(_.kkHaku)
+      val kkHakus = activeHakus.filter(_.kkHaku)
       val activeYhteisHakus: Seq[Haku] = activeHakus.filter(_.hakutapaUri.startsWith("hakutapa_01"))
       val activeKKYhteisHakus = activeYhteisHakus.filter(_.kkHaku)
       val active2AsteYhteisHakus = activeYhteisHakus.filter(_.toisenAsteenHaku)
-      val ytlHakuOidsWithNames =
-        ytlHakus.map(haku => haku.oid -> haku.nimi.fi.getOrElse("haulla ei nimeä")).toMap
-      val ytlHakuOids: Set[String] = ytlHakus.map(_.oid).toSet
+      val kkHakuOidsWithNames =
+        kkHakus.map(haku => haku.oid -> haku.nimi.fi.getOrElse("haulla ei nimeä")).toMap
+      val kkHakuOids: Set[String] = kkHakus.map(_.oid).toSet
       val active2AsteYhteisHakuOids: Set[String] = active2AsteYhteisHakus.map(_.oid).toSet
       val activeKKYhteisHakuOids: Set[String] = activeKKYhteisHakus.map(_.oid).toSet
       val activeToisenAsteenJatkuvaKoutaHakuOids = activeHakus
@@ -89,14 +89,15 @@ class HakuActor(
         .filter(_.oid.length == 35)
         .map(_.oid)
         .toSet
-      log.info(s"Asetetaan aktiiviset YTL-haut: ${ytlHakuOidsWithNames.toString()} ")
-      ytlIntegrationActor.actor ! ActiveKkHakuOids(ytlHakuOids)
+      log.info(s"Asetetaan aktiiviset Kk-haut: ${kkHakuOidsWithNames.toString()} ")
+      ytlIntegrationActor.actor ! ActiveKkHakuOids(kkHakuOids)
       koskiService.setAktiiviset2AsteYhteisHaut(active2AsteYhteisHakuOids)
       koskiService.setAktiivisetKKYhteisHaut(activeKKYhteisHakuOids)
       koskiService.setAktiivisetToisenAsteenJatkuvatHaut(activeToisenAsteenJatkuvaKoutaHakuOids)
+      koskiService.setAktiivisetKKHaut(kkHakuOids)
       log.info(s"size of stored application system set: [${storedHakus.size}]")
       log.info(s"active application systems: [${activeHakus.size}]")
-      log.info(s"active ytl application systems: [${ytlHakuOids.size}]")
+      log.info(s"active ytl application systems: [${kkHakuOids.size}]")
       log.info(s"active 2.aste-yhteishakus: [${active2AsteYhteisHakuOids.size}]")
       log.info(s"active korkeakoulu-yhteishakus: [${activeKKYhteisHakuOids.size}]")
       log.info(

diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/integration/koski/IKoskiService.scala b/src/main/scala/fi/vm/sade/hakurekisteri/integration/koski/IKoskiService.scala
@@ -10,6 +10,8 @@ trait IKoskiService {
 
   def setAktiivisetKKYhteisHaut(hakuOids: Set[String]): Unit
 
+  def setAktiivisetKKHaut(hakuOids: Set[String]): Unit
+
   def setAktiivisetToisenAsteenJatkuvatHaut(hakuOids: Set[String]): Unit
 
   def updateAktiivisetKkAsteenHaut(): () => Unit
@@ -50,6 +52,7 @@ trait IKoskiService {
 class KoskiServiceMock extends IKoskiService {
   override def setAktiiviset2AsteYhteisHaut(hakuOids: Set[String]): Unit = None
   override def setAktiivisetKKYhteisHaut(hakuOids: Set[String]): Unit = None
+  override def setAktiivisetKKHaut(hakuOids: Set[String]): Unit = None
   override def setAktiivisetToisenAsteenJatkuvatHaut(hakuOids: Set[String]): Unit = None
   override def updateAktiivisetKkAsteenHaut(): () => Unit = () => ()
   override def updateAktiivisetToisenAsteenHaut(): () => Unit = () => ()

diff --git a/src/main/scala/fi/vm/sade/hakurekisteri/integration/koski/KoskiService.scala b/src/main/scala/fi/vm/sade/hakurekisteri/integration/koski/KoskiService.scala
@@ -57,6 +57,12 @@ class KoskiService(
     aktiivisetKKYhteisHakuOidit.set(hakuOids)
   }
 
+  val aktiivisetKKHakuOidit = new AtomicReference[Set[String]](Set.empty)
+  def setAktiivisetKKHaut(hakuOids: Set[String]): Unit = {
+    logger.info(s"Asetetaan aktiiviset KK-yhteishaut haut: $hakuOids")
+    aktiivisetKKHakuOidit.set(hakuOids)
+  }
+
   val aktiivistenToisenAsteenJatkuvienHakujenOidit = new AtomicReference[Set[String]](Set.empty)
   def setAktiivisetToisenAsteenJatkuvatHaut(hakuOids: Set[String]): Unit = {
     logger.info(s"Asetetaan aktiiviset toisen asteen jatkuvat haut: $hakuOids")
@@ -168,7 +174,7 @@ class KoskiService(
    * - Aktiivisten korkeakouluhakujen ammatilliset suoritukset Koskesta
    */
   override def updateAktiivisetKkAsteenHaut(): () => Unit = { () =>
-    val haut: Set[String] = aktiivisetKKYhteisHakuOidit.get()
+    val haut: Set[String] = aktiivisetKKHakuOidit.get()
     logger.info(
       s"Saatiin tarjonnasta aktiivisia korkeakoulujen hakuja ${haut.size} kpl, aloitetaan ammatillisten suoritusten päivitys."
     )