140 lines
4.4 KiB
PHP
140 lines
4.4 KiB
PHP
<?php
|
|
/**
|
|
* Diagnostic Script — Run on server to verify processing works
|
|
*
|
|
* Usage: php app/cron/diagnose.php
|
|
*/
|
|
|
|
declare(strict_types=1);
|
|
|
|
require_once __DIR__ . '/../bootstrap/init.php';
|
|
|
|
use App\Core\Database;
|
|
|
|
echo "=== Musadaq Processing Diagnostics ===\n";
|
|
echo "Time: " . date('Y-m-d H:i:s') . "\n";
|
|
echo "PHP: " . PHP_VERSION . "\n";
|
|
echo "SAPI: " . php_sapi_name() . "\n\n";
|
|
|
|
// 1. Check DB connection
|
|
echo "--- Database ---\n";
|
|
try {
|
|
$db = Database::getInstance();
|
|
echo " ✓ Database connected\n";
|
|
} catch (\Throwable $e) {
|
|
echo " ✗ Database FAILED: " . $e->getMessage() . "\n";
|
|
exit(1);
|
|
}
|
|
|
|
// 2. Check pending queue items
|
|
echo "\n--- Queue Status ---\n";
|
|
$stmt = $db->query("SELECT status, COUNT(*) as cnt FROM invoice_processing_queue GROUP BY status");
|
|
$rows = $stmt->fetchAll();
|
|
if (empty($rows)) {
|
|
echo " (empty — no items in queue at all)\n";
|
|
} else {
|
|
foreach ($rows as $r) {
|
|
echo " {$r['status']}: {$r['cnt']}\n";
|
|
}
|
|
}
|
|
|
|
// 3. Check batch statuses
|
|
echo "\n--- Batch Status ---\n";
|
|
$stmt = $db->query("SELECT status, COUNT(*) as cnt FROM invoice_batches GROUP BY status");
|
|
$rows = $stmt->fetchAll();
|
|
if (empty($rows)) {
|
|
echo " (empty — no batches)\n";
|
|
} else {
|
|
foreach ($rows as $r) {
|
|
echo " {$r['status']}: {$r['cnt']}\n";
|
|
}
|
|
}
|
|
|
|
// 4. Check for stuck items (processing but no worker)
|
|
echo "\n--- Stuck Items (processing for >5 minutes) ---\n";
|
|
$stmt = $db->query("
|
|
SELECT q.id, q.batch_id, q.status, q.image_path, q.created_at, q.error_message
|
|
FROM invoice_processing_queue q
|
|
WHERE q.status IN ('pending', 'processing')
|
|
ORDER BY q.created_at DESC
|
|
LIMIT 10
|
|
");
|
|
$stuck = $stmt->fetchAll();
|
|
if (empty($stuck)) {
|
|
echo " (none — all clear)\n";
|
|
} else {
|
|
foreach ($stuck as $s) {
|
|
$exists = file_exists($s['image_path']) ? '✓ file exists' : '✗ FILE MISSING';
|
|
echo " ID={$s['id']} | Status={$s['status']} | $exists\n";
|
|
echo " Path: {$s['image_path']}\n";
|
|
if ($s['error_message']) echo " Error: {$s['error_message']}\n";
|
|
}
|
|
}
|
|
|
|
// 5. Check lock file
|
|
echo "\n--- Lock File ---\n";
|
|
$lockFile = STORAGE_PATH . '/logs/process_batches.lock';
|
|
if (file_exists($lockFile)) {
|
|
$age = time() - filemtime($lockFile);
|
|
$content = trim(file_get_contents($lockFile));
|
|
echo " ⚠ Lock file EXISTS (age: {$age}s, content: $content)\n";
|
|
if ($age > 300) {
|
|
echo " → This lock is STALE. Removing...\n";
|
|
@unlink($lockFile);
|
|
echo " ✓ Removed.\n";
|
|
}
|
|
} else {
|
|
echo " ✓ No lock file (good)\n";
|
|
}
|
|
|
|
// 6. Check key files
|
|
echo "\n--- Key Files ---\n";
|
|
$files = [
|
|
'InvoiceProcessor' => APP_PATH . '/Services/InvoiceProcessor.php',
|
|
'AI' => APP_PATH . '/Core/AI.php',
|
|
'process_batches' => APP_PATH . '/cron/process_batches.php',
|
|
'worker.log' => STORAGE_PATH . '/logs/worker.log',
|
|
];
|
|
foreach ($files as $name => $path) {
|
|
if (file_exists($path)) {
|
|
echo " ✓ $name: $path (" . filesize($path) . " bytes)\n";
|
|
} else {
|
|
echo " ✗ $name: MISSING — $path\n";
|
|
}
|
|
}
|
|
|
|
// 7. Check Gemini API key
|
|
echo "\n--- Configuration ---\n";
|
|
$apiKey = env('GEMINI_API_KEY');
|
|
echo " GEMINI_API_KEY: " . ($apiKey ? "✓ Set (" . strlen($apiKey) . " chars)" : "✗ MISSING!") . "\n";
|
|
echo " APP_DEBUG: " . env('APP_DEBUG', 'false') . "\n";
|
|
echo " fastcgi_finish_request: " . (function_exists('fastcgi_finish_request') ? '✓ Available' : '✗ Not available (CLI mode)') . "\n";
|
|
|
|
// 8. Show last lines of worker.log
|
|
echo "\n--- Last 20 lines of worker.log ---\n";
|
|
$workerLog = STORAGE_PATH . '/logs/worker.log';
|
|
if (file_exists($workerLog)) {
|
|
$lines = file($workerLog);
|
|
$last = array_slice($lines, -20);
|
|
foreach ($last as $line) {
|
|
echo " " . rtrim($line) . "\n";
|
|
}
|
|
} else {
|
|
echo " (worker.log does not exist yet)\n";
|
|
}
|
|
|
|
// 9. Try to reset any stuck 'processing' items back to 'pending'
|
|
echo "\n--- Fix Stuck Items? ---\n";
|
|
$stmt = $db->query("SELECT COUNT(*) FROM invoice_processing_queue WHERE status = 'processing'");
|
|
$stuckCount = (int)$stmt->fetchColumn();
|
|
if ($stuckCount > 0) {
|
|
echo " Found $stuckCount items stuck in 'processing' state.\n";
|
|
$db->query("UPDATE invoice_processing_queue SET status = 'pending' WHERE status = 'processing'");
|
|
echo " ✓ Reset them to 'pending' so they can be reprocessed.\n";
|
|
} else {
|
|
echo " ✓ No stuck items.\n";
|
|
}
|
|
|
|
echo "\n=== Diagnostics Complete ===\n";
|
|
echo "Next step: Run 'php app/cron/process_batches.php' to process pending items.\n";
|