EY-4905 avbryt annulerte behandlinger (#6747)

* Rydder bort "spøkelsesbehandlinger" som kun finnes i statistikk

* Legger på litt ekstra logging for å identifisere nye tilfeller

Av tilbakestilte behandlinger, slik at det er mulig å få med seg at det skjer på nytt.

* annulert -> annullert

* Bruker enum for avbrutt

* Legger på en ekstra try/catch for å unngå spam

I tilfelle noe brekker

* Rekjører rydding med faktisk riktig rydding

* Logger fra gjennomføringen

apps/etterlatte-statistikk/src/main/kotlin/statistikk/database/SakRepository.kt

@@ -138,6 +138,19 @@ class SakRepository(
                     }
             statement.executeQuery().toList { tilSakRad() }
         }
+
+    fun slettRad(id: Long) {
+        datasource.connection.use { connection ->
+            val statement =
+                connection.prepareStatement(
+                    """
+                    DELETE FROM sak WHERE id = ?
+                    """.trimIndent(),
+                )
+            statement.setLong(1, id)
+            statement.executeUpdate()
+        }
+    }
 }
 
 private fun PreparedStatement.setSakRad(sakRad: SakRad): PreparedStatement =

apps/etterlatte-statistikk/src/main/kotlin/statistikk/jobs/AvbrytAnnullerteBehandlingerJobb.kt

@@ -94,22 +94,30 @@ class AvbrytAnnullerteBehandlingerJobb(
                     .forEach {
                         try {
                             val rader = sakRepository.hentRaderForBehandlingId(it)
-                            val aktuellRad = rader.singleOrNull()
-                            if (aktuellRad == null) {
+                            if (rader.size != 2) {
                                 logger.warn(
                                     "Kunne ikke avbryte behandling som er rullet tilbake i behandling, siden vi har " +
                                         "${rader.size} rader registrert for id=$it.",
                                 )
                                 annulerteDao.lagreFikset(it)
                                 return@forEach
                             }
-                            aktuellRad.copy(
-                                status = BehandlingStatus.AVBRUTT.name,
-                                resultat = BehandlingStatus.AVBRUTT.name,
-                                resultatBegrunnelse = "BEHANDLING_RULLET_TILBAKE",
-                                ferdigbehandletTidspunkt = aktuellRad.tekniskTid,
+                            val aktuellRad = rader.minBy { rad -> rad.id }
+                            val radSomSkalFjernes = rader.maxBy { rad -> rad.id }
+                            val oppdatertRad =
+                                aktuellRad.copy(
+                                    status = BehandlingStatus.AVBRUTT.name,
+                                    resultat = BehandlingStatus.AVBRUTT.name,
+                                    resultatBegrunnelse = "BEHANDLING_RULLET_TILBAKE",
+                                    ferdigbehandletTidspunkt = aktuellRad.tekniskTid,
+                                )
+                            logger.info(
+                                "Fant 2 rader for behandling med id $it, med id ${aktuellRad.id} (original) " +
+                                    "og ${radSomSkalFjernes.id} (feil oppdatert). Oppdaterer med en ny rad basert " +
+                                    "på ${aktuellRad.id}, og sletter rad med id ${radSomSkalFjernes.id}",
                             )
-                            sakRepository.lagreRad(aktuellRad)
+                            sakRepository.slettRad(radSomSkalFjernes.id)
+                            sakRepository.lagreRad(oppdatertRad)
                             annulerteDao.lagreFikset(it)
                         } catch (e: Exception) {
                             logger.warn(

apps/etterlatte-statistikk/src/main/resources/db/migration/V57__rekjoer_fiksing.sql

@@ -0,0 +1,2 @@
+-- ryddingen må rekjøres med riktig / oppdatert kode, siden den ikke ryddet riktig
+update tilbakestilte_behandlinger set ryddet = false where ryddet = true;