PI-1846 ignore data integrity violation (duplicate key) exceptions

Author: anthony-britton-moj

src/main/kotlin/uk/gov/justice/digital/hmpps/hmppstier/service/TierCalculationService.kt

@@ -1,6 +1,7 @@
 package uk.gov.justice.digital.hmpps.hmppstier.service
 
 import org.slf4j.LoggerFactory
+import org.springframework.dao.DataIntegrityViolationException
 import org.springframework.stereotype.Service
 import uk.gov.justice.digital.hmpps.hmppstier.client.AssessmentForTier
 import uk.gov.justice.digital.hmpps.hmppstier.client.NeedSection
@@ -58,6 +59,10 @@ class TierCalculationService(
                 )
             }
         } catch (e: Exception) {
+            if (e is DataIntegrityViolationException) {
+                log.error("Multiple concurrent attempts to calculate tier for $crn => $recalculationSource")
+                return
+            }
             val eventType = if (allowUpdates) TIER_CALCULATION_FAILED else TIER_RECALCULATION_DRY_RUN_FAILURE
             telemetryService.trackEvent(
                 eventType,

src/main/kotlin/uk/gov/justice/digital/hmpps/hmppstier/service/TierUpdater.kt

@@ -2,6 +2,7 @@ package uk.gov.justice.digital.hmpps.hmppstier.service
 
 import org.springframework.data.repository.findByIdOrNull
 import org.springframework.stereotype.Service
+import org.springframework.transaction.annotation.Propagation
 import org.springframework.transaction.annotation.Transactional
 import uk.gov.justice.digital.hmpps.hmppstier.jpa.entity.TierCalculationEntity
 import uk.gov.justice.digital.hmpps.hmppstier.jpa.entity.TierSummary
@@ -14,6 +15,7 @@ class TierUpdater(
     private val tierSummaryRepository: TierSummaryRepository,
 ) {
 
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     fun removeTierCalculationsFor(crn: String) {
         tierCalculationRepository.deleteAllByCrn(crn)
         tierSummaryRepository.deleteById(crn)