0

我正在开发一个存储用户详细信息的 api，为此我创建了一个事件和作业。在我构建用户模型的事件中，在作业中我使用事件编写发送邮件功能（用于从用户详细信息中获取用户电子邮件） ，当我在邮递员中点击 API 时，用户详细信息已成功存储在我的数据库中，但邮件未发送（队列工作失败），如何在事件和工作之间建立连接或链接，请帮助我解决此问题。 ..

ProcessPodCast.php[job]

<?php

namespace App\Jobs;

use App\Events\UserRegistered;
use App\Listeners\SendWelcomeEmail;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Mail as FacadesMail;

class ProcessPodcast implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle(UserRegistered $event)
    {
        //return Log::info("welcome to the payarc");
   //event(new SendWelcomeEmail);
   
   $data = array('name' => $event->user->name, 'email' => $event->user->email, 'body' => 'Welcome to our website. Hope you will enjoy our articles');
        
   FacadesMail::send('emails.mail', $data, function($message) use ($data) {
       $message->to($data['email'])
               ->subject('Welcome to our Website');
   });
    }
}

UserRegistered.php[event]

<?php

namespace App\Events;

use App\Models\User;
use Illuminate\Broadcasting\Channel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;

class UserRegistered
{
    use Dispatchable, InteractsWithSockets, SerializesModels;
    public $user;

    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct(User $user)
    {
        //
        $this->user=$user;
    }

    /**
     * Get the channels the event should broadcast on.
     *
     * @return \Illuminate\Broadcasting\Channel|array
     */
    public function broadcastOn()
    {
        return new PrivateChannel('channel-name');
    }
}

UserController.php


    public function register(Request $request)
    {
        
 
        $user = User::create([
            'name' => $request->name,
            'email' => $request->email,
            'password' => bcrypt($request->password),
        ]);     
       //event(new UserRegistered($user));
       dispatch(new ProcessPodcast());
       return response()->json(['message'=>"welcome mail sent"]);
    }
4

0 回答 0