芝麻web文件管理V1.00
编辑当前文件:/home/mgatv524/public_html/avenida/lib/Factory/UserFactory.php
. */ namespace Xibo\Factory; use Xibo\Entity\User; use Xibo\Exception\NotFoundException; use Xibo\Service\ConfigServiceInterface; use Xibo\Service\LogServiceInterface; use Xibo\Service\SanitizerServiceInterface; use Xibo\Storage\StorageServiceInterface; /** * Class UserFactory * * @package Xibo\Factory */ class UserFactory extends BaseFactory { /** * @var ConfigServiceInterface */ private $configService; /** * @var PermissionFactory */ private $permissionFactory; /** * @var UserOptionFactory */ private $userOptionFactory; /** @var ApplicationScopeFactory */ private $applicationScopeFactory; /** * Construct a factory * @param StorageServiceInterface $store * @param LogServiceInterface $log * @param SanitizerServiceInterface $sanitizerService * @param ConfigServiceInterface $configService * @param PermissionFactory $permissionFactory * @param UserOptionFactory $userOptionFactory * @param ApplicationScopeFactory $applicationScopeFactory */ public function __construct($store, $log, $sanitizerService, $configService, $permissionFactory, $userOptionFactory, $applicationScopeFactory) { $this->setCommonDependencies($store, $log, $sanitizerService); $this->configService = $configService; $this->permissionFactory = $permissionFactory; $this->userOptionFactory = $userOptionFactory; $this->applicationScopeFactory = $applicationScopeFactory; } /** * Create a user * @return User */ public function create() { return new User($this->getStore(), $this->getLog(), $this->configService, $this, $this->permissionFactory, $this->userOptionFactory, $this->applicationScopeFactory ); } /** * Get User by ID * @param int $userId * @return User * @throws NotFoundException if the user cannot be found */ public function getById($userId) { $users = $this->query(null, array('disableUserCheck' => 1, 'userId' => $userId)); if (count($users) <= 0) throw new NotFoundException(__('User not found')); return $users[0]; } /** * Load by client Id * @param string $clientId * @throws NotFoundException */ public function loadByClientId($clientId) { $users = $this->query(null, array('disableUserCheck' => 1, 'clientId' => $clientId)); if (count($users) <= 0) throw new NotFoundException(sprintf('User not found')); return $users[0]; } /** * Get User by Name * @param string $userName * @return User * @throws NotFoundException if the user cannot be found */ public function getByName($userName) { $users = $this->query(null, array('disableUserCheck' => 1, 'exactUserName' => $userName)); if (count($users) <= 0) throw new NotFoundException(__('User not found')); return $users[0]; } /** * Get by email * @param string $email * @return User * @throws NotFoundException if the user cannot be found */ public function getByEmail($email) { $users = $this->query(null, array('disableUserCheck' => 1, 'email' => $email)); if (count($users) <= 0) throw new NotFoundException(__('User not found')); return $users[0]; } /** * Get by groupId * @param int $groupId * @return array[User] */ public function getByGroupId($groupId) { return $this->query(null, array('disableUserCheck' => 1, 'groupIds' => [$groupId])); } /** * Get Super Admins * @return User[] */ public function getSuperAdmins() { return $this->query(null, array('disableUserCheck' => 1, 'userTypeId' => 1)); } /** * Get system user * @return User */ public function getSystemUser() { $user = $this->create(); $user->userId = 0; $user->userName = 'system'; $user->userTypeId = 1; $user->email = $this->configService->GetSetting('mail_to'); return $user; } /** * Query for users * @param array[mixed] $sortOrder * @param array[mixed] $filterBy * @return array[User] */ public function query($sortOrder = array(), $filterBy = array()) { $entries = array(); // Default sort order if (count($sortOrder) <= 0) $sortOrder = array('userName'); $params = array(); $select = ' SELECT `user`.userId, userName, userTypeId, email, lastAccessed, newUserWizard, retired, CSPRNG, UserPassword AS password, group.groupId, group.group '; if (DBVERSION >= 120) { $select .= ' , `pages`.pageId AS homePageId, `pages`.title AS homePage '; } if (DBVERSION >= 121) { $select .= ' , `user`.firstName, `user`.lastName, `user`.phone, `user`.ref1, `user`.ref2, `user`.ref3, `user`.ref4, `user`.ref5 '; } if (DBVERSION >= 88) { $select .= ' , IFNULL(group.libraryQuota, 0) AS libraryQuota '; } if (DBVERSION >= 124) { $select .= ' , `group`.isSystemNotification '; } if (DBVERSION >= 134) { $select .= ' , `group`.isDisplayNotification '; } $body = ' FROM `user` INNER JOIN lkusergroup ON lkusergroup.userId = user.userId INNER JOIN `group` ON `group`.groupId = lkusergroup.groupId AND isUserSpecific = 1 '; if (DBVERSION >= 120) { $body .= ' LEFT OUTER JOIN `pages` ON pages.pageId = `user`.homePageId '; } $body .= ' WHERE 1 = 1 '; if ($this->getSanitizer()->getCheckbox('disableUserCheck', 0, $filterBy) == 0) { // Normal users can only see themselves if ($this->getUser()->userTypeId == 3) { $filterBy['userId'] = $this->getUser()->userId; } // Group admins can only see users from their groups. else if ($this->getUser()->userTypeId == 2) { $body .= ' AND user.userId IN ( SELECT `otherUserLinks`.userId FROM `lkusergroup` INNER JOIN `group` ON `group`.groupId = `lkusergroup`.groupId AND `group`.isUserSpecific = 0 INNER JOIN `lkusergroup` `otherUserLinks` ON `otherUserLinks`.groupId = `group`.groupId WHERE `lkusergroup`.userId = :currentUserId ) '; $params['currentUserId'] = $this->getUser()->userId; } } if ($this->getSanitizer()->getInt('notUserId', $filterBy) !== null) { $body .= ' AND user.userId <> :notUserId '; $params['notUserId'] = $this->getSanitizer()->getInt('notUserId', $filterBy); } // User Id Provided? if ($this->getSanitizer()->getInt('userId', $filterBy) !== null) { $body .= " AND user.userId = :userId "; $params['userId'] = $this->getSanitizer()->getInt('userId', $filterBy); } // Groups Provided $groups = $this->getSanitizer()->getParam('groupIds', $filterBy); if (count($groups) > 0) { $body .= ' AND user.userId IN (SELECT userId FROM `lkusergroup` WHERE groupId IN (' . implode($groups, ',') . ')) '; } // User Type Provided if ($this->getSanitizer()->getInt('userTypeId', $filterBy) !== null) { $body .= " AND user.userTypeId = :userTypeId "; $params['userTypeId'] = $this->getSanitizer()->getInt('userTypeId', $filterBy); } // User Name Provided if ($this->getSanitizer()->getString('exactUserName', $filterBy) != null) { $body .= " AND user.userName = :exactUserName "; $params['exactUserName'] = $this->getSanitizer()->getString('exactUserName', $filterBy); } if ($this->getSanitizer()->getString('userName', $filterBy) != null) { // Convert into commas foreach (explode(',', $this->getSanitizer()->getString('userName', $filterBy)) as $term) { if (empty(trim($term))) continue; // convert into a space delimited array $names = explode(' ', $term); $i = 0; foreach ($names as $searchName) { $i++; // Not like, or like? if (substr($searchName, 0, 1) == '-') { $body .= " AND `user`.userName NOT RLIKE (:userName$i) "; $params['userName' . $i] = ltrim(($searchName), '-'); } else { $body .= " AND `user`.userName RLIKE (:userName$i) "; $params['userName' . $i] = $searchName; } } } } // Email Provided if ($this->getSanitizer()->getString('email', $filterBy) != null) { $body .= " AND user.email = :email "; $params['email'] = $this->getSanitizer()->getString('email', $filterBy); } // Retired users? if ($this->getSanitizer()->getInt('retired', $filterBy) !== null) { $body .= " AND user.retired = :retired "; $params['retired'] = $this->getSanitizer()->getInt('retired', $filterBy); } if ($this->getSanitizer()->getString('clientId', $filterBy) != null) { $body .= ' AND user.userId = (SELECT userId FROM `oauth_clients` WHERE id = :clientId) '; $params['clientId'] = $this->getSanitizer()->getString('clientId', $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->create()->hydrate($row, ['intProperties' => ['libraryQuota']]); } // Paging if ($limit != '' && count($entries) > 0) { $results = $this->getStore()->select('SELECT COUNT(*) AS total ' . $body, $params); $this->_countLast = intval($results[0]['total']); } return $entries; } }