Logger kun om korrelasjonsId'en er utbetalt tidligere 🪵

navikt · Jan 23, 2024 · babca3a · babca3a
1 parent a7fecfc
commit babca3a
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 3 deletions.
diff --git a/sykepenger-model/src/main/kotlin/no/nav/helse/serde/migration/V285LoggeRareAnnulleringer.kt b/sykepenger-model/src/main/kotlin/no/nav/helse/serde/migration/V285LoggeRareAnnulleringer.kt
@@ -16,16 +16,26 @@ internal class V285LoggeRareAnnulleringer(
 
         jsonNode.path("arbeidsgivere").forEach { arbeidsgiver ->
             val organisasjonsnummer = arbeidsgiver.path("organisasjonsnummer").asText()
+            val utbetalteKorrelasjonsIder = arbeidsgiver.path("utbetalinger")
+                .groupBy { it.path("korrelasjonsId").asText() }
+                .mapValues { (_, utbetalinger) ->
+                    utbetalinger.filter { it.path("type").asText() == "UTBETALING" && it.path("status").asText() == "UTBETALT" }
+                }.filterValues { it.isNotEmpty() }
+                .keys
+
+
             arbeidsgiver.path("utbetalinger")
+                .asSequence()
                 .filter { it.path("type").asText() == "ANNULLERING" }
                 .filter { it.path("status").asText() != "FORKASTET" }
                 .filter { LocalDateTime.parse(it.path("oppdatert").asText()).year < 2024 }
                 .filter { it.path("arbeidsgiverOppdrag").oppdragManglerOverføring || it.path("personOppdrag").oppdragManglerOverføring }
+                .filter { it.path("korrelasjonsId").asText() in utbetalteKorrelasjonsIder }
                 .forEach { manglerOverføring ->
                     val id = manglerOverføring.path("id").asText()
                     val nåværendeStatus = manglerOverføring.path("status").asText()
                     val oppdatert = LocalDateTime.parse(manglerOverføring.path("oppdatert").asText())
-                    sikkerLogg.warn("Annullering $id i Status $nåværendeStatus ser ikke ut til å være overført til Oppdrag (sist oppdatert $oppdatert). AktørId $aktørId, Organisasjonsnummer $organisasjonsnummer (Versjon2)")
+                    sikkerLogg.warn("Annullering $id i Status $nåværendeStatus ser ikke ut til å være overført til Oppdrag (sist oppdatert $oppdatert). AktørId $aktørId, Organisasjonsnummer $organisasjonsnummer (Versjon3)")
                     if (id in forkast) {
                         sikkerLogg.info("Setter status på Utbetaling $id til FORKASTET og setter nytt oppdatert-tidspunkt")
                         manglerOverføring as ObjectNode

diff --git a/...nger-model/src/test/kotlin/no/nav/helse/serde/migration/V285LoggeRareAnnulleringerTest.kt b/...nger-model/src/test/kotlin/no/nav/helse/serde/migration/V285LoggeRareAnnulleringerTest.kt
@@ -5,7 +5,7 @@ import org.junit.jupiter.api.Test
 
 internal class V285LoggeRareAnnulleringerTest: MigrationTest(V285LoggeRareAnnulleringer(
     forkast = setOf("52fc8116-1757-45bc-8ca1-d333b33d3496"),
-    forkastetTidspunkt = { LocalDateTime.parse("2024-01-23T08:15:00.00001") }
+    forkastetTidspunkt = { LocalDateTime.parse("2024-01-23T08:15:00.204957") }
 )) {
 
     @Test

diff --git a/sykepenger-model/src/test/resources/migrations/285/expected.json b/sykepenger-model/src/test/resources/migrations/285/expected.json
@@ -552,9 +552,10 @@
         },
         {
           "id": "52fc8116-1757-45bc-8ca1-d333b33d3496",
+          "korrelasjonsId": "45763d0d-363a-4076-bcff-78ab26d49bf8",
           "status": "FORKASTET",
           "type": "ANNULLERING",
-          "oppdatert": "2024-01-23T08:15:00.000010",
+          "oppdatert": "2024-01-23T08:15:00.204957",
           "personOppdrag": {
             "linjer": [{ "fom": "2018-01-01", "tom": "2018-12-31"}],
             "status": null
@@ -564,8 +565,15 @@
             "status": null
           }
         },
+        {
+          "id": "69e318df-521b-484d-a7d9-ea47db76684e",
+          "korrelasjonsId": "45763d0d-363a-4076-bcff-78ab26d49bf8",
+          "status": "UTBETALT",
+          "type": "UTBETALING"
+        },
         {
           "id": "a3e2aaf8-fc6b-4b43-aeeb-16f60f5a24f8",
+          "korrelasjonsId": "7a8925f9-6fce-4789-b688-2e686433d98b",
           "status": "GODKJENT_UTEN_UTBETALING",
           "type": "ANNULLERING",
           "oppdatert": "2022-10-13T14:20:20.204188",

diff --git a/sykepenger-model/src/test/resources/migrations/285/original.json b/sykepenger-model/src/test/resources/migrations/285/original.json
@@ -552,6 +552,7 @@
         },
         {
           "id": "52fc8116-1757-45bc-8ca1-d333b33d3496",
+          "korrelasjonsId": "45763d0d-363a-4076-bcff-78ab26d49bf8",
           "status": "GODKJENT_UTEN_UTBETALING",
           "type": "ANNULLERING",
           "oppdatert": "2022-10-13T14:20:20.204188",
@@ -564,8 +565,15 @@
             "status": null
           }
         },
+        {
+          "id": "69e318df-521b-484d-a7d9-ea47db76684e",
+          "korrelasjonsId": "45763d0d-363a-4076-bcff-78ab26d49bf8",
+          "status": "UTBETALT",
+          "type": "UTBETALING"
+        },
         {
           "id": "a3e2aaf8-fc6b-4b43-aeeb-16f60f5a24f8",
+          "korrelasjonsId": "7a8925f9-6fce-4789-b688-2e686433d98b",
           "status": "GODKJENT_UTEN_UTBETALING",
           "type": "ANNULLERING",
           "oppdatert": "2022-10-13T14:20:20.204188",