芝麻web文件管理V1.00
编辑当前文件:/home/mgatv524/cms.mgaplay.com.br/lib/Factory/ActionFactory.php
. */ namespace Xibo\Factory; use Xibo\Entity\Action; use Xibo\Entity\User; use Xibo\Support\Exception\NotFoundException; /** * Class ActionFactory * @package Xibo\Factory */ class ActionFactory extends BaseFactory { /** * Construct a factory * @param User $user * @param UserFactory $userFactory */ public function __construct($user, $userFactory) { $this->setAclDependencies($user, $userFactory); } /** * Create Empty * @return Action */ public function createEmpty() { return new Action( $this->getStore(), $this->getLog(), $this->getDispatcher() ); } /** * Create a new action * @param string $triggerType * @param string|null $triggerCode * @param string $actionType * @param string $source * @param integer $sourceId * @param string $target * @param integer|null $targetId * @param integer|null $widgetId * @param string|null $layoutCode * @return Action */ public function create(string $triggerType, $triggerCode, string $actionType, string $source, int $sourceId, string $target, $targetId, $widgetId, $layoutCode) { $action = $this->createEmpty(); $action->ownerId = $this->getUser()->userId; $action->triggerType = $triggerType; $action->triggerCode = $triggerCode; $action->actionType = $actionType; $action->source = $source; $action->sourceId = $sourceId; $action->target = $target; $action->targetId = $targetId; $action->widgetId = $widgetId; $action->layoutCode = $layoutCode; return $action; } /** * @param int $actionId * @return Action * @throws NotFoundException */ public function getById(int $actionId) { $this->getLog()->debug('ActionFactory getById ' . $actionId); $actions = $this->query(null, ['disableUserCheck' => 1, 'actionId' => $actionId]); if (count($actions) <= 0) { $this->getLog()->debug('Action not found with ID ' . $actionId); throw new NotFoundException(__('Action not found')); } // Set our layout return $actions[0]; } /** * @param string $source * @param int $sourceId * @return Action[] */ public function getBySourceAndSourceId(string $source, int $sourceId) { $actions = $this->query(null, ['disableUserCheck' => 1, 'source' => $source, 'sourceId' => $sourceId]); return $actions; } /** * @param int $ownerId * @return Action[] */ public function getByOwnerId(int $ownerId) { return $this->query(null, ['disableUserCheck' => 1, 'ownerId' => $ownerId]); } /** * @param int $targetId * @return Action[] * @throws NotFoundException */ public function getByTargetId(int $targetId) { $actions = $this->query(null, ['disableUserCheck' => 1, 'targetId' => $targetId]); if (count($actions) <= 0) { $this->getLog()->debug('Unable to find target ID ' . $targetId); throw new NotFoundException(__('not found')); } return $actions; } /** * Check if Touch Action with provided source, sourceId and actionId already exist * * @param string $source * @param int $sourceId * @param string $triggerType * @param null $actionId * @return bool */ public function checkIfActionExist(string $source, int $sourceId, string $triggerType, $actionId = null) { // we can have multiple webhook Actions if ($triggerType == 'webhook') { return false; } // exclude our Action ID (for edit) $notActionId = ($actionId == null) ? 0 : $actionId; $actions = $this->query(null, ['source' => $source, 'sourceId' => $sourceId, 'triggerType' => $triggerType, 'notActionId' => $notActionId]); return ( count($actions) >= 1 ) ? true : false; } /** * @param null $sortOrder * @param array $filterBy * @return Action[] */ public function query($sortOrder = null, $filterBy = []) { if ($sortOrder === null) { $sortOrder = ['actionId DESC']; } $sanitizedFilter = $this->getSanitizer($filterBy); $params = []; $entries = []; $select = ' SELECT action.actionId, action.ownerId, action.triggerType, action.triggerCode, action.actionType, action.source, action.sourceId, action.target, action.targetId, action.widgetId, action.layoutCode '; $body = ' FROM action WHERE 1 = 1 '; if ($sanitizedFilter->getInt('actionId') !== null) { $body .= ' AND `action`.actionId = :actionId '; $params['actionId'] = $sanitizedFilter->getInt('actionId'); } if ($sanitizedFilter->getInt('ownerId') !== null) { $body .= ' AND `action`.ownerId = :ownerId '; $params['ownerId'] = $sanitizedFilter->getInt('ownerId'); } if ($sanitizedFilter->getString('triggerType') !== null) { $body .= ' AND `action`.triggerType = :triggerType '; $params['triggerType'] = $sanitizedFilter->getString('triggerType'); } if ($sanitizedFilter->getString('triggerCode') != null) { $body .= ' AND `action`.triggerCode = :triggerCode '; $params['triggerCode'] = $sanitizedFilter->getString('triggerCode'); } if ($sanitizedFilter->getString('actionType') != null) { $body .= ' AND `action`.actionType = :actionType '; $params['actionType'] = $sanitizedFilter->getInt('actionType'); } if ($sanitizedFilter->getString('source') != null) { $body .= ' AND `action`.source = :source '; $params['source'] = $sanitizedFilter->getString('source'); } if ($sanitizedFilter->getInt('sourceId') != null) { $body .= ' AND `action`.sourceId = :sourceId '; $params['sourceId'] = $sanitizedFilter->getInt('sourceId'); } if ($sanitizedFilter->getString('target') != null) { $body .= ' AND `action`.target = :target '; $params['target'] = $sanitizedFilter->getString('target'); } if ($sanitizedFilter->getInt('targetId') != null) { $body .= ' AND `action`.targetId = :targetId '; $params['targetId'] = $sanitizedFilter->getInt('targetId'); } if ($sanitizedFilter->getInt('widgetId') !== null) { $body .= ' AND `action`.widgetId = :widgetId '; $params['objectId'] = $sanitizedFilter->getInt('widgetId'); } if ($sanitizedFilter->getString('layoutCode') !== null) { $body .= ' AND `action`.layoutCode = :layoutCode '; $params['objectId'] = $sanitizedFilter->getString('layoutCode'); } if ($sanitizedFilter->getInt('notActionId') !== null) { $body .= ' AND `action`.actionId <> :notActionId '; $params['notActionId'] = $sanitizedFilter->getInt('notActionId'); } // Sorting? $order = ''; if (is_array($sortOrder)) { $order .= 'ORDER BY ' . implode(',', $sortOrder); } $limit = ''; // Paging if ($filterBy !== null && $sanitizedFilter->getInt('start') !== null && $sanitizedFilter->getInt('length') !== null) { $limit = ' LIMIT ' . $sanitizedFilter->getInt('start', ['default' => 0]) . ', ' . $sanitizedFilter->getInt('length', ['default' => 10]); } $sql = $select . $body . $order . $limit; foreach ($this->getStore()->select($sql, $params) as $row) { $action = $this->createEmpty()->hydrate($row); $action->targetId = ($action->targetId === 0) ? null : $action->targetId; $action->widgetId = ($action->widgetId === 0) ? null : $action->widgetId; $action->layoutCode = ($action->widgetId === '') ? null : $action->layoutCode; $entries[] = $action; } // Paging if ($limit != '' && count($entries) > 0) { $results = $this->getStore()->select('SELECT COUNT(*) AS total ' . $body, $params); $this->_countLast = intval($results[0]['total']); } return $entries; } }