*/ public function dueOrganizations(): Collection { return Organization::query() ->where('settings->plan', 'pro') ->whereNotNull('settings->plan_expires_at') ->get() ->filter(fn (Organization $organization) => $this->isDue($organization)); } public function isDue(Organization $organization): bool { $settings = $organization->settings ?? []; if (($settings['plan'] ?? '') !== 'pro') { return false; } if (array_key_exists('auto_renew', $settings) && $settings['auto_renew'] === false) { return false; } if (empty($settings['plan_expires_at'])) { return false; } return Carbon::parse($settings['plan_expires_at'])->lte(now()); } public function renewIfDue(Organization $organization): void { if (! $this->isDue($organization)) { return; } $settings = $organization->settings ?? []; $price = $this->plans->proPriceMinor(); $reference = 'queue-pro-'.$organization->id.'-'.now()->format('YmdHis'); try { $charged = $this->billing->debit( $organization->owner_ref, $price, 'queue_pro_renewal', $reference, 'Ladill Queue Pro — monthly renewal', ); } catch (\Throwable) { $charged = false; } if ($charged) { $settings['plan'] = 'pro'; $settings['auto_renew'] = true; $settings['plan_expires_at'] = now() ->addDays((int) config('qms.pro.period_days', 30)) ->toIso8601String(); unset($settings['plan_renewal_error']); $organization->update(['settings' => $settings]); return; } $expires = Carbon::parse($settings['plan_expires_at']); $graceEnd = $expires->copy()->addDays((int) config('qms.pro.grace_days', 3)); if ($graceEnd->isPast()) { $settings['plan'] = 'free'; unset($settings['plan_expires_at']); $settings['plan_renewal_error'] = 'Suspended after failed renewal.'; } else { $settings['plan_renewal_error'] = 'Renewal failed — top up your wallet.'; } $organization->update(['settings' => $settings]); } }