src/Biz/User/Event/UserEventSubscriber.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Biz\User\Event;

use Codeages\Biz\Framework\Event\Event;
use Codeages\PluginBundle\Event\EventSubscriber;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class UserEventSubscriber extends EventSubscriber implements EventSubscriberInterface
{
    public static function getSubscribedEvents()
    {
        return array(
            'user.registered' => 'onUserRegistered',
            'user.follow' => 'onUserFollowed',
            'user.unfollow' => 'onUserUnfollowed',
        );
    }

    public function onUserRegistered(Event $event)
    {
        $user = $event->getSubject();
        $this->sendRegisterMessage($user);
    }

    public function onUserFollowed(Event $event)
    {
        $friend = $event->getSubject();
        $user = $this->getUserService()->getUser($friend['fromId']);

        $message = array(
            'userId' => $user['id'],
            'userName' => $user['nickname'],
            'opration' => 'follow',
        );
        $this->getNotificationService()->notify($friend['toId'], 'user-follow', $message);
    }

    public function onUserUnfollowed(Event $event)
    {
        $friend = $event->getSubject();
        $user = $this->getUserService()->getUser($friend['fromId']);

        $message = array(
            'userId' => $user['id'],
            'userName' => $user['nickname'],
            'opration' => 'unfollow',
        );
        $this->getNotificationService()->notify($friend['toId'], 'user-follow', $message);
    }

    private function sendRegisterMessage($user)
    {
        $auth = $this->getSettingService()->get('auth', array());

        if (empty($auth['welcome_enabled'])
            || $auth['welcome_enabled'] != 'opened'
            || empty($auth['welcome_sender'])) {
            return;
        }