src/Controller/FrontApi/StoryApiController.php line 131

Open in your IDE?
  1. <?php
  4. namespace App\Controller\FrontApi;
  7. use App\Controller\BaseAbstractApiController;
  8. use App\Entity\Blog;
  9. use App\Entity\Story;
  10. use App\Entity\StoryComment;
  11. use App\Entity\User;
  12. use App\Enum\Banlist\Target;
  13. use App\Enum\Story\Status;
  14. use App\Enum\Site\Domain;
  15. use App\Enum\Site\Lang;
  16. use App\Service\Banlist\BanlistService;
  17. use App\Service\Category\CategoryService;
  18. use App\Service\Stories\StoryService;
  19. use App\Service\User\UserService;
  20. use Doctrine\ORM\EntityManagerInterface;
  21. use Symfony\Component\HttpFoundation\RequestStack;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Component\HttpKernel\KernelInterface;
  24. use Symfony\Component\Security\Core\Security;
  26. class StoryApiController extends BaseAbstractApiController
  27. {
  28.     /**
  29.      * @var StoryService
  30.      */
  31.     private $storiesService;
  32.     /**
  33.      * @var UserService
  34.      */
  35.     private $userService;
  36.     /**
  37.      * @var BanlistService
  38.      */
  39.     private $banlistService;
  41.     public function __construct(
  42.         RequestStack           $requestStack,
  43.         Security               $security,
  44.         EntityManagerInterface $em,
  45.         StoryService           $storiesService,
  46.         UserService            $userService,
  47.         BanlistService         $banlistService
  48.     )
  49.     {
  50.         parent::__construct($requestStack, $security, $em);
  51.         $this->storiesService = $storiesService;
  52.         $this->userService = $userService;
  53.         $this->banlistService = $banlistService;
  54.     }
  56.     public function add()
  57.     {
  58.         $user = $this->security->getUser() ? $this->security->getUser()->getAssociatedUser() : null;
  59.         $domain = Domain::isWLDomainHasOwnContent($this->dataArray['original_domain'] ?? '') ? $this->dataArray['original_domain'] : $this->dataArray['domain'];
  60.         $story = (new Story())->setDomain($domain);
  61.         if ($user) {
  62.             $story->setUser($user);
  63.         }
  65.         $data = $this->dataArray['story'];
  67.         if (($data['id'] ?? 0) > 0) {
  68.             $story = $this->storiesService->get($data['id'], $domain);
  70.             if (isset($data['user'])) {
  71.                 unset($data['user']);
  72.             }
  73.         }
  75.         if (isset($data['categories'])) {
  76.             foreach ($data['categories'] as $key => $categoryId) {
  77.                 $category = $this->storiesService->getCategory($categoryId);
  78.                 $story->addCategory($category);
  79.                 unset($data['categories']);
  80.             }
  81.         }
  83.         if (isset($data['firstStoryCategoryId'])) {
  84.             $story->setFirstStoryCategory($data['firstStoryCategoryId']);
  85.         }
  87.         $story->fromArray($data);
  88.         $story->setDomain($domain);
  89.         $errors = [];
  91.         if (!$this->banlistService->checkText(
  92.             $story->getName(),
  93.             $story->getDomain(),
  94.             Target::TARGET_STORY,
  95.             true,
  96.             null,
  97.             false,
  98.             [],
  99.             $user ? $user->getId() : null,
  100.             ($data['id'] ?? 0) > 0 ? $data['id'] : null
  101.         )) {
  102.             $errors['name'] = 'error_content_link_phone';
  103.         }
  104.         if (!$this->banlistService->checkText(
  105.             $story->getText(),
  106.             $story->getDomain(),
  107.             Target::TARGET_STORY,
  108.             true,
  109.             null,
  110.             false,
  111.             [],
  112.             $user ? $user->getId() : null,
  113.             ($data['id'] ?? 0) > 0 ? $data['id'] : null
  114.         )) {
  115.             $errors['text'] = 'error_content_link_phone';
  116.         }
  118.         if (empty($errors)) {
  119.             $this->storiesService->update($story);
  121.             if (!$story->getId() || $story->getId() <= 0) {
  122.                 $errors[] = 'Error';
  123.             } else {
  124.                 $this->dataArray['story'] = $story->toArray();
  125.             }
  126.         }
  128.         return $this->json(['errors' => $errors, 'data' => $this->dataArray['story']]);
  129.     }
  131.     public function getCategories()
  132.     {
  133.         $lang = $this->dataArray['sys_locale'];
  134.         $domain = $this->dataArray['domain'];
  135.         $originalDomain = $this->dataArray['original_domain'];
  137.         $data = $this->storiesService->getCategories($domain, $originalDomain, $lang);
  139.         return $this->json($data);
  140.     }
  142.     public function getStory()
  143.     {
  144.         $domain = $this->dataArray['domain'];
  145.         $slug = $this->dataArray['slug'];
  146.         $lang = $this->dataArray['lang'];
  147.         $page = $this->dataArray['page'];
  148.         $perPage = $this->dataArray['perPage'];
  150.         $data = $this->storiesService->getBySlug($slug, $domain, $lang, $page, $perPage);
  152.         return $this->json($data);
  153.     }
  155.     public function getStoryById()
  156.     {
  157.         return $this->json($this->storiesService->getById($this->dataArray['id'], $this->dataArray['domain']) ?: []);
  158.     }
  160.     public function update()
  161.     {
  162.         $user = $this->security->getUser() ? $this->security->getUser()->getAssociatedUser() : null;
  163.         $domain = $this->dataArray['domain'];
  164.         $story = (new Story())->setDomain($domain);
  165.         if ($user) {
  166.             $story->setUser($user);
  167.         }
  169.         $data = $this->dataArray['story'];
  171.         if (($data['id'] ?? 0) > 0) {
  172.             $story = $this->storiesService->get($data['id'], $domain);
  173.             if ($story && isset($data['categories'])) {
  174.                 $categoryIds = $this->storiesService->getCategoryIds($story->getCategories());
  175.                 foreach ($data['categories'] as $newStoryCategory) {
  176.                     if (!in_array($newStoryCategory, $categoryIds)) {
  177.                         $category = $this->storiesService->getCategory($newStoryCategory);
  178.                         if ($category) {
  179.                             $story->addCategory($category);
  180.                         }
  181.                     }
  182.                 }
  184.                 foreach ($categoryIds as $oldStoryCategoryId) {
  185.                     if (!in_array($oldStoryCategoryId, $data['categories'])) {
  186.                         $oldCategory = $this->storiesService->getCategory($oldStoryCategoryId);
  187.                         if ($oldCategory) {
  188.                             $story->removeCategory($oldCategory);
  189.                         }
  190.                     }
  191.                 }
  192.                 if (isset($data['user'])) {
  193.                     unset($data['user']);
  194.                 }
  195.             }
  196.         }
  197.         if (isset($data['firstStoryCategoryId'])) {
  198.             $story->setFirstStoryCategory($data['firstStoryCategoryId']);
  199.         }
  200.         $story->fromArray($data);
  201.         $story->setDomain($domain);
  202.         if (!isset($data['id']) || !$data['id'] || $data['id'] <= 0) {
  203.             $story->setStatus(Status::STATUS_NEW);
  204.         }
  206.         $errors = [];
  208.         if (!$this->banlistService->checkText(
  209.             $story->getName(),
  210.             $story->getDomain(),
  211.             Target::TARGET_STORY,
  212.             true,
  213.             null,
  214.             false,
  215.             [],
  216.             $user ? $user->getId() : null,
  217.             ($data['id'] ?? 0) > 0 ? $data['id'] : null
  218.         )) {
  219.             $errors['name'] = 'error_content_link_phone';
  220.         }
  221.         if (!$this->banlistService->checkText(
  222.             $story->getText(),
  223.             $story->getDomain(),
  224.             Target::TARGET_STORY,
  225.             true,
  226.             null,
  227.             false,
  228.             [],
  229.             $user ? $user->getId() : null,
  230.             ($data['id'] ?? 0) > 0 ? $data['id'] : null
  231.         )) {
  232.             $errors['text'] = 'error_content_link_phone';
  233.         }
  235.         if (empty($errors)) {
  236.             $this->storiesService->update($story);
  238.             if (!$story->getId() || $story->getId() <= 0) {
  239.                 $errors[] = 'Error';
  240.             } else {
  241.                 $this->dataArray['story'] = $story->toArray();
  242.                 if ($story->getUser()) {
  243.                     $this->dataArray['story']['user'] = $story->getUser()->toArray();
  244.                 }
  245.             }
  246.         }
  248.         return $this->json(['errors' => $errors, 'data' => $this->dataArray['story']]);
  249.     }
  251.     public function incViews()
  252.     {
  253.         if (getenv('APP_ENV') === 'dev') {
  254.             $story = $this->storiesService->get($this->dataArray['id'], $this->dataArray['domain']);
  255.             if ($story) {
  256.                 $story->incViews();
  257.                 $this->storiesService->update($story);
  259.                 file_put_contents(getenv('RAMFSPATH') . '/incStory.cnt', $this->dataArray['id'] . '|', FILE_APPEND);
  260.                 return $this->json(['views' => $story->getViews()]);
  261.             }
  262.         } else {
  263.             file_put_contents(getenv('RAMFSPATH') . '/incStory.cnt', $this->dataArray['id'] . '|', FILE_APPEND);
  264.         }
  266.         return $this->json([]);
  267.     }
  269.     public function map()
  270.     {
  271.         $sql = 'select slug, lang from story where status="active" and domain="'.$this->dataArray['domain'].'" order by id desc limit 0,1000';
  272.         $q = $this->getDoctrine()->getConnection()->prepare($sql);
  273.         $q->execute();
  274.         $result = [];
  276.         foreach ($q->fetchAll() as $item) {
  277.             $result[] = $item;
  278.         }
  279.         return $this->json($result);
  280.     }
  282.     public function random()
  283.     {
  284.         $domain = $this->dataArray['domain'];
  285.         $lang = $this->dataArray['lang'] ?: Lang::LANG_LV;
  286.         $skipId = $this->dataArray['skipId'] ?: 0;
  287.         $limit = $this->dataArray['limit'] ?: 3;
  289.         $data = $this->storiesService->getRandom($domain, $lang, $skipId, $limit);
  291.         return $this->json($data);
  292.     }
  294.     public function addComment()
  295.     {
  296.         /** @var Story $story */
  297.         $story = $this->storiesService->get($this->dataArray['storyId'], $this->dataArray['domain']);
  299.         /** @var User $user */
  300.         $user = $this->userService->get($this->dataArray['userId'], $this->dataArray['domain']);
  302.         $data = [];
  303.         if ($story && $user) {
  304.             $comment = new StoryComment();
  305.             $comment->setStory($story);
  306.             $comment->setUser($user);
  307.             $comment->setName($user->getUsername() ?: $user->getName() ?: 'Guest');
  308.             $comment->setStatus(Status::STATUS_ACTIVE);
  309.             $comment->setText($this->dataArray['text']);
  310.             $comment->setIp($this->dataArray['ip']);
  311.             $comment->setDomain($this->dataArray['domain']);
  313.             $this->storiesService->update($comment);
  315.             $isValid = $this->banlistService->checkText(
  316.                 $this->dataArray['text'],
  317.                 $this->dataArray['domain'],
  318.                 Target::TARGET_STORY_COMMENT,
  319.                 true,
  320.                 null,
  321.                 false,
  322.                 [],
  323.                 $user->getId(),
  324.                 $comment->getId()
  325.             );
  327.             if (!$isValid) {
  328.                 $comment->setStatus(Status::STATUS_DELETED);
  329.                 $this->storiesService->update($comment);
  330.             }
  332.             $data = $comment->toArray();
  333.             $data['user'] = $comment->getUser()->toArray();
  334.             $data['storySlug'] = $comment->getStory()->getSlug();
  335.         }
  337.         return $this->json($data);
  338.     }
  340.     public function getNewSlug()
  341.     {
  342.         $id = (int)($this->dataArray['id'] ?? 0);
  343.         if ($id > 0) {
  344.             switch ($this->dataArray['type'] ?? '') {
  345.                 case 'blog':
  346.                     $sql = 'SELECT*FROM setting s WHERE s.name="k6blog-'.$id.'-new_id"';
  347.                     $qTmp = $this->em->getConnection()->prepare($sql);
  348.                     $qTmp->execute();
  349.                     $tmp = $qTmp->fetch();
  350.                     if (isset($tmp['value'])) {
  351.                         $id = (int) unserialize($tmp['value']);
  352.                         if ($id > 0) {
  353.                             $sql = 'select slug from blog where id='.$id;
  354.                             $qTmp = $this->em->getConnection()->prepare($sql);
  355.                             $qTmp->execute();
  356.                             $tmp = $qTmp->fetch();
  357.                             if (isset($tmp['slug'])) {
  358.                                 return $this->json($tmp['slug']);
  359.                             }
  360.                         }
  361.                     }
  362.                     break;
  363.                 case 'novel':
  364.                     $sql = 'SELECT*FROM setting s WHERE s.name="k6story-'.$id.'-new_id"';
  365.                     $qTmp = $this->em->getConnection()->prepare($sql);
  366.                     $qTmp->execute();
  367.                     $tmp = $qTmp->fetch();
  368.                     if (isset($tmp['value'])) {
  369.                         $id = (int) unserialize($tmp['value']);
  370.                         if ($id > 0) {
  371.                             $sql = 'select slug from story where id='.$id;
  372.                             $qTmp = $this->em->getConnection()->prepare($sql);
  373.                             $qTmp->execute();
  374.                             $tmp = $qTmp->fetch();
  375.                             if (isset($tmp['slug'])) {
  376.                                 return $this->json($tmp['slug']);
  377.                             }
  378.                         }
  379.                     }
  380.                     break;
  381.                 default:
  382.             }
  383.         }
  384.         return $this->json('');
  385.     }
  387.     public function deleteComment()
  388.     {
  389.         /** @var StoryComment $comment */
  390.         $comment = $this->storiesService->getComment($this->dataArray['commentId'], $this->dataArray['domain']);
  392.         /** @var User $user */
  393.         $user = $this->userService->get($this->dataArray['userId'], $this->dataArray['domain']);
  395.         /** @var Story $story */
  396.         $story = $comment->getStory();
  397.         $storyOwner = $story ? $story->getUser() : null;
  399.         if ($comment && $user) {
  400.             $ownerStoryIsCorrect = $storyOwner && $storyOwner->getId() === $user->getId();
  401.             $userIdIsCorrect = $comment->getUser() && $comment->getUser()->getId() === $user->getId();
  402.             $isModer = $this->userService->isModer($user->getId(), $user->getDomain());
  403.             if ($userIdIsCorrect || $isModer || $ownerStoryIsCorrect) {
  404.                 $comment->setStatus(Status::STATUS_DELETED);
  405.                 $this->storiesService->update($comment);
  406.                 return $this->json([
  407.                     'status' => 'success',
  408.                     'storySlug' => $comment->getStory() ? $comment->getStory()->getSlug() : null,
  409.                     'storyLang' => $comment->getStory() ? $comment->getStory()->getLang() : null,
  410.                 ]);
  411.             }
  412.         }
  414.         return $this->json([
  415.             'status' => 'reject'
  416.         ]);
  417.     }
  419.     public function delete()
  420.     {
  421.         $user = $this->security->getUser() ? $this->security->getUser()->getAssociatedUser() : null;
  422.         $story = $this->storiesService->get($this->dataArray['id']);
  424.         if (!$story || !$user || ($story->getUser()->getId() !== $user->getId() && !$this->userService->isModer($user->getId(), $user->getDomain()))) {
  425.             return $this->json([
  426.                 'status' => 'reject'
  427.             ]);
  428.         }
  430.         $story->setStatus(Status::STATUS_DELETED);
  431.         $this->storiesService->update($story);
  432.         $storyCategoryIds = $this->storiesService->getCategoryIds($story->getCategories());
  433.         return $this->json([
  434.             'status' => 'success',
  435.             'id' => $story->getId(),
  436.             'categories' => $storyCategoryIds ?? null,
  437.             'slug' => $story->getSlug(),
  438.             'lang' => $story->getLang(),
  439.             'authorUsername' => $story->getUser() ? $story->getUser()->getUsername() : null,
  440.         ]);
  441.     }
  443.     public function prev()
  444.     {
  445.         $domain = $this->dataArray['domain'];
  446.         $lang = $this->dataArray['lang'];
  447.         $id = $this->dataArray['id'];
  449.         $data = $this->storiesService->getPrev($domain, $lang, $id);
  451.         return $this->json($data);
  452.     }
  454.     public function next()
  455.     {
  456.         $domain = $this->dataArray['domain'];
  457.         $lang = $this->dataArray['lang'];
  458.         $id = $this->dataArray['id'];
  460.         $data = $this->storiesService->getNext($domain, $lang, $id);
  462.         return $this->json($data);
  463.     }
  465.     public function getStories()
  466.     {
  468.         $data = $this->storiesService->getStoriesList(
  469.             $this->dataArray['page'],
  470.             $this->dataArray['perPage'],
  471.             $this->dataArray['domain'],
  472.             $this->dataArray['sort'],
  473.             $this->dataArray['sys_locale'],
  474.             $this->dataArray['categoryId'],
  475.             $this->dataArray['userId']
  476.         );
  478.         return $this->json($data);
  479.     }
  481.     public function getSoftStories()
  482.     {
  483.         $data = $this->storiesService->getSoftListByLang(
  484.             $this->dataArray['lang'],
  485.             $this->dataArray['domain'],
  486.             (int)$this->dataArray['cnt']
  487.         );
  489.         return $this->json($data);
  490.     }
  492.     public function getStoriesByCatsIds()
  493.     {
  494.         $domain = Domain::isWLDomainHasOwnContent($this->dataArray['original_domain'] ?? '') ? $this->dataArray['original_domain'] : $this->dataArray['domain'];
  495.         $data = $this->storiesService->getStoriesListBySeveralIds(
  496.             $this->dataArray['page'],
  497.             $this->dataArray['perPage'],
  498.             $domain,
  499.             $this->dataArray['sort'],
  500.             $this->dataArray['sys_locale'],
  501.             $this->dataArray['storyIds'],
  502.         );
  504.         return $this->json($data);
  505.     }
  507.     public function getStoriesSitemapData(): Response
  508.     {
  509.         $lang = $this->dataArray['sys_locale'];
  510.         $domain = $this->dataArray['domain'];
  512.         $storySql = "select id, name, slug, first_story_category_id from story where status='active' and domain='{$domain}' and lang='{$lang}' order by id desc limit 0,1000";
  513.         $storyQ = $this->getDoctrine()->getConnection()->prepare($storySql);
  514.         $storyQ->execute();
  515.         $storyResult = $storyQ->fetchAll();
  517.         $data = [];
  519.         foreach ($storyResult as $key => $story) {
  520.             if ($story['first_story_category_id'] === null || $story['first_story_category_id'] === '0') {
  521.                 continue;
  522.             }
  524.             $data[] = $story;
  525.             unset($storyResult[$key]);
  526.         }
  528.         $ids = array_map(function ($item) {
  529.             return $item['id'];
  530.         }, $storyResult);
  531.         if (count($ids) > 0) {
  532.             $idsAsString = implode(', ', $ids);
  534.             $storyCategorySql = "select * from story_story_category where story_id in ({$idsAsString})";
  535.             $storyCategoryQ = $this->getDoctrine()->getConnection()->prepare($storyCategorySql);
  536.             $storyCategoryQ->execute();
  537.             $storyCategoryResult = $storyCategoryQ->fetchAll();
  538.         } else {
  539.             $storyCategoryResult = [];
  540.         }
  541.         foreach ($storyResult as $story) {
  542.             foreach ($storyCategoryResult as $storyCategoryItem) {
  543.                 if ($story['id'] === $storyCategoryItem['story_id']) {
  544.                     $story['first_story_category_id'] = $storyCategoryItem['story_category_id'];
  545.                     $data[] = $story;
  546.                 }
  547.             }
  548.         }
  550.         usort($data, function ($a, $b) {
  551.             if ($a['id'] == $b['id']) {
  552.                 return 0;
  553.             }
  554.             return ($a['id'] > $b['id']) ? -1 : 1;
  555.         });
  557.         return $this->json($data);
  558.     }
  559. }