vendor/pimcore/pimcore/bundles/EcommerceFrameworkBundle/PricingManager/Rule/Dao.php line 63

Open in your IDE?
  1. <?php
  3. /**
  4.  * Pimcore
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Commercial License (PCL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PCL
  14.  */
  16. namespace Pimcore\Bundle\EcommerceFrameworkBundle\PricingManager\Rule;
  18. use Pimcore\Bundle\EcommerceFrameworkBundle\PricingManager\Rule;
  19. use Pimcore\Model\Dao\AbstractDao;
  20. use Pimcore\Model\Exception\NotFoundException;
  22. /**
  23.  * @internal
  24.  *
  25.  * @property Rule $model
  26.  */
  27. class Dao extends AbstractDao
  28. {
  29.     const TABLE_NAME = 'ecommerceframework_pricing_rule';
  31.     /**
  32.      * Contains all valid columns in the database table
  33.      *
  34.      * @var array
  35.      */
  36.     protected $validColumns = [];
  38.     /**
  39.      * @var array
  40.      */
  41.     protected $fieldsToSave = ['name', 'label', 'description', 'behavior', 'active', 'prio', 'condition', 'actions'];
  43.     /**
  44.      * @var array
  45.      */
  46.     protected $localizedFields = ['label', 'description'];
  48.     /**
  49.      * Get the valid columns from the database
  50.      *
  51.      * @return void
  52.      */
  53.     public function init()
  54.     {
  55.         $this->validColumns = $this->getValidTableColumns(self::TABLE_NAME);
  56.     }
  58.     /**
  59.      * @param int $id
  60.      *
  61.      * @throws NotFoundException
  62.      */
  63.     public function getById($id)
  64.     {
  65.         $classRaw = $this->db->fetchAssociative('SELECT * FROM ' . self::TABLE_NAME . ' WHERE id=' . $this->db->quote($id));
  66.         if (empty($classRaw)) {
  67.             throw new NotFoundException('pricing rule ' . $id . ' not found.');
  68.         }
  69.         $this->assignVariablesToModel($classRaw);
  70.     }
  72.     /**
  73.      * Create a new record for the object in database
  74.      */
  75.     public function create()
  76.     {
  77.         $this->db->insert(self::TABLE_NAME, []);
  78.         $this->model->setId((int) $this->db->lastInsertId());
  79.     }
  81.     /**
  82.      * Save object to database
  83.      *
  84.      * @return void
  85.      */
  86.     public function save()
  87.     {
  88.         if (!$this->model->getId()) {
  89.             $this->create();
  90.         }
  92.         $this->update();
  93.     }
  95.     /**
  96.      * @return void
  97.      */
  98.     public function update()
  99.     {
  100.         $data = [];
  102.         foreach ($this->fieldsToSave as $field) {
  103.             if (in_array($field, $this->validColumns)) {
  104.                 $getter = 'get' . ucfirst($field);
  106.                 if (in_array($field, $this->localizedFields)) {
  107.                     // handle localized Fields
  108.                     $localizedValues = [];
  109.                     foreach (\Pimcore\Tool::getValidLanguages() as $lang) {
  110.                         $localizedValues[$lang] = $value = $this->model->$getter($lang);
  111.                     }
  112.                     $value = $localizedValues;
  113.                 } else {
  114.                     // normal case
  115.                     $value = $this->model->$getter();
  116.                 }
  118.                 if (is_array($value) || is_object($value)) {
  119.                     $value = serialize($value);
  120.                 } elseif (is_bool($value)) {
  121.                     $value = (int)$value;
  122.                 }
  123.                 $data[$field] = $value;
  124.             }
  125.         }
  127.         $this->db->update(self::TABLE_NAME, $data, ['id' => $this->model->getId()]);
  128.     }
  130.     /**
  131.      * Deletes object from database
  132.      *
  133.      * @return void
  134.      */
  135.     public function delete()
  136.     {
  137.         $this->db->delete(self::TABLE_NAME, ['id' => $this->model->getId()]);
  138.     }
  140.     /**
  141.      * @param array $fields
  142.      */
  143.     public function setFieldsToSave(array $fields)
  144.     {
  145.         $this->fieldsToSave = $fields;
  146.     }
  147. }