1   2   3   4   5   6   7   8   9  10  11  12  13  14  15  16  17  18  19  20  21  22  23  24  25  26  27  28  29  30  31  32  33  34  35  36  37  38  39  40  41  42  43  44  45  46  47  48  49  50  51  52  53  54  55  56  57  58  59  60  61  62  63  64  65  66  67  68  69  70  71  72  73  74  75  76  77  78  79  80  81  82  83  84  85  86  87  88  89  90  91  92  93  94  95  96  97  98  99 100 101 102 103 104 105 106 

<?php

/* --------------------------------------------------------------
   ProductAttributeRepositoryWriter.inc.php 2016-01-08
   Gambio GmbH
   http://www.gambio.de
   Copyright (c) 2015 Gambio GmbH
   Released under the GNU General Public License (Version 2)
   [http://www.gnu.org/licenses/gpl-2.0.html]
   --------------------------------------------------------------
*/

/**
 * Class ProductAttributeRepositoryWriter
 *
 * @category   System
 * @package    ProductModule
 * @subpackage Writer
 */
class ProductAttributeRepositoryWriter implements ProductAttributeRepositoryWriterInterface
{
    /**
     * @var CI_DB_query_builder
     */
    protected $db;

    /**
     * @var string
     */
    protected $tableName = 'products_attributes';


    /**
     * Initialize the product attribute repository writer.
     *
     * @param CI_DB_query_builder $db
     */
    public function __construct(CI_DB_query_builder $db)
    {
        $this->db = $db;
    }


    /**
     * Adds a product attribute entity to a product by the given product id.
     *
     * @param IdType                    $productId         Id of product entity which should belongs to the added
     *                                                     attributes.
     * @param ProductAttributeInterface $productAttribute  Product attribute entity to add to the product.
     *
     * @return int Id of the stored product attribute.
     */
    public function insertIntoProduct(IdType $productId, ProductAttributeInterface $productAttribute)
    {
        $dataArray = array(
            'products_id'           => $productId->asInt(),
            'options_id'            => $productAttribute->getOptionId(),
            'options_values_id'     => $productAttribute->getOptionValueId(),
            'options_values_price'  => $productAttribute->getPrice(),
            'price_prefix'          => $productAttribute->getPriceType(),
            'attributes_model'      => $productAttribute->getAttributeModel(),
            'attributes_stock'      => $productAttribute->getStock(),
            'options_values_weight' => $productAttribute->getWeight(),
            'weight_prefix'         => $productAttribute->getWeightType(),
            'sortorder'             => $productAttribute->getSortOrder(),
            'products_vpe_id'       => $productAttribute->getVpeId(),
            'gm_vpe_value'          => $productAttribute->getVpeValue(),
            'gm_ean'                => $productAttribute->getAttributeEan(),
        );

        $this->db->insert($this->tableName, $dataArray);

        return $this->db->insert_id();
    }


    /**
     * Updates a product attribute entity.
     *
     * @param StoredProductAttributeInterface $productAttribute Product attribute entity to update.
     *
     * @return ProductAttributeRepositoryWriter|$this Same instance for chained method calls.
     */
    public function update(StoredProductAttributeInterface $productAttribute)
    {
        $dataArray = array(
            'options_id'            => $productAttribute->getOptionId(),
            'options_values_id'     => $productAttribute->getOptionValueId(),
            'options_values_price'  => $productAttribute->getPrice(),
            'price_prefix'          => $productAttribute->getPriceType(),
            'attributes_model'      => $productAttribute->getAttributeModel(),
            'attributes_stock'      => $productAttribute->getStock(),
            'options_values_weight' => $productAttribute->getWeight(),
            'weight_prefix'         => $productAttribute->getWeightType(),
            'sortorder'             => $productAttribute->getSortOrder(),
            'products_vpe_id'       => $productAttribute->getVpeId(),
            'gm_vpe_value'          => $productAttribute->getVpeValue(),
            'gm_ean'                => $productAttribute->getAttributeEan(),
        );

        $this->db->update($this->tableName, $dataArray,
                          array('products_attributes_id' => $productAttribute->getAttributeId()));

        return $this;
    }
}