MailController.php 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Requests\Admin\MailSend;
  4. use Illuminate\Http\Request;
  5. use App\Http\Controllers\Controller;
  6. use App\Models\User;
  7. use App\Jobs\SendEmail;
  8. class MailController extends Controller
  9. {
  10. public function send(MailSend $request)
  11. {
  12. switch ($request->input('type')) {
  13. case 1: $users = $this->getAllUser();
  14. break;
  15. case 2: $users = $this->getReceiver($request->input('receiver'));
  16. break;
  17. case 3: $users = $this->getSubscribeUser();
  18. break;
  19. case 4: $users = $this->getExpireUser();
  20. break;
  21. }
  22. foreach ($users as $user) {
  23. SendEmail::dispatch([
  24. 'email' => $user->email,
  25. 'subject' => $request->input('subject'),
  26. 'template_name' => 'mail.sendEmailCustom',
  27. 'template_value' => [
  28. 'name' => config('v2board.app_name', 'V2Board'),
  29. 'url' => config('v2board.app_url'),
  30. 'content' => $request->input('content')
  31. ]
  32. ])->onQueue('other_mail');
  33. }
  34. return response([
  35. 'data' => true
  36. ]);
  37. }
  38. private function getAllUser()
  39. {
  40. return User::all();
  41. }
  42. private function getReceiver($receiver)
  43. {
  44. if (empty($receiver)) {
  45. abort(500, '收件人不能为空');
  46. }
  47. return User::whereIn('id', $receiver)->get();
  48. }
  49. private function getSubscribeUser()
  50. {
  51. return User::where('expired_at', '=>', time())->get();
  52. }
  53. private function getExpireUser()
  54. {
  55. return User::where('expired_at', '<', time())->get();
  56. }
  57. }