Добавил формирование представлений после репликации

app/Http/Controllers/Api/Syncio/SyncioWebhookController.php

@@ -3,6 +3,7 @@
 namespace App\Http\Controllers\Api\Syncio;
 
 use App\Http\Controllers\Controller;
+use App\Jobs\RefreshMaterializedViews;
 use Illuminate\Http\Request;
 
 class SyncioWebhookController extends Controller
@@ -19,10 +20,10 @@ class SyncioWebhookController extends Controller
         // $data['tables']['success'] кол-во успешных
         // $data['errors']            массив ошибок
 
-        // Дальше что нужно:
-        // ReplicationFinished::dispatch($data);  // Job в очередь
-        // event(new ReplicationCompleted($data)); // Laravel Event
-        // Cache::put('replication_status', $data, now()->addHours(24));
+        // При успешной репликации обновляем материализованные представления
+        if (($data['status'] ?? null) === 'success') {
+            RefreshMaterializedViews::dispatch();
+        }
 
         return response()->noContent(); // 204
     }

app/Jobs/RefreshMaterializedViews.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\DB;
+
+class RefreshMaterializedViews implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    /**
+     * Материализованные представления, которые нужно обновить.
+     *
+     * @var string[]
+     */
+    protected array $views = [
+        'mv_medicalhistory_summary',
+        'mv_migrationpatient_details',
+        'mv_surgical_operations',
+        'mv_reanimation_summary',
+    ];
+
+    /**
+     * Время ожидания выполнения задачи (секунды).
+     */
+    public int $timeout = 1800;
+
+    public function handle(): void
+    {
+        foreach ($this->views as $view) {
+            // CONCURRENTLY не блокирует чтение представления во время обновления,
+            // но требует наличия уникального индекса на представлении и не может
+            // выполняться внутри транзакции (DB::statement работает в autocommit).
+            DB::statement("REFRESH MATERIALIZED VIEW CONCURRENTLY {$view}");
+            DB::statement("ANALYZE {$view}");
+        }
+    }
+}