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

…#1086)"

This reverts commit add15a9.

.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:

.gitignore

@@ -32,9 +32,3 @@ build/
 
 .DS_Store
 **generated-pdf-*.pdf
-
-# CDXGEN files
-app.atom
-bom.*
-reachables.slices.json
-usages.slices.json

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"
  }
  ]
  }

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

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

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)

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")

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
+)

src/main/kotlin/no/nav/k9punsj/kafka/KafkaConsumers.kt → src/main/kotlin/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 {

src/main/kotlin/no/nav/k9punsj/fordel/K9FordelType.kt → src/main/kotlin/no/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