f - Lagrer alle nye P_BUC_02 i gjennybucket og antar at det er gjenny…

…saker

Co-authored-by: [email protected]

src/main/kotlin/no/nav/eessi/pensjon/gcp/GcpStorageService.kt

@@ -11,6 +11,7 @@ import no.nav.eessi.pensjon.utils.toJson
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.stereotype.Component
+import java.nio.ByteBuffer
 import java.time.LocalDateTime
 import java.time.OffsetDateTime
 import java.time.temporal.ChronoUnit
@@ -19,7 +20,7 @@ import java.time.temporal.ChronoUnit
 class GcpStorageService(
     @param:Value("\${GCP_BUCKET_NAME_GJENNY}") var gjennyBucket: String,
     @param:Value("\${GCP_BUCKET_NAME_JOURNAL}") var journalBucket: String,
-    private val gcpStorage: Storage
+    var gcpStorage: Storage
 ) {
     private val logger = LoggerFactory.getLogger(GcpStorageService::class.java)
 
@@ -82,6 +83,18 @@ class GcpStorageService(
         return null
     }
 
+    fun lagre(euxCaseId: String, gjennysak: GjennySak? = null) {
+        if (eksisterer(euxCaseId, "eessi-pensjon-gjenny")) return
+        val blobInfo =  BlobInfo.newBuilder(BlobId.of("eessi-pensjon-gjenny", euxCaseId)).setContentType("application/json").build()
+        kotlin.runCatching {
+            gcpStorage.writer(blobInfo).use { it.write(ByteBuffer.wrap(gjennysak?.toJson()?.toByteArray())) }.also { logger.info("Lagret info på S3 med rinaID: $it") }
+        }.onFailure { e ->
+            logger.error("Feilet med å lagre dokument med id: ${blobInfo.blobId.name}", e)
+        }.onSuccess {
+            if (gjennysak != null) logger.info("Lagret info på S3 med rinaID: $euxCaseId for gjenny: ${gjennysak.toJson()}")
+        }
+    }
+
     fun lagreJournalpostDetaljer(
         journalpostId: String?,
         rinaSakId: String,

src/main/kotlin/no/nav/eessi/pensjon/listeners/SedMottattListener.kt

@@ -1,16 +1,19 @@
 package no.nav.eessi.pensjon.listeners
 
 import no.nav.eessi.pensjon.eux.EuxService
+import no.nav.eessi.pensjon.eux.model.BucType.P_BUC_02
 import no.nav.eessi.pensjon.eux.model.SedHendelse
 import no.nav.eessi.pensjon.gcp.GcpStorageService
+import no.nav.eessi.pensjon.gcp.GjennySak
 import no.nav.eessi.pensjon.journalforing.JournalforingService
 import no.nav.eessi.pensjon.listeners.fagmodul.FagmodulService
 import no.nav.eessi.pensjon.listeners.pesys.BestemSakService
 import no.nav.eessi.pensjon.metrics.MetricsHelper
+import no.nav.eessi.pensjon.models.Tema.EYBARNEP
+import no.nav.eessi.pensjon.models.Tema.OMSTILLING
 import no.nav.eessi.pensjon.oppgaverouting.HendelseType.MOTTATT
 import no.nav.eessi.pensjon.personidentifisering.PersonidentifiseringService
 import no.nav.eessi.pensjon.personidentifisering.relasjoner.RelasjonsHandler
-import no.nav.eessi.pensjon.utils.eessiRequire
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.slf4j.LoggerFactory
 import org.slf4j.MDC
@@ -19,6 +22,8 @@ import org.springframework.beans.factory.annotation.Value
 import org.springframework.kafka.annotation.KafkaListener
 import org.springframework.kafka.support.Acknowledgment
 import org.springframework.stereotype.Service
+import java.time.LocalDate
+import java.time.Period
 import java.util.*
 import java.util.concurrent.CountDownLatch
 
@@ -77,6 +82,7 @@ class SedMottattListener(
         if (gcpStorageService.journalFinnes(sedHendelse.rinaSakId)) {
             logger.info("Innkommende ${sedHendelse.sedType} med rinaId: ${sedHendelse.rinaSakId}  finnes i GCP storage")
         }
+
         val bucType = sedHendelse.bucType!!
         val buc = euxService.hentBuc(sedHendelse.rinaSakId)
 
@@ -103,6 +109,12 @@ class SedMottattListener(
 
         val alleSedIBucList = alleSedMedGyldigStatus.flatMap { (_, sed) -> listOf(sed) }
         val fdato = personidentifiseringService.hentFodselsDato(identifisertPerson, alleSedIBucList.plus(kansellerteSeder))
+
+        if (bucType == P_BUC_02 ) {
+            val gjennyTema = if (Period.between(fdato, LocalDate.now()).years > 19) OMSTILLING else EYBARNEP
+            gcpStorageService.lagre(sedHendelse.rinaSakId, GjennySak(sedHendelse.rinaSakId, gjennyTema.kode)).also { logger.info("asjdhføaisdhgfaødifhøi") }
+        }
+
         val saksInfoSamlet = hentSaksInformasjonForEessi(
             alleSedIBucList,
             sedHendelse,