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 index 65076c0bd..84a0ece89 100644 --- 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 index f67037903..57b741321 100644 --- 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 index 6df0732c6..173fcb772 100644 --- 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." )