File: /home/posscale/subdomains/xibo/lib/Factory/PlaylistFactory.php
<?php
/*
* Xibo - Digital Signage - http://www.xibo.org.uk
* Copyright (C) 2015 Spring Signage Ltd
*
* This file (PlaylistFactory.php) is part of Xibo.
*
* Xibo is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* any later version.
*
* Xibo is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with Xibo. If not, see <http://www.gnu.org/licenses/>.
*/
namespace Xibo\Factory;
use Xibo\Entity\Playlist;
use Xibo\Exception\NotFoundException;
use Xibo\Service\DateServiceInterface;
use Xibo\Service\LogServiceInterface;
use Xibo\Service\SanitizerServiceInterface;
use Xibo\Storage\StorageServiceInterface;
/**
* Class PlaylistFactory
* @package Xibo\Factory
*/
class PlaylistFactory extends BaseFactory
{
/**
* @var DateServiceInterface
*/
public $dateService;
/**
* @var PermissionFactory
*/
private $permissionFactory;
/**
* @var WidgetFactory
*/
private $widgetFactory;
/**
* Construct a factory
* @param StorageServiceInterface $store
* @param LogServiceInterface $log
* @param SanitizerServiceInterface $sanitizerService
* @param DateServiceInterface $date
* @param PermissionFactory $permissionFactory
* @param WidgetFactory $widgetFactory
*/
public function __construct($store, $log, $sanitizerService, $date, $permissionFactory, $widgetFactory)
{
$this->setCommonDependencies($store, $log, $sanitizerService);
$this->dateService = $date;
$this->permissionFactory = $permissionFactory;
$this->widgetFactory = $widgetFactory;
}
/**
* @return Playlist
*/
public function createEmpty()
{
return new Playlist($this->getStore(), $this->getLog(), $this->dateService, $this->permissionFactory, $this->widgetFactory);
}
/**
* Load Playlists by
* @param $regionId
* @return array[Playlist]
* @throws NotFoundException
*/
public function getByRegionId($regionId)
{
return $this->query(null, array('disableUserCheck' => 1, 'regionId' => $regionId));
}
/**
* Get by Id
* @param int $playlistId
* @return Playlist
* @throws NotFoundException
*/
public function getById($playlistId)
{
$playlists = $this->query(null, array('disableUserCheck' => 1, 'playlistId' => $playlistId));
if (count($playlists) <= 0)
throw new NotFoundException(__('Cannot find playlist'));
return $playlists[0];
}
/**
* Create a Playlist
* @param string $name
* @param int $ownerId
* @return Playlist
*/
public function create($name, $ownerId)
{
$playlist = $this->createEmpty();
$playlist->name = $name;
$playlist->ownerId = $ownerId;
return $playlist;
}
public function query($sortOrder = null, $filterBy = [])
{
$entries = array();
$params = array();
$select = 'SELECT playlist.* ';
if ($this->getSanitizer()->getInt('regionId', $filterBy) !== null) {
$select .= ' , lkregionplaylist.displayOrder ';
}
$body = ' FROM `playlist` ';
if ($this->getSanitizer()->getInt('regionId', $filterBy) !== null) {
$body .= '
INNER JOIN `lkregionplaylist`
ON lkregionplaylist.playlistId = playlist.playlistId
AND lkregionplaylist.regionId = :regionId
';
$params['regionId'] = $this->getSanitizer()->getInt('regionId', $filterBy);
}
$body .= ' WHERE 1 = 1 ';
if ($this->getSanitizer()->getInt('playlistId', $filterBy) != 0) {
$body .= ' AND playlistId = :playlistId ';
$params['playlistId'] = $this->getSanitizer()->getInt('playlistId', $filterBy);
}
// Sorting?
$order = '';
if (is_array($sortOrder))
$order .= 'ORDER BY ' . implode(',', $sortOrder);
$limit = '';
// Paging
if ($filterBy !== null && $this->getSanitizer()->getInt('start', $filterBy) !== null && $this->getSanitizer()->getInt('length', $filterBy) !== null) {
$limit = ' LIMIT ' . intval($this->getSanitizer()->getInt('start', $filterBy), 0) . ', ' . $this->getSanitizer()->getInt('length', 10, $filterBy);
}
$sql = $select . $body . $order . $limit;
foreach ($this->getStore()->select($sql, $params) as $row) {
$entries[] = $this->createEmpty()->hydrate($row);
}
// Paging
if ($limit != '' && count($entries) > 0) {
$results = $this->getStore()->select('SELECT COUNT(*) AS total ' . $body, $params);
$this->_countLast = intval($results[0]['total']);
}
return $entries;
}
}