diff --git a/src/main/kotlin/db/migration/V187__dvh_pesys_fix_migrated_anker_i_tr.kt b/src/main/kotlin/db/migration/V187__dvh_pesys_fix_migrated_anker_i_tr.kt new file mode 100644 index 000000000..2ed57e60a --- /dev/null +++ b/src/main/kotlin/db/migration/V187__dvh_pesys_fix_migrated_anker_i_tr.kt @@ -0,0 +1,162 @@ +package db.migration + +import no.nav.klage.oppgave.domain.kafka.StatistikkTilDVH +import no.nav.klage.oppgave.util.ourJacksonObjectMapper +import org.flywaydb.core.api.migration.BaseJavaMigration +import org.flywaydb.core.api.migration.Context +import java.time.LocalDateTime +import java.util.* + +class V187__dvh_pesys_fix_migrated_anker_i_tr : BaseJavaMigration() { + override fun migrate(context: Context) { + val preparedStatement = context.connection.prepareStatement( + """ + update klage.kafka_event + set json_payload = ?, status_id = ? + where id = ? + """.trimIndent() + ) + + context.connection.createStatement().use { select -> + select.executeQuery( + """ + select ke.id, ke.json_payload + from klage.kafka_event ke + where ke.type = 'STATS_DVH' + and ke.kilde_referanse in ( +'42732182', +'50839922', +'51000174', +'51237578', +'54868291', +'56015005', +'58105978', +'58123865', +'58164030', +'58242017', +'59562571', +'59570942', +'59677898', +'59858460', +'61798791', +'62711221', +'62762092', +'62770112', +'62771621', +'63239959', +'63252563', +'65002130', +'65025720', +'65043518', +'65079148', +'65092341', +'65110126', +'65118462', +'65229724', +'65515231', +'65515785', +'65519983', +'65665971', +'65677516', +'65677635', +'65677689', +'65694656', +'65697538', +'65881836', +'66015487', +'66037964', +'66056048', +'66074680', +'66079224', +'66080169', +'66089585', +'66089958', +'66097917', +'66105405', +'66141305', +'66218596', +'66235147', +'68380341', +'68400811' +) + """ + ) + .use { rows -> + while (rows.next()) { + val kafkaEventId = rows.getObject(1, UUID::class.java) + val jsonPayload = rows.getString(2) + + val statistikkTilDVH = + ourJacksonObjectMapper().readValue(jsonPayload, StatistikkTilDVH::class.java) + + val modifiedVersion = when (statistikkTilDVH.behandlingId) { + "29929939" -> statistikkTilDVH.copy(behandlingId = "46924798", tekniskTid = LocalDateTime.now()) + "34591160" -> statistikkTilDVH.copy(behandlingId = "37553958", tekniskTid = LocalDateTime.now()) + "35971378" -> statistikkTilDVH.copy(behandlingId = "37042716", tekniskTid = LocalDateTime.now()) + "36204480" -> statistikkTilDVH.copy(behandlingId = "44906368", tekniskTid = LocalDateTime.now()) + "36297746" -> statistikkTilDVH.copy(behandlingId = "39240108", tekniskTid = LocalDateTime.now()) + "36916837" -> statistikkTilDVH.copy(behandlingId = "46731299", tekniskTid = LocalDateTime.now()) + "39430889" -> statistikkTilDVH.copy(behandlingId = "40490013", tekniskTid = LocalDateTime.now()) + "39569750" -> statistikkTilDVH.copy(behandlingId = "41056652", tekniskTid = LocalDateTime.now()) + "39290541" -> statistikkTilDVH.copy(behandlingId = "42409863", tekniskTid = LocalDateTime.now()) + "39419643" -> statistikkTilDVH.copy(behandlingId = "48464095", tekniskTid = LocalDateTime.now()) + "40296601" -> statistikkTilDVH.copy(behandlingId = "43360766", tekniskTid = LocalDateTime.now()) + "40394607" -> statistikkTilDVH.copy(behandlingId = "44368650", tekniskTid = LocalDateTime.now()) + "42524508" -> statistikkTilDVH.copy(behandlingId = "46795526", tekniskTid = LocalDateTime.now()) + "42763873" -> statistikkTilDVH.copy(behandlingId = "48372473", tekniskTid = LocalDateTime.now()) + "43016284" -> statistikkTilDVH.copy(behandlingId = "48386800", tekniskTid = LocalDateTime.now()) + "45180705" -> statistikkTilDVH.copy(behandlingId = "47032750", tekniskTid = LocalDateTime.now()) + "44771630" -> statistikkTilDVH.copy(behandlingId = "50200505", tekniskTid = LocalDateTime.now()) + "44874762" -> statistikkTilDVH.copy(behandlingId = "49229515", tekniskTid = LocalDateTime.now()) + "45698696" -> statistikkTilDVH.copy(behandlingId = "48803016", tekniskTid = LocalDateTime.now()) + "44511107" -> statistikkTilDVH.copy(behandlingId = "46705285", tekniskTid = LocalDateTime.now()) + "45155349" -> statistikkTilDVH.copy(behandlingId = "48211098", tekniskTid = LocalDateTime.now()) + "46685908" -> statistikkTilDVH.copy(behandlingId = "48273054", tekniskTid = LocalDateTime.now()) + "46592319" -> statistikkTilDVH.copy(behandlingId = "49153114", tekniskTid = LocalDateTime.now()) + "46863905" -> statistikkTilDVH.copy(behandlingId = "47165156", tekniskTid = LocalDateTime.now()) + "46761693" -> statistikkTilDVH.copy(behandlingId = "47789603", tekniskTid = LocalDateTime.now()) + "46581200" -> statistikkTilDVH.copy(behandlingId = "48279856", tekniskTid = LocalDateTime.now()) + "46796956" -> statistikkTilDVH.copy(behandlingId = "48632600", tekniskTid = LocalDateTime.now()) + "46966952" -> statistikkTilDVH.copy(behandlingId = "48360549", tekniskTid = LocalDateTime.now()) + "46871851" -> statistikkTilDVH.copy(behandlingId = "49775165", tekniskTid = LocalDateTime.now()) + "46987163" -> statistikkTilDVH.copy(behandlingId = "48655923", tekniskTid = LocalDateTime.now()) + "46831512" -> statistikkTilDVH.copy(behandlingId = "49189245", tekniskTid = LocalDateTime.now()) + "47050347" -> statistikkTilDVH.copy(behandlingId = "48610584", tekniskTid = LocalDateTime.now()) + "47112614" -> statistikkTilDVH.copy(behandlingId = "48656851", tekniskTid = LocalDateTime.now()) + "47221565" -> statistikkTilDVH.copy(behandlingId = "48830671", tekniskTid = LocalDateTime.now()) + "47223409" -> statistikkTilDVH.copy(behandlingId = "49064507", tekniskTid = LocalDateTime.now()) + "47232933" -> statistikkTilDVH.copy(behandlingId = "48815445", tekniskTid = LocalDateTime.now()) + "47195122" -> statistikkTilDVH.copy(behandlingId = "49083804", tekniskTid = LocalDateTime.now()) + "47676204" -> statistikkTilDVH.copy(behandlingId = "49088281", tekniskTid = LocalDateTime.now()) + "47075843" -> statistikkTilDVH.copy(behandlingId = "48496134", tekniskTid = LocalDateTime.now()) + "47789246" -> statistikkTilDVH.copy(behandlingId = "49120882", tekniskTid = LocalDateTime.now()) + "47677558" -> statistikkTilDVH.copy(behandlingId = "48656611", tekniskTid = LocalDateTime.now()) + "48191344" -> statistikkTilDVH.copy(behandlingId = "49081011", tekniskTid = LocalDateTime.now()) + "48226548" -> statistikkTilDVH.copy(behandlingId = "48376197", tekniskTid = LocalDateTime.now()) + "48235012" -> statistikkTilDVH.copy(behandlingId = "49420080", tekniskTid = LocalDateTime.now()) + "48230503" -> statistikkTilDVH.copy(behandlingId = "49128417", tekniskTid = LocalDateTime.now()) + "48253006" -> statistikkTilDVH.copy(behandlingId = "49091125", tekniskTid = LocalDateTime.now()) + "48020994" -> statistikkTilDVH.copy(behandlingId = "48816117", tekniskTid = LocalDateTime.now()) + "46852801" -> statistikkTilDVH.copy(behandlingId = "49088709", tekniskTid = LocalDateTime.now()) + "47794890" -> statistikkTilDVH.copy(behandlingId = "49120897", tekniskTid = LocalDateTime.now()) + "48348749" -> statistikkTilDVH.copy(behandlingId = "49182562", tekniskTid = LocalDateTime.now()) + "48492846" -> statistikkTilDVH.copy(behandlingId = "49219505", tekniskTid = LocalDateTime.now()) + "48412294" -> statistikkTilDVH.copy(behandlingId = "49054828", tekniskTid = LocalDateTime.now()) + "48396802" -> statistikkTilDVH.copy(behandlingId = "49189586", tekniskTid = LocalDateTime.now()) + "49190951" -> statistikkTilDVH.copy(behandlingId = "49420081", tekniskTid = LocalDateTime.now()) + + + else -> throw RuntimeException("Unknown behandlingId: ${statistikkTilDVH.behandlingId}") + } + + preparedStatement.setString(1, ourJacksonObjectMapper().writeValueAsString(modifiedVersion)) + preparedStatement.setObject(2,"IKKE_SENDT") + preparedStatement.setObject(3, kafkaEventId) + + preparedStatement.executeUpdate() + } + + } + } + } +} \ No newline at end of file diff --git a/src/main/resources/db/migration/V186__pesys_fix_dvh_ref_anker_i_tr.sql b/src/main/resources/db/migration/V186__pesys_fix_dvh_ref_anker_i_tr.sql new file mode 100644 index 000000000..289a2e68c --- /dev/null +++ b/src/main/resources/db/migration/V186__pesys_fix_dvh_ref_anker_i_tr.sql @@ -0,0 +1,216 @@ +UPDATE klage.behandling +SET dvh_referanse = '46924798' +WHERE kilde_referanse = '42732182' + AND dvh_referanse = '29929939'; +UPDATE klage.behandling +SET dvh_referanse = '37553958' +WHERE kilde_referanse = '50839922' + AND dvh_referanse = '34591160'; +UPDATE klage.behandling +SET dvh_referanse = '37042716' +WHERE kilde_referanse = '51000174' + AND dvh_referanse = '35971378'; +UPDATE klage.behandling +SET dvh_referanse = '44906368' +WHERE kilde_referanse = '51237578' + AND dvh_referanse = '36204480'; +UPDATE klage.behandling +SET dvh_referanse = '39240108' +WHERE kilde_referanse = '54868291' + AND dvh_referanse = '36297746'; +UPDATE klage.behandling +SET dvh_referanse = '46731299' +WHERE kilde_referanse = '56015005' + AND dvh_referanse = '36916837'; +UPDATE klage.behandling +SET dvh_referanse = '40490013' +WHERE kilde_referanse = '58105978' + AND dvh_referanse = '39430889'; +UPDATE klage.behandling +SET dvh_referanse = '41056652' +WHERE kilde_referanse = '58123865' + AND dvh_referanse = '39569750'; +UPDATE klage.behandling +SET dvh_referanse = '42409863' +WHERE kilde_referanse = '58164030' + AND dvh_referanse = '39290541'; +UPDATE klage.behandling +SET dvh_referanse = '48464095' +WHERE kilde_referanse = '58242017' + AND dvh_referanse = '39419643'; +UPDATE klage.behandling +SET dvh_referanse = '43360766' +WHERE kilde_referanse = '59562571' + AND dvh_referanse = '40296601'; +UPDATE klage.behandling +SET dvh_referanse = '44368650' +WHERE kilde_referanse = '59570942' + AND dvh_referanse = '40394607'; +UPDATE klage.behandling +SET dvh_referanse = '46795526' +WHERE kilde_referanse = '59677898' + AND dvh_referanse = '42524508'; +UPDATE klage.behandling +SET dvh_referanse = '48372473' +WHERE kilde_referanse = '59858460' + AND dvh_referanse = '42763873'; +UPDATE klage.behandling +SET dvh_referanse = '48386800' +WHERE kilde_referanse = '61798791' + AND dvh_referanse = '43016284'; +UPDATE klage.behandling +SET dvh_referanse = '47032750' +WHERE kilde_referanse = '62711221' + AND dvh_referanse = '45180705'; +UPDATE klage.behandling +SET dvh_referanse = '50200505' +WHERE kilde_referanse = '62762092' + AND dvh_referanse = '44771630'; +UPDATE klage.behandling +SET dvh_referanse = '49229515' +WHERE kilde_referanse = '62770112' + AND dvh_referanse = '44874762'; +UPDATE klage.behandling +SET dvh_referanse = '48803016' +WHERE kilde_referanse = '62771621' + AND dvh_referanse = '45698696'; +UPDATE klage.behandling +SET dvh_referanse = '46705285' +WHERE kilde_referanse = '63239959' + AND dvh_referanse = '44511107'; +UPDATE klage.behandling +SET dvh_referanse = '48211098' +WHERE kilde_referanse = '63252563' + AND dvh_referanse = '45155349'; +UPDATE klage.behandling +SET dvh_referanse = '48273054' +WHERE kilde_referanse = '65002130' + AND dvh_referanse = '46685908'; +UPDATE klage.behandling +SET dvh_referanse = '49153114' +WHERE kilde_referanse = '65025720' + AND dvh_referanse = '46592319'; +UPDATE klage.behandling +SET dvh_referanse = '47165156' +WHERE kilde_referanse = '65043518' + AND dvh_referanse = '46863905'; +UPDATE klage.behandling +SET dvh_referanse = '47789603' +WHERE kilde_referanse = '65079148' + AND dvh_referanse = '46761693'; +UPDATE klage.behandling +SET dvh_referanse = '48279856' +WHERE kilde_referanse = '65092341' + AND dvh_referanse = '46581200'; +UPDATE klage.behandling +SET dvh_referanse = '48632600' +WHERE kilde_referanse = '65110126' + AND dvh_referanse = '46796956'; +UPDATE klage.behandling +SET dvh_referanse = '48360549' +WHERE kilde_referanse = '65118462' + AND dvh_referanse = '46966952'; +UPDATE klage.behandling +SET dvh_referanse = '49775165' +WHERE kilde_referanse = '65229724' + AND dvh_referanse = '46871851'; +UPDATE klage.behandling +SET dvh_referanse = '48655923' +WHERE kilde_referanse = '65515231' + AND dvh_referanse = '46987163'; +UPDATE klage.behandling +SET dvh_referanse = '49189245' +WHERE kilde_referanse = '65515785' + AND dvh_referanse = '46831512'; +UPDATE klage.behandling +SET dvh_referanse = '48610584' +WHERE kilde_referanse = '65519983' + AND dvh_referanse = '47050347'; +UPDATE klage.behandling +SET dvh_referanse = '48656851' +WHERE kilde_referanse = '65665971' + AND dvh_referanse = '47112614'; +UPDATE klage.behandling +SET dvh_referanse = '48830671' +WHERE kilde_referanse = '65677516' + AND dvh_referanse = '47221565'; +UPDATE klage.behandling +SET dvh_referanse = '49064507' +WHERE kilde_referanse = '65677635' + AND dvh_referanse = '47223409'; +UPDATE klage.behandling +SET dvh_referanse = '48815445' +WHERE kilde_referanse = '65677689' + AND dvh_referanse = '47232933'; +UPDATE klage.behandling +SET dvh_referanse = '49083804' +WHERE kilde_referanse = '65694656' + AND dvh_referanse = '47195122'; +UPDATE klage.behandling +SET dvh_referanse = '49088281' +WHERE kilde_referanse = '65697538' + AND dvh_referanse = '47676204'; +UPDATE klage.behandling +SET dvh_referanse = '48496134' +WHERE kilde_referanse = '65881836' + AND dvh_referanse = '47075843'; +UPDATE klage.behandling +SET dvh_referanse = '49120882' +WHERE kilde_referanse = '66015487' + AND dvh_referanse = '47789246'; +UPDATE klage.behandling +SET dvh_referanse = '48656611' +WHERE kilde_referanse = '66037964' + AND dvh_referanse = '47677558'; +UPDATE klage.behandling +SET dvh_referanse = '49081011' +WHERE kilde_referanse = '66056048' + AND dvh_referanse = '48191344'; +UPDATE klage.behandling +SET dvh_referanse = '48376197' +WHERE kilde_referanse = '66074680' + AND dvh_referanse = '48226548'; +UPDATE klage.behandling +SET dvh_referanse = '49420080' +WHERE kilde_referanse = '66079224' + AND dvh_referanse = '48235012'; +UPDATE klage.behandling +SET dvh_referanse = '49128417' +WHERE kilde_referanse = '66080169' + AND dvh_referanse = '48230503'; +UPDATE klage.behandling +SET dvh_referanse = '49091125' +WHERE kilde_referanse = '66089585' + AND dvh_referanse = '48253006'; +UPDATE klage.behandling +SET dvh_referanse = '48816117' +WHERE kilde_referanse = '66089958' + AND dvh_referanse = '48020994'; +UPDATE klage.behandling +SET dvh_referanse = '49088709' +WHERE kilde_referanse = '66097917' + AND dvh_referanse = '46852801'; +UPDATE klage.behandling +SET dvh_referanse = '49120897' +WHERE kilde_referanse = '66105405' + AND dvh_referanse = '47794890'; +UPDATE klage.behandling +SET dvh_referanse = '49182562' +WHERE kilde_referanse = '66141305' + AND dvh_referanse = '48348749'; +UPDATE klage.behandling +SET dvh_referanse = '49219505' +WHERE kilde_referanse = '66218596' + AND dvh_referanse = '48492846'; +UPDATE klage.behandling +SET dvh_referanse = '49054828' +WHERE kilde_referanse = '66235147' + AND dvh_referanse = '48412294'; +UPDATE klage.behandling +SET dvh_referanse = '49189586' +WHERE kilde_referanse = '68380341' + AND dvh_referanse = '48396802'; +UPDATE klage.behandling +SET dvh_referanse = '49420081' +WHERE kilde_referanse = '68400811' + AND dvh_referanse = '49190951'; \ No newline at end of file