=fix endpoint e race stampe

app/Http/Controllers/EndpointController.php

@@ -17,6 +17,7 @@ use Illuminate\Support\Facades\Validator;
 use Illuminate\Support\Facades\Session;
 use Illuminate\Support\Facades\Storage;
 use Illuminate\Support\Facades\Auth;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Str;
 use App\Services\Attivita\AttivitaService;
 
@@ -284,20 +285,49 @@ class EndpointController extends Controller
 
         $stampanti = $endpoint->stampanti;
         $stampanti_ids = $endpoint->stampanti->pluck('id')->toArray();
-        $query = PrintJob::whereIn('stampante_id', $stampanti_ids)
-            ->where('stato', PrintJob::STATO_IN_CODA);
-
-            $lavori = $query->get();
-        if($query->count() > 0){
-            PrintJob::whereIn('stampante_id', $stampanti_ids)
-            ->where('stato', PrintJob::STATO_IN_CODA)
-            ->update([
-                'stato' => PrintJob::STATO_PRESO,
-            ]);
-            $has_lavoro = true;
-        }else{
-            $has_lavoro = false;
+        $presoTimeoutSeconds = (int) env('PRINTJOB_PRESO_TIMEOUT_SECONDS', 60);
+        $strictSingleFetchEnv = env('PRINTJOB_STRICT_SINGLE_FETCH', true);
+        $strictSingleFetch = filter_var($strictSingleFetchEnv, FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE);
+        if ($strictSingleFetch === null) {
+            $strictSingleFetch = true;
         }
+        $batchSize = $strictSingleFetch
+            ? 1
+            : max(1, (int) env('PRINTJOB_FETCH_BATCH_SIZE', 2));
+        $lavori = collect();
+
+        DB::transaction(function () use ($stampanti_ids, $presoTimeoutSeconds, $batchSize, &$lavori, &$has_lavoro) {
+            // Recupera automaticamente i job "preso" vecchi (agent/pc caduto o esito non inviato).
+            PrintJob::query()
+                ->whereIn('stampante_id', $stampanti_ids)
+                ->where('stato', PrintJob::STATO_PRESO)
+                ->where('updated_at', '<', now()->subSeconds($presoTimeoutSeconds))
+                ->update([
+                    'stato' => PrintJob::STATO_IN_CODA,
+                    'last_error' => 'Ripristinato automaticamente da stato PRESO scaduto',
+                ]);
+
+            // Prelievo FIFO rigoroso: blocca e prende i job più vecchi in ordine.
+            $jobsDaConsegnare = PrintJob::query()
+                ->whereIn('stampante_id', $stampanti_ids)
+                ->where('stato', PrintJob::STATO_IN_CODA)
+                ->orderBy('id')
+                ->lockForUpdate()
+                ->limit($batchSize)
+                ->get();
+
+            if ($jobsDaConsegnare->isEmpty()) {
+                return;
+            }
+
+            foreach ($jobsDaConsegnare as $job) {
+                $job->stato = PrintJob::STATO_PRESO;
+                $job->save();
+                $lavori->push($job);
+            }
+
+            $has_lavoro = true;
+        }, 3);
 
         return response()->json([
             'message' => $has_lavoro ? 'Lavoro trovato con successo' : 'Nessun lavoro trovato',