prepare("SELECT v FROM settings_kv WHERE k='backfill_countries'"); $stBf->execute(); $backfillCountriesRaw = (string)($stBf->fetchColumn() ?: ''); $backfillCountries = []; if ($backfillCountriesRaw !== '') { $parts = preg_split('/[\s,]+/', strtoupper($backfillCountriesRaw)); foreach ($parts as $p0) { $p0 = trim((string)$p0); if ($p0!=='') $backfillCountries[] = $p0; } $backfillCountries = array_values(array_unique($backfillCountries)); } $title = 'Crons'; $active = 'crons'; $cronKey = (string)($cfg['security']['cron_key'] ?? ''); $countries = $pdo->query("SELECT code,name FROM countries WHERE enabled=1 ORDER BY code")->fetchAll(); // Countries for Backfill dropdown: use backfill_countries setting if present; otherwise enabled countries if (count($backfillCountries) > 0) { $in = implode(',', array_fill(0, count($backfillCountries), '?')); $stC = $pdo->prepare("SELECT code,name FROM countries WHERE code IN ($in) ORDER BY code"); $stC->execute($backfillCountries); $countriesBackfill = $stC->fetchAll(); } else { $countriesBackfill = $countries; } $jobs = [ ['id'=>'sync_leads','name'=>'Sync leads list','desc'=>'Fetch /api/leads?country=... pages and upsert basic lead rows.'], ['id'=>'sync_details','name'=>'Sync lead details','desc'=>'Fetch /api/leads/details and store items + tracking + courier.'], ['id'=>'watch_tracking','name'=>'Watch missing tracking','desc'=>'Refetch details for leads created in the last 48h where tracking is still missing.'], ['id'=>'refresh_statuses','name'=>'Refresh statuses','desc'=>'Fetch /api/leads/history, store history, compute derived timestamps, freeze final statuses.'], ['id'=>'sync_stock','name'=>'Sync stock','desc'=>'Refresh active card stock by provider: EFC /api/products/get-stock/{sku}, Pick&Pack /product/quantity, QCargo manual stock.'], ]; $lastRuns = []; $st = $pdo->query("SELECT job, status, started_at, finished_at, duration_ms, metrics_json, message FROM cron_runs ORDER BY started_at DESC LIMIT 200"); while($r=$st->fetch()){ if (!isset($lastRuns[$r['job']])) $lastRuns[$r['job']] = $r; } function lock_info(string $job): array { $file = __DIR__ . '/cron/locks/' . $job . '.lock'; if (!file_exists($file)) return ['locked'=>false,'age'=>null,'ttl'=>1200,'stale'=>false]; $age = time() - filemtime($file); $ttl = 1200; $stale = $age >= $ttl; return ['locked'=>true,'age'=>$age,'ttl'=>$ttl,'stale'=>$stale]; } require_once __DIR__ . '/_inc/layout_top.php'; ?>
Crons
Open leads Bad tracking Pick&Pack import
Run from UI or via server cron (recommended)
Auto refresh: 15s · Shows live lock files + last run
JobDescriptionHealthLast runMetrics
s / ttl s
UNLOCKED
· s (ms)
— 		— Run
For real server cron: call these URLs with the key, or run via CLI (recommended). 
wget -qO- "/cron/run.php?job=sync_leads&key=&max_seconds=20&max_pages=5&max_leads=800&per_country_limit=200" >/dev/null
wget -qO- "/cron/run.php?job=refresh_statuses&key=&max_seconds=20&limit=20" >/dev/null
wget -qO- "/cron/run.php?job=watch_tracking&key=&max_seconds=55&limit=100&retry_minutes=10&max_age_hours=48&all_missing=1" >/dev/null
wget -qO- "/cron/run.php?job=sync_details&key=&max_seconds=20&limit=12" >/dev/null
wget -qO- "/cron/run.php?job=sync_stock&key=&max_seconds=20&limit=500" >/dev/null
Recent cron runs
Last 50 runs
query("SELECT job,status,started_at,finished_at,duration_ms,message,metrics_json FROM cron_runs ORDER BY started_at DESC LIMIT 50")->fetchAll(); ?>
WhenJobStatusDurationMetricsMessage
Backfill (FULL lead data)
Country-by-country · pulls details + history for N leads
Country
Leads per run
Max seconds
Lock TTL (s)
Tip: run it every minute until FULL DETAILS reaches 100%.
Endpoint: /cron/run.php?job=backfill_full&key=…&country=SPAIN&limit=10&max_seconds=20&lock_ttl=1200