Skip to content

Commit

Permalink
Merge pull request #1339 from navikt/patch_anke_i_tr_pesys
Browse files Browse the repository at this point in the history 
Patch wrong values in anker i TR migrated from Pesys.
  • Loading branch information
@oyvind-wedoe
oyvind-wedoe authored Feb 13, 2025
2 parents 4c88f31 + 5626036 commit ad0e101
Show file tree
Hide file tree
Showing 2 changed files with 378 additions and 0 deletions.
162 changes: 162 additions & 0 deletions src/main/kotlin/db/migration/V187__dvh_pesys_fix_migrated_anker_i_tr.kt
View file
Original file line number Diff line number Diff line change
@@ -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()
}

}
}
}
}
216 changes: 216 additions & 0 deletions src/main/resources/db/migration/V186__pesys_fix_dvh_ref_anker_i_tr.sql
View file
Original file line number Diff line number Diff line change
@@ -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';

0 comments on commit ad0e101

Please sign in to comment.