@@ -61,7 +61,11 @@ class JpaLogbookReportRepository(
61
61
}
62
62
}.filter { it.operationType != LogbookOperationType .DEL }
63
63
.map {
64
- PriorNotification .fromLogbookMessage(it.toLogbookMessage(objectMapper))
64
+ val pno = PriorNotification .fromLogbookMessage(it.toLogbookMessage(objectMapper))
65
+ // All messages returned from the SQL query are acknowledged
66
+ pno.markAsAcknowledged()
67
+
68
+ return @map pno
65
69
}
66
70
}
67
71
@@ -343,7 +347,10 @@ class JpaLogbookReportRepository(
343
347
isVerified : Boolean ,
344
348
) {
345
349
val logbookReport = dbLogbookReportRepository
346
- .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(reportId, operationDate.withZoneSameInstant(UTC ).toString()).firstOrNull()
350
+ .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(
351
+ reportId,
352
+ operationDate.withZoneSameInstant(UTC ).toString(),
353
+ ).firstOrNull()
347
354
? : throw BackendUsageException (BackendUsageErrorCode .NOT_FOUND )
348
355
349
356
val pnoValue = objectMapper.readValue(logbookReport.message, PNO ::class .java)
@@ -367,7 +374,10 @@ class JpaLogbookReportRepository(
367
374
note : String? ,
368
375
) {
369
376
val logbookReport = dbLogbookReportRepository
370
- .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(reportId, operationDate.withZoneSameInstant(UTC ).toString()).firstOrNull()
377
+ .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(
378
+ reportId,
379
+ operationDate.withZoneSameInstant(UTC ).toString(),
380
+ ).firstOrNull()
371
381
? : throw BackendUsageException (BackendUsageErrorCode .NOT_FOUND )
372
382
373
383
val pnoValue = objectMapper.readValue(logbookReport.message, PNO ::class .java)
@@ -399,7 +409,10 @@ class JpaLogbookReportRepository(
399
409
@CacheEvict(value = [" pno_to_verify" ], allEntries = true )
400
410
override fun invalidate (reportId : String , operationDate : ZonedDateTime ) {
401
411
val logbookReport = dbLogbookReportRepository
402
- .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(reportId, operationDate.withZoneSameInstant(UTC ).toString()).firstOrNull()
412
+ .findAcknowledgedNonDeletedPnoDatAndCorsByReportId(
413
+ reportId,
414
+ operationDate.withZoneSameInstant(UTC ).toString(),
415
+ ).firstOrNull()
403
416
? : throw BackendUsageException (BackendUsageErrorCode .NOT_FOUND )
404
417
405
418
val pnoValue = objectMapper.readValue(logbookReport.message, PNO ::class .java)
0 commit comments