Merge pull request #103 from navikt/bug/sletting_av_inntekter

Try to fetch beregningsdato from backup table.

Author: gtcno

dp-inntekt-api/src/main/kotlin/no/nav/dagpenger/inntekt/db/PostgresInntektStore.kt

@@ -88,16 +88,17 @@ internal class PostgresInntektStore(private val dataSource: DataSource) : Inntek
 
     override fun getBeregningsdato(inntektId: InntektId): LocalDate {
         @Language("sql")
-        val statement = """SELECT beregningsdato
-                                FROM inntekt_V1_person_mapping
-                                WHERE inntektId = ?
+        val statement = """SELECT coalesce(
+               (SELECT beregningsdato FROM inntekt_V1_person_mapping WHERE inntektId = :inntektId),
+               (SELECT beregningsdato FROM temp_inntekt_V1_person_mapping WHERE inntektId = :inntektId)
+           ) as beregningsdato
                         """.trimMargin()
 
         return using(sessionOf(dataSource)) { session ->
             session.run(
-                queryOf(statement, inntektId.id
+                queryOf(statement, mapOf("inntektId" to inntektId.id)
                 ).map { row ->
-                    row.localDate("beregningsdato")
+                    row.localDateOrNull("beregningsdato")
                 }.asSingle
             ) ?: throw InntektNotFoundException("Inntekt with id $inntektId not found.")
         }
@@ -194,9 +195,9 @@ internal class PostgresInntektStore(private val dataSource: DataSource) : Inntek
                         tx.run(
                             queryOf(
                                 "INSERT INTO inntekt_V1_manuelt_redigert VALUES(:id,:redigert)", mapOf(
-                                    "id" to inntektId.id,
-                                    "redigert" to it.redigertAv
-                                )
+                                "id" to inntektId.id,
+                                "redigert" to it.redigertAv
+                            )
                             ).asUpdate
                         )
                     }

dp-inntekt-api/src/test/kotlin/no/nav/dagpenger/inntekt/db/PostgresTest.kt

@@ -280,6 +280,23 @@ internal class PostgresInntektStoreTest {
         }
     }
 
+    @Test
+    fun `Sucessfully get beregningsdato from backup table`() {
+        withCleanDb {
+            migrate(DataSource.instance, locations = listOf("db/migration", "unit-testdata"))
+
+            with(PostgresInntektStore(DataSource.instance)) {
+                val beregningsDatoFromMain = getBeregningsdato(InntektId("01E46501PMY105AFXE4XF088MV"))
+                assertNotNull(beregningsDatoFromMain)
+                assertEquals(LocalDate.of(2019, 1, 1), beregningsDatoFromMain)
+
+                val beregningsDatoFromBackup = getBeregningsdato(InntektId("01EDBSHDENAHCVBYT02W160E6X"))
+                assertNotNull(beregningsDatoFromBackup)
+                assertEquals(LocalDate.of(2019, 3, 3), beregningsDatoFromBackup)
+            }
+        }
+    }
+
     @Test
     fun ` Getting beregningsdato for unknown inntektId should throw error`() {
         withMigratedDb {
@@ -292,6 +309,7 @@ internal class PostgresInntektStoreTest {
             }
         }
     }
+
     @Test
     fun ` Should mark an inntekt as used `() {
         withMigratedDb {

dp-inntekt-api/src/test/resources/unit-testdata/R__testscenario_backup_person_mapping.sql

@@ -0,0 +1,21 @@
+INSERT INTO inntekt_v1(id, brukt ,inntekt)
+VALUES ('01E46501PMY105AFXE4XF088MV', TRUE, '{
+  "arbeidsInntektMaaned": [],
+  "ident": {
+    "identifikator": "-1",
+    "aktoerType": "NATURLIG_IDENT"
+  }
+}')
+ON CONFLICT DO NOTHING;
+
+INSERT INTO inntekt_v1_person_mapping (inntektid, aktørid, vedtakid, fnr, beregningsdato)
+VALUES ('01E46501PMY105AFXE4XF088MV', 'INGEN_INNTEKT', 12345, null, '2019-01-01')
+ON CONFLICT DO NOTHING;
+
+INSERT INTO temp_inntekt_v1_person_mapping (inntektid, aktørid, vedtakid, fnr, beregningsdato)
+VALUES ('01E46501PMY105AFXE4XF088MV', 'INGEN_INNTEKT', 12345, null, '2019-02-02')
+ON CONFLICT DO NOTHING;
+
+INSERT INTO temp_inntekt_v1_person_mapping (inntektid, aktørid, vedtakid, fnr, beregningsdato)
+VALUES ('01EDBSHDENAHCVBYT02W160E6X', 'INGEN_INNTEKT', 12345, null, '2019-03-03')
+ON CONFLICT DO NOTHING;