diff options
Diffstat (limited to 'src/Wallabag/CoreBundle/Repository/EntryRepository.php')
-rw-r--r-- | src/Wallabag/CoreBundle/Repository/EntryRepository.php | 114 |
1 files changed, 114 insertions, 0 deletions
diff --git a/src/Wallabag/CoreBundle/Repository/EntryRepository.php b/src/Wallabag/CoreBundle/Repository/EntryRepository.php new file mode 100644 index 00000000..f4c803f9 --- /dev/null +++ b/src/Wallabag/CoreBundle/Repository/EntryRepository.php | |||
@@ -0,0 +1,114 @@ | |||
1 | <?php | ||
2 | |||
3 | namespace Wallabag\CoreBundle\Repository; | ||
4 | |||
5 | use Doctrine\ORM\Query; | ||
6 | use Doctrine\ORM\EntityRepository; | ||
7 | use Doctrine\ORM\Tools\Pagination\Paginator; | ||
8 | |||
9 | class EntryRepository extends EntityRepository | ||
10 | { | ||
11 | /** | ||
12 | * Retrieves unread entries for a user | ||
13 | * | ||
14 | * @param $userId | ||
15 | * @param $firstResult | ||
16 | * @param int $maxResults | ||
17 | * @return Paginator | ||
18 | */ | ||
19 | public function findUnreadByUser($userId, $firstResult, $maxResults = 12) | ||
20 | { | ||
21 | $qb = $this->createQueryBuilder('e') | ||
22 | ->select('e') | ||
23 | ->setFirstResult($firstResult) | ||
24 | ->setMaxResults($maxResults) | ||
25 | ->where('e.isArchived = false') | ||
26 | ->andWhere('e.userId =:userId')->setParameter('userId', $userId) | ||
27 | ->andWhere('e.isDeleted=false') | ||
28 | ->orderBy('e.createdAt', 'desc') | ||
29 | ->getQuery(); | ||
30 | |||
31 | $paginator = new Paginator($qb); | ||
32 | |||
33 | return $paginator; | ||
34 | } | ||
35 | |||
36 | /** | ||
37 | * Retrieves read entries for a user | ||
38 | * | ||
39 | * @param $userId | ||
40 | * @param $firstResult | ||
41 | * @param int $maxResults | ||
42 | * @return Paginator | ||
43 | */ | ||
44 | public function findArchiveByUser($userId, $firstResult, $maxResults = 12) | ||
45 | { | ||
46 | $qb = $this->createQueryBuilder('e') | ||
47 | ->select('e') | ||
48 | ->setFirstResult($firstResult) | ||
49 | ->setMaxResults($maxResults) | ||
50 | ->where('e.isArchived = true') | ||
51 | ->andWhere('e.userId =:userId')->setParameter('userId', $userId) | ||
52 | ->andWhere('e.isDeleted=false') | ||
53 | ->orderBy('e.createdAt', 'desc') | ||
54 | ->getQuery(); | ||
55 | |||
56 | $paginator = new Paginator($qb); | ||
57 | |||
58 | return $paginator; | ||
59 | } | ||
60 | |||
61 | /** | ||
62 | * Retrieves starred entries for a user | ||
63 | * | ||
64 | * @param $userId | ||
65 | * @param $firstResult | ||
66 | * @param int $maxResults | ||
67 | * @return Paginator | ||
68 | */ | ||
69 | public function findStarredByUser($userId, $firstResult, $maxResults = 12) | ||
70 | { | ||
71 | $qb = $this->createQueryBuilder('e') | ||
72 | ->select('e') | ||
73 | ->setFirstResult($firstResult) | ||
74 | ->setMaxResults($maxResults) | ||
75 | ->where('e.isStarred = true') | ||
76 | ->andWhere('e.userId =:userId')->setParameter('userId', $userId) | ||
77 | ->andWhere('e.isDeleted=false') | ||
78 | ->orderBy('e.createdAt', 'desc') | ||
79 | ->getQuery(); | ||
80 | |||
81 | $paginator = new Paginator($qb); | ||
82 | |||
83 | return $paginator; | ||
84 | } | ||
85 | |||
86 | public function findEntries($userId, $isArchived, $isStarred, $isDeleted, $sort, $order) | ||
87 | { | ||
88 | $qb = $this->createQueryBuilder('e') | ||
89 | ->select('e') | ||
90 | ->where('e.userId =:userId')->setParameter('userId', $userId); | ||
91 | |||
92 | if (!is_null($isArchived)) { | ||
93 | $qb->andWhere('e.isArchived =:isArchived')->setParameter('isArchived', $isArchived); | ||
94 | } | ||
95 | |||
96 | if (!is_null($isStarred)) { | ||
97 | $qb->andWhere('e.isStarred =:isStarred')->setParameter('isStarred', $isStarred); | ||
98 | } | ||
99 | |||
100 | if (!is_null($isDeleted)) { | ||
101 | $qb->andWhere('e.isDeleted =:isDeleted')->setParameter('isDeleted', $isDeleted); | ||
102 | } | ||
103 | |||
104 | if ('created' === $sort) { | ||
105 | $qb->orderBy('e.createdAt', $order); | ||
106 | } elseif ('updated' === $sort) { | ||
107 | $qb->orderBy('e.updatedAt', $order); | ||
108 | } | ||
109 | |||
110 | return $qb | ||
111 | ->getQuery() | ||
112 | ->getResult(Query::HYDRATE_ARRAY); | ||
113 | } | ||
114 | } | ||