. */ namespace SP\Repositories\CustomField; use RuntimeException; use SP\Core\Exceptions\ConstraintException; use SP\Core\Exceptions\QueryException; use SP\Core\Exceptions\SPException; use SP\DataModel\CustomFieldDefinitionData; use SP\DataModel\ItemSearchData; use SP\Repositories\NoSuchItemException; use SP\Repositories\Repository; use SP\Repositories\RepositoryItemInterface; use SP\Repositories\RepositoryItemTrait; use SP\Storage\Database\QueryData; use SP\Storage\Database\QueryResult; /** * Class CustomFieldDefRepository * * @package SP\Repositories\CustomField */ final class CustomFieldDefRepository extends Repository implements RepositoryItemInterface { use RepositoryItemTrait; /** * @var CustomFieldDefCollection */ private $customFieldDefCollection; /** * Creates an item * * @param CustomFieldDefinitionData $itemData * * @return mixed * @throws ConstraintException * @throws QueryException */ public function create($itemData) { $query = /** @lang SQL */ 'INSERT INTO CustomFieldDefinition SET `name` = ?, moduleId = ?, required = ?, `help` = ?, showInList = ?, typeId = ?, isEncrypted = ?'; $queryData = new QueryData(); $queryData->setQuery($query); $queryData->setParams([ $itemData->getName(), $itemData->getModuleId(), $itemData->getRequired(), $itemData->getHelp(), $itemData->getShowInList(), $itemData->getTypeId(), $itemData->getisEncrypted() ]); $queryData->setOnErrorMessage(__u('Error while creating the custom field')); return $this->db->doQuery($queryData)->getLastId(); } /** * Updates an item * * @param CustomFieldDefinitionData $itemData * * @return int * @throws ConstraintException * @throws QueryException */ public function update($itemData) { if ($this->customFieldDefCollection->exists($itemData->getId())) { $this->customFieldDefCollection->remove($itemData->getId()); } $query = /** @lang SQL */ 'UPDATE CustomFieldDefinition SET `name` = ?, moduleId = ?, required = ?, `help` = ?, showInList = ?, typeId = ?, isEncrypted = ? WHERE id = ? LIMIT 1'; $queryData = new QueryData(); $queryData->setQuery($query); $queryData->setParams([ $itemData->getName(), $itemData->getModuleId(), $itemData->getRequired(), $itemData->getHelp(), $itemData->getShowInList(), $itemData->getTypeId(), $itemData->getisEncrypted(), $itemData->getId() ]); $queryData->setOnErrorMessage(__u('Error while updating the custom field')); return $this->db->doQuery($queryData)->getAffectedNumRows(); } /** * Returns the item for given id * * @param int $id * * @return CustomFieldDefinitionData * @throws ConstraintException * @throws QueryException * @throws NoSuchItemException */ public function getById($id) { if ($this->customFieldDefCollection->exists($id)) { return $this->customFieldDefCollection->get($id); } $query = /** @lang SQL */ 'SELECT id, `name`, moduleId, required, `help`, showInList, typeId, isEncrypted FROM CustomFieldDefinition WHERE id = ? LIMIT 1'; $queryData = new QueryData(); $queryData->setMapClassName(CustomFieldDefinitionData::class); $queryData->setQuery($query); $queryData->addParam($id); $result = $this->db->doSelect($queryData); if ($result->getNumRows() === 0) { throw new NoSuchItemException(__u('Custom field not found')); } $this->customFieldDefCollection->set($id, $result->getData()); return $result->getData(); } /** * Returns all the items * * @return QueryResult * @throws ConstraintException * @throws QueryException */ public function getAll() { $query = /** @lang SQL */ 'SELECT id, `name`, moduleId, required, `help`, showInList, isEncrypted, typeId FROM CustomFieldDefinition ORDER BY moduleId'; $queryData = new QueryData(); $queryData->setMapClassName(CustomFieldDefinitionData::class); $queryData->setQuery($query); return $this->db->doSelect($queryData); } /** * Returns all the items for given ids * * @param array $ids * * @return QueryResult * @throws ConstraintException * @throws QueryException */ public function getByIdBatch(array $ids) { if (empty($ids)) { return new QueryResult(); } $query = /** @lang SQL */ 'SELECT id, `name`, moduleId, required, `help`, showInList, typeId, isEncrypted FROM CustomFieldDefinition WHERE id IN (' . $this->getParamsFromArray($ids) . ') ORDER BY id'; $queryData = new QueryData(); $queryData->setMapClassName(CustomFieldDefinitionData::class); $queryData->setQuery($query); $queryData->setParams($ids); return $this->db->doSelect($queryData); } /** * Deletes all the items for given ids * * @param array $ids * * @return int * @throws SPException * @throws ConstraintException * @throws QueryException */ public function deleteByIdBatch(array $ids) { if (empty($ids)) { return 0; } $query = /** @lang SQL */ 'DELETE FROM CustomFieldDefinition WHERE id IN (' . $this->getParamsFromArray($ids) . ')'; $queryData = new QueryData(); $queryData->setQuery($query); $queryData->setParams($ids); $queryData->setOnErrorMessage(__u('Error while removing the custom fields')); return $this->db->doQuery($queryData)->getAffectedNumRows(); } /** * Deletes an item * * @param $id * * @return int * @throws ConstraintException * @throws QueryException * @throws SPException */ public function delete($id) { $queryData = new QueryData(); $queryData->setQuery('DELETE FROM CustomFieldDefinition WHERE id = ? LIMIT 1'); $queryData->addParam($id); $queryData->setOnErrorMessage(__u('Error while removing the custom field')); return $this->db->doQuery($queryData)->getAffectedNumRows(); } /** * Checks whether the item is in use or not * * @param $id int */ public function checkInUse($id) { throw new RuntimeException('Not implemented'); } /** * Checks whether the item is duplicated on updating * * @param mixed $itemData */ public function checkDuplicatedOnUpdate($itemData) { throw new RuntimeException('Not implemented'); } /** * Checks whether the item is duplicated on adding * * @param mixed $itemData */ public function checkDuplicatedOnAdd($itemData) { throw new RuntimeException('Not implemented'); } /** * Searches for items by a given filter * * @param ItemSearchData $itemSearchData * * @return QueryResult * @throws ConstraintException * @throws QueryException */ public function search(ItemSearchData $itemSearchData) { $queryData = new QueryData(); $queryData->setMapClassName(CustomFieldDefinitionData::class); $queryData->setSelect('CFD.id, CFD.name, CFD.moduleId, CFD.required, CFD.help, CFD.showInList, CFD.typeId, CFD.isEncrypted, CFT.name AS typeName'); $queryData->setFrom('CustomFieldDefinition CFD INNER JOIN CustomFieldType CFT ON CFD.typeId = CFT.id'); $queryData->setOrder('CFD.moduleId'); if ($itemSearchData->getSeachString() !== '') { $queryData->setWhere('CFD.name LIKE ? OR CFT.name LIKE ?'); $search = '%' . $itemSearchData->getSeachString() . '%'; $queryData->addParams([$search, $search]); } $queryData->setLimit( '?,?', [$itemSearchData->getLimitStart(), $itemSearchData->getLimitCount()] ); return $this->db->doSelect($queryData, true); } /** * Resets the custom fields collection cache */ public function resetCollection() { $this->customFieldDefCollection->clear(); } protected function initialize() { $this->customFieldDefCollection = new CustomFieldDefCollection(); } }