Bruk tildato for oppslag på oppfølgingsperiode hvis hvis før moddato (#89)

* Sette modDato til not optional

* Bruk tildato for oppslag hvis før moddato

* Test overnevnte case

Author: holymaloney

src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/domain/kafka/arena/tiltak/ArenaDeltakelse.kt

@@ -66,7 +66,7 @@ data class ArenaDeltakelse(
 			innsokBegrunnelse = BEGRUNNELSE_BESTILLING,
 			modUser = MOD_USER,
 			regUser = REG_USER,
-			modDato = MOD_DATO?.asValidatedLocalDateTime("MOD_DATO"),
+			modDato = MOD_DATO.asValidatedLocalDateTime("MOD_DATO"),
 		)
 	}
 

src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/domain/kafka/arena/tiltak/TiltakDeltakelse.kt

@@ -18,7 +18,7 @@ data class TiltakDeltakelse(
 	val innsokBegrunnelse: String?,
 	val regUser: String?,
 	val modUser: String?,
-	val modDato: LocalDateTime?,
+	val modDato: LocalDateTime,
 )
 
 data class DeltakelseId(

src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/processors/DeltakerProcessor.kt

@@ -56,7 +56,8 @@ open class DeltakerProcessor(
 		}
 
 		var opprettetFoerMenAktivEtterLansering = false
-		if (deltakelse.regDato.isBefore(AKTIVITETSPLAN_LANSERINGSDATO)) {
+		if (deltakelse.regDato.isBefore(AKTIVITETSPLAN_LANSERINGSDATO) && deltakelse.modDato.isBefore(
+				AKTIVITETSPLAN_LANSERINGSDATO)) {
 			// Hvis deltakelsen er opprettet før aktivitetsplan lanseringsdato,
 			// _men_ datoTil er etter aktivitetsplan lanseringsdato,
 			// _og_ bruker hadde en aktiv oppfølgingsperiode ved aktivitetsplan lanseringsdato
@@ -165,10 +166,9 @@ open class DeltakerProcessor(
 	}
 
 	private fun getOppfolgingsPeriodeOrThrow(deltaker: TiltakDeltakelse, personIdent: String): FinnOppfolgingResult.FunnetPeriodeResult {
-		val funnetPeriode = deltaker.modDato
-			?.let { modDato -> oppfolgingsperiodeService.finnOppfolgingsperiode(personIdent, modDato) }
-			?: oppfolgingsperiodeService.finnOppfolgingsperiode(personIdent, deltaker.regDato)
-				.also { log.info("arenaId: ${deltaker.tiltakdeltakelseId} Fant ikke oppfolgingsperiode på modDato, bruker fallback til regDato") }
+		val oppslagsDato = deltaker.datoTil
+			?.let { tilDato -> minOf(tilDato.atStartOfDay(), deltaker.modDato) } ?: deltaker.modDato
+		val funnetPeriode = oppfolgingsperiodeService.finnOppfolgingsperiode(personIdent, oppslagsDato)
 		return when (funnetPeriode) {
 			is FinnOppfolgingResult.FunnetPeriodeResult -> funnetPeriode
 			is FinnOppfolgingResult.IngenPeriodeResult -> handleOppfolgingsperiodeNull(deltaker, personIdent, deltaker.modDato ?: deltaker.regDato, deltaker.tiltakdeltakelseId)

src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/services/OppfolgingsperiodeService.kt

@@ -7,7 +7,7 @@ import org.springframework.stereotype.Service
 import java.time.Duration
 import java.time.LocalDateTime
 import java.time.ZoneId
-import java.time.chrono.ChronoZonedDateTime
+import java.time.ZonedDateTime
 import java.time.temporal.ChronoUnit
 import java.time.temporal.TemporalAmount
 import kotlin.math.abs
@@ -42,14 +42,14 @@ open class OppfolgingsperiodeService(
 			return FinnOppfolgingResult.IngenPeriodeResult( emptyList())
 		}
 
-		val tidspunktCZDT = ChronoZonedDateTime.from(tidspunkt.atZone(ZoneId.systemDefault()))
+		val tidspunktZDT = ZonedDateTime.from(tidspunkt.atZone(ZoneId.systemDefault()))
 		val oppfolgingsperiode = oppfolgingsperioder
-			.find {periode -> periode.tidspunktInnenforPeriode(tidspunktCZDT) }
+			.find {periode -> periode.tidspunktInnenforPeriode(tidspunktZDT) }
 		if (oppfolgingsperiode != null) return FinnOppfolgingResult.FunnetPeriodeResult(oppfolgingsperiode, oppfolgingsperioder)
 
 		return oppfolgingsperioder
-				.filter { it.sluttDato == null || it.sluttDato.isAfter(tidspunktCZDT) }
-				.minByOrNull { abs(ChronoUnit.MILLIS.between(tidspunktCZDT, it.startDato)) }
+				.filter { it.sluttDato == null || it.sluttDato.isAfter(tidspunktZDT) }
+				.minByOrNull { abs(ChronoUnit.MILLIS.between(tidspunktZDT, it.startDato)) }
 				.let { periodeMatch ->
 					if (periodeMatch == null || !tidspunktRettFoerStartDatoEllerSenere(tidspunkt, periodeMatch.startDato.toLocalDateTime(), defaultSlakk)) {
 						secureLog.info(

src/test/kotlin/no/nav/arena_tiltak_aktivitet_acl/integration/DeltakerIntegrationTests.kt

@@ -380,14 +380,15 @@ class DeltakerIntegrationTests : IntegrationTestBase() {
 	}
 
 	@Test
-	fun `ignore deltaker before aktivitetsplan launch if tilDato before aktivitetsplan launch`() {
+	fun `ignore deltaker moddato before aktivitetsplan launch if tilDato before aktivitetsplan launch`() {
 		val (gjennomforingId, deltakerId) = setup()
 		val deltakerInput = DeltakerInput(
 			tiltakDeltakelseId = deltakerId,
 			tiltakgjennomforingId = gjennomforingId,
 			innsokBegrunnelse = "innsøkbegrunnelse",
 			endretAv = Ident(ident = "SIG123"),
 			datoTil = AKTIVITETSPLAN_LANSERINGSDATO.toLocalDate().minusDays(1),
+			endretTidspunkt = AKTIVITETSPLAN_LANSERINGSDATO.minusDays(1),
 			registrertDato = AKTIVITETSPLAN_LANSERINGSDATO.minusDays(2)
 		)
 		val deltakerCommand = NyDeltakerCommand(deltakerInput)
@@ -400,14 +401,15 @@ class DeltakerIntegrationTests : IntegrationTestBase() {
 	}
 
 	@Test
-	fun `ignore deltaker before aktivitetsplan launch if tilDato after aktivitetplan launch, but no oppfolgingsperiode`() {
+	fun `ignore deltaker moddato before aktivitetsplan launch if tilDato after aktivitetplan launch, but no oppfolgingsperiode`() {
 		val (gjennomforingId, deltakerId) = setup()
 		val deltakerInput = DeltakerInput(
 			tiltakDeltakelseId = deltakerId,
 			tiltakgjennomforingId = gjennomforingId,
 			innsokBegrunnelse = "innsøkbegrunnelse",
 			endretAv = Ident(ident = "SIG123"),
 			datoTil = AKTIVITETSPLAN_LANSERINGSDATO.plusMonths(1).toLocalDate(),
+			endretTidspunkt = AKTIVITETSPLAN_LANSERINGSDATO.minusDays(1),
 			registrertDato = AKTIVITETSPLAN_LANSERINGSDATO.minusDays(1)
 		)
 		val deltakerCommand = NyDeltakerCommand(deltakerInput)
@@ -420,7 +422,7 @@ class DeltakerIntegrationTests : IntegrationTestBase() {
 	}
 
 	@Test
-	fun `dont ignore deltaker before aktivitetsplan launch if tildato after aktivitetsplan launch and oppfolgingsperiode was active`() {
+	fun `dont ignore deltaker moddato before aktivitetsplan launch if tildato after aktivitetsplan launch and oppfolgingsperiode was active`() {
 		val (gjennomforingId, deltakerId) = setup()
 
 		val foerstePeriode = Oppfolgingsperiode(
@@ -454,6 +456,42 @@ class DeltakerIntegrationTests : IntegrationTestBase() {
 		}
 	}
 
+	@Test
+	fun `find correct periode for deltakelse before aktivitetsplan launch when moddato is very recent`() {
+		val (gjennomforingId, deltakerId) = setup()
+
+		val foerstePeriode = Oppfolgingsperiode(
+			uuid = UUID.randomUUID(),
+			startDato = ZonedDateTime.of(AKTIVITETSPLAN_LANSERINGSDATO.minusDays(1), ZoneId.systemDefault()),
+			sluttDato = null
+		)
+
+		val deltakerInput = DeltakerInput(
+			personId = 345L,
+			tiltakDeltakelseId = deltakerId,
+			tiltakgjennomforingId = gjennomforingId,
+			innsokBegrunnelse = "innsøkbegrunnelse",
+			endretAv = Ident(ident = "SIG123"),
+			registrertDato = AKTIVITETSPLAN_LANSERINGSDATO.minusYears(1),
+			endretTidspunkt = LocalDateTime.now(),
+			datoTil = LocalDate.now().plusYears(25)
+		)
+
+		val fnr = "12345678901"
+		OrdsClientMock.fnrHandlers[deltakerInput.personId!!] = { fnr }
+		OppfolgingClientMock.oppfolgingsperioder[fnr] = listOf(foerstePeriode)
+
+
+
+		val deltakerCommand = NyDeltakerCommand(deltakerInput)
+		val result = deltakerExecutor.execute(deltakerCommand)
+
+		result.expectHandled {
+				data -> data.headers.oppfolgingsperiode shouldBe foerstePeriode.uuid
+		}
+	}
+
+
 	@Test
 	fun `tittel should be set to default value when gjennomforing navn is null`() {
 		val gjennomforingId: Long = Random.nextLong()