Queue guest document extraction

src/main/kotlin/com/android/trisolarisserver/component/ExtractionQueue.kt

@@ -0,0 +1,27 @@
+package com.android.trisolarisserver.component
+
+import jakarta.annotation.PreDestroy
+import org.springframework.stereotype.Component
+import java.util.concurrent.Executors
+
+@Component
+class ExtractionQueue {
+    private val executor = Executors.newSingleThreadExecutor { runnable ->
+        Thread(runnable, "doc-extraction-queue").apply { isDaemon = true }
+    }
+
+    fun enqueue(task: () -> Unit) {
+        executor.submit {
+            try {
+                task()
+            } catch (_: Exception) {
+                // Best-effort processing; failures should not crash the worker.
+            }
+        }
+    }
+
+    @PreDestroy
+    fun shutdown() {
+        executor.shutdown()
+    }
+}

src/main/kotlin/com/android/trisolarisserver/controller/GuestDocuments.kt

@@ -2,6 +2,7 @@ package com.android.trisolarisserver.controller
 
 import com.android.trisolarisserver.component.DocumentStorage
 import com.android.trisolarisserver.component.DocumentTokenService
+import com.android.trisolarisserver.component.ExtractionQueue
 import com.android.trisolarisserver.component.LlamaClient
 import com.android.trisolarisserver.component.PropertyAccess
 import com.android.trisolarisserver.db.repo.BookingRepo
@@ -38,6 +39,7 @@ class GuestDocuments(
     private val appUserRepo: AppUserRepo,
     private val storage: DocumentStorage,
     private val tokenService: DocumentTokenService,
+    private val extractionQueue: ExtractionQueue,
     private val llamaClient: LlamaClient,
     private val objectMapper: ObjectMapper,
     @org.springframework.beans.factory.annotation.Value("\${storage.documents.publicBaseUrl}")
@@ -88,8 +90,8 @@ class GuestDocuments(
             storagePath = stored.storagePath
         )
         val saved = guestDocumentRepo.save(document)
-        runExtraction(saved, propertyId, guestId)
-        return guestDocumentRepo.save(saved).toResponse(objectMapper)
+        runExtraction(saved.id!!, propertyId, guestId)
+        return saved.toResponse(objectMapper)
     }
 
     @GetMapping
@@ -135,7 +137,9 @@ class GuestDocuments(
             .body(resource)
     }
 
-    private fun runExtraction(document: GuestDocument, propertyId: UUID, guestId: UUID) {
+    private fun runExtraction(documentId: UUID, propertyId: UUID, guestId: UUID) {
+        extractionQueue.enqueue {
+            val document = guestDocumentRepo.findById(documentId).orElse(null) ?: return@enqueue
             try {
                 val token = tokenService.createToken(document.id.toString())
                 val imageUrl =
@@ -190,10 +194,12 @@ class GuestDocuments(
 
                 document.extractedData = objectMapper.writeValueAsString(results)
                 document.extractedAt = OffsetDateTime.now()
+                guestDocumentRepo.save(document)
             } catch (_: Exception) {
                 // Keep upload successful even if AI extraction fails.
             }
         }
+    }
 
 }