ActivePageRepository.php 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  1. <?php
  2. declare(strict_types=1);
  3. namespace Meramo\Pagemanager\Domain\Repository;
  4. use Meramo\Pagemanager\Domain\Model\ActivePage;
  5. use TYPO3\CMS\Extbase\Persistence\Repository;
  6. use \TYPO3\CMS\Extbase\Persistence\Generic\QueryResult;
  7. use TYPO3\CMS\Core\Database\ConnectionPool;
  8. use TYPO3\CMS\Core\Utility\GeneralUtility;
  9. /**
  10. * This file is part of the "ABI2021 Page Manager" Extension for TYPO3 CMS.
  11. *
  12. * For the full copyright and license information, please read the
  13. * LICENSE.txt file that was distributed with this source code.
  14. *
  15. * (c) 2023 Meramo Developer <development@meramo.de>, Meramo Verlag GmbH
  16. */
  17. /**
  18. * The repository for ActivePages
  19. */
  20. class ActivePageRepository extends Repository
  21. {
  22. /**
  23. * Queries the pages and be_users tables and returns the Data as an array
  24. *
  25. * @return QueryResult|array
  26. */
  27. public function findActivePagesAndPageCreatetors()
  28. {
  29. $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable('pages');
  30. $queryBuilder->getRestrictions()->removeAll();
  31. /*
  32. SELECT p.uid, p.starttime, p.endtime, p.title, p.roof, u.username, u.realName
  33. FROM pages p LEFT JOIN be_users u ON p.cruser_id = u.uid
  34. WHERE p.starttime > 0 AND p.endtime > 0 and p.red_status = 12 and p.deleted = 0 and p.hidden = 0
  35. GROUP BY p.slug ORDER BY p.endtime ASC;
  36. SELECT `p`.`uid`, `p`.`starttime`, `p`.`endtime`, `p`.`title`, `p`.`roof`, `p`.`slug`, `u`.`username`, `u`.`realName` FROM `pages` `p` LEFT JOIN `be_users` `u` ON `p`.`cruser_id` = `u`.`uid` WHERE (`p`.`starttime` > 0)
  37. AND (`p`.`endtime` <= 1683040238) AND (`p`.`red_status` = 12) AND (`p`.`deleted` = 0) AND (`p`.`hidden` = 0) GROUP BY `p`.`slug` ORDER BY `p`.`endtime` ASC
  38. */
  39. $statement = $queryBuilder
  40. ->select('p.uid', 'p.starttime', 'p.endtime', 'p.title', 'p.roof', 'p.slug', 'u.username', 'u.realName')
  41. ->from('pages', 'p')
  42. //->from('be_users', 'u')
  43. ->leftJoin(
  44. 'p',
  45. 'be_users',
  46. 'u',
  47. $queryBuilder->expr()->eq('p.cruser_id', $queryBuilder->quoteIdentifier('u.uid'))
  48. )
  49. ->where(
  50. $queryBuilder->expr()->gt('p.starttime', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  51. $queryBuilder->expr()->gt('p.endtime', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  52. $queryBuilder->expr()->eq('p.red_status', $queryBuilder->createNamedParameter(12, \PDO::PARAM_INT)),
  53. $queryBuilder->expr()->eq('p.deleted', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  54. $queryBuilder->expr()->eq('p.hidden', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT))
  55. )
  56. ->groupBy('p.slug')
  57. ->orderBy('p.endtime', 'ASC');
  58. $result = $statement->execute();
  59. return $result->fetchAllAssociative();
  60. }
  61. /**
  62. * Queries the pages and be_users to get Records which expired in the last 30 days
  63. *
  64. * @return QueryResult|array
  65. */
  66. public function findExpiredRecordsInTheLast30Days()
  67. {
  68. $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable('pages');
  69. $queryBuilder->getRestrictions()->removeAll();
  70. $currentDate = new \DateTime("now");
  71. $last30Days = $currentDate->sub(new \DateInterval('P30D'));
  72. $timestamp = date_format($last30Days, 'U');
  73. $statement = $queryBuilder
  74. ->select('p.uid', 'p.starttime', 'p.endtime', 'p.title', 'p.roof', 'p.slug', 'u.username', 'u.realName')
  75. ->from('pages', 'p')
  76. //->from('be_users', 'u')
  77. ->leftJoin(
  78. 'p',
  79. 'be_users',
  80. 'u',
  81. $queryBuilder->expr()->eq('p.cruser_id', $queryBuilder->quoteIdentifier('u.uid'))
  82. )
  83. ->where(
  84. $queryBuilder->expr()->gt('p.starttime', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  85. $queryBuilder->expr()->lt('p.endtime', $queryBuilder->createNamedParameter($timestamp, \PDO::PARAM_INT)),
  86. $queryBuilder->expr()->eq('p.red_status', $queryBuilder->createNamedParameter(12, \PDO::PARAM_INT)),
  87. $queryBuilder->expr()->eq('p.deleted', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  88. $queryBuilder->expr()->eq('p.hidden', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT))
  89. )
  90. ->groupBy('p.slug')
  91. ->orderBy('p.endtime', 'ASC');
  92. $result = $statement->execute();
  93. return $result->fetchAllAssociative();
  94. }
  95. /**
  96. * Queries the pages and be_users to get Records which expired in the last 30 days
  97. *
  98. * @return QueryResult|array
  99. */
  100. public function findExpiredRecordsInTheLast90Days()
  101. {
  102. $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable('pages');
  103. $queryBuilder->getRestrictions()->removeAll();
  104. $currentDate = new \DateTime("now");
  105. $last90Days = $currentDate->sub(new \DateInterval('P90D'));
  106. $timestamp = date_format($last90Days, 'U');
  107. $statement = $queryBuilder
  108. ->select('p.uid', 'p.starttime', 'p.endtime', 'p.title', 'p.roof', 'p.slug', 'u.username', 'u.realName')
  109. ->from('pages', 'p')
  110. //->from('be_users', 'u')
  111. ->leftJoin(
  112. 'p',
  113. 'be_users',
  114. 'u',
  115. $queryBuilder->expr()->eq('p.cruser_id', $queryBuilder->quoteIdentifier('u.uid'))
  116. )
  117. ->where(
  118. $queryBuilder->expr()->gt('p.starttime', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  119. $queryBuilder->expr()->lt('p.endtime', $queryBuilder->createNamedParameter($timestamp, \PDO::PARAM_INT)),
  120. $queryBuilder->expr()->eq('p.red_status', $queryBuilder->createNamedParameter(12, \PDO::PARAM_INT)),
  121. $queryBuilder->expr()->eq('p.deleted', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT)),
  122. $queryBuilder->expr()->eq('p.hidden', $queryBuilder->createNamedParameter(0, \PDO::PARAM_INT))
  123. )
  124. ->groupBy('p.slug')
  125. ->orderBy('p.endtime', 'ASC');
  126. var_dump($queryBuilder->getSQL());
  127. $result = $statement->execute();
  128. return $result->fetchAllAssociative();
  129. }
  130. /**
  131. * Create category from slug
  132. *
  133. */
  134. public function createCategoryFromSlug($slug)
  135. {
  136. if (substr($slug, 0, 1) === '/') $value = ltrim($slug, '/');
  137. if (substr($slug, 0, 1) === '_') $value = ltrim($slug, '_');
  138. return explode('/', $value)[0];
  139. }
  140. }