Revert "TSFF-163 Endringer i kontrakt mot los for å støtte oppgave v3 (…

…#1086)" This reverts commit add15a9.
navikt · Feb 15, 2024 · 647c542 · 647c542
1 parent fce8988
commit 647c542
Show file tree

Hide file tree

Showing 40 changed files with 226 additions and 345 deletions.
diff --git a/.github/workflows/deploy-kafka.yaml b/.github/workflows/deploy-kafka.yaml
@@ -14,7 +14,7 @@ jobs:
   deploy-topics:
     strategy:
       matrix:
-        topic: [punsjbar-journalpost, punsj-aksjonspunkthendelse-v1, k9-punsj-til-los]
+        topic: [punsjbar-journalpost, punsj-aksjonspunkthendelse-v1]
 
     runs-on: ubuntu-latest
     steps:

diff --git a/.gitignore b/.gitignore
@@ -32,9 +32,3 @@ build/
 
 .DS_Store
 **generated-pdf-*.pdf
-
-# CDXGEN files
-app.atom
-bom.*
-reachables.slices.json
-usages.slices.json
diff --git a/kafka/kafka-manager.yaml b/kafka/kafka-manager.yaml
@@ -6,7 +6,7 @@ metadata:
   labels:
     team: k9saksbehandling
 spec:
-  image: europe-north1-docker.pkg.dev/nais-management-233d/poao/kafka-manager:2023.12.13-06.32-bd9f953
+  image: europe-north1-docker.pkg.dev/nais-management-233d/poao/kafka-manager:2023.08.02-07.02-45dfb71
   port: 8080
   webproxy: true
   ingresses:
@@ -56,12 +56,6 @@ spec:
               "location": "AIVEN",
               "keyDeserializerType": "STRING",
               "valueDeserializerType": "STRING"
-            },
-            {
-              "name": "k9saksbehandling.k9-punsj-til-los",
-              "location": "AIVEN",
-              "keyDeserializerType": "STRING",
-              "valueDeserializerType": "STRING"
             }
           ]
         }
diff --git a/kafka/topics/k9-punsj-til-los.yaml b/kafka/topics/k9-punsj-til-los.yaml
diff --git a/nais/dev-fss.yml b/nais/dev-fss.yml
@@ -127,12 +127,6 @@ spec:
       value: "k9saksbehandling.punsj-aksjonspunkthendelse-v1"
     - name: SEND_BREVBESTILLING_TIL_K9_FORMIDLING
       value: "k9saksbehandling.k9-dokumenthendelse-v1"
-    - name: SEND_OPPDATERING_TIL_K9LOS
-      value: "k9saksbehandling.k9-punsj-til-los"
-    - name: K9_FORDEL_TOPIC
-      value: "k9saksbehandling.fordel-journalforing"
-    - name: K9_PUNSJBOLLE_TOPIC
-      value: "k9saksbehandling.punsjbar-journalpost"
 
     # Feature toggles
     - name: FERDIGSTILL_GOSYSOPPGAVE_ENABLED

diff --git a/nais/prod-fss.yml b/nais/prod-fss.yml
@@ -124,12 +124,6 @@ spec:
       value: "k9saksbehandling.punsj-aksjonspunkthendelse-v1"
     - name: SEND_BREVBESTILLING_TIL_K9_FORMIDLING
       value: "k9saksbehandling.k9-dokumenthendelse-v1"
-    - name: SEND_OPPDATERING_TIL_K9LOS
-      value: "k9saksbehandling.k9-punsj-til-los"
-    - name: K9_FORDEL_TOPIC
-      value: "k9saksbehandling.fordel-journalforing"
-    - name: K9_PUNSJBOLLE_TOPIC
-      value: "k9saksbehandling.punsjbar-journalpost"
 
     # Feature toggles
     - name: FERDIGSTILL_GOSYSOPPGAVE_ENABLED

diff --git a/src/main/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImpl.kt b/src/main/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImpl.kt
@@ -4,8 +4,7 @@ import com.fasterxml.jackson.module.kotlin.convertValue
 import kotlinx.coroutines.runBlocking
 import no.nav.k9punsj.domenetjenester.PersonService
 import no.nav.k9punsj.domenetjenester.SoknadService
-import no.nav.k9punsj.integrasjoner.k9losapi.K9LosOppgaveStatusDto
-import no.nav.k9punsj.integrasjoner.k9losapi.PunsjEventDto
+import no.nav.k9punsj.fordel.PunsjEventDto
 import no.nav.k9punsj.journalpost.JournalpostService
 import no.nav.k9punsj.journalpost.dto.PunsjJournalpost
 import no.nav.k9punsj.journalpost.dto.VentDto
@@ -27,7 +26,6 @@ internal class AksjonspunktServiceImpl(
     private val søknadsService: SoknadService,
     private val personService: PersonService,
     @Value("\${no.nav.kafka.k9_los.topic}") private val k9losAksjonspunkthendelseTopic: String,
-    @Value("\${no.nav.kafka.k9_punsj_til_los.topic}") private val k9PunsjTilLosTopic: String
 ) : AksjonspunktService {
 
     private companion object {
@@ -54,34 +52,19 @@ internal class AksjonspunktServiceImpl(
             aktørId = punsjJournalpost.aktørId,
             aksjonspunkter = mutableMapOf(aksjonspunktKode.kode to aksjonspunktStatus.kode),
             ytelse = ytelse,
-            type = punsjJournalpost.type!!
+            type = type
         )
 
-        log.info("Oppretter aksjonspunkt(" + aksjonspunktEntitet.aksjonspunktId + ") med kode (" + aksjonspunktEntitet.aksjonspunktKode.kode + ")")
-
         hendelseProducer.sendMedOnSuccess(
             topicName = k9losAksjonspunkthendelseTopic,
             data = punsjDtoJson,
             key = eksternId.toString()
         ) {
             runBlocking {
                 aksjonspunktRepository.opprettAksjonspunkt(aksjonspunktEntitet)
-                log.info("Sendt aksjonspunkt til los via topic $k9losAksjonspunkthendelseTopic")
+                log.info("Opprettet aksjonspunkt(" + aksjonspunktEntitet.aksjonspunktId + ") med kode (" + aksjonspunktEntitet.aksjonspunktKode.kode + ")")
             }
         }
-
-        hendelseProducer.sendMedOnSuccess(
-            topicName = k9PunsjTilLosTopic,
-            data = punsjDtoJson,
-            key = eksternId.toString()
-        ) {
-            runBlocking {
-                aksjonspunktRepository.opprettAksjonspunkt(aksjonspunktEntitet)
-                log.info("Sendt aksjonspunkt til los via topic $k9PunsjTilLosTopic")
-            }
-        }
-
-        log.info("Opprettet aksjonspunkt(" + aksjonspunktEntitet.aksjonspunktId + ") med kode (" + aksjonspunktEntitet.aksjonspunktKode.kode + ")")
     }
 
     override suspend fun settUtførtPåAltSendLukkOppgaveTilK9Los(
@@ -106,8 +89,7 @@ internal class AksjonspunktServiceImpl(
                 aktørId = journalpost.aktørId,
                 aksjonspunkter = mutableMap,
                 sendtInn = erSendtInn,
-                ferdigstiltAv = ansvarligSaksbehandler,
-                type = journalpost.type!!
+                ferdigstiltAv = ansvarligSaksbehandler
             )
 
             hendelseProducer.sendMedOnSuccess(
@@ -122,14 +104,6 @@ internal class AksjonspunktServiceImpl(
                     }
                 }
             }
-
-            hendelseProducer.sendMedOnSuccess(
-                topicName = k9PunsjTilLosTopic,
-                data = punsjDtoJson,
-                key = eksternId.toString()
-            ) {
-                // DO NOTHING
-            }
         }
     }
 
@@ -187,8 +161,7 @@ internal class AksjonspunktServiceImpl(
                     AksjonspunktKode.PUNSJ.kode to AksjonspunktStatus.UTFØRT.kode,
                     AksjonspunktKode.VENTER_PÅ_INFORMASJON.kode to AksjonspunktStatus.OPPRETTET.kode
                 ),
-                barnIdent = barnIdent,
-                type = journalpost.type!!
+                barnIdent = barnIdent
             )
 
             hendelseProducer.sendMedOnSuccess(
@@ -203,14 +176,6 @@ internal class AksjonspunktServiceImpl(
                     log.info("Opprettet aksjonspunkt(${aksjonspunktEntitet.aksjonspunktId}) med kode (${aksjonspunktEntitet.aksjonspunktKode.kode})")
                 }
             }
-
-            hendelseProducer.sendMedOnSuccess(
-                topicName = k9PunsjTilLosTopic,
-                data = punsjDtoJson,
-                key = eksternId.toString()
-            ) {
-                // DO NOTHING
-            }
         } else {
             // inntreffer der man går manuelt inn i punsj og ønsker å sette noe på vent, det finnes altså ingen punsje oppgave opprinnelig
             val ventePunkt =
@@ -223,8 +188,7 @@ internal class AksjonspunktServiceImpl(
                     aksjonspunkter = mutableMapOf(
                         AksjonspunktKode.VENTER_PÅ_INFORMASJON.kode to AksjonspunktStatus.OPPRETTET.kode
                     ),
-                    barnIdent = barnIdent,
-                    type = journalpost.type!!
+                    barnIdent = barnIdent
                 )
 
                 hendelseProducer.sendMedOnSuccess(
@@ -237,51 +201,12 @@ internal class AksjonspunktServiceImpl(
                         log.info("Opprettet aksjonspunkt(" + aksjonspunktEntitet.aksjonspunktId + ") med kode (" + aksjonspunktEntitet.aksjonspunktKode.kode + ")")
                     }
                 }
-
-                hendelseProducer.sendMedOnSuccess(
-                    topicName = k9PunsjTilLosTopic,
-                    data = punsjDtoJson,
-                    key = eksternId.toString()
-                ) {
-                    // DO NOTHING
-                }
             } else {
                 log.info("Denne journalposten($journalpostId) venter allerede - venter til ${ventePunkt?.frist_tid}")
             }
         }
     }
 
-    @Deprecated("Skall kun brukes for å hente ut journalposter som skal sendes til k9-los-api for ny oppgavemodell")
-    private suspend fun sendNåStatusTilLosForAlleJournalposter() {
-        val aapneJournalposter = journalpostService.hentÅpneJournalposter()
-
-        for (punsjJournalpost in aapneJournalposter) {
-            val aksjonspunkterPaJournalpost =
-                aksjonspunktRepository.hentAlleAksjonspunkter(punsjJournalpost.journalpostId).associate {
-                    it.aksjonspunktKode.kode to it.aksjonspunktStatus.kode
-                }
-
-            // TODO: Trenger mer info her? Finns det en bedre måte og sende journalpost på?
-            val punsjDtoJson = lagPunsjDto(
-                eksternId = punsjJournalpost.uuid,
-                journalpostId = punsjJournalpost.journalpostId,
-                ytelse = punsjJournalpost.ytelse,
-                aktørId = punsjJournalpost.aktørId,
-                barnIdent = null,
-                type = punsjJournalpost.type!!,
-                aksjonspunkter = aksjonspunkterPaJournalpost
-            )
-            hendelseProducer.sendMedOnSuccess(
-                topicName = k9PunsjTilLosTopic,
-                data = punsjDtoJson,
-                key = punsjJournalpost.uuid.toString()
-            ) {
-                // DO NOTHING
-            }
-        }
-
-    }
-
     private suspend fun utledAktørId(søknadId: String?, punsjJournalpost: PunsjJournalpost): String? {
         if (søknadId == null) {
             return punsjJournalpost.aktørId
@@ -301,14 +226,12 @@ internal class AksjonspunktServiceImpl(
         eksternId: UUID,
         journalpostId: String,
         aktørId: String?,
-        aksjonspunkter: Map<String, String>,
+        aksjonspunkter: MutableMap<String, String>,
         ytelse: String? = null,
-        type: String,
+        type: String? = null,
         barnIdent: String? = null,
         sendtInn: Boolean? = null,
-        ferdigstiltAv: String? = null,
-        mottattDato: LocalDateTime? = null,
-        status: K9LosOppgaveStatusDto? = null
+        ferdigstiltAv: String? = null
     ): String {
         val punsjEventDto = PunsjEventDto(
             eksternId = eksternId.toString(),
@@ -320,9 +243,7 @@ internal class AksjonspunktServiceImpl(
             ytelse = ytelse,
             type = type,
             sendtInn = sendtInn,
-            ferdigstiltAv = ferdigstiltAv,
-            mottattDato = mottattDato,
-            status = status
+            ferdigstiltAv = ferdigstiltAv
         )
 
         return objectMapper().writeValueAsString(punsjEventDto)

diff --git a/src/main/kotlin/no/nav/k9punsj/fordel/HendelseMottaker.kt b/src/main/kotlin/no/nav/k9punsj/fordel/HendelseMottaker.kt
@@ -31,7 +31,7 @@ class HendelseMottaker @Autowired constructor(
 
         if (journalpostIkkeEksisterer) {
             val aktørId = fordelPunsjEventDto.aktørId
-            val punsjEventType = K9FordelType.fraKode(fordelPunsjEventDto.type).kode
+            val punsjEventType = PunsjInnsendingType.fraKode(fordelPunsjEventDto.type).kode
             val ytelse = FagsakYtelseType.fromKode(fordelPunsjEventDto.ytelse).kode
             val gosysoppgaveId = fordelPunsjEventDto.gosysoppgaveId
 
@@ -55,10 +55,10 @@ class HendelseMottaker @Autowired constructor(
                 ytelse = fordelPunsjEventDto.ytelse
             )
         } else {
-            if (K9FordelType.fraKode(fordelPunsjEventDto.type) == K9FordelType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG) {
+            if (PunsjInnsendingType.fraKode(fordelPunsjEventDto.type) == PunsjInnsendingType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG) {
                 val journalpostFraDb = journalpostService.hent(journalpostId)
-                if (journalpostFraDb.type != null && K9FordelType.fraKode(journalpostFraDb.type) != K9FordelType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG) {
-                    journalpostService.settInnsendingstype(K9FordelType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG, journalpostId)
+                if (journalpostFraDb.type != null && PunsjInnsendingType.fraKode(journalpostFraDb.type) != PunsjInnsendingType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG) {
+                    journalpostService.settInnsendingstype(PunsjInnsendingType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG, journalpostId)
                     aksjonspunktService.settUtførtPåAltSendLukkOppgaveTilK9Los(journalpostId, false, null)
                 } else {
                     log.info("Journalposten($journalpostId) kjenner punsj fra før, blir ikke laget ny oppgave")

diff --git a/src/main/kotlin/no/nav/k9punsj/fordel/K9LosOppgaveDto.kt b/src/main/kotlin/no/nav/k9punsj/fordel/K9LosOppgaveDto.kt
@@ -0,0 +1,16 @@
+package no.nav.k9punsj.fordel
+
+import java.time.LocalDateTime
+
+data class PunsjEventDto(
+    val eksternId: String,
+    val journalpostId: String,
+    val aktørId: String?,
+    val eventTid: LocalDateTime,
+    val aksjonspunktKoderMedStatusListe: MutableMap<String, String>,
+    val pleietrengendeAktørId: String? = null,
+    val type: String? = null,
+    val ytelse: String? = null,
+    val sendtInn: Boolean? = null,
+    val ferdigstiltAv: String? = null
+)
diff --git a/...in/no/nav/k9punsj/kafka/KafkaConsumers.kt → ...n/no/nav/k9punsj/fordel/KafkaConsumers.kt b/...in/no/nav/k9punsj/kafka/KafkaConsumers.kt → ...n/no/nav/k9punsj/fordel/KafkaConsumers.kt
@@ -1,20 +1,16 @@
-package no.nav.k9punsj.kafka
+package no.nav.k9punsj.fordel
 
 import kotlinx.coroutines.runBlocking
 import no.nav.k9punsj.StandardProfil
 import no.nav.k9punsj.fordel.FordelPunsjEventDto.Companion.somFordelPunsjEventDto
-import no.nav.k9punsj.fordel.HendelseMottaker
-import org.springframework.beans.factory.annotation.Value
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.stereotype.Component
 import java.io.IOException
 
 @Component
 @StandardProfil
 class KafkaConsumers(
-    val hendelseMottaker: HendelseMottaker,
-    @Value("\${no.nav.kafka.k9_punsjbolle.topic}") private val meldingerFraPunsjbolleTopic: String,
-    @Value("\${no.nav.kafka.k9_fordel.topic}") private val meldingerFraFordelTopic: String,
+    val hendelseMottaker: HendelseMottaker
 ) {
 
     @KafkaListener(
@@ -24,7 +20,7 @@ class KafkaConsumers(
     )
     @Throws(IOException::class)
     fun consumePunsjbarJournalpost(message: String) {
-        runBlocking { hendelseMottaker.prosesser(message.somFordelPunsjEventDto(meldingerFraPunsjbolleTopic)) }
+        runBlocking { hendelseMottaker.prosesser(message.somFordelPunsjEventDto(PUNSJBOLLE_TOPIC)) }
     }
 
     @KafkaListener(
@@ -34,7 +30,7 @@ class KafkaConsumers(
     )
     @Throws(IOException::class)
     fun consumeFordelJournalpost(message: String) {
-        runBlocking { hendelseMottaker.prosesser(message.somFordelPunsjEventDto(meldingerFraFordelTopic)) }
+        runBlocking { hendelseMottaker.prosesser(message.somFordelPunsjEventDto(FORDEL_TOPIC)) }
     }
 
     private companion object {

diff --git a/...lin/no/nav/k9punsj/fordel/K9FordelType.kt → ...nav/k9punsj/fordel/PunsjInnsendingType.kt b/...lin/no/nav/k9punsj/fordel/K9FordelType.kt → ...nav/k9punsj/fordel/PunsjInnsendingType.kt
@@ -3,14 +3,8 @@ package no.nav.k9punsj.fordel
 import com.fasterxml.jackson.annotation.JsonCreator
 import com.fasterxml.jackson.annotation.JsonFormat
 
-/*
-*
-* Dette er en kontrakt som settes av K9-Fordel
-* https://github.com/navikt/k9-fordel/blob/323140f23a7ee80e32943fbaad8081265478b8b1/fordel/domene/src/main/java/no/nav/k9/domenetjenester/punsj/PunsjInnsendingType.java
-*
- */
 @JsonFormat(shape = JsonFormat.Shape.OBJECT)
-enum class K9FordelType(val kode: String, val navn: String, val erScanning: Boolean) {
+enum class PunsjInnsendingType(val kode: String, val navn: String, val erScanning: Boolean) {
     PAPIRSØKNAD("PAPIRSØKNAD", "Papirsøknad", true),
     DIGITAL_SØKNAD("DIGITAL_SØKNAD", "Digital søknad", false),
     PAPIRETTERSENDELSE("PAPIRETTERSENDELSE", "Papirettersendelse", true),
@@ -29,7 +23,7 @@ enum class K9FordelType(val kode: String, val navn: String, val erScanning: Bool
     companion object {
         @JsonCreator
         @JvmStatic
-        fun fraKode(kode: String): K9FordelType = values().find {
+        fun fraKode(kode: String): PunsjInnsendingType = values().find {
             it.kode == kode
         } ?: UKJENT