Laravel 的 Events 及 Observers模型观察者的实例

作者：袖梨 2022-06-25

首先，我们为你展示如何通过模型观察者实现前面模式事件中的第一个例子。

在 app/Observers 文件夹中创建 WelcomeUserObserver.php 文件，并加入下面的代码：

namespace AppObservers;

class WelcomeUserObserver {

    public function created($user){

      Mail::send('emails.welcome', ['user' => $user], function($message) use ($user)
      {
          $message->to($user->email, $user->first_name . ' ' . $user->last_name)->subject('Welcome to My Awesome App, '.$user->first_name.'!');
      });

    }

}

然后在 EventServiceProvider 的 boot() 方法中注册该观察者：

/**
   * Register any other events for your application.
   *
   * @param IlluminateContractsEventsDispatcher $events
   * @return void
   */
public function boot(DispatcherContract $events)
{
      parent::boot($events);

      User::observe(new WelcomeUserObserver);
}
这样就 OK 了！现在你的观察者已经与模型关联起来了。

下面我们假设另一种情况。图书管理员对代码提出了一些新的需求：

当添加一个新的作者的时候，每一个用户都收到一条通知
每次添加/删除作者的时候，都发送一封邮件
最后，每次删除一本书的时候，图书管理员都要知道数据库中有多少作者是没有与相关的图书的
好了，下面我们就开始吧。我们需要三个单独的类（请记住我们的单一职责原则）：CustomerNewAuthorObserver、LibrarianAuthorObserver、AuthorsWithoutBooksObservers。

注意：你可以按自己喜欢的方式命名这些类，我们这里只是选择比较容易与所选行为关联起来的名称。

下面我们分别来创建三个类：

// file: app/Observers/CustomerNewAuthorObserver

namespace AppObservers;

class CustomerNewAuthorObserver {

    public function created($author)
    {

    }

}

// file: app/Observers/LibrarianAuthorObserver

namespace AppObservers;

class LibrarianAuthorObserver {

    public function created($author)
    {

    }

    public function deleted($author)
    {

    }

}

// file: app/Observers/AuthorsWithoutBooksObservers

namespace AppObservers;

class AuthorsWithoutBooksObservers {

    public function deleted($author)
    {

    }

}
好了，现在应该添加一些逻辑了，首先为 CustomerNewAuthorObserver 添加：

// file: app/Observers/CustomerNewAuthorObserver

namespace AppObservers;

class CustomerNewAuthorObserver {

    public function created($author)
    {
      // getting all users...
      $users = AppUser::all();

      foreach($users as $user)
      {
        Mail::send('emails.created_author_customer', ['author' => $author], function($message) use ($user)
        {
            $message->to($user->email, $user->first_name . ' ' . $user->last_name)->subject('New Author Added!');
        });
      }
    }

}
注意：我知道这是一种非常简单粗暴的方法，这里只是为了实现上面的目的。实际情况中可以使用邮件队列。

// file: app/Observers/LibrarianAuthorObserver

namespace AppObservers;

class LibrarianAuthorObserver {

    public function created($author) {
      Mail::send('emails.created_author_librarian', ['author' => $author], function($message) use ($author)
      {
          $message->to('[email protected]', 'The Librarian')->subject('New Author: ' . $author->first_name . ' ' . $author->last_name);
      });
    }

    public function deleted($author) {
      Mail::send('emails.deleted_author_librarian', ['author' => $author], function($message) use ($author)
      {
          $message->to('[email protected]', 'The Librarian')->subject('New Author: ' . $author->first_name . ' ' . $author->last_name);
      });
    }

}

最后：

// file: app/Observers/AuthorsWithoutBooksObservers

namespace AppObservers;

class AuthorsWithoutBooksObservers {

    public function deleted($author) {
      $authorsWithoutBooks = AppAuthor::has('books', '=', 0)->get();

      if(count($authorsWithoutBooks) > 0){
        Mail::send('emails.author_without_books_librarian', ['authorsWithoutBooks' => $authorsWithoutBooks], function($message)
        {
            $message->to('[email protected]', 'The Librarian')->subject('Authors without Books! A check is required!');
        });
      }
    }

}