From 025bebaca8d0c946bf1ebb4ecd41d5d51228401b Mon Sep 17 00:00:00 2001 From: sigurdgroneng Date: Fri, 8 Mar 2024 10:23:07 +0100 Subject: [PATCH] Remove OpprettSingleHistorisk --- .../DeletedMessagesFixSchedule.kt | 14 +++----- .../historiserteDeltakerFix/FixMetode.kt | 36 +++++-------------- .../HistoriskDeltakelseRepo.kt | 3 +- 3 files changed, 14 insertions(+), 39 deletions(-) diff --git a/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/DeletedMessagesFixSchedule.kt b/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/DeletedMessagesFixSchedule.kt index 4a98697..35d3a54 100644 --- a/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/DeletedMessagesFixSchedule.kt +++ b/src/main/kotlin/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 index ac3236b..87f2c59 100644 --- 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/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/HistoriskDeltakelseRepo.kt b/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/HistoriskDeltakelseRepo.kt index 14104f6..d5a2009 100644 --- a/src/main/kotlin/no/nav/arena_tiltak_aktivitet_acl/historiserteDeltakerFix/HistoriskDeltakelseRepo.kt +++ b/src/main/kotlin/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" } }