32 lines
855 B
PHP
32 lines
855 B
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Service;
|
|
|
|
use Hyperf\DbConnection\Db;
|
|
|
|
/**
|
|
* TimescaleDB 连续聚合刷新实现
|
|
*
|
|
* 调用 PG 的 refresh_continuous_aggregate 存储过程，按整日窗口刷新。
|
|
*/
|
|
class ContinuousAggregateRefresher implements AggregateRefresherInterface
|
|
{
|
|
public function refresh(string $view, string $refresh_date): void
|
|
{
|
|
$start = sprintf("'%s 00:00:00+00'::timestamptz", $refresh_date);
|
|
$end = sprintf("'%s 23:59:59.999999+00'::timestamptz", $refresh_date);
|
|
|
|
// view 在 P23.2 中硬编码为 'orders_daily_by_created'，但仍走 PDO quote 防御
|
|
$quoted_view = Db::getPdo()->quote($view);
|
|
|
|
Db::statement(sprintf(
|
|
'CALL refresh_continuous_aggregate(%s, %s, %s)',
|
|
$quoted_view,
|
|
$start,
|
|
$end
|
|
));
|
|
}
|
|
}
|