custom/plugins/EconsorAmity/src/Services/AmityPosts/AmityPostService.php line 113

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Econsor\Amity\Services\AmityPosts;
  7. use Econsor\Amity\Models\AmityPostLikes\AmityPostLikesEntity;
  8. use Econsor\Amity\Services\Helpers\AmityRepositoryHelper;
  9. use Econsor\Amity\Services\Stream\StreamProcessor;
  10. use Econsor\Amity\Services\Stream\StreamSorter;
  11. use Econsor\Amity\Services\Stream\StreamUtilities;
  12. use Exception;
  13. use Shopware\Core\Content\Product\ProductEntity;
  14. use Shopware\Core\Framework\Context;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\MultiFilter;
  19. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  22. use Econsor\Amity\Services\AmityPosts\LocalPostService;
  23. use Shopware\Core\Content\Product\Aggregate\ProductMedia\ProductMediaCollection;
  25. /**
  26.  * Class AmityPostService
  27.  * @package Econsor\Amity\Services\AmityPosts
  28.  */
  29. class AmityPostService
  30. {
  31.     const STREAM_LIMIT = 100;
  32.     const STREAM_OFFSET = 10;
  34.     public function __construct(
  35.         protected StreamProcessor $streamProcessor,
  36.         protected StreamSorter $streamSorter,
  37.         protected StreamUtilities $utilities,
  38.         protected AmityRepositoryHelper $repositoryHelper,
  39.         protected LocalPostService $localPostService
  40.     ) {}
  42.     /**
  43.      * @throws Exception
  44.      */
  45.     public function fetchCustomerStats(string $customerId, SalesChannelContext $context): array
  46.     {
  47.         return [
  48.             'totalLikes' => $this->repositoryHelper->queryLikes($this->streamProcessor->getCriteriaLikeCount($customerId), $context->getContext())->count(),
  49.             'totalFollowers' => $this->repositoryHelper->queryFollowed($this->streamProcessor->getFollowing($customerId), $context->getContext())->count(),
  50.             'totalFollowings' => $this->repositoryHelper->queryFollowed($this->streamProcessor->getFollowed($customerId), $context->getContext())->count(),
  51.             'isFollowed' => $this->repositoryHelper->queryFollowed($this->streamProcessor->getFollowing($customerId)->addFilter(new EqualsFilter('customerId', $context->getCustomerId())), $context->getContext())->count() > 0,
  52.             'postCount' => $this->repositoryHelper->queryTotalPost($this->streamProcessor->getCriteriaPostCount($customerId), $context->getContext())->count(),
  53.         ];
  54.     }
  56.     /**
  57.      * @throws Exception
  58.      */
  59.     public function fetchStream(
  60.         ?string $customerId,
  61.         SalesChannelContext $context,
  62.         string $mode = 'tags', // tags|liked|uploaded
  63.         ?string $productId = null,
  64.         ?string $postId = null,
  65.         $page = 1,
  66.         $limit = 100
  67.     ): array {
  68.         $customerTags = !empty($customerId) ? $this->utilities->getCustomerTags($customerId, $context->getContext())?->get('tags')?->getElements() : [];
  70.         if (empty($customerTags)) {
  71.             $customerTags = $this->utilities->getAllTags($context->getContext())->getElements();
  72.         }
  74.         $result = match ($mode) {
  75.             'tags' => $this->buildNormalStream($customerTags, $customerId, $context, $productId, $postId, $page, $limit),
  76.             'liked' => !empty($customerId) ? $this->buildLikedStream($customerTags, $customerId, $context) : [],
  77.             'uploaded' => !empty($customerId) ? $this->buildUploadedStream($customerTags, $customerId, $context) : [],
  78.             'saved' => !empty($customerId) ? $this->buildSavedStream($customerTags, $customerId, $context) : [],
  79.             'details' => !empty($productId) ? $this->buildDetailStream($productId, $customerId, $context) : [],
  80.             default => throw new Exception('Stream Mode not recognized - try "tags", "details", "liked" or "uploaded"'),
  81.         };
  83.         $likedPostIds = [];
  84.         $savedPostIds = [];
  85.         $followedIds = [];
  86.         if (!empty($customerId)) {
  87.             foreach ($this->repositoryHelper->queryLikes($this->streamProcessor->getCriteriaLiked($customerId, 499), $context->getContext())->getIterator() as $like) {
  88.                 /** @var AmityPostLikesEntity $like */
  89.                 $likedPostIds[] = $like->getPostId();
  90.             }
  91.             foreach ($this->repositoryHelper->querySaved($this->streamProcessor->getSaved($customerId, 499), $context->getContext())->getIterator() as $saved) {
  92.                 $savedPostIds[] = $saved->getPostId();
  93.             }
  94.             foreach ($this->repositoryHelper->queryFollowed($this->streamProcessor->getFollowed($customerId), $context->getContext())->getIterator() as $followed) {
  95.                 $followedIds[] = $followed->followerId;
  96.             }
  97.         }
  99.         foreach ($result as &$post) {
  100.             /** @var AmityPostLikesEntity $post */
  101.             $post->addArrayExtension('stats', [
  102.                 'liked' => in_array($post->getId(), $likedPostIds),
  103.                 'saved' => in_array($post->getId(), $savedPostIds),
  104.                 'followed' => in_array($post->postUser, $followedIds),
  105.             ]);
  106.             $post = $this->convertVideoKey($post);
  107.         }
  110.         return $result;
  111.     }
  113.     public function buildNormalStream($customerTags, ?string $customerId, SalesChannelContext $context, ?string $productId = null, ?string $postId = null, $page = 1, $limit): array
  114.     {
  115.         $viewedVideos = !empty($customerId) ? $this->utilities->getViewedVideos($customerId, $context->getContext()) : [];
  116.         $viewedResults = $restResults = $latest = null;
  118.         $mainResults = $this->repositoryHelper->queryPosts2(
  119.             $this->streamProcessor->getCriteriaMain($customerTags, $viewedVideos, $limit, $productId, $customerId),
  120.             $context,
  121.             $postId,
  122.             $page,
  123.         );
  126.         //        /*
  127.         //         * If the total Stream amount doesn't reach the 100 video cap, add videos from viewed.
  128.         //         */
  129.         //        if(($total = $mainResults->getTotal()) < $limit)
  130.         //        {
  131.         //            $limit = $limit - $total;
  132.         //
  133.         //            $viewedResults =  $this->repositoryHelper->queryPosts2(
  134.         //                $this->streamProcessor->getCriteriaViewed($viewedVideos, $limit),
  135.         //                $context,
  136.         //                false,
  137.         //                !empty($productId),
  138.         //            );
  139.         //
  140.         //            /*
  141.         //            * If the total Stream amount STILL doesn't reach the 100 video cap, add videos from all tags.
  142.         //            */
  143.         //            if(($total += $viewedResults->getTotal()) < $limit)
  144.         //            {
  145.         //                /*
  146.         //                * Update for not duplicate videos
  147.         //                */
  148.         //                $viewedIds = [];
  149.         //                foreach ($viewedResults as $result)
  150.         //                {
  151.         //                    $viewedIds[] = $result->getId();
  152.         //                }
  153.         //                $limit = $limit - $total;
  154.         //
  155.         //                $restResults = $this->repositoryHelper->queryPosts2(
  156.         //                    $this->streamProcessor->getCriteriaRest($customerTags, $viewedIds, 100),
  157.         //                    $context,
  158.         //                    false,
  159.         //                    !empty($productId),
  160.         //                );
  161.         //                $restResults = $restResults->slice(0, 2);
  162.         //            }
  163.         //
  164.         //            $latest = $viewedResults->first();
  165.         //        }
  166.         //
  167.         //        // Get the latest watched video
  168.         //        if(!$latest && !empty($customerId))
  169.         //        {
  170.         //            $latest = $this->getLatestViewed($customerId, $context);
  171.         //        }
  172.         //
  173.         //        if(!empty($productId))
  174.         //        {
  175.         //            $latest = null;
  176.         //        }
  178.         return $this->streamSorter->sort(
  179.             $this->grabWeights($customerTags, $customerId, $context),
  180.             $mainResults,
  181.             $viewedResults,
  182.             $restResults,
  183.             $latest
  184.         );
  185.     }
  187.     public function buildUploadedStream($customerTags, string $customerId, SalesChannelContext $context): array
  188.     {
  189.         return $this->streamSorter->sort(
  190.             $this->grabWeights($customerTags, $customerId, $context),
  191. //            $this->repositoryHelper->queryPosts2($this->streamProcessor->getUploadedCriteria($customerId, 499), $context, null, 1, 'uploaded')
  192.             $this->repositoryHelper->queryPosts($this->streamProcessor->getUploadedCriteria($customerId, 499), $context, true)
  193.         );
  194.     }
  196.     public function buildLikedStream($customerTags, string $customerId, SalesChannelContext $context): array
  197.     {
  198.         $ids = [];
  200.         foreach ($this->repositoryHelper->queryLikes($this->streamProcessor->getCriteriaLiked($customerId, 499), $context->getContext())->getIterator() as $like) {
  201.             /** @var AmityPostLikesEntity $like */
  202.             $ids[] = $like->getPostId();
  203.         }
  205.         if (empty($ids)) {
  206.             return [];
  207.         }
  209.         return $this->streamSorter->sort(
  210.             $this->grabWeights($customerTags, $customerId, $context),
  211.             $this->repositoryHelper->queryPosts2($this->streamProcessor->getIdCriteria($ids, 100, $customerId), $context, null, 1, 'liked')
  212.         );
  213.     }
  215.     public function buildSavedStream($customerTags, string $customerId, SalesChannelContext $context): array
  216.     {
  217.         $ids = [];
  219.         foreach ($this->repositoryHelper->querySaved($this->streamProcessor->getSaved($customerId, 499), $context->getContext())->getIterator() as $saved) {
  220.             /** @var AmityPostLikesEntity $saved */
  221.             $ids[] = $saved->getPostId();
  222.         }
  224.         if (empty($ids)) {
  225.             return [];
  226.         }
  228.         return $this->streamSorter->sort(
  229.             $this->grabWeights($customerTags, $customerId, $context),
  230.             $this->repositoryHelper->queryPosts2($this->streamProcessor->getIdCriteria($ids, 100, $customerId), $context, null, 1, 'saved')
  231.         );
  232.     }
  234.     public function getLatestViewed(string $customerId, SalesChannelContext $context)
  235.     {
  236.         $latest = $this->repositoryHelper->queryPosts(
  237.             $this->utilities->getLastViewedCriteria($customerId, $context->getContext()),
  238.             $context
  239.         );
  241.         return $latest->getTotal() ? $latest->first() : null;
  242.     }
  244.     public function grabWeights($customerTags, ?string $customerId, SalesChannelContext $context): array
  245.     {
  246.         return [
  247.             'viewTime'  =>  !empty($customerId) ? $this->utilities->getViewTimeWeights($customerTags, $customerId, $context->getContext()) : null,
  248.             'orders'    =>  !empty($customerId) ? $this->utilities->getOrderWeights($customerTags, $customerId, $context->getContext()) : null,
  249.             'social'    =>  !empty($customerId) ? $this->utilities->getSocialGraphWeights($customerId, $context->getContext()) : null,
  250.         ];
  251.     }
  253.     /**
  254.      * @param ProductEntity $product
  255.      * @param SalesChannelContext $context
  256.      * @param string|null $type
  257.      * @return array
  258.      */
  259.     public function fetchPostsByEAN(ProductEntity $product, SalesChannelContext $context, ?string $type = null): array
  260.     {
  261.         $EANs = [$product->getEan()];
  263.         if (
  264.             array_key_exists('amityEANs', $product->getCustomFields())
  265.             && $product->getCustomFields()['amityEANs']
  266.         ) {
  267.             $EANs = array_merge($EANs, explode(',', $product->getCustomFields()['amityEANs']));
  268.         }
  270.         $filters = [];
  272.         foreach ($EANs as $EAN) {
  273.             $filters[] = (new EqualsFilter('ean', $EAN));
  274.         }
  276.         $criteria = (new Criteria())
  277.             ->addFilter(new MultiFilter('OR', $filters))
  278.             ->addAssociation('postChildren');
  280.         if ($type) {
  281.             $criteria->addFilter(new EqualsFilter('type', $type));
  282.         }
  284.         return $this->repositoryHelper->queryPosts(
  285.             $criteria,
  286.             $context
  287.         )->getElements();
  288.     }
  290.     public function buildDetailStream(string $productId, $customerId, SalesChannelContext $context): array
  291.     {
  292.         $ids = [];
  293.         foreach ($this->repositoryHelper->queryDetailPost($this->streamProcessor->getCriteriaDetail($productId, $customerId, 100), $context->getContext())->getIterator() as $post) {
  294.             $ids[] = $post->getId();
  295.         }
  296.         if (empty($ids)) {
  297.             return [];
  298.         }
  300.         return $this->streamSorter->sort(
  301.             $this->grabWeights([], $customerId, $context),
  302.             $this->repositoryHelper->queryPosts($this->streamProcessor->getIdCriteria($ids, 10, $customerId), $context, true)
  303.         );
  304.     }
  306.     public function convertVideoKey($post)
  307.     {
  308.         if (!empty($post->getCustomer())) {
  309.                 if (!empty($post->getCustomer()?->getCustomFields())) {
  310.                     $postCustomerCustomFields = $post->getCustomer()?->getCustomFields();
  312.                     if (!empty($postCustomerCustomFields['emailListInvited'])) {
  313.                         $postCustomerCustomFields['emailListInvited'] = [];
  314.                     }
  315.                     if (!empty($postCustomerCustomFields['emailsInvited'])) {
  316.                         $postCustomerCustomFields['emailsInvited'] = [];
  317.                     }
  319.                     $post->getCustomer()?->setCustomFields($postCustomerCustomFields);
  320.                 }
  321.             }
  322.             if (!empty($post->getProduct())) {
  323.                 if (!empty($post->getProduct()?->getMedia())) {
  324.                     $post->getProduct()?->setMedia(new ProductMediaCollection([]));
  325.                 }
  326.                 if (!empty($post->getProduct()?->getCustomFields())) {
  327.                     $post->getProduct()?->setCustomFields([]);
  328.                 }
  329.                 if (!empty($post->getProduct()?->getTranslated())) {
  330.                     $postProductCustomFields = $post->getProduct()?->getTranslated();
  332.                     if (!empty($postProductCustomFields['customFields'])) {
  333.                         $postProductCustomFields['customFields'] = [];
  334.                     }
  336.                     $post->getProduct()->setTranslated($postProductCustomFields);
  337.                 }
  338.             }
  339.             if (!empty($post->getAmityObject())) {
  340.                 $post->setAmityObject([]);
  341.             }
  342.             if (!empty($post->getPostChildren())) {
  343.                 foreach ($post->getPostChildren() as $postChild) {
  344.                     if (!empty($postChild->getAmityObject())) {
  345.                         $postChild->setAmityObject([]);
  346.                     }
  347.                     if (!empty($postChild->getFile()) && !empty($postChild->getFile()->{'fileObject'})) {
  348.                         $postChild->getFile()->{'fileObject'} = [];
  349.                     }
  350.                 }
  351.             }
  353.             return $post;
  354.     }
  355. }