Skip to content

Commit

Permalink
🔥 Fjern diverse dao-funksjoner som ikke lenger er i bruk med tilhørende
Browse files Browse the repository at this point in the history 
* Oppdaget at OpprettMinimaltVedtakCommand ikke er i bruk, slettet denne
også
* Forenklet grensesnittet for å legge til en utbetaling på en
vedtaksperiode
  • Loading branch information
@chsko
chsko committed Aug 20, 2024
1 parent fb4db6b commit a6c5bde
Show file tree
Hide file tree
Showing 19 changed files with 223 additions and 1,655 deletions.
60 changes: 0 additions & 60 deletions ...ialist-selve/src/main/kotlin/no/nav/helse/modell/kommando/OpprettMinimaltVedtakCommand.kt
View file

This file was deleted.

17 changes: 12 additions & 5 deletions spesialist-selve/src/main/kotlin/no/nav/helse/modell/person/Person.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ import no.nav.helse.modell.vedtaksperiode.Vedtaksperiode
import no.nav.helse.modell.vedtaksperiode.Vedtaksperiode.Companion.relevanteFor
import no.nav.helse.modell.vedtaksperiode.VedtaksperiodeDto
import no.nav.helse.modell.vedtaksperiode.VedtaksperiodeForkastet
import no.nav.helse.modell.vedtaksperiode.VedtaksperiodeNyUtbetaling
import no.nav.helse.modell.vedtaksperiode.vedtak.VedtakFattet
import no.nav.helse.modell.vilkårsprøving.Avviksvurdering
import no.nav.helse.modell.vilkårsprøving.AvviksvurderingDto
Expand Down Expand Up @@ -64,7 +63,12 @@ class Person private constructor(
vedtaksperioder.forEach { it.nyttGodkjenningsbehov(perioder) }
}

fun oppdaterPeriodeTilGodkjenning(vedtaksperiodeId: UUID, tags: List<String>, spleisBehandlingId: UUID, utbetalingId: UUID) {
fun oppdaterPeriodeTilGodkjenning(
vedtaksperiodeId: UUID,
tags: List<String>,
spleisBehandlingId: UUID,
utbetalingId: UUID,
) {
vedtaksperiode(vedtaksperiodeId)?.mottaBehandlingsinformasjon(tags, spleisBehandlingId, utbetalingId)
}

Expand Down Expand Up @@ -129,9 +133,12 @@ class Person private constructor(
}
}

internal fun nyUtbetalingForVedtaksperiode(vedtaksperiodeNyUtbetaling: VedtaksperiodeNyUtbetaling) {
vedtaksperiode(vedtaksperiodeNyUtbetaling.vedtaksperiodeId())
?.nyUtbetaling(vedtaksperiodeNyUtbetaling.id, vedtaksperiodeNyUtbetaling.utbetalingId)
internal fun nyUtbetalingForVedtaksperiode(
vedtaksperiodeId: UUID,
utbetalingId: UUID,
) {
vedtaksperiode(vedtaksperiodeId)
?.nyUtbetaling(utbetalingId)
}

companion object {
Expand Down
144 changes: 0 additions & 144 deletions spesialist-selve/src/main/kotlin/no/nav/helse/modell/varsel/VarselDao.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,30 +3,13 @@ package no.nav.helse.modell.varsel
import kotliquery.queryOf
import kotliquery.sessionOf
import no.nav.helse.HelseDao
import no.nav.helse.modell.person.vedtaksperiode.Varsel
import no.nav.helse.modell.person.vedtaksperiode.Varsel.Status
import org.intellij.lang.annotations.Language
import java.time.LocalDateTime
import java.util.UUID
import javax.sql.DataSource

internal class VarselDao(private val dataSource: DataSource) : HelseDao(dataSource) {
internal fun lagreVarsel(
varselId: UUID,
varselkode: String,
opprettet: LocalDateTime,
vedtaksperiodeId: UUID,
generasjonId: UUID,
) {
@Language("PostgreSQL")
val query =
"INSERT INTO selve_varsel (unik_id, kode, vedtaksperiode_id, opprettet, generasjon_ref, definisjon_ref) VALUES (?, ?, ?, ?, (SELECT id FROM selve_vedtaksperiode_generasjon WHERE unik_id = ?), null);"

sessionOf(dataSource).use { session ->
session.run(queryOf(query, varselId, varselkode, vedtaksperiodeId, opprettet, generasjonId).asUpdate)
}
}

internal fun avvikleVarsel(
varselkode: String,
definisjonId: UUID,
Expand Down Expand Up @@ -58,131 +41,4 @@ internal class VarselDao(private val dataSource: DataSource) : HelseDao(dataSour
)
}
}

internal fun oppdaterStatus(
vedtaksperiodeId: UUID,
generasjonId: UUID,
varselkode: String,
status: Status,
ident: String?,
definisjonId: UUID?,
) {
@Language("PostgreSQL")
val query =
"""
UPDATE selve_varsel
SET
status = :status,
status_endret_tidspunkt = :endretTidspunkt,
status_endret_ident = :ident,
definisjon_ref = case :definisjonId
when NULL then NULL
else (SELECT id FROM api_varseldefinisjon WHERE unik_id = :definisjonId)
end
WHERE vedtaksperiode_id = :vedtaksperiodeId
AND generasjon_ref = (SELECT id FROM selve_vedtaksperiode_generasjon WHERE unik_id = :generasjonId)
AND kode = :varselkode
AND status != :status;
"""

sessionOf(dataSource).use { session ->
session.run(
queryOf(
query,
mapOf(
"status" to status.name,
"endretTidspunkt" to LocalDateTime.now(),
"ident" to ident,
"definisjonId" to definisjonId,
"vedtaksperiodeId" to vedtaksperiodeId,
"generasjonId" to generasjonId,
"varselkode" to varselkode,
),
).asUpdate,
).also {
check(
it > 0,
) { "Varsel $varselkode for generasjonId $generasjonId, vedtaksperiodeId $vedtaksperiodeId har allerede status $status" }
}
}
}

internal fun oppdaterGenerasjon(
id: UUID,
gammelGenerasjonId: UUID,
nyGenerasjonId: UUID,
) {
@Language("PostgreSQL")
val query = """
UPDATE selve_varsel
SET generasjon_ref = (SELECT id FROM selve_vedtaksperiode_generasjon WHERE unik_id = :ny_generasjon_id)
WHERE unik_id = :id
AND generasjon_ref = (SELECT id FROM selve_vedtaksperiode_generasjon WHERE unik_id = :gammel_generasjon_id)
"""

sessionOf(dataSource).use { session ->
session.run(
queryOf(
query,
mapOf(
"ny_generasjon_id" to nyGenerasjonId,
"gammel_generasjon_id" to gammelGenerasjonId,
"id" to id,
),
).asUpdate,
)
}
}

internal fun finnVarselstatus(
vedtaksperiodeId: UUID,
varselkode: String,
): Status? {
@Language("PostgreSQL")
val query = "SELECT status FROM selve_varsel WHERE vedtaksperiode_id = ? and kode = ?;"

return sessionOf(dataSource).use { session ->
session.run(
queryOf(query, vedtaksperiodeId, varselkode).map {
enumValueOf<Status>(it.string(1))
}.asSingle,
)
}
}

internal fun varslerFor(generasjonId: UUID): List<Varsel> {
@Language("PostgreSQL")
val query =
"SELECT unik_id, vedtaksperiode_id, kode, opprettet, status FROM selve_varsel WHERE generasjon_ref = (SELECT id FROM selve_vedtaksperiode_generasjon WHERE unik_id = ?)"
return sessionOf(dataSource).use { session ->
session.run(
queryOf(query, generasjonId).map {
Varsel(
it.uuid("unik_id"),
it.string("kode"),
it.localDateTime("opprettet"),
it.uuid("vedtaksperiode_id"),
enumValueOf(it.string("status")),
)
}.asList,
)
}
}

internal fun slettFor(
vedtaksperiodeId: UUID,
generasjonId: UUID,
varselkode: String,
) = asSQL(
"""
delete from selve_varsel where vedtaksperiode_id = :vedtaksperiodeId
and kode = :varselkode
and generasjon_ref = (select id from selve_vedtaksperiode_generasjon where unik_id = :generasjonId)
""".trimIndent(),
mapOf(
"vedtaksperiodeId" to vedtaksperiodeId,
"generasjonId" to generasjonId,
"varselkode" to varselkode,
),
).update()
}
9 changes: 2 additions & 7 deletions spesialist-selve/src/main/kotlin/no/nav/helse/modell/vedtaksperiode/Generasjon.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -105,11 +105,8 @@ internal class Generasjon private constructor(

internal fun automatiskGodkjennSpesialsakvarsler() = varsler.automatiskGodkjennSpesialsakvarsler()

internal fun håndterNyUtbetaling(
hendelseId: UUID,
utbetalingId: UUID,
) {
tilstand.nyUtbetaling(this, hendelseId, utbetalingId)
internal fun håndterNyUtbetaling(utbetalingId: UUID) {
tilstand.nyUtbetaling(this, utbetalingId)
}

internal fun håndterForkastetUtbetaling(utbetalingId: UUID) {
Expand Down Expand Up @@ -300,7 +297,6 @@ internal class Generasjon private constructor(

fun nyUtbetaling(
generasjon: Generasjon,
hendelseId: UUID,
utbetalingId: UUID,
) {
sikkerlogg.error(
Expand Down Expand Up @@ -359,7 +355,6 @@ internal class Generasjon private constructor(

override fun nyUtbetaling(
generasjon: Generasjon,
hendelseId: UUID,
utbetalingId: UUID,
) {
generasjon.nyUtbetaling(utbetalingId)
Expand Down
Loading

0 comments on commit a6c5bde

Please sign in to comment.