Skip to content

Commit

Permalink
Renamer forsinket til utsatt ifm utsettelse av oppgaveopprettelser
Browse files Browse the repository at this point in the history
  • Loading branch information
throndi committed Sep 11, 2024
1 parent dff30be commit 5b934f3
Show file tree
Hide file tree
Showing 6 changed files with 34 additions and 34 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ class PersonhendelseService(

@Transactional
fun opprettOppgaverAvUkesgamleHendelser() {
val utsatteOppgaver = utsattOppgaveService.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
val utsatteOppgaver = utsattOppgaveService.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()
utsatteOppgaver.forEach { utsattOppgave ->
opprettOppgave(
utsattOppgave.hendelsesId,
Expand All @@ -107,7 +107,7 @@ class PersonhendelseService(
utsattOppgave.personId,
)
}
utsattOppgaveService.settForsinkedeOppgaverTilUtført(utsatteOppgaver)
utsattOppgaveService.settUtsatteOppgaverTilUtført(utsatteOppgaver)
}

private fun logHendelse(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ class UtsattOppgaveRepository(
namedParameterJdbcTemplate.update(sql, params)
}

fun hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid(): List<UtsattOppgave> {
fun hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke(): List<UtsattOppgave> {
val sql =
"SELECT * FROM utsattoppgave WHERE hendelsestid <= (NOW() - INTERVAL '1 week') AND opprettetoppgavetid IS NULL"
return namedParameterJdbcTemplate.query(sql, utsattOppgaveMapper)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ class UtsattOppgaveScheduler(
val logger: Logger = LoggerFactory.getLogger(this::class.java)

@Scheduled(cron = "\${OPPGAVERDØDSFALL_CRON_EXPRESSION}")
fun opprettForsinkedeOppgaver() {
fun opprettUtsatteOppgaver() {
if (LeaderClient.isLeader() == true) {
logger.info("Cron scheduler starter for opprettelse av oppgaver ifm dødsfall")
personhendelseService.opprettOppgaverAvUkesgamleHendelser()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,9 @@ class UtsattOppgaveService(
)
}

fun hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid(): List<UtsattOppgave> = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
fun hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke(): List<UtsattOppgave> = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

fun settForsinkedeOppgaverTilUtført(oppgaver: List<UtsattOppgave>) {
fun settUtsatteOppgaverTilUtført(oppgaver: List<UtsattOppgave>) {
oppgaver.forEach { utsattOppgaveRepository.settOppgaveTilUtført(it.hendelsesId) }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -140,13 +140,13 @@ internal class PersonhendelseServiceTest {
null,
)

every { utsattOppgaveService.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid() } returns listOf(utsattOppgave)
every { utsattOppgaveService.settForsinkedeOppgaverTilUtført(any()) } just runs
every { utsattOppgaveService.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke() } returns listOf(utsattOppgave)
every { utsattOppgaveService.settUtsatteOppgaverTilUtført(any()) } just runs

personhendelseService.opprettOppgaverAvUkesgamleHendelser()

verify { utsattOppgaveService.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid() }
verify { utsattOppgaveService.settForsinkedeOppgaverTilUtført(any()) }
verify { utsattOppgaveService.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke() }
verify { utsattOppgaveService.settUtsatteOppgaverTilUtført(any()) }

assertThat(oppgaveRequestSlot.captured.ident!!.ident).isEqualTo(utsattOppgave.personId)
assertThat(oppgaveRequestSlot.captured.beskrivelse).contains(utsattOppgave.beskrivelse)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,19 +28,19 @@ class UtsattOppgaveRepositoryTest : IntegrasjonSpringRunnerTest() {

lagreOppgave(utsattOppgave)

val forsinkedeOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()

assertThat(forsinkedeOppgaver.first().hendelsesId).isEqualTo(utsattOppgave.hendelsesId)
assertThat(forsinkedeOppgaver.first().personId).isEqualTo(utsattOppgave.personId)
assertThat(forsinkedeOppgaver.first().personhendelseType).isEqualTo(utsattOppgave.personhendelseType)
assertThat(forsinkedeOppgaver.first().beskrivelse).isEqualTo(utsattOppgave.beskrivelse)
assertThat(forsinkedeOppgaver.first().endringstype).isEqualTo(utsattOppgave.endringstype)
assertThat(forsinkedeOppgaver.first().hendelsesTid).isNotNull()
assertThat(forsinkedeOppgaver.first().opprettetOppgaveTid).isNull()
val utsatteOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

assertThat(utsatteOppgaver.first().hendelsesId).isEqualTo(utsattOppgave.hendelsesId)
assertThat(utsatteOppgaver.first().personId).isEqualTo(utsattOppgave.personId)
assertThat(utsatteOppgaver.first().personhendelseType).isEqualTo(utsattOppgave.personhendelseType)
assertThat(utsatteOppgaver.first().beskrivelse).isEqualTo(utsattOppgave.beskrivelse)
assertThat(utsatteOppgaver.first().endringstype).isEqualTo(utsattOppgave.endringstype)
assertThat(utsatteOppgaver.first().hendelsesTid).isNotNull()
assertThat(utsatteOppgaver.first().opprettetOppgaveTid).isNull()
}

@Test
fun `lagre og hent flere forsinkede oppgaver`() {
fun `lagre og hent flere utsatte oppgaver`() {
val utsattOppgave =
UtsattOppgave(
UUID.randomUUID(),
Expand Down Expand Up @@ -75,13 +75,13 @@ class UtsattOppgaveRepositoryTest : IntegrasjonSpringRunnerTest() {
lagreOppgave(utsattOppgave2)
lagreOppgave(utsattOppgave3)

val forsinkedeOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
val utsatteOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

assertThat(forsinkedeOppgaver).hasSize(3)
assertThat(utsatteOppgaver).hasSize(3)
}

@Test
fun `lagre og hent kun forsinkede oppgaver som er over en uke gammel`() {
fun `lagre og hent kun utsatte oppgaver som er over en uke gammel`() {
val utsattOppgave =
UtsattOppgave(
UUID.randomUUID(),
Expand Down Expand Up @@ -117,15 +117,15 @@ class UtsattOppgaveRepositoryTest : IntegrasjonSpringRunnerTest() {
lagreOppgave(utsattOppgave2)
lagreOppgave(utsattOppgave3)

val forsinkedeOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
val utsatteOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

assertThat(forsinkedeOppgaver).hasSize(2)
assertThat(forsinkedeOppgaver.firstOrNull { it.hendelsesId == utsattOppgave.hendelsesId }).isNotNull()
assertThat(forsinkedeOppgaver.firstOrNull { it.hendelsesId == utsattOppgave2.hendelsesId }).isNotNull()
assertThat(utsatteOppgaver).hasSize(2)
assertThat(utsatteOppgaver.firstOrNull { it.hendelsesId == utsattOppgave.hendelsesId }).isNotNull()
assertThat(utsatteOppgaver.firstOrNull { it.hendelsesId == utsattOppgave2.hendelsesId }).isNotNull()
}

@Test
fun `lagre og hent kun forsinkede oppgaver som ikke har blitt utført`() {
fun `lagre og hent kun utsatte oppgaver som ikke har blitt utført`() {
val utsattOppgaveIkkeOpprettet =
UtsattOppgave(
UUID.randomUUID(),
Expand All @@ -151,14 +151,14 @@ class UtsattOppgaveRepositoryTest : IntegrasjonSpringRunnerTest() {
lagreOppgave(utsattOppgaveOpprettet)
utsattOppgaveRepository.settOppgaveTilUtført(utsattOppgaveOpprettet.hendelsesId)

val forsinkedeOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
val utsatteOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

assertThat(forsinkedeOppgaver).hasSize(1)
assertThat(forsinkedeOppgaver.first().hendelsesId).isEqualTo(utsattOppgaveIkkeOpprettet.hendelsesId)
assertThat(utsatteOppgaver).hasSize(1)
assertThat(utsatteOppgaver.first().hendelsesId).isEqualTo(utsattOppgaveIkkeOpprettet.hendelsesId)
}

@Test
fun `ikke lagre duplikate forsinkede oppgaver`() {
fun `ikke lagre duplikate utsatte oppgaver`() {
val utsattOppgave =
UtsattOppgave(
UUID.randomUUID(),
Expand All @@ -173,9 +173,9 @@ class UtsattOppgaveRepositoryTest : IntegrasjonSpringRunnerTest() {
lagreOppgave(utsattOppgave)
lagreOppgave(utsattOppgave)

val forsinkedeOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeForsinkedeOppgaverOverEnUkeTilbakeITid()
val utsatteOppgaver = utsattOppgaveRepository.hentIkkeOpprettedeUtsatteOppgaverEldreEnnEnUke()

assertThat(forsinkedeOppgaver).hasSize(1)
assertThat(utsatteOppgaver).hasSize(1)
}

private fun lagreOppgave(utsattOppgave: UtsattOppgave) {
Expand Down

0 comments on commit 5b934f3

Please sign in to comment.