src/Bundles/Messenger/Controller/NotificationController.php line 52

Open in your IDE?
  1. <?php
  3. namespace Bundles\Messenger\Controller;
  5. use Symfony\Component\HttpFoundation\JsonResponse;
  6. use App\Controller\ParentController;
  7. use Doctrine\DBAL\Connection;
  8. use Bundles\Messenger\Entity\Notification;
  9. use Doctrine\ORM\EntityManager;
  10. use Doctrine\ORM\QueryBuilder;
  11. use App\Entity\Customer;
  12. use Doctrine\ORM\Query\Expr\Join;
  13. use App\Entity\User;
  14. use Bundles\Messenger\Entity\Article;
  16. class NotificationController extends ParentController {
  18. protected $options = [];
  19. /** @var Connection */
  20. protected $connection;
  22. /**
  23. * @param $entityClass
  24. * @param $sortDirection
  25. * @param $sortField
  26. * @param $dqlFilter
  27. * @return QueryBuilder
  28. */
  29. protected function createListQueryBuilder($entityClass, $sortDirection, $sortField = null, $dqlFilter = null) {
  30. $userId = $this->getUser()->getId();
  31. $type = $this->request->get('type') ?? '';
  32. $show = $this->request->get('show') ?? '';
  34. /* @var EntityManager */
  35. $em = $this->getDoctrine()->getManagerForClass($this->entity['class']);
  36. /* @var QueryBuilder */
  37. $queryBuilder = $em->createQueryBuilder()
  38. ->select('entity')
  39. ->from($this->entity['class'], 'entity')
  40. ->orderBy('entity.id', 'DESC');
  42. if (!$this->getUser()->isAdmin() || $show != 'all') {
  43. $queryBuilder->andWhere('entity.User = '.$userId);
  44. }
  46. if (!empty($type)) {
  47. $queryBuilder->andWhere('entity.type = \''.$type.'\'');
  48. }
  49. return $queryBuilder;
  50. }
  52. public function newMessages($type) {
  53. $this->em = $this->getDoctrine()->getManager();
  54. $user = $this->getUser();
  55. if ($type == 'articles') {
  56. $messages = $this->em->getRepository(Article::class)->findByValidDates();
  58. } else {
  59. $messages = $this->em->getRepository(Notification::class)->findWithCashflowBy($user, $type);
  60. }
  62. $data = [
  63. 'messages' => $messages,
  64. 'count' => count($messages),
  65. ];
  66. $content = $this->render('@messenger/new_'.$type.'.html.twig', $data)->getContent();
  69. return new JsonResponse($content, 200);
  70. }
  72. public function setAsSeen($id) {
  73. $this->em = $this->getDoctrine()->getManager();
  74. $user = $this->getUser();
  75. $status = 'false';
  76. $message = $this->em->getRepository(Notification::class)->findOneBy(['User' => $user, 'id' => $id]);
  77. if (!empty($message)) {
  78. $message->setSeen(true);
  79. $this->em->persist($message);
  80. $this->em->flush();
  81. $status = 'ok';
  82. }
  83. return new JsonResponse($status, 200);
  84. }
  85. }