From 647c5428e1e4f788d4706a2816b2af88cae1da1a Mon Sep 17 00:00:00 2001 From: Ramin Esfandiari Date: Thu, 15 Feb 2024 14:59:43 +0100 Subject: [PATCH] =?UTF-8?q?Revert=20"TSFF-163=20Endringer=20i=20kontrakt?= =?UTF-8?q?=20mot=20los=20for=20=C3=A5=20st=C3=B8tte=20oppgave=20v3=20(#10?= =?UTF-8?q?86)"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit add15a9e338cfb8097db526deac717ba42b882a2. --- .github/workflows/deploy-kafka.yaml | 2 +- .gitignore | 6 -- kafka/kafka-manager.yaml | 8 +- kafka/topics/k9-punsj-til-los.yaml | 28 ------ nais/dev-fss.yml | 6 -- nais/prod-fss.yml | 6 -- .../akjonspunkter/AksjonspunktServiceImpl.kt | 99 ++----------------- .../no/nav/k9punsj/fordel/HendelseMottaker.kt | 8 +- .../no/nav/k9punsj/fordel/K9LosOppgaveDto.kt | 16 +++ .../{kafka => fordel}/KafkaConsumers.kt | 12 +-- ...K9FordelType.kt => PunsjInnsendingType.kt} | 10 +- .../integrasjoner/k9losapi/K9LosOppgaveDto.kt | 18 ---- .../k9losapi/K9LosOppgaveStatusDto.kt | 9 -- .../jobber/SjekkOmUtl\303\270ptJobb.kt" | 17 +--- .../journalpost/JournalpostRepository.kt | 21 +--- .../k9punsj/journalpost/JournalpostRoutes.kt | 10 +- .../k9punsj/journalpost/JournalpostService.kt | 9 +- .../nav/k9punsj/journalpost/VirkedagerUtil.kt | 4 +- .../journalpost/dto/JournalpostInfoDto.kt | 6 +- .../journalpost/dto/PunsjJournalpost.kt | 3 +- .../metrikker/JournalpostMetrikkRepository.kt | 14 +-- .../kotlin/no/nav/k9punsj/openapi/OpenApi.kt | 12 ++- src/main/resources/application.yml | 6 -- .../no/nav/k9punsj/MockConfiguration.kt | 5 +- src/test/kotlin/no/nav/k9punsj/TestSetup.kt | 19 ++++ .../AksjonspunktServiceImplTest.kt | 2 +- .../brev/BrevRoutesConfigurationTest.kt | 4 +- .../no/nav/k9punsj/fordel/FordelKafkaTest.kt | 7 +- .../k9punsj/fordel/FordelPunsjEventDtoTest.kt | 2 +- .../k9punsj/fordel/HendelseMottakerTest.kt | 20 ++-- .../no/nav/k9punsj/jobber/MetrikkJobbTest.kt | 47 ++++----- .../jobber/SjekkOmUtl\303\270ptJobbTest.kt" | 1 - .../journalpost/KopierJournalpostRouteTest.kt | 8 +- .../PunsjJournalpostMetrikkRepositoryTest.kt | 45 ++++----- .../PunsjJournalpostRepositoryTest.kt | 18 ++-- .../k9punsj/journalpost/VirkedagerUtilTest.kt | 6 +- .../OpplaeringspengerTests.kt | 38 +++++++ .../no/nav/k9punsj/person/BarnApiTest.kt | 5 + .../server/PunsjJournalpostInfoRoutesTest.kt | 7 ++ src/test/resources/application-test.yaml | 7 +- 40 files changed, 226 insertions(+), 345 deletions(-) delete mode 100644 kafka/topics/k9-punsj-til-los.yaml create mode 100644 src/main/kotlin/no/nav/k9punsj/fordel/K9LosOppgaveDto.kt rename src/main/kotlin/no/nav/k9punsj/{kafka => fordel}/KafkaConsumers.kt (71%) rename src/main/kotlin/no/nav/k9punsj/fordel/{K9FordelType.kt => PunsjInnsendingType.kt} (79%) delete mode 100644 src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveDto.kt delete mode 100644 src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveStatusDto.kt create mode 100644 src/test/kotlin/no/nav/k9punsj/TestSetup.kt diff --git a/.github/workflows/deploy-kafka.yaml b/.github/workflows/deploy-kafka.yaml index 1942de82c..7aa287143 100644 --- 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 index 369f7a47a..95ba194a8 100644 --- 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 \ No newline at end of file diff --git a/kafka/kafka-manager.yaml b/kafka/kafka-manager.yaml index 8e22e63dc..3718e0491 100644 --- 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 deleted file mode 100644 index f7514e0b8..000000000 --- a/kafka/topics/k9-punsj-til-los.yaml +++ /dev/null @@ -1,28 +0,0 @@ -apiVersion: kafka.nais.io/v1 -kind: Topic -metadata: - name: k9-punsj-til-los - namespace: k9saksbehandling - labels: - team: k9saksbehandling -spec: - pool: {{pool}} - config: - cleanupPolicy: delete - minimumInSyncReplicas: 1 - partitions: 3 - replication: 2 - retentionBytes: -1 - retentionHours: 720 - acl: - - team: k9saksbehandling - application: k9-punsj - access: write - - team: k9saksbehandling - application: k9-los-api - access: read - {{#if enablekafkamanager}} - - team: k9saksbehandling - application: k9-kafka-manager - access: readwrite - {{/if}} \ No newline at end of file diff --git a/nais/dev-fss.yml b/nais/dev-fss.yml index 9351832f0..75467c6e2 100644 --- 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 index c91ad0cab..fb3c667e2 100644 --- 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 index 05f1d67af..87321f6ac 100644 --- 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,11 +52,9 @@ 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, @@ -66,22 +62,9 @@ internal class AksjonspunktServiceImpl( ) { 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, + aksjonspunkter: MutableMap, 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 index 9010012f8..b55e3e2a7 100644 --- 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 new file mode 100644 index 000000000..0bcc11b62 --- /dev/null +++ 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, + val pleietrengendeAktørId: String? = null, + val type: String? = null, + val ytelse: String? = null, + val sendtInn: Boolean? = null, + val ferdigstiltAv: String? = null +) diff --git a/src/main/kotlin/no/nav/k9punsj/kafka/KafkaConsumers.kt b/src/main/kotlin/no/nav/k9punsj/fordel/KafkaConsumers.kt similarity index 71% rename from src/main/kotlin/no/nav/k9punsj/kafka/KafkaConsumers.kt rename to src/main/kotlin/no/nav/k9punsj/fordel/KafkaConsumers.kt index 5946f55c4..48f530a7a 100644 --- a/src/main/kotlin/no/nav/k9punsj/kafka/KafkaConsumers.kt +++ b/src/main/kotlin/no/nav/k9punsj/fordel/KafkaConsumers.kt @@ -1,10 +1,8 @@ -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 @@ -12,9 +10,7 @@ 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/src/main/kotlin/no/nav/k9punsj/fordel/K9FordelType.kt b/src/main/kotlin/no/nav/k9punsj/fordel/PunsjInnsendingType.kt similarity index 79% rename from src/main/kotlin/no/nav/k9punsj/fordel/K9FordelType.kt rename to src/main/kotlin/no/nav/k9punsj/fordel/PunsjInnsendingType.kt index 3eead7bca..edddcfbf0 100644 --- a/src/main/kotlin/no/nav/k9punsj/fordel/K9FordelType.kt +++ b/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 diff --git a/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveDto.kt b/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveDto.kt deleted file mode 100644 index f95517be2..000000000 --- a/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveDto.kt +++ /dev/null @@ -1,18 +0,0 @@ -package no.nav.k9punsj.integrasjoner.k9losapi - -import java.time.LocalDateTime - -data class PunsjEventDto( - val eksternId: String, // Unik id i journalpostId - val journalpostId: String, - val aktørId: String?, - val eventTid: LocalDateTime, // Brukes av LOS for å differensiere versjon, mappes til ekstern_versjon - val aksjonspunktKoderMedStatusListe: Map, // Slettes når los er over på ny modell og bruker K9LosOppgaveStatusDto - val pleietrengendeAktørId: String? = null, // Slettes om vi ikke trenger funksjonalitet på og reservere oppgaver på tvers av pleietrengende. - val type: String, // Skall ikke vara nullable, null = ukjent - val ytelse: String? = null, - val sendtInn: Boolean? = null, // Slettes, erstattes med status UTFØRT - val ferdigstiltAv: String? = null, // Slettes - val mottattDato: LocalDateTime? = null, - val status: K9LosOppgaveStatusDto? = null -) \ No newline at end of file diff --git a/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveStatusDto.kt b/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveStatusDto.kt deleted file mode 100644 index b96509077..000000000 --- a/src/main/kotlin/no/nav/k9punsj/integrasjoner/k9losapi/K9LosOppgaveStatusDto.kt +++ /dev/null @@ -1,9 +0,0 @@ -package no.nav.k9punsj.integrasjoner.k9losapi - -/* -* Disse mappes om til riktig format i k9-los-api. -* Skall på sikt erstattes av kontrakt fra k9-los-api (eller andre veien) - */ -enum class K9LosOppgaveStatusDto { - AAPEN, VENTER, LUKKET; -} diff --git "a/src/main/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobb.kt" "b/src/main/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobb.kt" index 09a87e5fc..2a5c8b953 100644 --- "a/src/main/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobb.kt" +++ "b/src/main/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobb.kt" @@ -5,8 +5,7 @@ import no.nav.k9punsj.akjonspunkter.AksjonspunktEntitet import no.nav.k9punsj.akjonspunkter.AksjonspunktKode import no.nav.k9punsj.akjonspunkter.AksjonspunktRepository import no.nav.k9punsj.akjonspunkter.AksjonspunktStatus -import no.nav.k9punsj.fordel.K9FordelType -import no.nav.k9punsj.integrasjoner.k9losapi.PunsjEventDto +import no.nav.k9punsj.fordel.PunsjEventDto import no.nav.k9punsj.journalpost.JournalpostRepository import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.kafka.HendelseProducer @@ -24,8 +23,7 @@ class SjekkOmUtløptJobb @Autowired constructor( val aksjonspunktRepository: AksjonspunktRepository, val hendelseProducer: HendelseProducer, val journalpostRepository: JournalpostRepository, - @Value("\${no.nav.kafka.k9_los.topic}") private val k9losAksjonspunkthendelseTopic: String, - @Value("\${no.nav.kafka.k9_punsj_til_los.topic}") private val k9PunsjTilLosTopic: String + @Value("\${no.nav.kafka.k9_los.topic}") private val k9losAksjonspunkthendelseTopic: String ) { private val logger = LoggerFactory.getLogger(SjekkOmUtløptJobb::class.java) @@ -67,11 +65,10 @@ class SjekkOmUtløptJobb @Autowired constructor( journalpostId = punsjJournalpost.journalpostId, eventTid = LocalDateTime.now(), aktørId = punsjJournalpost.aktørId, - aksjonspunktKoderMedStatusListe = mapOf( + aksjonspunktKoderMedStatusListe = mutableMapOf( aksjonspunkt.aksjonspunktKode.kode to AksjonspunktStatus.UTFØRT.kode, AksjonspunktKode.PUNSJ_HAR_UTLØPT.kode to AksjonspunktStatus.OPPRETTET.kode - ), - type = punsjJournalpost.type ?: K9FordelType.UKJENT.kode + ) ) ) hendelseProducer.send( @@ -79,11 +76,5 @@ class SjekkOmUtløptJobb @Autowired constructor( data = punsjEventJson, key = punsjJournalpost.uuid.toString() ) - - hendelseProducer.send( - topicName = k9PunsjTilLosTopic, - data = punsjEventJson, - key = punsjJournalpost.uuid.toString() - ) } } diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRepository.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRepository.kt index 2d37e7a11..62daf67b9 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRepository.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRepository.kt @@ -3,7 +3,8 @@ package no.nav.k9punsj.journalpost import kotliquery.queryOf import kotliquery.sessionOf import kotliquery.using -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.felles.FagsakYtelseType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.journalpost.dto.PunsjJournalpostKildeType import no.nav.k9punsj.utils.objectMapper @@ -222,7 +223,7 @@ class JournalpostRepository(private val dataSource: DataSource) { } } - suspend fun settInnsendingstype(type: K9FordelType, journalpostId: String) { + suspend fun settInnsendingstype(type: PunsjInnsendingType, journalpostId: String) { val journalpost = hentHvis(journalpostId) if (journalpost != null) { val medType = journalpost.copy(type = type.kode) @@ -251,20 +252,4 @@ class JournalpostRepository(private val dataSource: DataSource) { return !using.contains(true) } - - @Deprecated("Skall kun brukes for å hente ut journalposter som skal sendes til k9-los-api for ny oppgavemodell") - fun hentÅpneJournalposter(): List { - return using(sessionOf(dataSource)) { - val statement = queryOf( - "SELECT DATA FROM $JOURNALPOST_TABLE WHERE FERDIG_BEHANDLET IS FALSE" - ) - val resultat = it.run( - statement - .map { row -> - row.string("data") - }.asList - ) - resultat.map { res -> objectMapper.readValue(res, PunsjJournalpost::class.java) } - } - } } diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRoutes.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRoutes.kt index 738a42b63..4e5c26085 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRoutes.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostRoutes.kt @@ -11,7 +11,7 @@ import no.nav.k9punsj.felles.Identitetsnummer.Companion.somIdentitetsnummer import no.nav.k9punsj.felles.IkkeFunnet import no.nav.k9punsj.felles.IkkeStøttetJournalpost import no.nav.k9punsj.felles.IkkeTilgang -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.innsending.InnsendingClient import no.nav.k9punsj.integrasjoner.dokarkiv.SafDtos import no.nav.k9punsj.integrasjoner.gosys.GosysService @@ -103,7 +103,7 @@ internal class JournalpostRoutes( } val punsjJournalpost = journalpostService.hentHvisJournalpostMedId(journalpostId = journalpostId) - val k9FordelType = punsjJournalpost?.type?.let { K9FordelType.fraKode(it) } + val punsjInnsendingType = punsjJournalpost?.type?.let { PunsjInnsendingType.fraKode(it) } val kanOpprettesJournalforingsOppgave = (journalpostInfo.journalpostType == SafDtos.JournalpostType.I.name && @@ -117,7 +117,7 @@ internal class JournalpostRoutes( norskIdent = norskIdent, dokumenter = journalpostInfo.dokumenter, venter = aksjonspunktService.sjekkOmDenErPåVent(journalpostId = journalpostId), - punsjInnsendingType = k9FordelType, + punsjInnsendingType = punsjInnsendingType, kanSendeInn = journalpostService.kanSendeInn(listOf(journalpostId)), erSaksbehandler = pepClient.erSaksbehandler(), erInngående = journalpostInfo.erInngående, @@ -175,7 +175,7 @@ internal class JournalpostRoutes( dokumenter = dok, dato = it.mottattDato?.toLocalDate(), klokkeslett = it.mottattDato?.toLocalTime(), - punsjInnsendingType = if (it.type != null) K9FordelType.fraKode(it.type) else null + punsjInnsendingType = if (it.type != null) PunsjInnsendingType.fraKode(it.type) else null ) }.toList() @@ -392,7 +392,7 @@ internal class JournalpostRoutes( val fagsakYtelseType = FagsakYtelseType.fromKode(journalpost.ytelse) - if (journalpost?.type != null && journalpost.type == K9FordelType.INNTEKTSMELDING_UTGÅTT.kode) { + if (journalpost?.type != null && journalpost.type == PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT.kode) { return@RequestContext kanIkkeKopieres("Kan ikke kopier journalpost med type inntektsmelding utgått.") } diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostService.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostService.kt index 912d9477c..3ff627448 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostService.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/JournalpostService.kt @@ -9,7 +9,7 @@ import no.nav.k9punsj.felles.IkkeTilgang import no.nav.k9punsj.felles.Sak import no.nav.k9punsj.felles.dto.JournalposterDto import no.nav.k9punsj.felles.dto.SøknadEntitet -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.integrasjoner.dokarkiv.DokarkivGateway import no.nav.k9punsj.integrasjoner.dokarkiv.Dokument import no.nav.k9punsj.integrasjoner.dokarkiv.JournalPostRequest @@ -270,14 +270,9 @@ class JournalpostService( return journalpostRepository.opprettJournalpost(jp) } - internal suspend fun settInnsendingstype(type: K9FordelType, journalpostId: String) { + internal suspend fun settInnsendingstype(type: PunsjInnsendingType, journalpostId: String) { journalpostRepository.settInnsendingstype(type, journalpostId) } - - @Deprecated("Skall kun brukes for å hente ut journalposter som skal sendes til k9-los-api for ny oppgavemodell") - internal suspend fun hentÅpneJournalposter(): List { - return journalpostRepository.hentÅpneJournalposter() - } } private fun SafDtos.Journalpost.parseJournalpost(): ParsedSafJournalpost { diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtil.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtil.kt index d1fb33002..e9c40143c 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtil.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtil.kt @@ -1,6 +1,6 @@ package no.nav.k9punsj.journalpost -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import java.time.DayOfWeek import java.time.LocalDateTime @@ -19,7 +19,7 @@ internal class VirkedagerUtil { if (type == null) { return mottattDato } - if (K9FordelType.sjekkOmDetErScanning(type)) { + if (PunsjInnsendingType.sjekkOmDetErScanning(type)) { return mottattDato.trekkFraToVirkeDager() } return mottattDato diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/dto/JournalpostInfoDto.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/dto/JournalpostInfoDto.kt index 1f72e7d4e..e4c356f02 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/dto/JournalpostInfoDto.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/dto/JournalpostInfoDto.kt @@ -1,21 +1,21 @@ package no.nav.k9punsj.journalpost.dto import com.fasterxml.jackson.annotation.JsonIgnore -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType data class JournalpostInfoDto( val journalpostId: String, val norskIdent: String?, val dokumenter: List, val venter: VentDto?, - val punsjInnsendingType: K9FordelType?, // Kan ikke bytte navn på denne, brukes av frontend? + val punsjInnsendingType: PunsjInnsendingType?, @JsonIgnore val erInngående: Boolean, val kanSendeInn: Boolean, val erSaksbehandler: Boolean? = null, val journalpostStatus: String, val kanOpprettesJournalføringsoppgave: Boolean, // Brukes av frontend - val kanKopieres: Boolean = punsjInnsendingType != K9FordelType.KOPI && erInngående, // Brukes av frontend, + val kanKopieres: Boolean = punsjInnsendingType != PunsjInnsendingType.KOPI && erInngående, // Brukes av frontend, val erFerdigstilt: Boolean, // Brukes av frontend for å bestemme om ytelse å fagsak må settes før punsjing. (Ref: Postmottak) val gosysoppgaveId: String?, ) diff --git a/src/main/kotlin/no/nav/k9punsj/journalpost/dto/PunsjJournalpost.kt b/src/main/kotlin/no/nav/k9punsj/journalpost/dto/PunsjJournalpost.kt index 16e8906cc..41997a77b 100644 --- a/src/main/kotlin/no/nav/k9punsj/journalpost/dto/PunsjJournalpost.kt +++ b/src/main/kotlin/no/nav/k9punsj/journalpost/dto/PunsjJournalpost.kt @@ -1,7 +1,6 @@ package no.nav.k9punsj.journalpost.dto import no.nav.k9.kodeverk.behandling.FagsakYtelseType -import no.nav.k9punsj.fordel.K9FordelType import org.slf4j.LoggerFactory import java.time.LocalDateTime import java.util.UUID @@ -14,7 +13,7 @@ data class PunsjJournalpost( val aktørId: String?, val skalTilK9: Boolean? = null, val mottattDato: LocalDateTime? = null, - val type: String? = K9FordelType.UKJENT.kode, + val type: String? = null, val gosysoppgaveId: String? = null, val ytelse: String? = null, val payload: String? = null, diff --git a/src/main/kotlin/no/nav/k9punsj/metrikker/JournalpostMetrikkRepository.kt b/src/main/kotlin/no/nav/k9punsj/metrikker/JournalpostMetrikkRepository.kt index 15b583e53..a46da3aa4 100644 --- a/src/main/kotlin/no/nav/k9punsj/metrikker/JournalpostMetrikkRepository.kt +++ b/src/main/kotlin/no/nav/k9punsj/metrikker/JournalpostMetrikkRepository.kt @@ -3,7 +3,7 @@ package no.nav.k9punsj.metrikker import kotliquery.queryOf import kotliquery.sessionOf import kotliquery.using -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import org.slf4j.LoggerFactory import org.springframework.stereotype.Repository import javax.sql.DataSource @@ -31,7 +31,7 @@ class JournalpostMetrikkRepository(private val dataSource: DataSource) { } } - suspend fun hentAntallJournalposttyper(): List> { + suspend fun hentAntallJournalposttyper(): List> { return using(sessionOf(dataSource)) { session -> session.transaction { tx -> //language=PostgreSQL @@ -41,11 +41,11 @@ class JournalpostMetrikkRepository(private val dataSource: DataSource) { ).map { row -> val antall = row.int("antall") val type = row.stringOrNull("type")?.replace("\"", "") // fjerner ekstra fnutter "" - val k9FordelType = type?.let { - if ("null" == it) K9FordelType.UKJENT - else K9FordelType.fraKode(it) - } ?: K9FordelType.UKJENT - Pair(antall, k9FordelType) + val punsjInnsendingType = type?.let { + if ("null" == it) PunsjInnsendingType.UKJENT + else PunsjInnsendingType.fraKode(it) + } ?: PunsjInnsendingType.UKJENT + Pair(antall, punsjInnsendingType) }.asList ) return@transaction antallTyper diff --git a/src/main/kotlin/no/nav/k9punsj/openapi/OpenApi.kt b/src/main/kotlin/no/nav/k9punsj/openapi/OpenApi.kt index 5c05db1da..c7b929e36 100644 --- a/src/main/kotlin/no/nav/k9punsj/openapi/OpenApi.kt +++ b/src/main/kotlin/no/nav/k9punsj/openapi/OpenApi.kt @@ -1,16 +1,24 @@ package no.nav.k9punsj.openapi import com.fasterxml.jackson.annotation.JsonFormat +import io.swagger.v3.core.converter.AnnotatedType +import io.swagger.v3.core.converter.ModelConverter +import io.swagger.v3.core.converter.ModelConverterContext +import io.swagger.v3.core.util.Json import io.swagger.v3.oas.models.OpenAPI import io.swagger.v3.oas.models.info.Contact import io.swagger.v3.oas.models.info.Info import io.swagger.v3.oas.models.info.License +import io.swagger.v3.oas.models.media.ObjectSchema +import io.swagger.v3.oas.models.media.Schema import io.swagger.v3.oas.models.servers.Server -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType +import no.nav.k9punsj.integrasjoner.pdl.PdlPersonDto import org.springframework.beans.factory.annotation.Value import org.springframework.context.annotation.Bean import org.springframework.stereotype.Component import java.net.URI +import java.time.Duration import java.time.LocalDate import java.time.LocalTime @@ -79,5 +87,5 @@ data class OasJournalpostDto( val dato: LocalDate?, @JsonFormat(pattern = "HH:mm") val klokkeslett: LocalTime?, - val punsjInnsendingType: K9FordelType? + val punsjInnsendingType: PunsjInnsendingType? ) diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index cb8f5ee17..363923456 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -89,14 +89,8 @@ no.nav: topic: ${SEND_BREVBESTILLING_TIL_K9_FORMIDLING} k9_los: topic: ${SEND_AKSJONSPUNKTHENDELSE_TIL_K9LOS} - k9_punsj_til_los: - topic: ${SEND_OPPDATERING_TIL_K9LOS} k9_rapid: topic: ${K9_RAPID_TOPIC} - k9_fordel: - topic: ${K9_FORDEL_TOPIC} - k9_punsjbolle: - topic: ${K9_PUNSJBOLLE_TOPIC} override_truststore_password: ${KAFKA_OVERRIDE_TRUSTSTORE_PASSWORD} server: diff --git a/src/test/kotlin/no/nav/k9punsj/MockConfiguration.kt b/src/test/kotlin/no/nav/k9punsj/MockConfiguration.kt index b28ec53e5..4ab0aa591 100644 --- a/src/test/kotlin/no/nav/k9punsj/MockConfiguration.kt +++ b/src/test/kotlin/no/nav/k9punsj/MockConfiguration.kt @@ -64,10 +64,7 @@ internal object MockConfiguration { "AAREG_SCOPE" to "aareg-services-nais/.default", "EREG_BASE_URL" to wireMockServer.getEregBaseUrl(), "SEND_BREVBESTILLING_TIL_K9_FORMIDLING" to "privat-k9-dokumenthendelse", - "SEND_AKSJONSPUNKTHENDELSE_TIL_K9LOS" to "privat-k9punsj-aksjonspunkthendelse-v1", - "SEND_OPPDATERING_TIL_K9LOS" to "k9saksbehandling.k9-punsj-til-los", - "K9_FORDEL_TOPIC" to "k9saksbehandling.fordel-journalforing", - "K9_PUNSJBOLLE_TOPIC" to "k9saksbehandling.punsjbar-journalpost" + "SEND_AKSJONSPUNKTHENDELSE_TIL_K9LOS" to "privat-k9punsj-aksjonspunkthendelse-v1" ) } } diff --git a/src/test/kotlin/no/nav/k9punsj/TestSetup.kt b/src/test/kotlin/no/nav/k9punsj/TestSetup.kt new file mode 100644 index 000000000..613aaa3ec --- /dev/null +++ b/src/test/kotlin/no/nav/k9punsj/TestSetup.kt @@ -0,0 +1,19 @@ +package no.nav.k9punsj + +import no.nav.k9punsj.wiremock.initWireMock +import org.springframework.web.reactive.function.client.WebClient + +object TestSetup { + private val wireMockServer = initWireMock( + port = 9192 + ) + + private const val port = 9194 + val client = WebClient.create("http://localhost:$port/") + + private val app = K9PunsjApplicationWithMocks.startup( + wireMockServer = wireMockServer, + port = port, + profiles = "test" + ) +} diff --git a/src/test/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImplTest.kt b/src/test/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImplTest.kt index a20512a62..f955283b5 100644 --- a/src/test/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImplTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/akjonspunkter/AksjonspunktServiceImplTest.kt @@ -11,7 +11,7 @@ import no.nav.k9punsj.domenetjenester.repository.SøknadRepository import no.nav.k9punsj.felles.FagsakYtelseType import no.nav.k9punsj.felles.dto.SøknadEntitet import no.nav.k9punsj.fordel.FordelPunsjEventDto -import no.nav.k9punsj.integrasjoner.k9losapi.PunsjEventDto +import no.nav.k9punsj.fordel.PunsjEventDto import no.nav.k9punsj.innsending.InnsendingClient import no.nav.k9punsj.integrasjoner.dokarkiv.DokarkivGateway import no.nav.k9punsj.integrasjoner.dokarkiv.SafGateway diff --git a/src/test/kotlin/no/nav/k9punsj/brev/BrevRoutesConfigurationTest.kt b/src/test/kotlin/no/nav/k9punsj/brev/BrevRoutesConfigurationTest.kt index a95522cda..9a857752c 100644 --- a/src/test/kotlin/no/nav/k9punsj/brev/BrevRoutesConfigurationTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/brev/BrevRoutesConfigurationTest.kt @@ -6,7 +6,7 @@ import no.nav.k9punsj.AbstractContainerBaseTest import no.nav.k9punsj.brev.BrevRoutes.Urls.BestillBrev import no.nav.k9punsj.brev.dto.DokumentbestillingDto import no.nav.k9punsj.brev.dto.MottakerDto -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.journalpost.JournalpostRepository import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.util.IdGenerator @@ -54,7 +54,7 @@ internal class BrevRoutesConfigurationTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = journalpostId, aktørId = aktørId, - type = K9FordelType.INNTEKTSMELDING_UTGÅTT.kode + type = PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT.kode ) journalpostRepository.lagre(jp) { diff --git a/src/test/kotlin/no/nav/k9punsj/fordel/FordelKafkaTest.kt b/src/test/kotlin/no/nav/k9punsj/fordel/FordelKafkaTest.kt index e33930b37..7e16c705c 100644 --- a/src/test/kotlin/no/nav/k9punsj/fordel/FordelKafkaTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/fordel/FordelKafkaTest.kt @@ -10,7 +10,6 @@ import no.nav.k9punsj.domenetjenester.SoknadService import no.nav.k9punsj.innsending.InnsendingClient import no.nav.k9punsj.integrasjoner.dokarkiv.DokarkivGateway import no.nav.k9punsj.integrasjoner.dokarkiv.SafGateway -import no.nav.k9punsj.integrasjoner.k9losapi.PunsjEventDto import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.kafka.HendelseProducer import no.nav.k9punsj.utils.objectMapper @@ -48,7 +47,7 @@ internal class FordelKafkaTest: AbstractContainerBaseTest() { @Test fun `motta melding om journalføringsoppgave fra fordel`() { - val melding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = "666", type = K9FordelType.PAPIRSØKNAD.kode, ytelse = "PSB") + val melding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = "666", type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB") val topicCaptor = ArgumentCaptor.forClass(String::class.java) val keyCaptor = ArgumentCaptor.forClass(String::class.java) @@ -60,9 +59,7 @@ internal class FordelKafkaTest: AbstractContainerBaseTest() { runBlocking { hendelseMottaker.prosesser(melding) val punsjJournalpost = - PunsjJournalpost( - UUID.randomUUID(), journalpostId = melding.journalpostId, aktørId = melding.aktørId, type = K9FordelType.PAPIRSØKNAD.kode - ) + PunsjJournalpost(UUID.randomUUID(), journalpostId = melding.journalpostId, aktørId = melding.aktørId) aksjonspunktService.opprettAksjonspunktOgSendTilK9Los( punsjJournalpost, Pair(AksjonspunktKode.PUNSJ, AksjonspunktStatus.OPPRETTET), diff --git a/src/test/kotlin/no/nav/k9punsj/fordel/FordelPunsjEventDtoTest.kt b/src/test/kotlin/no/nav/k9punsj/fordel/FordelPunsjEventDtoTest.kt index 2f65db18a..d70fd19f2 100644 --- a/src/test/kotlin/no/nav/k9punsj/fordel/FordelPunsjEventDtoTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/fordel/FordelPunsjEventDtoTest.kt @@ -20,6 +20,6 @@ internal class FordelPunsjEventDtoTest { val fordelPunsjEventDto = dto.somFordelPunsjEventDto(topic) - Assertions.assertThat(fordelPunsjEventDto.type).isEqualTo(K9FordelType.INNTEKTSMELDING_UTGÅTT.kode) + Assertions.assertThat(fordelPunsjEventDto.type).isEqualTo(PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT.kode) } } diff --git a/src/test/kotlin/no/nav/k9punsj/fordel/HendelseMottakerTest.kt b/src/test/kotlin/no/nav/k9punsj/fordel/HendelseMottakerTest.kt index d93714f44..568f4151b 100644 --- a/src/test/kotlin/no/nav/k9punsj/fordel/HendelseMottakerTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/fordel/HendelseMottakerTest.kt @@ -66,7 +66,7 @@ internal class HendelseMottakerTest: AbstractContainerBaseTest() { fun `skal lagre ned informasjon om journalpost`(): Unit = runBlocking { val journalpostId = IdGenerator.nesteId() - val melding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = K9FordelType.PAPIRSØKNAD.kode, ytelse = "PSB") + val melding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB") hendelseMottaker.prosesser(melding) val journalpost = journalpostService.hent(journalpostId) @@ -82,44 +82,44 @@ internal class HendelseMottakerTest: AbstractContainerBaseTest() { @Test fun `skal ikke lagre ned informasjon om journalpost når det kommer samme uten status`(): Unit = runBlocking { val journalpostId = IdGenerator.nesteId() - val meldingSomIkkeSkalBrukes = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = K9FordelType.PAPIRSØKNAD.kode, ytelse = "PSB") + val meldingSomIkkeSkalBrukes = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB") - val punsjJournalpostTilDb = PunsjJournalpost(UUID.randomUUID(), journalpostId = meldingSomIkkeSkalBrukes.journalpostId, aktørId = meldingSomIkkeSkalBrukes.aktørId, type = K9FordelType.DIGITAL_ETTERSENDELSE.kode) + val punsjJournalpostTilDb = PunsjJournalpost(UUID.randomUUID(), journalpostId = meldingSomIkkeSkalBrukes.journalpostId, aktørId = meldingSomIkkeSkalBrukes.aktørId, type = PunsjInnsendingType.DIGITAL_ETTERSENDELSE.kode) journalpostService.lagre(punsjJournalpostTilDb) hendelseMottaker.prosesser(meldingSomIkkeSkalBrukes) val journalpost = journalpostService.hent(journalpostId) - assertThat(journalpost.type).isEqualTo(K9FordelType.DIGITAL_ETTERSENDELSE.kode) + assertThat(journalpost.type).isEqualTo(PunsjInnsendingType.DIGITAL_ETTERSENDELSE.kode) } @Test fun `skal ikke lagre ned informasjon om journalpost når journalposten har ankommet fra før med samme status`(): Unit = runBlocking { val journalpostId = IdGenerator.nesteId() - val meldingSomIkkeSkalBrukes = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = K9FordelType.PAPIRSØKNAD.kode, ytelse = "PSB") + val meldingSomIkkeSkalBrukes = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB") - val punsjJournalpostTilDb = PunsjJournalpost(UUID.randomUUID(), journalpostId = meldingSomIkkeSkalBrukes.journalpostId, aktørId = meldingSomIkkeSkalBrukes.aktørId, type = K9FordelType.DIGITAL_ETTERSENDELSE.kode) + val punsjJournalpostTilDb = PunsjJournalpost(UUID.randomUUID(), journalpostId = meldingSomIkkeSkalBrukes.journalpostId, aktørId = meldingSomIkkeSkalBrukes.aktørId, type = PunsjInnsendingType.DIGITAL_ETTERSENDELSE.kode) journalpostService.lagre(punsjJournalpostTilDb) hendelseMottaker.prosesser(meldingSomIkkeSkalBrukes) val journalpost = journalpostService.hent(journalpostId) - assertThat(journalpost.type).isEqualTo(K9FordelType.DIGITAL_ETTERSENDELSE.kode) + assertThat(journalpost.type).isEqualTo(PunsjInnsendingType.DIGITAL_ETTERSENDELSE.kode) } @Test fun `skal fjerne oppgave når det kommer info fra fordel`(): Unit = runBlocking { val journalpostId = IdGenerator.nesteId() - val førsteMelding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = K9FordelType.INNTEKTSMELDING_UTGÅTT.kode, ytelse = "PSB") + val førsteMelding = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT.kode, ytelse = "PSB") hendelseMottaker.prosesser(førsteMelding) - val meldingSomSkalLukkeOppgave = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = K9FordelType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG.kode, ytelse = "PSB") + val meldingSomSkalLukkeOppgave = FordelPunsjEventDto(aktørId = "1234567890", journalpostId = journalpostId, type = PunsjInnsendingType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG.kode, ytelse = "PSB") hendelseMottaker.prosesser(meldingSomSkalLukkeOppgave) val journalpost = journalpostService.hent(meldingSomSkalLukkeOppgave.journalpostId) - assertThat(journalpost.type).isEqualTo(K9FordelType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG.kode) + assertThat(journalpost.type).isEqualTo(PunsjInnsendingType.PUNSJOPPGAVE_IKKE_LENGER_NØDVENDIG.kode) val alleAksjonspunkter = aksjonspunktRepository.hentAlleAksjonspunkter(journalpostId = førsteMelding.journalpostId) diff --git a/src/test/kotlin/no/nav/k9punsj/jobber/MetrikkJobbTest.kt b/src/test/kotlin/no/nav/k9punsj/jobber/MetrikkJobbTest.kt index 1446d13cc..092050efc 100644 --- a/src/test/kotlin/no/nav/k9punsj/jobber/MetrikkJobbTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/jobber/MetrikkJobbTest.kt @@ -3,7 +3,7 @@ package no.nav.k9punsj.jobber import io.micrometer.core.instrument.simple.SimpleMeterRegistry import kotlinx.coroutines.runBlocking import no.nav.k9punsj.AbstractContainerBaseTest -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.journalpost.JournalpostRepository import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.metrikker.JournalpostMetrikkRepository @@ -14,6 +14,7 @@ import no.nav.k9punsj.util.MetricUtils.MetrikkTag import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test +import org.slf4j.LoggerFactory import org.springframework.beans.factory.annotation.Autowired import org.springframework.boot.actuate.metrics.MetricsEndpoint import java.util.* @@ -50,7 +51,7 @@ internal class MetrikkJobbTest: AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost) { punsjJournalpost } @@ -71,7 +72,7 @@ internal class MetrikkJobbTest: AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost) { punsjJournalpost } @@ -86,15 +87,15 @@ internal class MetrikkJobbTest: AbstractContainerBaseTest() { @Test fun sjekk_journalpostertyper(): Unit = runBlocking { - genererJournalposter(antall = 9, type = K9FordelType.PAPIRSØKNAD) - genererJournalposter(antall = 8, type = K9FordelType.DIGITAL_ETTERSENDELSE) - genererJournalposter(antall = 7, type = K9FordelType.PAPIRETTERSENDELSE) - genererJournalposter(antall = 6, type = K9FordelType.KOPI) - genererJournalposter(antall = 5, type = K9FordelType.INNLOGGET_CHAT) - genererJournalposter(antall = 4, type = K9FordelType.INNTEKTSMELDING_UTGÅTT) - genererJournalposter(antall = 3, type = K9FordelType.PAPIRINNTEKTSOPPLYSNINGER) - genererJournalposter(antall = 2, type = K9FordelType.SKRIV_TIL_OSS_SPØRMSÅL) - genererJournalposter(antall = 1, type = K9FordelType.SKRIV_TIL_OSS_SVAR) + genererJournalposter(antall = 9, type = PunsjInnsendingType.PAPIRSØKNAD) + genererJournalposter(antall = 8, type = PunsjInnsendingType.DIGITAL_ETTERSENDELSE) + genererJournalposter(antall = 7, type = PunsjInnsendingType.PAPIRETTERSENDELSE) + genererJournalposter(antall = 6, type = PunsjInnsendingType.KOPI) + genererJournalposter(antall = 5, type = PunsjInnsendingType.INNLOGGET_CHAT) + genererJournalposter(antall = 4, type = PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT) + genererJournalposter(antall = 3, type = PunsjInnsendingType.PAPIRINNTEKTSOPPLYSNINGER) + genererJournalposter(antall = 2, type = PunsjInnsendingType.SKRIV_TIL_OSS_SPØRMSÅL) + genererJournalposter(antall = 1, type = PunsjInnsendingType.SKRIV_TIL_OSS_SVAR) metrikkJobb.oppdaterMetrikkMåling() MetricUtils.assertGuage( @@ -104,21 +105,21 @@ internal class MetrikkJobbTest: AbstractContainerBaseTest() { MetrikkTag( "type", setOf( - K9FordelType.PAPIRSØKNAD.name, - K9FordelType.DIGITAL_ETTERSENDELSE.name, - K9FordelType.PAPIRETTERSENDELSE.name, - K9FordelType.KOPI.name, - K9FordelType.INNLOGGET_CHAT.name, - K9FordelType.INNTEKTSMELDING_UTGÅTT.name, - K9FordelType.PAPIRINNTEKTSOPPLYSNINGER.name, - K9FordelType.SKRIV_TIL_OSS_SPØRMSÅL.name, - K9FordelType.SKRIV_TIL_OSS_SVAR.name + PunsjInnsendingType.PAPIRSØKNAD.name, + PunsjInnsendingType.DIGITAL_ETTERSENDELSE.name, + PunsjInnsendingType.PAPIRETTERSENDELSE.name, + PunsjInnsendingType.KOPI.name, + PunsjInnsendingType.INNLOGGET_CHAT.name, + PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT.name, + PunsjInnsendingType.PAPIRINNTEKTSOPPLYSNINGER.name, + PunsjInnsendingType.SKRIV_TIL_OSS_SPØRMSÅL.name, + PunsjInnsendingType.SKRIV_TIL_OSS_SVAR.name ) ) ) } - private suspend fun opprettJournalpost(dummyAktørId: String, type: K9FordelType): PunsjJournalpost { + private suspend fun opprettJournalpost(dummyAktørId: String, type: PunsjInnsendingType): PunsjJournalpost { val punsjJournalpost = PunsjJournalpost( uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), @@ -129,7 +130,7 @@ internal class MetrikkJobbTest: AbstractContainerBaseTest() { return punsjJournalpost } - private suspend fun genererJournalposter(antall: Int, type: K9FordelType) { + private suspend fun genererJournalposter(antall: Int, type: PunsjInnsendingType) { IntStream.range(0, antall).forEach { runBlocking { opprettJournalpost(IdGenerator.nesteId(), type) diff --git "a/src/test/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobbTest.kt" "b/src/test/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobbTest.kt" index 49f0e3ab8..669034176 100644 --- "a/src/test/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobbTest.kt" +++ "b/src/test/kotlin/no/nav/k9punsj/jobber/SjekkOmUtl\303\270ptJobbTest.kt" @@ -37,7 +37,6 @@ internal class SjekkOmUtløptJobbTest : AbstractContainerBaseTest() { hendelseProducer = hendelseProducer, journalpostRepository = journalpostRepository, k9losAksjonspunkthendelseTopic = "test", - k9PunsjTilLosTopic = "test" ) val dummyAktørId = "1000000000000" diff --git a/src/test/kotlin/no/nav/k9punsj/journalpost/KopierJournalpostRouteTest.kt b/src/test/kotlin/no/nav/k9punsj/journalpost/KopierJournalpostRouteTest.kt index 4df7b1bcd..9dbc5f2ee 100644 --- a/src/test/kotlin/no/nav/k9punsj/journalpost/KopierJournalpostRouteTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/journalpost/KopierJournalpostRouteTest.kt @@ -8,7 +8,7 @@ import no.nav.k9punsj.akjonspunkter.AksjonspunktService import no.nav.k9punsj.domenetjenester.SoknadService import no.nav.k9punsj.fordel.FordelPunsjEventDto import no.nav.k9punsj.fordel.HendelseMottaker -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.innsending.InnsendingClient import no.nav.k9punsj.integrasjoner.dokarkiv.DokarkivGateway import no.nav.k9punsj.integrasjoner.dokarkiv.SafGateway @@ -83,7 +83,7 @@ internal class KopierJournalpostRouteTest : AbstractContainerBaseTest() { val melding = FordelPunsjEventDto( aktørId = "1234567890", journalpostId = journalpostId, - type = K9FordelType.PAPIRSØKNAD.kode, + type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB" ) hendelseMottaker.prosesser(melding) @@ -121,7 +121,7 @@ internal class KopierJournalpostRouteTest : AbstractContainerBaseTest() { val melding = FordelPunsjEventDto( aktørId = "1234567890", journalpostId = journalpostId, - type = K9FordelType.PAPIRSØKNAD.kode, + type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB" ) hendelseMottaker.prosesser(melding) @@ -152,7 +152,7 @@ internal class KopierJournalpostRouteTest : AbstractContainerBaseTest() { val melding = FordelPunsjEventDto( aktørId = "1234567890", journalpostId = journalpostId, - type = K9FordelType.PAPIRSØKNAD.kode, + type = PunsjInnsendingType.PAPIRSØKNAD.kode, ytelse = "PSB" ) hendelseMottaker.prosesser(melding) diff --git a/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostMetrikkRepositoryTest.kt b/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostMetrikkRepositoryTest.kt index 0a545684e..766ee27f2 100644 --- a/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostMetrikkRepositoryTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostMetrikkRepositoryTest.kt @@ -2,9 +2,10 @@ package no.nav.k9punsj.journalpost import kotlinx.coroutines.runBlocking import no.nav.k9punsj.AbstractContainerBaseTest -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.metrikker.JournalpostMetrikkRepository +import no.nav.k9punsj.util.DbContainerInitializer import no.nav.k9punsj.util.IdGenerator import org.assertj.core.api.Assertions.assertThat import org.junit.jupiter.api.AfterEach @@ -34,7 +35,7 @@ internal class PunsjJournalpostMetrikkRepositoryTest: AbstractContainerBaseTest( @Test fun hentAntallFerdigBehandledeJournalposter(): Unit = runBlocking { - val journalpost = opprettJournalpost(IdGenerator.nesteId(), K9FordelType.PAPIRSØKNAD) + val journalpost = opprettJournalpost(IdGenerator.nesteId(), PunsjInnsendingType.PAPIRSØKNAD) journalpostRepo.lagre(journalpost) { journalpost } journalpostRepo.ferdig(journalpost.journalpostId) @@ -46,31 +47,31 @@ internal class PunsjJournalpostMetrikkRepositoryTest: AbstractContainerBaseTest( @Test fun hentAntallPunsjInnsendingstyper(): Unit = runBlocking { - genererJournalposter(antall = 9, type = K9FordelType.PAPIRSØKNAD) - genererJournalposter(antall = 8, type = K9FordelType.DIGITAL_ETTERSENDELSE) - genererJournalposter(antall = 7, type = K9FordelType.PAPIRETTERSENDELSE) - genererJournalposter(antall = 6, type = K9FordelType.KOPI) - genererJournalposter(antall = 5, type = K9FordelType.INNLOGGET_CHAT) - genererJournalposter(antall = 4, type = K9FordelType.INNTEKTSMELDING_UTGÅTT) - genererJournalposter(antall = 3, type = K9FordelType.PAPIRINNTEKTSOPPLYSNINGER) - genererJournalposter(antall = 2, type = K9FordelType.SKRIV_TIL_OSS_SPØRMSÅL) - genererJournalposter(antall = 1, type = K9FordelType.SKRIV_TIL_OSS_SVAR) + genererJournalposter(antall = 9, type = PunsjInnsendingType.PAPIRSØKNAD) + genererJournalposter(antall = 8, type = PunsjInnsendingType.DIGITAL_ETTERSENDELSE) + genererJournalposter(antall = 7, type = PunsjInnsendingType.PAPIRETTERSENDELSE) + genererJournalposter(antall = 6, type = PunsjInnsendingType.KOPI) + genererJournalposter(antall = 5, type = PunsjInnsendingType.INNLOGGET_CHAT) + genererJournalposter(antall = 4, type = PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT) + genererJournalposter(antall = 3, type = PunsjInnsendingType.PAPIRINNTEKTSOPPLYSNINGER) + genererJournalposter(antall = 2, type = PunsjInnsendingType.SKRIV_TIL_OSS_SPØRMSÅL) + genererJournalposter(antall = 1, type = PunsjInnsendingType.SKRIV_TIL_OSS_SVAR) val antallTyper = journalpostMetrikkRepository.hentAntallJournalposttyper() assertThat(antallTyper).containsExactlyInAnyOrder( - Pair(9, K9FordelType.PAPIRSØKNAD), - Pair(8, K9FordelType.DIGITAL_ETTERSENDELSE), - Pair(7, K9FordelType.PAPIRETTERSENDELSE), - Pair(6, K9FordelType.KOPI), - Pair(5, K9FordelType.INNLOGGET_CHAT), - Pair(4, K9FordelType.INNTEKTSMELDING_UTGÅTT), - Pair(3, K9FordelType.PAPIRINNTEKTSOPPLYSNINGER), - Pair(2, K9FordelType.SKRIV_TIL_OSS_SPØRMSÅL), - Pair(1, K9FordelType.SKRIV_TIL_OSS_SVAR) + Pair(9, PunsjInnsendingType.PAPIRSØKNAD), + Pair(8, PunsjInnsendingType.DIGITAL_ETTERSENDELSE), + Pair(7, PunsjInnsendingType.PAPIRETTERSENDELSE), + Pair(6, PunsjInnsendingType.KOPI), + Pair(5, PunsjInnsendingType.INNLOGGET_CHAT), + Pair(4, PunsjInnsendingType.INNTEKTSMELDING_UTGÅTT), + Pair(3, PunsjInnsendingType.PAPIRINNTEKTSOPPLYSNINGER), + Pair(2, PunsjInnsendingType.SKRIV_TIL_OSS_SPØRMSÅL), + Pair(1, PunsjInnsendingType.SKRIV_TIL_OSS_SVAR) ) } - private suspend fun opprettJournalpost(dummyAktørId: String, type: K9FordelType): PunsjJournalpost { + private suspend fun opprettJournalpost(dummyAktørId: String, type: PunsjInnsendingType): PunsjJournalpost { val punsjJournalpost = PunsjJournalpost( uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), @@ -81,7 +82,7 @@ internal class PunsjJournalpostMetrikkRepositoryTest: AbstractContainerBaseTest( return punsjJournalpost } - private suspend fun genererJournalposter(antall: Int, type: K9FordelType) { + private suspend fun genererJournalposter(antall: Int, type: PunsjInnsendingType) { IntStream.range(0, antall).forEach { runBlocking { opprettJournalpost(IdGenerator.nesteId(), type) diff --git a/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostRepositoryTest.kt b/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostRepositoryTest.kt index 2061b36d3..c1f41370a 100644 --- a/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostRepositoryTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/journalpost/PunsjJournalpostRepositoryTest.kt @@ -2,7 +2,7 @@ package no.nav.k9punsj.journalpost import kotlinx.coroutines.runBlocking import no.nav.k9punsj.AbstractContainerBaseTest -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import no.nav.k9punsj.journalpost.dto.PunsjJournalpost import no.nav.k9punsj.journalpost.dto.PunsjJournalpostKildeType import no.nav.k9punsj.util.IdGenerator @@ -28,7 +28,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost1) { punsjJournalpost1 @@ -39,7 +39,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost2) { punsjJournalpost2 @@ -53,7 +53,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { val finnJournalposterPåPerson = journalpostRepository.finnJournalposterPåPerson(dummyAktørId) assertThat(finnJournalposterPåPerson).hasSize(2) - assertThat(finnJournalposterPåPerson[0].type).isEqualTo(K9FordelType.PAPIRSØKNAD.kode) + assertThat(finnJournalposterPåPerson[0].type).isEqualTo(PunsjInnsendingType.PAPIRSØKNAD.kode) } @Test @@ -65,7 +65,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost1, PunsjJournalpostKildeType.SAKSBEHANDLER) { punsjJournalpost1 @@ -76,7 +76,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.PAPIRSØKNAD.kode + type = PunsjInnsendingType.PAPIRSØKNAD.kode ) journalpostRepository.lagre(punsjJournalpost2, PunsjJournalpostKildeType.FORDEL) { punsjJournalpost2 @@ -90,7 +90,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { val finnJournalposterPåPerson = journalpostRepository.finnJournalposterPåPersonBareFordel(dummyAktørId) assertThat(finnJournalposterPåPerson).hasSize(1) - assertThat(finnJournalposterPåPerson[0].type).isEqualTo(K9FordelType.PAPIRSØKNAD.kode) + assertThat(finnJournalposterPåPerson[0].type).isEqualTo(PunsjInnsendingType.PAPIRSØKNAD.kode) } @Test @@ -304,7 +304,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { uuid = UUID.randomUUID(), journalpostId = IdGenerator.nesteId(), aktørId = dummyAktørId, - type = K9FordelType.SAMTALEREFERAT.kode, + type = PunsjInnsendingType.SAMTALEREFERAT.kode, gosysoppgaveId = forventetGosysoppgaveId ) @@ -315,7 +315,7 @@ internal class PunsjJournalpostRepositoryTest : AbstractContainerBaseTest() { assertThat(journalpost.gosysoppgaveId!!).isEqualTo(forventetGosysoppgaveId) val finnJournalposterPåPerson = journalpostRepository.finnJournalposterPåPerson(dummyAktørId) - assertThat(finnJournalposterPåPerson[0].type).isEqualTo(K9FordelType.SAMTALEREFERAT.kode) + assertThat(finnJournalposterPåPerson[0].type).isEqualTo(PunsjInnsendingType.SAMTALEREFERAT.kode) assertThat(finnJournalposterPåPerson[0].gosysoppgaveId).isEqualTo(forventetGosysoppgaveId) } } diff --git a/src/test/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtilTest.kt b/src/test/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtilTest.kt index 605d4be3c..db1778547 100644 --- a/src/test/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtilTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/journalpost/VirkedagerUtilTest.kt @@ -1,6 +1,6 @@ package no.nav.k9punsj.journalpost -import no.nav.k9punsj.fordel.K9FordelType +import no.nav.k9punsj.fordel.PunsjInnsendingType import org.assertj.core.api.Assertions import org.junit.jupiter.api.Test import java.time.LocalDateTime @@ -9,7 +9,7 @@ internal class VirkedagerUtilTest { @Test fun `skal gi 2 dager ekstra på papirsøknad`() { - val papirsøknad = K9FordelType.PAPIRSØKNAD + val papirsøknad = PunsjInnsendingType.PAPIRSØKNAD val mandag = LocalDateTime.of(2021, 5, 31, 10, 22) val tirsdag = LocalDateTime.of(2021, 6, 1, 10, 22) val onsdag = LocalDateTime.of(2021, 6, 2, 10, 22) @@ -37,7 +37,7 @@ internal class VirkedagerUtilTest { @Test fun `skal ikke gi 2 dager ekstra på ikke papirsøknad`() { - val papirsøknad = K9FordelType.DIGITAL_ETTERSENDELSE + val papirsøknad = PunsjInnsendingType.DIGITAL_ETTERSENDELSE val søndag = LocalDateTime.of(2021, 6, 6, 10, 22) diff --git a/src/test/kotlin/no/nav/k9punsj/opplaeringspenger/OpplaeringspengerTests.kt b/src/test/kotlin/no/nav/k9punsj/opplaeringspenger/OpplaeringspengerTests.kt index 951912308..ef1939929 100644 --- a/src/test/kotlin/no/nav/k9punsj/opplaeringspenger/OpplaeringspengerTests.kt +++ b/src/test/kotlin/no/nav/k9punsj/opplaeringspenger/OpplaeringspengerTests.kt @@ -1,5 +1,43 @@ package no.nav.k9punsj.opplaeringspenger +import com.fasterxml.jackson.module.kotlin.convertValue +import io.mockk.junit5.MockKExtension +import kotlinx.coroutines.runBlocking +import no.nav.helse.dusseldorf.testsupport.jws.Azure +import no.nav.k9.søknad.felles.personopplysninger.Utenlandsopphold +import no.nav.k9.søknad.felles.type.Periode +import no.nav.k9.søknad.ytelse.olp.v1.Opplæringspenger +import no.nav.k9punsj.TestSetup +import no.nav.k9punsj.felles.dto.OpprettNySøknad +import no.nav.k9punsj.felles.dto.PeriodeDto +import no.nav.k9punsj.felles.dto.SendSøknad +import no.nav.k9punsj.utils.objectMapper +import no.nav.k9punsj.openapi.OasFeil +import no.nav.k9punsj.openapi.OasSoknadsfeil +import no.nav.k9punsj.util.DbContainerInitializer +import no.nav.k9punsj.util.IdGenerator +import no.nav.k9punsj.util.LesFraFilUtil +import no.nav.k9punsj.util.SøknadJson +import no.nav.k9punsj.util.TestUtils.hentSøknadId +import no.nav.k9punsj.util.WebClientUtils.awaitBodyWithType +import no.nav.k9punsj.util.WebClientUtils.awaitExchangeBlocking +import no.nav.k9punsj.util.WebClientUtils.awaitStatusWithBody +import no.nav.k9punsj.util.WebClientUtils.awaitStatuscode +import no.nav.k9punsj.wiremock.saksbehandlerAccessToken +import org.assertj.core.api.Assertions.assertThat +import org.junit.jupiter.api.Assertions.* +import org.junit.jupiter.api.Disabled +import org.junit.jupiter.api.Test +import org.junit.jupiter.api.extension.ExtendWith +import org.springframework.http.HttpHeaders +import org.springframework.http.HttpStatus +import org.springframework.http.HttpStatusCode +import org.springframework.test.context.junit.jupiter.SpringExtension +import org.springframework.web.reactive.function.BodyInserters +import java.net.URI +import java.time.Duration +import java.time.LocalDate + /* @ExtendWith(SpringExtension::class, MockKExtension::class) @Disabled("OLP er ikke i bruk eller under utvikling") diff --git a/src/test/kotlin/no/nav/k9punsj/person/BarnApiTest.kt b/src/test/kotlin/no/nav/k9punsj/person/BarnApiTest.kt index afa79fdcc..0105df999 100644 --- a/src/test/kotlin/no/nav/k9punsj/person/BarnApiTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/person/BarnApiTest.kt @@ -3,10 +3,15 @@ package no.nav.k9punsj.person import kotlinx.coroutines.runBlocking import no.nav.helse.dusseldorf.testsupport.jws.Azure import no.nav.k9punsj.AbstractContainerBaseTest +import no.nav.k9punsj.TestSetup +import no.nav.k9punsj.util.WebClientUtils.awaitBodyWithType import no.nav.k9punsj.wiremock.saksbehandlerAccessToken import org.intellij.lang.annotations.Language import org.junit.jupiter.api.Test +import org.junit.jupiter.api.extension.ExtendWith +import org.skyscreamer.jsonassert.JSONAssert import org.springframework.http.HttpHeaders +import org.springframework.test.context.junit.jupiter.SpringExtension class BarnApiTest : AbstractContainerBaseTest() { private val saksbehandlerAuthorizationHeader = "Bearer ${Azure.V2_0.saksbehandlerAccessToken()}" diff --git a/src/test/kotlin/no/nav/k9punsj/rest/server/PunsjJournalpostInfoRoutesTest.kt b/src/test/kotlin/no/nav/k9punsj/rest/server/PunsjJournalpostInfoRoutesTest.kt index ebd9e26fa..bd1cd4350 100644 --- a/src/test/kotlin/no/nav/k9punsj/rest/server/PunsjJournalpostInfoRoutesTest.kt +++ b/src/test/kotlin/no/nav/k9punsj/rest/server/PunsjJournalpostInfoRoutesTest.kt @@ -1,14 +1,21 @@ package no.nav.k9punsj.rest.server import com.fasterxml.jackson.module.kotlin.convertValue +import io.mockk.junit5.MockKExtension import kotlinx.coroutines.runBlocking import no.nav.k9punsj.AbstractContainerBaseTest +import no.nav.k9punsj.TestSetup import no.nav.k9punsj.felles.JsonB import no.nav.k9punsj.journalpost.dto.SøkUferdigJournalposter import no.nav.k9punsj.utils.objectMapper +import no.nav.k9punsj.util.WebClientUtils.awaitStatuscode import no.nav.k9punsj.wiremock.saksbehandlerAccessToken +import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Test +import org.junit.jupiter.api.extension.ExtendWith import org.springframework.http.HttpHeaders +import org.springframework.http.HttpStatus +import org.springframework.test.context.junit.jupiter.SpringExtension import org.springframework.web.reactive.function.BodyInserters class PunsjJournalpostInfoRoutesTest : AbstractContainerBaseTest() { diff --git a/src/test/resources/application-test.yaml b/src/test/resources/application-test.yaml index 4571a8f39..52e7d6aea 100644 --- a/src/test/resources/application-test.yaml +++ b/src/test/resources/application-test.yaml @@ -11,10 +11,7 @@ server: logging: level: - web: INFO + web: TRACE org: springframework: - web: INFO - apache: - kafka: WARN - kafka: WARN \ No newline at end of file + web: TRACE