>
>
>
>
>
>
VkCommentObserver.php
<?php namespace app\core\social\vk\observer; use app\comments\forms\AddCommentForm; use app\core\helpers\Date; use app\core\social\vk\comments\CommentSaverInterface; use app\core\social\vk\comments\ExistsVkCommentRepository; use app\core\social\vk\comments\ExistsVkCommentRepositoryInterface; use app\core\social\vk\VkWallCommentsApi; use app\users\external\VkUser; use app\users\external\VkUserInterface; /** * Предназначение этого класса наблюдать за изменениями комментариев в социальной сети вконтакте и загружать комментарии * из социальной сети в комментарии под новостями на сайте. * * Class VkCommentObserver * @package app\news\vk */ class VkCommentObserver { /** * С помощью экземпляра этого класса мы будем загружать комментарии из соц. сети вконтакте * @var VkWallCommentsApi */ private $api; /** * Спомощью этого класса мы можем проверить, есть ли такой комментарий на сайте, * а также связать комментарии из вк с комментариями на сайте. * * Обратите внимание, что этот экземпляр класса лишь связывает уже добавленный комментарий на сайте с комментарием в вк, * но не создает его. * * @var ExistsVkCommentRepositoryInterface */ private $existsCommentsRepository; /** * Через этот класс будут сохраняться комментарии на сайте. * @var CommentSaverInterface */ private $saver; /** * Через этот класс мы будем создавать пользователей, * если пользователь на сайте не существует * @var VkUserInterface */ private $vkUser; public function __construct( VkWallCommentsApi $api, ExistsVkCommentRepositoryInterface $existsCommentsRepository, CommentSaverInterface $saver, VkUserInterface $vkUser) { $this->api = $api; $this->existsCommentsRepository = $existsCommentsRepository; $this->saver = $saver; $this->vkUser = $vkUser; } /** * Функция возвращает экземпляр класса VkCommentObserver с уже настроенными зависимостями. * * @param CommentSaverInterface $saver * @return VkCommentObserver */ public static function instance(CommentSaverInterface $saver) { return new static(VkWallCommentsApi::instance(), new ExistsVkCommentRepository(), $saver, new VkUser()); } protected function getUserId($comment) { // проверим, есть ли такой пользователь на сайте if (VkUser::isExistUser($comment->user->id) == false) { // пользователя нет, для начала создадим его в бд. try { return $this->vkUser->createUserFromVkObject($comment->user); } catch (\Exception $e) { // Не удалось создать пользователя, пропустим добавление комментария. return 0; } } else { // пользователь есть, тогда возьем его из бд return VkUser::getUserIdByExternalId($comment->user->id); } } /** * С помощью этого метода мы провести наблюдение за постом и сохранить комментарий из вк в базу данных. * @param VkPostRelation $postRelation */ public function observe(VkPostRelation $postRelation) { /* * stdClass Object ( [id] => 122 [from_id] => 5964344 [date] => 1548923739 [text] => что угодно [user] => stdClass Object ( [id] => 5964344 [first_name] => Ирина [last_name] => Крахмалева [sex] => 1 [screen_name] => id5964344 [photo_50] => https://sun1-9.userapi.com/c830108/v830108911/1b6bf4/09urv3Ak6AM.jpg?ava=1 [photo_100] => https://sun1-4.userapi.com/c830108/v830108911/1b6bf3/Wl6POTdOL_Y.jpg?ava=1 [online] => 0 ) ) */ // если данные в observer пришли не правильные, пропустим их if ($postRelation->getVkGroupId() == -1 || $postRelation->getEntityId() == 0 || $postRelation->getVkPostId() == 0) { return; } // получим комментари из вк по переданному посту $comments = $this->api ->setGroupId($postRelation->getVkGroupId()) ->setPostId($postRelation->getVkPostId()) ->comments(); // пройдемся по комментариям из вк и загрузим их на сайт foreach ($comments as $comment) { // пропустим те данные, которые переданы в неправильном формате. if (isset($comment->user) == false || isset($comment->id) == false || isset($comment->text) == false) { continue; } // комментарий уже добавлен, не нужно его заново добавлять. if ($this->existsCommentsRepository->exist($postRelation, $comment->id)) { continue; } if (empty($comment->text)) { continue; } // функция возвращает идентификатор пользователя с этого сайта // если пользователя нет, функция создает его и возвращает идентификатор // Обратите внимание, функция возвращает идентификатор пользователя на сайте, // а не идентификатор пользователя из вк $userId = $this->getUserId($comment); if ($userId <= 0) { continue; } $commentId = $this->saver->save($postRelation, $userId, $comment); if ($commentId > 0) { $this->existsCommentsRepository->save($postRelation, $commentId, $comment->id); } } } }
/app/core/social/vk/observer/
..
2019-02-06
VkCommentObserver.php
2019-02-01
7 .
VkObserverError.php
2019-02-01
1 .
VkObserverErrorInterface.php
2019-02-01
144
VkObserverRepositoryInterface.php
2019-02-01
138
VkPostRelation.php
2019-02-01
1 .
/app/core/social/vk/observer
1
2
3
..
