Skip to content

Commit

Permalink
♻️ Rydder i periodehistorikkDao
Browse files Browse the repository at this point in the history
  • Loading branch information
elitho committed Nov 12, 2024
1 parent b2a1684 commit 5c915e2
Show file tree
Hide file tree
Showing 11 changed files with 25 additions and 25 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,12 @@ import no.nav.helse.modell.periodehistorikk.HistorikkinnslagDto
import java.util.UUID

interface PeriodehistorikkDao {
fun lagre(
fun lagreMedOppgaveId(
historikkinnslag: HistorikkinnslagDto,
oppgaveId: Long,
)

fun lagre(
fun lagreMedGenerasjonId(
historikkinnslag: HistorikkinnslagDto,
generasjonId: UUID,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,24 +22,24 @@ class PgPeriodehistorikkDao(
constructor(session: Session) : this(MedSession(session))
constructor(dataSource: DataSource) : this(MedDataSource(dataSource))

override fun lagre(
override fun lagreMedOppgaveId(
historikkinnslag: HistorikkinnslagDto,
oppgaveId: Long,
) {
val generasjonId = PgOppgaveDao(queryRunner).finnGenerasjonId(oppgaveId)
lagre(historikkinnslag, generasjonId)
lagreMedGenerasjonId(historikkinnslag, generasjonId)
}

override fun lagre(
override fun lagreMedGenerasjonId(
historikkinnslag: HistorikkinnslagDto,
generasjonId: UUID,
) {
when (historikkinnslag) {
is FjernetFraPåVent -> lagre(historikkinnslag, generasjonId, null)
is LagtPåVent -> lagre(historikkinnslag, generasjonId, null)
is TotrinnsvurderingFerdigbehandlet -> lagre(historikkinnslag, generasjonId, null)
is AvventerTotrinnsvurdering -> lagre(historikkinnslag, generasjonId, null)
is TotrinnsvurderingAutomatiskRetur -> lagre(historikkinnslag, generasjonId, null)
is FjernetFraPåVent -> lagre(historikkinnslag, generasjonId)
is LagtPåVent -> lagre(historikkinnslag, generasjonId)
is TotrinnsvurderingFerdigbehandlet -> lagre(historikkinnslag, generasjonId)
is AvventerTotrinnsvurdering -> lagre(historikkinnslag, generasjonId)
is TotrinnsvurderingAutomatiskRetur -> lagre(historikkinnslag, generasjonId)
is TotrinnsvurderingRetur -> {
val notatId =
PgNotatDao(queryRunner)
Expand All @@ -53,15 +53,15 @@ class PgPeriodehistorikkDao(
lagre(historikkinnslag, generasjonId, notatId)
}

is AutomatiskBehandlingStanset -> lagre(historikkinnslag, generasjonId, null)
is VedtaksperiodeReberegnet -> lagre(historikkinnslag, generasjonId, null)
is AutomatiskBehandlingStanset -> lagre(historikkinnslag, generasjonId)
is VedtaksperiodeReberegnet -> lagre(historikkinnslag, generasjonId)
}
}

private fun lagre(
historikkinnslag: HistorikkinnslagDto,
generasjonId: UUID,
notatId: Int?,
notatId: Int? = null,
) {
asSQL(
"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ internal class GodkjenningService(
val beslutter = totrinnsvurdering.beslutter?.let { saksbehandlerRepository.finnSaksbehandler(it)?.toDto() }
checkNotNull(beslutter) { "Forventer at beslutter er satt" }
val innslag = HistorikkinnslagDto.totrinnsvurderingFerdigbehandletInnslag(beslutter)
periodehistorikkDao.lagre(innslag, godkjenningDTO.oppgavereferanse)
periodehistorikkDao.lagreMedOppgaveId(innslag, godkjenningDTO.oppgavereferanse)
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ internal class SaksbehandlerMediator(
frist = handling.frist,
dialogRef = dialogRef,
)
periodehistorikkDao.lagre(innslag, handling.oppgaveId)
periodehistorikkDao.lagreMedOppgaveId(innslag, handling.oppgaveId)
oppgaveService.leggPåVent(handling, saksbehandler)
PåVentRepository(påVentDao).leggPåVent(saksbehandler.oid(), handling, dialogRef)
} catch (e: Modellfeil) {
Expand All @@ -288,7 +288,7 @@ internal class SaksbehandlerMediator(
}
try {
val innslag = HistorikkinnslagDto.fjernetFraPåVentInnslag(saksbehandler.toDto())
periodehistorikkDao.lagre(innslag, handling.oppgaveId)
periodehistorikkDao.lagreMedOppgaveId(innslag, handling.oppgaveId)
oppgaveService.fjernFraPåVent(handling.oppgaveId)
PåVentRepository(påVentDao).fjernFraPåVent(handling.oppgaveId)
} catch (e: Modellfeil) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ internal class VedtaksperiodeReberegnetPeriodehistorikk(
) : Command {
override fun execute(context: CommandContext): Boolean {
val innslag = HistorikkinnslagDto.vedtaksperiodeReberegnet()
periodehistorikkDao.lagre(historikkinnslag = innslag, generasjonId = vedtaksperiode.gjeldendeGenerasjonId)
periodehistorikkDao.lagreMedGenerasjonId(historikkinnslag = innslag, generasjonId = vedtaksperiode.gjeldendeGenerasjonId)
return true
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ internal class StansAutomatiskBehandlingMediator(
val oppgaveId = oppgaveDao.finnOppgaveId(fødselsnummer)
if (oppgaveId != null) {
val innslag = HistorikkinnslagDto.automatiskBehandlingStanset()
periodehistorikkDao.lagre(innslag, oppgaveId)
periodehistorikkDao.lagreMedOppgaveId(innslag, oppgaveId)
} else {
sikkerlogg.info("Fant ikke oppgave for $fødselsnummer. Fikk ikke lagret historikkinnslag om stans av automatisk behandling")
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ class TotrinnsvurderingService(
oppgaveDao.finnIdForAktivOppgave(vedtaksperiodeId)?.let {
totrinnsvurderingDao.settErRetur(vedtaksperiodeId)
val innslag = HistorikkinnslagDto.totrinnsvurderingAutomatiskRetur()
periodehistorikkDao.lagre(innslag, it)
periodehistorikkDao.lagreMedOppgaveId(innslag, it)
}
}

Expand All @@ -44,15 +44,15 @@ class TotrinnsvurderingService(
saksbehandler = saksbehandlerFraApi.toDto(),
dialogRef = dialogRef,
)
periodehistorikkDao.lagre(innslag, oppgaveId)
periodehistorikkDao.lagreMedOppgaveId(innslag, oppgaveId)
}

override fun avventerTotrinnsvurdering(
oppgaveId: Long,
saksbehandlerFraApi: SaksbehandlerFraApi,
) {
val innslag = HistorikkinnslagDto.avventerTotrinnsvurdering(saksbehandlerFraApi.toDto())
periodehistorikkDao.lagre(innslag, oppgaveId)
periodehistorikkDao.lagreMedOppgaveId(innslag, oppgaveId)
}

override fun erBeslutterOppgave(oppgaveId: Long): Boolean = hentAktiv(oppgaveId)?.erBeslutteroppgave() ?: false
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ class PgPeriodehistorikkDaoTest : DatabaseIntegrationTest() {
val saksbehandler = SaksbehandlerDto(SAKSBEHANDLER_EPOST, SAKSBEHANDLER_OID, SAKSBEHANDLER_NAVN, SAKSBEHANDLER_IDENT)
val historikkinnslag = HistorikkinnslagDto.fjernetFraPåVentInnslag(saksbehandler)

historikkinnslagRepository.lagre(historikkinnslag, oppgaveId)
historikkinnslagRepository.lagreMedOppgaveId(historikkinnslag, oppgaveId)
val result = periodehistorikkApiDao.finn(UTBETALING_ID)

assertEquals(1, result.size)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,6 @@ class VedtaksperiodeReberegnetPeriodehistorikkTest {
val repository = mockk<PeriodehistorikkDao>(relaxed = true)
val command = VedtaksperiodeReberegnetPeriodehistorikk(mockk(relaxed = true), repository)
assertTrue(command.execute(context))
verify(exactly = 1) { repository.lagre(any<VedtaksperiodeReberegnet>(), any<UUID>()) }
verify(exactly = 1) { repository.lagreMedGenerasjonId(any<VedtaksperiodeReberegnet>(), any<UUID>()) }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ class StansAutomatiskBehandlingMediatorTest {

verify(exactly = 1) { stansAutomatiskBehandlingDao.lagreFraISyfo(melding) }
verify(exactly = 1) {
periodehistorikkDao.lagre(
periodehistorikkDao.lagreMedOppgaveId(
historikkinnslag = any<AutomatiskBehandlingStanset>(),
oppgaveId = any(),
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ class TotrinnsvurderingServiceTest {
verify(exactly = 1) { totrinnsvurderingDao.settErRetur(vedtaksperiodeId) }
verify(exactly = 1) { oppgaveDao.finnIdForAktivOppgave(vedtaksperiodeId) }
verify(exactly = 1) {
periodehistorikkDao.lagre(
periodehistorikkDao.lagreMedOppgaveId(
historikkinnslag = any<TotrinnsvurderingAutomatiskRetur>(),
oppgaveId = oppgaveId,
)
Expand Down

0 comments on commit 5c915e2

Please sign in to comment.