summaryrefslogtreecommitdiff
path: root/src/main/kotlin/dev/dnpm/etl
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2023-07-25 16:48:45 +0200
committerPaul-Christian Volkmer2023-07-25 16:48:45 +0200
commit46928964ef2b469a8c3f9eb997591ead0e6ea093 (patch)
tree84b0a7431f1fa82f2f43f20de032d94c7308f5f7 /src/main/kotlin/dev/dnpm/etl
parentc8e99133e2c560a10a2d512d1985518f3e373949 (diff)
Add postgres migration file and configuration for postgres
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl')
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/monitoring/Request.kt1
-rw-r--r--src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt3
2 files changed, 4 insertions, 0 deletions
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/Request.kt b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/Request.kt
index 80ddde8..e1dd267 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/monitoring/Request.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/monitoring/Request.kt
@@ -32,6 +32,7 @@ data class Request(
@Id val id: Long? = null,
val uuid: RequestId = RequestId.randomUUID(),
val patientId: String,
+ val pid: String,
val fingerprint: String,
val status: RequestStatus,
val processedAt: Instant = Instant.now()
diff --git a/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt b/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt
index 7276561..04c1594 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/web/MtbFileController.kt
@@ -46,6 +46,7 @@ class MtbFileController(
@PostMapping(path = ["/mtbfile"])
fun mtbFile(@RequestBody mtbFile: MtbFile): ResponseEntity<Void> {
+ val pid = mtbFile.patient.id
val pseudonymized = pseudonymizeService.pseudonymize(mtbFile)
val lastRequestForPatient =
@@ -55,6 +56,7 @@ class MtbFileController(
requestRepository.save(
Request(
patientId = pseudonymized.patient.id,
+ pid = pid,
fingerprint = fingerprint(mtbFile),
status = RequestStatus.DUPLICATION
)
@@ -93,6 +95,7 @@ class MtbFileController(
requestRepository.save(
Request(
patientId = pseudonymized.patient.id,
+ pid = pid,
fingerprint = fingerprint(mtbFile),
status = requestStatus
)