Completed
Push — master ( 2627e7...02bb7a )
by Valentyn
05:09
created

MovieRepository::findAllByIdsWithSimilarMovies()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 12

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 12
ccs 0
cts 9
cp 0
rs 9.8666
c 0
b 0
f 0
cc 1
nc 1
nop 1
crap 2
1
<?php
2
3
declare(strict_types=1);
4
5
namespace App\Movies\Repository;
6
7
use App\Guests\Entity\GuestSession;
8
use App\Movies\Entity\Movie;
9
use App\Users\Entity\User;
10
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
11
use Doctrine\ORM\Query;
12
use Doctrine\ORM\QueryBuilder;
13
use Symfony\Bridge\Doctrine\RegistryInterface;
14
15
/**
16
 * @method Movie|null find($id, $lockMode = null, $lockVersion = null)
17
 * @method Movie|null findOneBy(array $criteria, array $orderBy = null)
18
 * @method Movie[]    findAll()
19
 * @method Movie[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
20
 */
21
class MovieRepository extends ServiceEntityRepository
22
{
23 27
    public function __construct(RegistryInterface $registry)
24
    {
25 27
        parent::__construct($registry, Movie::class);
26 27
    }
27
28 23
    private function getBaseQuery(): QueryBuilder
29
    {
30 23
        return $this->createQueryBuilder('m')
31 23
            ->leftJoin('m.translations', 'mt', null, null, 'mt.locale')
32 23
            ->addSelect('mt')
33 23
            ->leftJoin('m.genres', 'mg')
34 23
            ->addSelect('mg')
35 23
            ->leftJoin('mg.translations', 'mgt', null, null, 'mgt.locale')
36 23
            ->addSelect('mgt');
37
    }
38
39
    /**
40
     * @param int       $id
41
     * @param User|null $user
42
     *
43
     * @throws \Doctrine\ORM\NoResultException
44
     * @throws \Doctrine\ORM\NonUniqueResultException
45
     *
46
     * @return Movie|null
47
     */
48 2
    public function findOneForMoviePage(int $id, ?User $user = null): ?Movie
49
    {
50 2
        if ($user === null) {
51 2
            return $this->getBaseQuery()
52 2
                ->where('m.id = :id')
53 2
                ->setParameter('id', $id)
54 2
                ->getQuery()
55 2
                ->getSingleResult();
56
        }
57
58
        $result = $this->getBaseQuery()
59
            ->where('m.id = :id')
60
            ->leftJoin('m.userWatchedMovie', 'uwm', 'WITH', 'uwm.user = :user_id')
61
            ->addSelect('uwm')
62
            ->leftJoin('m.userRecommendedMovie', 'urm', 'WITH', 'urm.user = :user_id AND urm.originalMovie = :id')
63
            ->addSelect('urm')
64
            ->leftJoin('m.userInterestedMovie', 'uim', 'WITH', 'uim.user = :user_id AND uim.movie = :id')
65
            ->addSelect('uim')
66
            ->setParameter('user_id', $user->getId())
67
            ->setParameter('id', $id)
68
            ->getQuery()
69
            ->getSingleResult();
70
71
        return $result;
72
    }
73
74 17
    public function findAllWithIsWatchedFlag(?User $user = null, ?GuestSession $guest = null): array
75
    {
76 17
        $items = $this->getBaseQuery();
77
78 17
        if ($user !== null) {
79
            $items
80
                ->leftJoin('m.userWatchedMovie', 'uwm', 'WITH', 'uwm.user = :user_id')
81
                ->addSelect('uwm')
82
                ->setParameter('user_id', $user->getId());
83
        }
84
85 17
        if ($guest !== null) {
86
            $items
87
                ->leftJoin('m.guestWatchedMovie', 'gwm', 'WITH', 'gwm.guestSession = :guest_id')
88
                ->addSelect('gwm')
89
                ->setParameter('guest_id', $guest->getId());
90
        }
91
92 17
        $items->where('m.id IN (:ids)');
93
94
        /** Ids query */
95 17
        $ids = $this->createQueryBuilder('m')
96 17
            ->select('m.id')
97 17
            ->orderBy('m.id', 'DESC');
98
99
        /** Count query */
100 17
        $count = $this->createQueryBuilder('m')
101 17
            ->select('COUNT(m.id)');
102
103 17
        return [$items->getQuery(), $ids->getQuery(), $count->getQuery()];
104
    }
105
106
    /**
107
     * @param array $ids
108
     *
109
     * @return array|Movie[]
110
     */
111
    public function findAllByIds(array $ids)
112
    {
113
        $result = $this->getBaseQuery()
114
            ->where('m.id IN (:ids)')
115
            ->setParameter('ids', $ids)
116
            ->getQuery()
117
            ->getResult();
118
119
        return $result;
120
    }
121
122
    /**
123
     * @param array $ids
124
     *
125
     * @return array|Movie[]
126
     */
127
    public function findAllByIdsWithSimilarMovies(array $ids): array
128
    {
129
        $result = $this->createQueryBuilder('m')
130
            ->leftJoin('m.similarMovies', 'sm')
131
            ->addSelect('sm')
132
            ->where('m.id IN (:ids)')
133
            ->setParameter('ids', $ids)
134
            ->getQuery()
135
            ->getScalarResult();
136
137
        return $result;
138
    }
139
140
    /**
141
     * @param array $ids
142
     *
143
     * @return array|Movie[]
144
     */
145 1
    public function findAllByTmdbIds(array $ids)
146
    {
147 1
        $result = $this->getBaseQuery()
148 1
            ->where('m.tmdb.id IN (:ids)')
149 1
            ->setParameter('ids', $ids)
150 1
            ->getQuery()
151 1
            ->getResult();
152
153 1
        return $result;
154
    }
155
156
    /**
157
     * @param array $ids
158
     *
159
     * @return array of int
160
     */
161
    public function findAllIdsByTmdbIds(array $ids)
162
    {
163
        $result = $this->createQueryBuilder('m')
164
            ->select('m.id, m.tmdb.voteAverage, m.releaseDate')
165
            ->where('m.tmdb.id IN (:ids)')
166
            ->setParameter('ids', $ids)
167
            ->getQuery()
168
            ->getScalarResult();
169
170
        return $result;
171
    }
172
173 2
    public function getAllWatchedMoviesByUserId(User $owner, ?User $currentUser = null): array
174
    {
175 2
        $items = $this->getBaseQuery()
176 2
            ->leftJoin('m.ownerWatchedMovie', 'owm', 'WITH', 'owm.user = :owner_id')
177 2
            ->addSelect('owm')
178 2
            ->setParameter('owner_id', $owner->getId());
179
180 2
        if ($currentUser !== null) {
181 2
            $items->leftJoin('m.userWatchedMovie', 'uwm', 'WITH', 'uwm.user = :user_id')
182 2
                ->addSelect('uwm')
183 2
                ->setParameter('user_id', $currentUser->getId());
184
        }
185
186 2
        $items->where('m.id IN (:ids)');
187
188 2
        $ids = $this->createQueryBuilder('m')
189 2
            ->select('m.id')
190 2
            ->leftJoin('m.ownerWatchedMovie', 'owm', 'WITH', 'owm.user = :owner_id')
191 2
            ->where('owm.id != 0')
192 2
            ->setParameter('owner_id', $owner->getId())
193 2
            ->orderBy('owm.id', 'DESC');
194
195 2
        $count = $this->createQueryBuilder('m')
196 2
            ->select('COUNT(m.id)')
197 2
            ->leftJoin('m.ownerWatchedMovie', 'owm', 'WITH', 'owm.user = :owner_id')
198 2
            ->setParameter('owner_id', $owner->getId())
199
200 2
            ->where('owm.id != 0');
201
202 2
        return [$items->getQuery(), $ids->getQuery(), $count->getQuery()];
203
    }
204
205 3
    public function getAllInterestedMoviesByUserId(int $profileOwnerId, ?User $currentUser = null): Query
206
    {
207 3
        $result = $this->getBaseQuery()
208 3
            ->leftJoin('m.userInterestedMovie', 'uim', 'WITH', 'uim.user = :owner_id')
209 3
            ->addSelect('uim')
210 3
            ->setParameter('owner_id', $profileOwnerId)
211 3
            ->andWhere('uim.id != 0')
212 3
            ->orderBy('uim.id', 'DESC');
213
214 3
        if ($currentUser !== null) {
215 3
            $result->leftJoin('m.userWatchedMovie', 'uwm', 'WITH', 'uwm.user = :current_user_id')
216 3
                ->addSelect('uwm')
217 3
                ->setParameter('current_user_id', $currentUser->getId());
218
        }
219
220 3
        return $result->getQuery();
221
    }
222
223 2
    public function findAllByActor(int $actorId, ?User $currentUser = null): array
224
    {
225 2
        $items = $this->getBaseQuery()
226 2
            ->leftJoin('m.actors', 'ma', 'WITH', 'ma.actor = :actor AND ma.movie = m')
227 2
            ->setParameter('actor', $actorId)
228 2
            ->orderBy('m.releaseDate', 'DESC');
229
230 2
        if ($currentUser !== null) {
231 1
            $items->leftJoin('m.userWatchedMovie', 'uwm', 'WITH', 'uwm.user = :user_id')
232 1
                ->addSelect('uwm')
233 1
                ->setParameter('user_id', $currentUser->getId());
234
        }
235
236 2
        $items->where('m.id IN (:ids)');
237
238 2
        $ids = $this->createQueryBuilder('m')
239 2
            ->select('m.id')
240 2
            ->leftJoin('m.actors', 'ma', 'WITH', 'ma.actor = :actor AND ma.movie = m')
241 2
            ->setParameter('actor', $actorId)
242 2
            ->andWhere('ma.id != 0')
243 2
            ->orderBy('m.releaseDate', 'DESC');
244
245 2
        $count = $this->createQueryBuilder('m')
246 2
            ->select('COUNT(m.id)')
247 2
            ->leftJoin('m.actors', 'ma', 'WITH', 'ma.actor = :actor AND ma.movie = m')
248 2
            ->setParameter('actor', $actorId)
249 2
            ->andWhere('ma.id != 0');
250
251 2
        return [$items->getQuery(), $ids->getQuery(), $count->getQuery()];
252
    }
253
254
    public function findAllQuery()
255
    {
256
        $result = $this->getBaseQuery()
257
            ->orderBy('m.id', 'DESC')
258
            ->getQuery();
259
260
        return $result;
261
    }
262
263 2
    public function findByTitleQuery(string $query)
264
    {
265 2
        $query = mb_strtolower($query);
266 2
        $result = $this->getBaseQuery()
267 2
            ->andWhere('LOWER(m.originalTitle) LIKE :title OR LOWER(mt.title) LIKE :title')
268 2
            ->setParameter('title', "%{$query}%")
269 2
            ->getQuery();
270
271 2
        return $result;
272
    }
273
274
    public function findByTitleWithUserRecommendedMovieQuery(string $query, int $userId, int $originalMovieId)
275
    {
276
        $query = mb_strtolower($query);
277
        $result = $this->getBaseQuery()
278
            ->andWhere('LOWER(m.originalTitle) LIKE :title OR LOWER(mt.title) LIKE :title')
279
            ->setParameter('title', "%{$query}%")
280
            ->leftJoin('m.userRecommendedMovie', 'urm', 'WITH', 'urm.user = :user_id AND urm.originalMovie = :movie_id')
281
            ->addSelect('urm')
282
            ->setParameter('user_id', $userId)
283
            ->setParameter('movie_id', $originalMovieId)
284
            ->getQuery();
285
286
        return $result;
287
    }
288
289 9
    public function findOneByIdOrTmdbId(?int $id = null, ?int $tmdb_id = null)
290
    {
291 9
        if ($id === null && $tmdb_id === null) {
292
            throw new \InvalidArgumentException('Movie ID or TMDB ID should be provided');
293
        }
294
295 9
        return $id ? $this->find($id) : $this->findOneBy(['tmdb.id' => $tmdb_id]);
296
    }
297
}
298