<?php

declare(strict_types=1);

require __DIR__ . '/db-config.php';

$script = 'coltemp';

try {
    $db = cgny_db_connect();

    $db->query(
        "UPDATE LOW_PRIORITY columntable c
         INNER JOIN (
             SELECT photoid, COUNT(id) AS view_count
             FROM columntemp5
             GROUP BY photoid
         ) t ON c.id = t.photoid
         SET c.views = c.views + t.view_count"
    );
    $columnViewsUpdated = $db->affected_rows;

    $db->query(
        "UPDATE LOW_PRIORITY ListingsStats l
         INNER JOIN (
             SELECT photoid, COUNT(id) AS view_count
             FROM columntemp5listing
             GROUP BY photoid
         ) t ON l.id = t.photoid
         SET l.views = l.views + t.view_count"
    );
    $listingViewsUpdated = $db->affected_rows;

    $db->query('TRUNCATE TABLE columntemp5');
    $db->query('TRUNCATE TABLE columntemp5listing');

    cgny_cron_log(
        $script,
        sprintf(
            'OK column_views=%d listing_views=%d truncated',
            $columnViewsUpdated,
            $listingViewsUpdated
        )
    );
} catch (Throwable $e) {
    cgny_cron_log($script, 'ERROR ' . $e->getMessage());
    fwrite(STDERR, $e->getMessage() . PHP_EOL);
    exit(1);
}