argument('broadcastId'); $data = cache($broadcastId); if (!$data || !is_array($data)) { $this->error('Broadcast data not found or expired.'); return 1; } $siteName = Setting::get('site_name', 'Bursa Kerja'); $sendDelay = (int) Setting::get('notification_send_delay_seconds', 3); $sent = 0; $failed = 0; $this->info("Processing email broadcast to " . count($data) . " recipients..."); foreach ($data as $i => $item) { if (!isset($item['email']) || !isset($item['message']) || !isset($item['subject'])) { $failed++; Log::warning("Broadcast email: invalid data at index {$i}"); continue; } if ($i > 0 && $sendDelay > 0) { sleep($sendDelay); } try { $htmlContent = $this->buildEmailHtml($item['subject'], $item['message'], $siteName); $recipientName = $item['name'] ?? ''; $recipientEmail = $item['email']; $subject = $item['subject']; Mail::html($htmlContent, function ($mail) use ($recipientEmail, $recipientName, $subject) { $mail->to($recipientEmail, $recipientName) ->subject($subject); }); $sent++; } catch (\Exception $e) { $failed++; Log::error("Broadcast email failed for {$item['email']}: " . $e->getMessage()); } } // Clean up cache cache()->forget($broadcastId); $this->info("Broadcast done. Sent: {$sent}, Failed: {$failed}"); return 0; } private function buildEmailHtml(string $subject, string $body, string $siteName): string { return <<

{$siteName}

{$subject}

{$body}

Email ini dikirim oleh {$siteName}

HTML; } }