PHPHub\Listeners\NotificationListener

Complexity

Total Complexity

8

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	push()	0	22	3
B	handle()	0	28	2
A	subscribe()	0	6	2

<?php

namespace PHPHub\Listeners;

use JPush\Exception\APIRequestException;
use PHPHub\Events\Event;
use PHPHub\Events\NewReply;
use PHPHub\Events\TopicUpVoted;
use PHPHub\Repositories\NotificationRepositoryInterface;
use PHPHub\Services\PushService\Jpush;

class NotificationListener
{
    /**
     * 订阅的时间和处理的方法.
     *
     * @var array
     */
    protected $subscribe_events = [
        TopicUpVoted::class => 'handle',
        NewReply::class     => 'handle',
    ];

    /**
     * Jpush 对象
     *
     * @var Jpush
     */
    private $jpush = null;
    /**
     * @var NotificationRepositoryInterface
     */
    private $notifications;

    /**
     * PushNotificationHandler constructor.
     *
     * @param NotificationRepositoryInterface $notifications
     */
    public function __construct(NotificationRepositoryInterface $notifications)
    {
        $this->notifications = $notifications;
    }

    /**
     * 推送消息.
     *
     * @param $user_ids
     * @param $msg
     * @param $extras
     */
    protected function push($user_ids, $msg, $extras = null)
    {
        if (! $this->jpush) {
            $this->jpush = new Jpush();
        }

        $user_ids = (array) $user_ids;
        $user_ids = array_map(function ($user_id) {
            return 'userid_'.$user_id;
        }, $user_ids);

        try {
            $this->jpush
                ->platform('all')
                ->message($msg)
                ->toAlias($user_ids)
                ->extras($extras)
                ->send();
        } catch (APIRequestException $e) {
            // Ignore
        }
    }

    /**
     * Handle the event.
     *
     * @param Event|TopicUpVoted $event
     */
    public function handle(Event $event)
    {
        $data = [
            'topic_id'     => $event->getTopicId(),

The method getTopicId() does not seem to exist on object<PHPHub\Events\Event>.

            'body'         => $event->getBody(),

The method getBody() does not seem to exist on object<PHPHub\Events\Event>.

            'from_user_id' => $event->getFromUserId(),

The method getFromUserId() does not seem to exist on object<PHPHub\Events\Event>.

            'user_id'      => $event->getUserId(),

The method getUserId() does not seem to exist on object<PHPHub\Events\Event>.

            'type'         => $event->getType(),

The method getType() does not seem to exist on object<PHPHub\Events\Event>.

            'reply_id'     => $event->getReplyId(),
        ];

        $notification = $this->notifications->store($data);

        $presenter = app('autopresenter')->decorate($notification);

        $push_data = array_only($data, [
            'topic_id',
            'from_user_id',
            'type',
        ]);

        if ($data['reply_id'] !== 0) {
            $push_data['reply_id'] = $data['reply_id'];
            $push_data['replies_url'] = route('replies.web_view', $data['topic_id']);
        }

        $this->push($event->getUserId(), $presenter->message(), $push_data);

The method getUserId() does not seem to exist on object<PHPHub\Events\Event>.

    }

    /**
     * 注册监听器给订阅者。.
     *
     * @param \Illuminate\Events\Dispatcher $events
     */
    public function subscribe($events)
    {
        foreach ($this->subscribe_events as $event => $handle_method) {
            $events->listen($event, self::class.'@'.$handle_method);
        }
    }
}