bot-28/app/Services/SiteRealtimeService.php

<?php

namespace App\Services;

use Carbon\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;
use Illuminate\Validation\ValidationException;
use InvalidArgumentException;

/** Written inside the same transaction as the change; consumed by the member WebSocket worker. */
final class SiteRealtimeService
{
    public static function changed(string $module, int $id, string $action, array $boundaries = [], bool $notifyNow = true): void
    {
        if (!in_array($module, ['message', 'announcement', 'maintenance'], true) || $id < 1) throw new InvalidArgumentException('Invalid site event');
        if (!Schema::hasTable('site_realtime_events')) {
            throw ValidationException::withMessages(['realtime' => '实时通知服务未初始化，请先完成系统更新']);
        }
        $now = Carbon::now('Asia/Shanghai')->format('Y-m-d H:i:s');
        $pending = DB::table('site_realtime_events')->where('module', $module)->where('resource_id', $id)->whereNull('dispatched_at');
        if ($module !== 'announcement') $pending->where('available_at', '>', $now);
        $pending->delete();
        $rows = $notifyNow ? [['module' => $module, 'resource_id' => $id, 'action' => $action, 'available_at' => $now, 'created_at' => $now]] : [];
        foreach ($boundaries as $edge => $at) {
            if ($at !== null && $at > $now) $rows[] = ['module' => $module, 'resource_id' => $id, 'action' => $edge, 'available_at' => $at, 'created_at' => $now];
        }
        if ($rows) DB::table('site_realtime_events')->insert($rows);
    }
}