Chore: added functionality for send and avvis sykmelding

chore: Added functionality for send and avvis sykmelding to this app. Korrigere sykmelding endpoint will save the updated object in the DB as well as smregistrering until the functionality is moved.
navikt · Dec 9, 2024 · 9a0166a · 9a0166a
1 parent ac25481
commit 9a0166a
Show file tree

Hide file tree

Showing 67 changed files with 3,155 additions and 602 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -48,16 +48,18 @@ val prometheusVersion = "0.16.0"
 val mockkVersion = "1.13.10"
 val kluentVersion = "1.73"
 val coroutinesVersion = "1.8.1"
+val coroutineReactorVersion = "1.9.0"
 val hibernateVersion = "6.2.6.Final"
 val jacksonDatatypeJsr310Version = "2.18.0"
-
+val mockitoKotlinVersion = "5.4.0"
 dependencies {
     implementation(platform("com.netflix.graphql.dgs:graphql-dgs-platform-dependencies:$graphqlDgsPlatformDependenciesVersion"))
     implementation("com.netflix.graphql.dgs:graphql-dgs-spring-boot-starter")
     implementation("com.netflix.graphql.dgs:graphql-dgs-extended-scalars")
     implementation("com.graphql-java:graphql-java:$graphqlVersion")
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-slf4j:$coroutinesVersion")
-    implementation("org.springframework.boot:spring-boot-starter-web")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor:$coroutineReactorVersion")
+//    implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
     implementation("com.fasterxml.jackson.module:jackson-module-jaxb-annotations")
     implementation("com.fasterxml.jackson.datatype:jackson-datatype-jsr310:$jacksonDatatypeJsr310Version")
@@ -109,11 +111,13 @@ dependencies {
     testImplementation("org.testcontainers:kafka:$testContainersVersion")
     testImplementation("io.mockk:mockk:$mockkVersion")
     testImplementation("org.amshove.kluent:kluent:$kluentVersion")
+    testImplementation("org.mockito.kotlin:mockito-kotlin:$mockitoKotlinVersion")
     constraints {
         testImplementation("org.apache.commons:commons-compress:$commonsCompressVersion") {
             because("overstyrer sårbar dependency fra com.opentable.components:otj-pg-embedded")
         }
     }
+    testImplementation(kotlin("test"))
 }
 
 tasks {

diff --git a/naiserator-dev.yaml b/naiserator-dev.yaml
@@ -83,6 +83,12 @@ spec:
         - application: syfohelsenettproxy
           namespace: teamsykmelding
           cluster: dev-gcp
+        - application: smtss
+          namespace: teamsykmelding
+          cluster: dev-gcp
+        - application: syfosmpapirregler
+          namespace: teamsykmelding
+          cluster: dev-gcp
       external:
         - host: kodeverk-api.nav.no
         - host: oppgave-q1.dev-fss-pub.nais.io
@@ -127,3 +133,11 @@ spec:
       value: http://syfohelsenettproxy
     - name: HELSENETT_CLIENT_ID
       value: dev-gcp.teamsykmelding.syfohelsenettproxy
+    - name: SMTSS_URL
+      value: http://smtss
+    - name: SMTSS_CLIENT_ID
+      value: dev-gcp.teamsykmelding.smtss
+    - name: SYFOSMPAPIRREGLER_URL
+      value: http://syfosmpapirregler
+    - name: SYFOSMPAPIRREGLER_CLIENT_ID
+      value: dev-gcp.teamsykmelding.syfosmpapirregler
diff --git a/naiserator-prod.yaml b/naiserator-prod.yaml
@@ -83,6 +83,12 @@ spec:
         - application: syfohelsenettproxy
           namespace: teamsykmelding
           cluster: prod-gcp
+        - application: smtss
+          namespace: teamsykmelding
+          cluster: prod-gcp
+        - application: syfosmpapirregler
+          namespace: teamsykmelding
+          cluster: prod-gcp
       external:
         - host: saf.prod-fss-pub.nais.io
         - host: pdl-api.prod-fss-pub.nais.io
@@ -124,3 +130,11 @@ spec:
       value: http://syfohelsenettproxy
     - name: HELSENETT_CLIENT_ID
       value: prod-gcp.teamsykmelding.syfohelsenettproxy
+    - name: SMTSS_URL
+      value: http://smtss
+    - name: SMTSS_CLIENT_ID
+      value: prod-gcp.teamsykmelding.smtss
+    - name: SYFOSMPAPIRREGLER_URL
+      value: http://syfosmpapirregler
+    - name: SYFOSMPAPIRREGLER_CLIENT_ID
+      value: prod-gcp.teamsykmelding.syfosmpapirregler
diff --git a/src/main/kotlin/no/nav/sykdig/Log.kt b/src/main/kotlin/no/nav/sykdig/Log.kt
@@ -18,3 +18,11 @@ inline fun <reified T> T.securelog(): Logger {
 inline fun <reified T> T.auditlog(): Logger {
     return LoggerFactory.getLogger("auditLogger")
 }
+
+data class LoggingMeta(
+    val mottakId: String,
+    val journalpostId: String?,
+    val dokumentInfoId: String?,
+    val msgId: String,
+    val sykmeldingId: String,
+)
diff --git a/src/main/kotlin/no/nav/sykdig/config/M2MRestTemplate.kt b/src/main/kotlin/no/nav/sykdig/config/M2MRestTemplate.kt
@@ -41,6 +41,20 @@ class M2MRestTemplate(
             .build()
     }
 
+    @Bean
+    fun smtssM2mRestTemplate(): RestTemplate {
+        return restTemplateBuilder
+            .additionalInterceptors(bearerTokenInterceptor("smtss-m2m"))
+            .build()
+    }
+
+    @Bean
+    fun regeltM2mRestTemplate(): RestTemplate {
+        return restTemplateBuilder
+            .additionalInterceptors(bearerTokenInterceptor("regel-m2m"))
+            .build()
+    }
+
     private fun bearerTokenInterceptor(type: String): ClientHttpRequestInterceptor {
         return ClientHttpRequestInterceptor { request: HttpRequest, body: ByteArray, execution: ClientHttpRequestExecution ->
             val token = m2mTokenService.getM2MToken(type)

diff --git a/src/main/kotlin/no/nav/sykdig/config/SecurityConfiguration.kt b/src/main/kotlin/no/nav/sykdig/config/SecurityConfiguration.kt
@@ -5,6 +5,7 @@ import org.springframework.context.annotation.Configuration
 import org.springframework.http.HttpMethod
 import org.springframework.security.config.annotation.method.configuration.EnableMethodSecurity
 import org.springframework.security.config.annotation.web.builders.HttpSecurity
+import org.springframework.security.config.annotation.web.reactive.EnableWebFluxSecurity
 import org.springframework.security.web.SecurityFilterChain
 
 @Configuration

diff --git a/src/main/kotlin/no/nav/sykdig/config/kafka/AivenKafkaConfig.kt b/src/main/kotlin/no/nav/sykdig/config/kafka/AivenKafkaConfig.kt
@@ -105,4 +105,4 @@ class AivenKafkaConfig(
 }
 
 const val SYK_DIG_OPPGAVE_TOPIC = "teamsykmelding.syk-dig-oppgave"
-const val OK_SYKMLEDING_TOPIC = "teamsykmelding.ok-sykmelding"
+const val OK_SYKMELDING_TOPIC = "teamsykmelding.ok-sykmelding"
diff --git a/src/main/kotlin/no/nav/sykdig/db/OppgaveRepository.kt b/src/main/kotlin/no/nav/sykdig/db/OppgaveRepository.kt
@@ -3,11 +3,11 @@ package no.nav.sykdig.db
 import com.fasterxml.jackson.module.kotlin.readValue
 import no.nav.sykdig.applog
 import no.nav.sykdig.digitalisering.model.RegisterOppgaveValues
-import no.nav.sykdig.digitalisering.sykmelding.AktivitetIkkeMulig
-import no.nav.sykdig.digitalisering.sykmelding.Diagnose
-import no.nav.sykdig.digitalisering.sykmelding.Gradert
-import no.nav.sykdig.digitalisering.sykmelding.MedisinskVurdering
-import no.nav.sykdig.digitalisering.sykmelding.Periode
+import no.nav.sykdig.digitalisering.felles.AktivitetIkkeMulig
+import no.nav.sykdig.digitalisering.felles.Diagnose
+import no.nav.sykdig.digitalisering.felles.Gradert
+import no.nav.sykdig.digitalisering.felles.MedisinskVurdering
+import no.nav.sykdig.digitalisering.felles.Periode
 import no.nav.sykdig.digitalisering.sykmelding.UtenlandskSykmelding
 import no.nav.sykdig.generated.types.Avvisingsgrunn
 import no.nav.sykdig.generated.types.PeriodeInput

diff --git a/src/main/kotlin/no/nav/sykdig/digitalisering/OppgaveMapping.kt b/src/main/kotlin/no/nav/sykdig/digitalisering/OppgaveMapping.kt
@@ -1,8 +1,7 @@
 package no.nav.sykdig.digitalisering
 
 import no.nav.sykdig.digitalisering.pdl.toFormattedNameString
-import no.nav.sykdig.digitalisering.sykmelding.Periode
-import no.nav.sykdig.generated.DgsConstants.QUERY.DigitalisertSykmelding
+import no.nav.sykdig.digitalisering.felles.Periode
 import no.nav.sykdig.generated.types.Bostedsadresse
 import no.nav.sykdig.generated.types.DiagnoseValue
 import no.nav.sykdig.generated.types.Digitaliseringsoppgave

diff --git a/src/main/kotlin/no/nav/sykdig/digitalisering/SykDigOppgaveService.kt b/src/main/kotlin/no/nav/sykdig/digitalisering/SykDigOppgaveService.kt
@@ -13,9 +13,8 @@ import no.nav.sykdig.digitalisering.ferdigstilling.oppgave.OppgaveClient
 import no.nav.sykdig.digitalisering.model.FerdistilltRegisterOppgaveValues
 import no.nav.sykdig.digitalisering.model.RegisterOppgaveValues
 import no.nav.sykdig.digitalisering.pdl.Person
+import no.nav.sykdig.digitalisering.saf.graphql.DokumentInfo
 import no.nav.sykdig.digitalisering.saf.graphql.SafJournalpost
-import no.nav.sykdig.digitalisering.tilgangskontroll.OppgaveSecurityService
-import no.nav.sykdig.digitalisering.tilgangskontroll.getNavEmail
 import no.nav.sykdig.generated.types.Avvisingsgrunn
 import no.nav.sykdig.model.DokumentDbModel
 import no.nav.sykdig.model.OppgaveDbModel
@@ -35,59 +34,28 @@ class SykDigOppgaveService(
     private val log = applog()
     private val securelog = securelog()
 
-    private fun createOppgave(oppgaveId: String, fnr: String, journalpostId: String, journalpost: SafJournalpost, dokumentInfoId: String, source: String = "syk-dig"): OppgaveDbModel {
-        val dokumenter = journalpost.dokumenter.map {
-            val oppdatertTittel = if (it.tittel == "Utenlandsk sykmelding") {
-                "Digitalisert utenlandsk sykmelding"
-            } else {
-                it.tittel ?: "Mangler Tittel"
-            }
-            DokumentDbModel(it.dokumentInfoId, oppdatertTittel)
-        }
-
-        return OppgaveDbModel(
-            oppgaveId = oppgaveId,
-            fnr = fnr,
-            journalpostId = journalpostId,
-            dokumentInfoId = dokumentInfoId,
-            dokumenter = dokumenter,
-            opprettet = OffsetDateTime.now(ZoneOffset.UTC),
-            ferdigstilt = null,
-            tilbakeTilGosys = false,
-            avvisingsgrunn = null,
-            sykmeldingId = UUID.randomUUID(),
-            type = UTLAND,
-            sykmelding = null,
-            endretAv = getNavEmail(),
-            timestamp = OffsetDateTime.now(ZoneOffset.UTC),
-            source = source,
-        )
-    }
 
     fun opprettOgLagreOppgave(
         journalpost: SafJournalpost,
         journalpostId: String,
         fnr: String,
         aktoerId: String,
+        navEpost: String,
     ): String {
-        val response =
-            oppgaveClient.opprettOppgave(
-                journalpostId = journalpostId,
-                aktoerId = aktoerId,
-            )
+        val opprettetOppgave = oppgaveClient.opprettOppgave(
+            journalpostId = journalpostId,
+            aktoerId = aktoerId,
+        )
+        val oppgaveId = opprettetOppgave.id.toString()
 
-        val oppgaveId = response.id.toString()
-        val dokumentInfoId = journalpost.dokumenter.first().dokumentInfoId
-        val tittel = journalpost.tittel.lowercase().contains("egenerklæring")
-        securelog.info("is egenarklaring: $tittel journalpostId: $journalpostId")
-        val oppgave = createOppgave(
+        val oppgave = buildOppgaveModel(
             oppgaveId = oppgaveId,
-            fnr = fnr,
-            journalpostId = journalpostId,
             journalpost = journalpost,
-            dokumentInfoId = dokumentInfoId,
-            source = if (journalpost.kanal == "NAV_NO" || tittel) "navno" else if (journalpost.kanal == "RINA") "rina" else "syk-dig"
+            journalpostId = journalpostId,
+            fnr = fnr,
+            navEpost = navEpost,
         )
+
         oppgaveRepository.lagreOppgave(oppgave)
         log.info("Oppgave med id $oppgaveId lagret")
         return oppgaveId
@@ -211,7 +179,7 @@ class SykDigOppgaveService(
     ) {
         val sykmelding = oppgaveRepository.getLastSykmelding(oppgave.oppgaveId)
         oppgaveRepository.ferdigstillAvvistOppgave(oppgave, navEpost, sykmelding, avvisningsgrunn)
-        ferdigstillingService.ferdigstillAvvistJournalpost(
+        ferdigstillingService.ferdigstillUtenlandskAvvistJournalpost(
             enhet = enhetId,
             oppgave = oppgave,
             sykmeldt = sykmeldt,
@@ -220,7 +188,7 @@ class SykDigOppgaveService(
     }
 
     @Transactional
-    fun ferdigstillOppgave(
+    fun ferdigstillUtenlandskAvvistOppgave(
         oppgave: OppgaveDbModel,
         navEpost: String,
         values: FerdistilltRegisterOppgaveValues,
@@ -230,7 +198,7 @@ class SykDigOppgaveService(
         val sykmelding = toSykmelding(oppgave, values)
 
         oppgaveRepository.updateOppgave(oppgave, sykmelding, navEpost, true)
-        ferdigstillingService.ferdigstill(
+        ferdigstillingService.ferdigstillUtenlandskOppgave(
             enhet = enhetId,
             oppgave = oppgave,
             sykmeldt = sykmeldt,
@@ -247,6 +215,56 @@ class SykDigOppgaveService(
         ferdigstillingService.sendUpdatedSykmelding(oppgave, sykmeldt, navEmail, values)
     }
 
+    private fun buildOppgaveModel(
+        oppgaveId: String,
+        journalpost: SafJournalpost,
+        journalpostId: String,
+        fnr: String,
+        navEpost: String,
+    ): OppgaveDbModel {
+        val dokumentInfoId = journalpost.dokumenter.first().dokumentInfoId
+        val dokumenter = buildDokumenter(journalpost.dokumenter)
+        val source = determineSource(journalpost)
+
+        return OppgaveDbModel(
+            oppgaveId = oppgaveId,
+            fnr = fnr,
+            journalpostId = journalpostId,
+            dokumentInfoId = dokumentInfoId,
+            dokumenter = dokumenter,
+            opprettet = OffsetDateTime.now(ZoneOffset.UTC),
+            ferdigstilt = null,
+            tilbakeTilGosys = false,
+            avvisingsgrunn = null,
+            sykmeldingId = UUID.randomUUID(),
+            type = UTLAND,
+            sykmelding = null,
+            endretAv = navEpost,
+            timestamp = OffsetDateTime.now(ZoneOffset.UTC),
+            source = source,
+        )
+    }
+
+    private fun buildDokumenter(dokumenter: List<DokumentInfo>): List<DokumentDbModel> {
+        return dokumenter.map {
+            val oppdatertTittel = if (it.tittel == "Utenlandsk sykmelding") {
+                "Digitalisert utenlandsk sykmelding"
+            } else {
+                it.tittel ?: "Mangler Tittel"
+            }
+            DokumentDbModel(it.dokumentInfoId, oppdatertTittel)
+        }
+    }
+
+    private fun determineSource(journalpost: SafJournalpost): String {
+        val isEgenerklaering = journalpost.tittel.lowercase().contains("egenerklæring")
+        return when {
+            journalpost.kanal == "NAV_NO" || isEgenerklaering -> "navno"
+            journalpost.kanal == "RINA" -> "rina"
+            else -> "syk-dig"
+        }
+    }
+
     companion object {
         private const val UTLAND = "UTLAND"
     }

diff --git a/src/main/kotlin/no/nav/sykdig/digitalisering/UtenlandskOppgaveService.kt b/src/main/kotlin/no/nav/sykdig/digitalisering/UtenlandskOppgaveService.kt
@@ -7,13 +7,9 @@ import no.nav.sykdig.digitalisering.model.FerdistilltRegisterOppgaveValues
 import no.nav.sykdig.digitalisering.model.RegisterOppgaveValues
 import no.nav.sykdig.digitalisering.pdl.PersonService
 import no.nav.sykdig.digitalisering.regelvalidering.RegelvalideringService
-import no.nav.sykdig.digitalisering.sykmelding.Sykmelding
 import no.nav.sykdig.generated.types.Avvisingsgrunn
-import no.nav.sykdig.generated.types.DigitaliseringsoppgaveStatus
-import no.nav.sykdig.generated.types.DigitaliseringsoppgaveStatusEnum
 import no.nav.sykdig.generated.types.OppdatertSykmeldingStatus
 import no.nav.sykdig.generated.types.OppdatertSykmeldingStatusEnum
-import no.nav.sykdig.generated.types.SykmeldingUnderArbeidValues
 import no.nav.sykdig.metrics.MetricRegister
 import no.nav.sykdig.model.OppgaveDbModel
 import org.springframework.stereotype.Service
@@ -83,7 +79,7 @@ class UtenlandskOppgaveService(
             throw ClientException(valideringsresultat.joinToString())
         }
 
-        sykDigOppgaveService.ferdigstillOppgave(oppgave, navEpost, values, enhetId, sykmeldt)
+        sykDigOppgaveService.ferdigstillUtenlandskAvvistOppgave(oppgave, navEpost, values, enhetId, sykmeldt)
         metricRegister.ferdigstiltOppgave.increment()
     }