@@ 232-250 (lines=19) @@ | ||
229 | * |
|
230 | * @return integer |
|
231 | */ |
|
232 | protected function getIdentifyPrevVisitsCount() |
|
233 | { |
|
234 | $em = $this->getEntityManager(); |
|
235 | $queryBuilder = $em |
|
236 | ->getRepository(self::TRACKING_VISIT_ENTITY) |
|
237 | ->createQueryBuilder('entity'); |
|
238 | $queryBuilder |
|
239 | ->select('COUNT (entity.id)') |
|
240 | ->where('entity.identifierDetected = false') |
|
241 | ->andWhere('entity.parsedUID > 0') |
|
242 | ->andWhere('entity.parsingCount < :maxRetries') |
|
243 | ->setParameter('maxRetries', $this->getMaxRetriesCount()); |
|
244 | ||
245 | if (count($this->skipList)) { |
|
246 | $queryBuilder->andWhere('entity.id not in(' . implode(',', $this->skipList) . ')'); |
|
247 | } |
|
248 | ||
249 | return $queryBuilder->getQuery()->getSingleScalarResult(); |
|
250 | } |
|
251 | ||
252 | /** |
|
253 | * Returns count of tracking visit events to be processed. |
|
@@ 257-273 (lines=17) @@ | ||
254 | * |
|
255 | * @return integer |
|
256 | */ |
|
257 | protected function getIdentifyPrevVisitEventsCount() |
|
258 | { |
|
259 | $em = $this->getEntityManager(); |
|
260 | $queryBuilder = $em |
|
261 | ->getRepository(self::TRACKING_VISIT_EVENT_ENTITY) |
|
262 | ->createQueryBuilder('entity'); |
|
263 | $queryBuilder |
|
264 | ->select('COUNT (entity.id)') |
|
265 | ->andWhere('entity.parsingCount < :maxRetries') |
|
266 | ->setParameter('maxRetries', $this->getMaxRetriesCount()); |
|
267 | ||
268 | if (count($this->skipList)) { |
|
269 | $queryBuilder->andWhere('entity.id not in(' . implode(',', $this->skipList) . ')'); |
|
270 | } |
|
271 | ||
272 | return $queryBuilder->getQuery()->getSingleScalarResult(); |
|
273 | } |
|
274 | ||
275 | /** |
|
276 | * Process previous visit events |