42 lines
1.3 KiB
PHP
42 lines
1.3 KiB
PHP
<?php
|
||
/**
|
||
* etl_stock_maintenance.php — Called by Node.js scheduler every hour.
|
||
* Checks and repairs etl_stock_summary for companies in the current slot.
|
||
*
|
||
* Body: { slot: 14 } (0–23, = HOUR(NOW()) from Node.js)
|
||
*/
|
||
require __DIR__ . '/../assets/utils/cron_auth.php';
|
||
require_once __DIR__ . '/../assets/utils/classes/EtlStockManager.php';
|
||
|
||
$slot = (int)($data['slot'] ?? -1);
|
||
if ($slot < 0 || $slot > 23) {
|
||
http_response_code(400);
|
||
exit(json_encode(['success' => 0, 'message' => 'Invalid slot.']));
|
||
}
|
||
|
||
$sth = $pdo1->prepare(
|
||
"SELECT company_id FROM company_list WHERE company_id % 24 = :slot"
|
||
);
|
||
$sth->execute([':slot' => $slot]);
|
||
$companies = $sth->fetchAll(PDO::FETCH_COLUMN);
|
||
|
||
$results = [];
|
||
foreach ($companies as $company_id) {
|
||
try {
|
||
$etl = new EtlStockManager($pdo2, $pdo1, (int)$company_id);
|
||
$result = $etl->checkAndRepair();
|
||
$results[] = [
|
||
'company_id' => $company_id,
|
||
'gaps_found' => $result['gaps_found'],
|
||
'periods_rebuilt' => $result['periods_rebuilt'],
|
||
];
|
||
} catch (Exception $e) {
|
||
$results[] = ['company_id' => $company_id, 'error' => $e->getMessage()];
|
||
}
|
||
}
|
||
|
||
$answer['success'] = 1;
|
||
$answer['slot'] = $slot;
|
||
$answer['results'] = $results;
|
||
exit(json_encode($answer));
|