b - Legger inn gjennysak i sed i bucket

Author: MariamPervez

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

@@ -82,13 +82,13 @@ class GcpStorageService(
         }
     }
 
-    fun oppdaterGjennysak(sedHendelse: SedHendelse, gcpstorageObject: GjennySak) : String {
+    fun oppdaterGjennysak(sedHendelse: SedHendelse, gcpstorageObject: GjennySak, gjennysakFraSed: String) : String {
         val blobId = hentBlobId(gjennyBucket, sedHendelse.rinaSakId)
         slettJournalpostDetaljer(blobId)
         logger.warn("Gjennysak finnes for rinaSakId: ${sedHendelse.rinaSakId}")
 
         val saksType = if (gcpstorageObject.sakType == "OMSORG") OMSORG else BARNEP
-        lagre(sedHendelse.rinaSakId, GjennySak(sedHendelse.rinaSakId, saksType.name))
+        lagre(sedHendelse.rinaSakId, GjennySak(gjennysakFraSed, saksType.name))
         return saksType.name
     }
 

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

@@ -78,7 +78,9 @@ abstract class SedListenerBase(
         val erGjennysak = gcpStorageService.gjennyFinnes(sedHendelse.rinaSakId)
         if(erGjennysak) {
             val gjennySakId = fagmodulService.hentGjennySakIdFraSed(currentSed)
-            oppdaterGjennySak(sedHendelse).also { logger.info("Gjennysak oppdatert med sakId: $it") }
+            if (gjennySakId != null) {
+                oppdaterGjennySak(sedHendelse, gjennySakId).also { logger.info("Gjennysak oppdatert med sakId: $it") }
+            }
             return SaksInfoSamlet(gjennySakId, null, null)
         }
         val saksIdFraSed = fagmodulService.hentSakIdFraSED(alleSedIBucList, currentSed)
@@ -99,12 +101,12 @@ abstract class SedListenerBase(
         return SaksInfoSamlet(saksIdFraSed, sakInformasjon, saktypeFraSedEllerPesys)
     }
 
-    private fun oppdaterGjennySak(sedHendelse: SedHendelse) : String? {
+    private fun oppdaterGjennySak(sedHendelse: SedHendelse, gjennysakFraSed: String) : String? {
         val gcpGjennysak = gcpStorageService.hentFraGjenny(sedHendelse.rinaSakId)?.let { mapJsonToAny<GjennySak>(it) }
         val gjennyFinnes = gcpStorageService.gjennyFinnes(sedHendelse.rinaSakId)
 
         return if (gjennyFinnes && gcpGjennysak?.sakId == null && gcpGjennysak != null) {
-            gcpStorageService.oppdaterGjennysak(sedHendelse, gcpGjennysak)
+            gcpStorageService.oppdaterGjennysak(sedHendelse, gcpGjennysak, gjennysakFraSed)
         }
         else null
 

src/test/kotlin/no/nav/eessi/pensjon/listeners/SedMottattListenerTest.kt

@@ -51,7 +51,7 @@ internal class SedMottattListenerTest {
             }
         """.trimIndent()
         every { gcpStorageService.gjennyFinnes(any()) } returns true
-        every { gcpStorageService.oppdaterGjennysak(any(), any()) } returns "123546"
+        every { gcpStorageService.oppdaterGjennysak(any(), any(), any()) } returns "123546"
         every { gcpStorageService.hentFraGjenny(any()) } returns gjennysakIBucket
         sedListener.consumeSedMottatt(String(Files.readAllBytes(Paths.get("src/test/resources/eux/hendelser/P_BUC_02_P2100.json"))), cr, acknowledgment)