Skip to content

Commit

Permalink
Merge pull request #4089 from navikt/slett-egen-regi-fra-api
Browse files Browse the repository at this point in the history
Slett egen regi tiltak fra api
  • Loading branch information
fredrikpe authored Jul 26, 2024
2 parents c6dcd16 + 160d225 commit 43dce6d
Show file tree
Hide file tree
Showing 7 changed files with 11 additions and 62 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,6 @@ data class TiltaksgjennomforingAdminDto(
val administratorer: List<Administrator>,
val navRegion: NavEnhetDbo?,
val navEnheter: List<NavEnhetDbo>,
@Serializable(with = UUIDSerializer::class)
val sanityId: UUID?,
val oppstart: TiltaksgjennomforingOppstartstype,
val opphav: ArenaMigrering.Opphav,
val kontaktpersoner: List<TiltaksgjennomforingKontaktperson>,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -377,43 +377,6 @@ class TiltaksgjennomforingRepository(private val db: Database) {
.let { db.run(it) }
}

fun getSanityTiltaksgjennomforingId(id: UUID, tx: Session): UUID? {
@Language("PostgreSQL")
val query = """
select sanity_id
from tiltaksgjennomforing
where id = :id::uuid
""".trimIndent()

return queryOf(query, mapOf("id" to id))
.map { it.uuidOrNull("sanity_id") }
.asSingle
.runWithSession(tx)
}

fun updateSanityTiltaksgjennomforingId(id: UUID, sanityId: UUID) =
db.transaction { updateSanityTiltaksgjennomforingId(id, sanityId, it) }

fun updateSanityTiltaksgjennomforingId(id: UUID, sanityId: UUID, tx: Session) {
@Language("PostgreSQL")
val query = """
update tiltaksgjennomforing
set sanity_id = :sanity_id::uuid
where id = :id::uuid
and sanity_id is null
""".trimIndent()

queryOf(
query,
mapOf(
"sanity_id" to sanityId,
"id" to id,
),
)
.asUpdate
.let { tx.run(it) }
}

fun getAll(
pagination: Pagination = Pagination.all(),
search: String? = null,
Expand Down Expand Up @@ -516,7 +479,6 @@ class TiltaksgjennomforingRepository(private val db: Database) {
select
gjennomforing.id,
a.id as avtale_id,
gjennomforing.sanity_id,
gjennomforing.navn,
gjennomforing.sted_for_gjennomforing,
gjennomforing.apent_for_innsok,
Expand Down Expand Up @@ -785,7 +747,6 @@ class TiltaksgjennomforingRepository(private val db: Database) {
val avbruttAarsak = stringOrNull("avbrutt_aarsak")?.let { AvbruttAarsak.fromString(it) }

return VeilederflateTiltaksgjennomforing(
sanityId = uuidOrNull("sanity_id").toString(),
id = uuidOrNull("id"),
avtaleId = uuidOrNull("avtale_id"),
tiltakstype = VeilederflateTiltakstype(
Expand Down Expand Up @@ -866,7 +827,6 @@ class TiltaksgjennomforingRepository(private val db: Database) {
},
),
apentForInnsok = boolean("apent_for_innsok"),
sanityId = uuidOrNull("sanity_id"),
antallPlasser = intOrNull("antall_plasser"),
avtaleId = uuidOrNull("avtale_id"),
oppstart = TiltaksgjennomforingOppstartstype.valueOf(string("oppstart")),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -184,10 +184,6 @@ class ArenaAdapterService(

suspend fun removeTiltaksgjennomforing(id: UUID) {
db.transactionSuspend { tx ->
tiltaksgjennomforinger.getSanityTiltaksgjennomforingId(id, tx)?.let {
sanityTiltakService.deleteSanityTiltaksgjennomforing(it)
}

val numDeleted = tiltaksgjennomforinger.delete(id, tx)
if (numDeleted > 0) {
logDelete(tx, DocumentClass.TILTAKSGJENNOMFORING, id)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,6 @@ class SanityTiltakService(
)

val sanityId = tiltaksgjennomforing.sanityId
// Fallback mens egen regi tiltak fortsatt er i api, og sanity_id ikke har blitt flyttet
// over til arena-adapter (som gjøres via denne metoden)
?: tiltaksgjennomforingRepository.getSanityTiltaksgjennomforingId(tiltaksgjennomforing.id, tx)

return if (sanityId != null) {
patchSanityTiltaksgjennomforing(sanityId, sanityTiltaksgjennomforingFields)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ select gjennomforing.id,
gjennomforing.start_dato,
gjennomforing.slutt_dato,
gjennomforing.apent_for_innsok,
gjennomforing.sanity_id,
gjennomforing.antall_plasser,
gjennomforing.avtale_id,
gjennomforing.oppstart,
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
alter table deltaker drop constraint deltaker_tiltaksgjennomforing_id_fkey;
alter table deltaker
add constraint deltaker_tiltaksgjennomforing_id_fkey
foreign key (tiltaksgjennomforing_id) references tiltaksgjennomforing(id) on delete cascade;

delete from tiltaksgjennomforing
using tiltakstype
where tiltaksgjennomforing.tiltakstype_id = tiltakstype.id
and tiltakstype.arena_kode in ('IPSUNG', 'UTVAOONAV', 'INDJOBSTOT');

alter table tiltaksgjennomforing drop column sanity_id;
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,6 @@ class TiltaksgjennomforingRepositoryTest : FunSpec({
it.administratorer shouldBe emptyList()
it.navEnheter shouldBe emptyList()
it.navRegion shouldBe null
it.sanityId shouldBe null
it.opphav shouldBe ArenaMigrering.Opphav.ARENA
it.kontaktpersoner shouldBe emptyList()
it.stedForGjennomforing shouldBe null
Expand Down Expand Up @@ -251,7 +250,6 @@ class TiltaksgjennomforingRepositoryTest : FunSpec({
),
)
it.navEnheter shouldBe listOf(Gjovik)
it.sanityId shouldBe null
it.oppstart shouldBe TiltaksgjennomforingOppstartstype.LOPENDE
it.opphav shouldBe ArenaMigrering.Opphav.MR_ADMIN_FLATE
it.kontaktpersoner shouldBe listOf()
Expand Down Expand Up @@ -425,16 +423,6 @@ class TiltaksgjennomforingRepositoryTest : FunSpec({
)
}

test("update sanity_id") {
val id = UUID.randomUUID()

tiltaksgjennomforinger.upsert(Oppfolging1)
tiltaksgjennomforinger.updateSanityTiltaksgjennomforingId(Oppfolging1.id, id)
tiltaksgjennomforinger.get(Oppfolging1.id).should {
it!!.sanityId.shouldBe(id)
}
}

test("arrangør kontaktperson") {
val arrangorRepository = ArrangorRepository(database.db)

Expand Down

0 comments on commit 43dce6d

Please sign in to comment.