OY-4836 Backtrack hours instead of days, tweaks to YtlFetchActor

Author: msiukola

src/main/resources/oph-configuration/suoritusrekisteri.properties.template

@@ -126,7 +126,7 @@ suoritusrekisteri.koski.update.cronJob={{ suoritusrekisteri_koski_update_cronjob
 suoritusrekisteri.koski.update.kkHaut={{ suoritusrekisteri_koski_update_kkHaut | default('false') }}
 suoritusrekisteri.koski.update.toisenAsteenHaut={{ suoritusrekisteri_koski_update_toisenAsteenHaut | default('false') }}
 suoritusrekisteri.koski.update.jatkuvatHaut={{ suoritusrekisteri_koski_update_jatkuvatHaut | default('false') }}
-suoritusrekisteri.modifiedhakemukset.backtrack.days={{ suoritusrekisteri_modifiedhakemukset_backtrack_days | default('2')}}
+suoritusrekisteri.modifiedhakemukset.backtrack.hours={{ suoritusrekisteri_modifiedhakemukset_backtrack_hours | default('2')}}
 suoritusrekisteri.oppijanumerorekisteri-service.max-connections={{ suoritusrekisteri_oppijanumerorekisteriservice_max_connections | default('50')}}
 suoritusrekisteri.oppijanumerorekisteri-service.max-connection-queue-ms={{ suoritusrekisteri_oppijanumerorekisteriservice_max_connection_queue_ms | default('60000')}}
 suoritusrekisteri.oppijanumerorekisteri-service.max.oppijat.batch.size={{ suoritusrekisteri_oppijanumerorekisteriservice_max_oppijat_batch_size | default('5000')}}

src/main/scala/fi/vm/sade/hakurekisteri/integration/ytl/YtlFetchActor.scala

@@ -1,15 +1,11 @@
 package fi.vm.sade.hakurekisteri.integration.ytl
 
-import akka.actor.{Actor, ActorLogging, ActorRef}
+import akka.actor.{Actor, ActorLogging, ActorRef, ActorSystem}
 import akka.pattern.pipe
 import fi.vm.sade.hakurekisteri.Config
 import fi.vm.sade.hakurekisteri.integration.ExecutorUtil
 import fi.vm.sade.hakurekisteri.integration.hakemus.{HetuPersonOid, IHakemusService}
-import fi.vm.sade.hakurekisteri.integration.henkilo.{
-  Henkilo,
-  IOppijaNumeroRekisteri,
-  PersonOidsWithAliases
-}
+import fi.vm.sade.hakurekisteri.integration.henkilo.{Henkilo, IOppijaNumeroRekisteri, PersonOidsWithAliases}
 import fi.vm.sade.properties.OphProperties
 import org.apache.commons.io.IOUtils
 import scalaz.concurrent.Task
@@ -52,7 +48,7 @@ class YtlFetchActor(
   val minIntervalBetween = 1000 * 60 * 60 * 22 //At least 22 hours between nightly syncs
 
   implicit val ec: ExecutionContext = ExecutorUtil.createExecutor(
-    config.integrations.asyncOperationThreadPoolSize,
+    20,
     getClass.getSimpleName
   )
 
@@ -99,7 +95,7 @@ class YtlFetchActor(
           log.error(t, s"($tunniste) Manual sync for haku ${s.hakuOid} failed...")
       }
       log.info(s"Ytl-sync käynnistetty haulle ${s.hakuOid} tunnisteella $tunniste")
-      resultF pipeTo sender
+      sender ! tunniste
     case s: YtlSyncSingle =>
       if (s.needsToBeActiveKkHakuOid.forall(oid => activeKKHakuOids.get().contains(oid))) {
         val tunniste = s.tunniste
@@ -110,7 +106,7 @@ class YtlFetchActor(
           case Failure(t) =>
             log.error(t, s"($tunniste) Manual sync for person ${s.personOid} failed...")
         }
-        log.info(s"Ytl-sync käynnistetty haulle ${s.personOid} tunnisteella $tunniste")
+        log.info(s"Ytl-sync käynnistetty oidille ${s.personOid} tunnisteella $tunniste")
         resultF pipeTo sender
       } else {
         val infoStr = s"Not ytl-syncing $s because the haku is not an active kk-haku"

src/main/scala/support/Integrations.scala

@@ -550,11 +550,11 @@ class BaseIntegrations(rekisterit: Registers, system: ActorSystem, config: Confi
   hakemusService.addTrigger(arvosanaTrigger)
   hakemusService.addTrigger(ytlTrigger)
 
-  val daysToBacktrack: Int =
-    OphUrlProperties.getProperty("suoritusrekisteri.modifiedhakemukset.backtrack.days").toInt
+  val hoursToBacktrack: Int =
+    OphUrlProperties.getProperty("suoritusrekisteri.modifiedhakemukset.backtrack.hours").toInt
   implicit val scheduler = system.scheduler
   hakemusService.processModifiedHakemukset(modifiedAfter =
-    new Date(Platform.currentTime - TimeUnit.DAYS.toMillis(daysToBacktrack))
+    new Date(Platform.currentTime - TimeUnit.HOURS.toMillis(hoursToBacktrack))
   )
 
   val quartzScheduler = StdSchedulerFactory.getDefaultScheduler()