Remove OpprettSingleHistorisk

navikt · Mar 8, 2024 · 025beba · 025beba
1 parent 44112d6
commit 025beba
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 39 deletions.
diff --git a/...n/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/DeletedMessagesFixSchedule.kt b/...n/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/DeletedMessagesFixSchedule.kt
@@ -65,10 +65,6 @@ class DeletedMessagesFixSchedule(
 				log.info("Oppdater eksisterende deltakerid ${fix.deltakelseId}")
 				arenaDataRepository.upsertTemp(fix.toArenaDataUpsertInput())
 			}
-			is OpprettSingelHistorisk -> {
-				log.info("Oppretter historisk deltakelse som mangler andre deltakelser i arena_data")
-				arenaDataRepository.upsertTemp(fix.toArenaDataUpsertInput())
-			}
 		}
 		historiskDeltakelseRepo.oppdaterFixMetode(fix, table)
 	}
@@ -131,13 +127,10 @@ class DeletedMessagesFixSchedule(
 			.filter { it.lastestStatusEndretDato == datoStatusEndring } // er det noen av våre deltakelser som matcher med denne historisk deltakelsen?
 
 		return when {
-			arenaDataDeltakelser.isEmpty() -> {
-				log.info("Mangler person-gjennomføring i arena_data. Enslig deltakelse i historikk. person:${person_id} gjennomforing:${tiltakgjennomforing_id}")
-				OpprettSingelHistorisk(genererDeltakelseId(), this, generertPos = hentPosFraHullet())
-			}
 			// Alt som kommer på relast er ikke slettet, hvis vi har bare 1, har den også kommet på relast
-			arenaDataDeltakelser.size == 1 -> {
-				log.info("Fant bare 1 eksisterende arenadeltakelse for historisk deltakelse ${this.hist_tiltakdeltaker_id}")
+			// Hvis det er 0 eller 1 treff på arena-data så har vi ikke deltakelsen og den må opprettes (ikke Oppdatering)
+			arenaDataDeltakelser.size < 2  -> {
+				log.info("Fant ${arenaDataDeltakelser.size} eksisterende arenadeltakelser for historisk deltakelse ${this.hist_tiltakdeltaker_id}")
 				val legacyId = datoStatusEndring?.let { historiskDeltakelseRepo.getLegacyId(this.person_id, this.tiltakgjennomforing_id, it) }
 				when {
 					legacyId != null -> OpprettMedLegacyId(legacyId.deltakerId, this, legacyId.funksjonellId, generertPos = hentPosFraHullet())
@@ -156,6 +149,7 @@ class DeletedMessagesFixSchedule(
 					legacyId != null -> {
 						if (historiskDeltakelseRepo.deltakelseExists(legacyId)) {  // Fant den den i translation, men vi har den i arena_data
 							val arenaDeltakelse = finnSisteOppdateringArenaDeltakelse(legacyId.deltakerId)
+							// Siden dato-statusendring ikke matcher vet vi at dataen vår ikke er oppdatert
 							Oppdater(legacyId.deltakerId, arenaDeltakelse, this, generertPos = hentPosFraHullet())
 						} else {
 							OpprettMedLegacyId(legacyId.deltakerId, this, legacyId.funksjonellId, generertPos = hentPosFraHullet())

diff --git a/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/FixMetode.kt b/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/FixMetode.kt
@@ -23,11 +23,11 @@ class Oppdater(deltakelseId: DeltakelseId, val arenaDeltakelse: ArenaDeltakelse,
 	fun toArenaDataUpsertInput(): ArenaDataUpsertInput {
 		return historiskDeltakelseTilArenaDataUpsertInput(
 			deltakelseId = deltakelseId,
-			operation = Operation.MODIFIED,
+			operation = Operation.DELETED,
 			pos = generertPos,
 			operationTimestamp = historiskDeltakelse.mod_dato.asBackwardsFormattedLocalDateTime(),
-			before = mapper.writeValueAsString(arenaDeltakelse),
-			after = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
+			after = mapper.writeValueAsString(arenaDeltakelse),
+			before = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
 		)
 	}
 }
@@ -36,29 +36,11 @@ class OpprettMedLegacyId(deltakelseId: DeltakelseId, val historiskDeltakelse: Hi
 	fun toArenaDataUpsertInput(): ArenaDataUpsertInput {
 		return historiskDeltakelseTilArenaDataUpsertInput(
 			deltakelseId = deltakelseId,
-			operation = Operation.CREATED,
+			operation = Operation.DELETED,
 			pos = generertPos,
 			operationTimestamp = historiskDeltakelse.mod_dato.asBackwardsFormattedLocalDateTime(),
-			before = null,
-			after = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
-		)
-	}
-}
-
-/**
- * Vi mangler deltakelse i arena_data for denne person-gjennomføring.
- * Det er sannsynligvis fordi den 'nye' deltakelsen ble IGNORED og at IGNORED-data tidligere ble slettet rutinemessig.
- */
-class OpprettSingelHistorisk(deltakelseId: DeltakelseId, val historiskDeltakelse: HistoriskDeltakelse, val generertPos: OperationPos)
-	: FixMetode(historiskDeltakelse.hist_tiltakdeltaker_id, deltakelseId) {
-	fun toArenaDataUpsertInput(): ArenaDataUpsertInput {
-		return historiskDeltakelseTilArenaDataUpsertInput(
-			deltakelseId = deltakelseId,
-			operation = Operation.CREATED,
-			pos = generertPos,
-			operationTimestamp = historiskDeltakelse.mod_dato.asBackwardsFormattedLocalDateTime(),
-			before = null,
-			after = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
+			after = null,
+			before = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
 		)
 	}
 }
@@ -67,11 +49,11 @@ class Opprett(deltakelseId: DeltakelseId, val historiskDeltakelse: HistoriskDelt
 	fun toArenaDataUpsertInput(): ArenaDataUpsertInput {
 		return historiskDeltakelseTilArenaDataUpsertInput(
 			deltakelseId = deltakelseId,
-			operation = Operation.CREATED,
+			operation = Operation.DELETED,
 			pos = generertPos,
 			operationTimestamp = historiskDeltakelse.mod_dato.asBackwardsFormattedLocalDateTime(),
-			before = null,
-			after = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
+			after = null,
+			before = mapper.writeValueAsString(historiskDeltakelse.toArenaDeltakelse(deltakelseId))
 		)
 	}
 }

diff --git a/...tlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/HistoriskDeltakelseRepo.kt b/...tlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/HistoriskDeltakelseRepo.kt
@@ -42,7 +42,7 @@ class HistoriskDeltakelseRepo(
 		WHERE hist_tiltakdeltaker_id = :hist_tiltakdeltaker_id
 	""".trimIndent()
 		val muligPos = when(fixMetode) {
-			is Ignorer, is OpprettSingelHistorisk -> null
+			is Ignorer -> null
 			is Oppdater -> fixMetode.generertPos
 			is Opprett -> fixMetode.generertPos
 			is OpprettMedLegacyId -> fixMetode.generertPos
@@ -63,7 +63,6 @@ class HistoriskDeltakelseRepo(
 			is Oppdater -> "Oppdater"
 			is Opprett -> "Opprett"
 			is OpprettMedLegacyId -> "OpprettMedLegacyId"
-			is OpprettSingelHistorisk -> "OpprettSingelHistorisk"
 		}
 	}