8695d5ec95
The features JSON column required defensive fallback stubs in three places (Plan::resolveForUser, PlanFeatures::__construct, PlanSeeder) and silently swallowed misspelled keys. Typed columns give Eloquent type-safe reads, simplify the Filament form (no more dotted JSON paths), and let resolveForUser fail loud when the free row is missing. PlanFeatures public API is unchanged so consumers (jobs, middleware) need no rewrites — one missed JSON read in SendScheduledWhatsAppJob was caught and converted to a typed where() query. tests/Pest.php seeds PlanSeeder in beforeEach so any feature test that resolves a plan finds the free row, mirroring production where plans always exist. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
64 lines
1.9 KiB
PHP
64 lines
1.9 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\Plan;
|
|
use App\Models\User;
|
|
use App\Models\UserNotificationPreference;
|
|
use App\Services\PlanFeatures;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Queue\Queueable;
|
|
|
|
/**
|
|
* Fan-out job for scheduled WhatsApp updates (morning / evening).
|
|
* Finds all eligible users and dispatches DispatchUserNotificationJob per user.
|
|
*
|
|
* Scheduled at 07:30 (morning) and 18:00 (evening) via routes/console.php.
|
|
*/
|
|
final class SendScheduledWhatsAppJob implements ShouldQueue
|
|
{
|
|
use Queueable;
|
|
|
|
public function __construct(public readonly string $period)
|
|
{
|
|
//
|
|
}
|
|
|
|
public function handle(): void
|
|
{
|
|
$triggerType = $this->period === 'morning' ? 'scheduled_morning' : 'scheduled_evening';
|
|
|
|
// Plans that allow scheduled WhatsApp updates
|
|
$eligiblePlanNames = Plan::where('active', true)
|
|
->where('whatsapp_scheduled_updates', '>', 0)
|
|
->pluck('name')
|
|
->all();
|
|
|
|
if (empty($eligiblePlanNames)) {
|
|
return;
|
|
}
|
|
|
|
// Users who have whatsapp preference enabled
|
|
$userIds = UserNotificationPreference::where('channel', 'whatsapp')
|
|
->where('enabled', true)
|
|
->distinct()
|
|
->pluck('user_id');
|
|
|
|
User::whereIn('id', $userIds)
|
|
->each(function (User $user) use ($triggerType, $eligiblePlanNames): void {
|
|
$features = PlanFeatures::for($user);
|
|
|
|
// Skip if their tier isn't eligible or daily limit is hit
|
|
if (! in_array($features->tier(), $eligiblePlanNames, strict: true)) {
|
|
return;
|
|
}
|
|
|
|
if (! $features->canSendNow('whatsapp')) {
|
|
return;
|
|
}
|
|
|
|
DispatchUserNotificationJob::dispatch($user, $triggerType, fuelType: 'all');
|
|
});
|
|
}
|
|
}
|