1 <?php
  2 
  3 /* --------------------------------------------------------------
  4    OrderRepositoryWriter.inc.php 2016-01-20
  5    Gambio GmbH
  6    http://www.gambio.de
  7    Copyright (c) 2016 Gambio GmbH
  8    Released under the GNU General Public License (Version 2)
  9    [http://www.gnu.org/licenses/gpl-2.0.html]
 10    --------------------------------------------------------------
 11 */
 12 
 13 MainFactory::load_class('OrderRepositoryWriterInterface');
 14 
 15 /**
 16  * Class OrderRepositoryWriter
 17  *
 18  * @category   System
 19  * @package    Order
 20  * @subpackage Repositories
 21  */
 22 class OrderRepositoryWriter implements OrderRepositoryWriterInterface
 23 {
 24     /**
 25      * Query builder.
 26      * @var CI_DB_query_builder
 27      */
 28     protected $db;
 29     
 30     
 31     /**
 32      * OrderRepositoryWriter constructor
 33      *
 34      * @param CI_DB_query_builder $db Query builder.
 35      */
 36     public function __construct(CI_DB_query_builder $db)
 37     {
 38         $this->db = $db;
 39     }
 40     
 41     
 42     /**
 43      * Inserts a new order to the orders table.
 44      *
 45      * @param OrderInterface $order Order.
 46      *
 47      * @return int ID of inserted order.
 48      */
 49     public function insert(OrderInterface $order)
 50     {
 51         $record = $this->_serializeOrder($order);
 52         
 53         // Insert orders_hash
 54         $record['orders_hash'] = time() + mt_rand();
 55         
 56         $this->db->insert('orders', $record);
 57         
 58         return $this->db->insert_id();
 59     }
 60     
 61     
 62     /**
 63      * Updates an existing order in the orders table.
 64      *
 65      * @param OrderInterface $order Order object.
 66      *
 67      * @return OrderRepositoryWriter Same instance for method chaining.
 68      */
 69     public function update(OrderInterface $order)
 70     {
 71         $record = $this->_serializeOrder($order);
 72         $this->db->update('orders', $record, array('orders_id' => $order->getOrderId()));
 73     }
 74     
 75     
 76     /**
 77      * Converts the order to an associative array that is later used to insert/update
 78      * the values into the database.
 79      *
 80      * @param OrderInterface $order The object to be serialized.
 81      *
 82      * @return array Contains the orders object matched with their respective db columns.
 83      */
 84     protected function _serializeOrder(OrderInterface $order)
 85     {
 86         // Find the correct language directory.
 87         $language = $this->db->get_where('languages', array('code' => strtolower((string)$order->getLanguageCode())))
 88                              ->row_array();
 89         
 90         $record = array(
 91             'customers_id'              => $order->getCustomerId(),
 92             'orders_status'             => $order->getStatusId(),
 93             'customers_cid'             => (string)$order->getCustomerNumber(),
 94             'customers_vat_id'          => (string)$order->getVatIdNumber(),
 95             'customers_status'          => $order->getCustomerStatusInformation()->getStatusId(),
 96             'customers_status_name'     => $order->getCustomerStatusInformation()->getStatusName(),
 97             'customers_status_image'    => $order->getCustomerStatusInformation()->getStatusImage(),
 98             'customers_status_discount' => $order->getCustomerStatusInformation()->getStatusDiscount(),
 99             'account_type'              => (int)$order->getCustomerStatusInformation()->isGuest(),
100             'payment_method'            => $order->getPaymentType()->getTitle(),
101             'payment_class'             => $order->getPaymentType()->getModule(),
102             'shipping_method'           => $order->getShippingType()->getTitle(),
103             'shipping_class'            => $order->getShippingType()->getModule(),
104             'comments'                  => $order->getComment(),
105             'date_purchased'            => $order->getPurchaseDateTime()->format('Y-m-d H:i:s'),
106             'last_modified'             => $order->getLastModifiedDateTime()->format('Y-m-d H:i:s'),
107             'language'                  => (string)$language['directory'],
108             'currency'                  => (string)$order->getCurrencyCode()->getCode(),
109             'currency_value'            => (float)$order->getCurrencyCode()->getCurrencyValue(),
110             'customers_telephone'       => $order->getCustomerTelephone(),
111             'customers_email_address'   => $order->getCustomerEmail()
112         );
113         
114         $customerAddress = $this->_serializeAddressBlock($order->getCustomerAddress(), new StringType('customers'));
115         $deliveryAddress = $this->_serializeAddressBlock($order->getDeliveryAddress(), new StringType('delivery'));
116         $billingAddress  = $this->_serializeAddressBlock($order->getBillingAddress(), new StringType('billing'));
117         
118         $record = array_merge($record, $customerAddress, $deliveryAddress, $billingAddress);
119         
120         return $record;
121     }
122     
123     
124     /**
125      * Serializes address block.
126      *
127      * @param AddressBlockInterface $addressBlock  The object to be serialized.
128      * @param StringType            $prefix        The address prefix can be one of the "delivery", "billing" and
129      *                                             "customers".
130      *
131      * @return array Array with the address data.
132      */
133     protected function _serializeAddressBlock(AddressBlockInterface $addressBlock, StringType $prefix)
134     {
135         $country = $this->db->select('address_format_id')
136                             ->get_where('countries', array('countries_id' => $addressBlock->getCountry()->getId()))
137                             ->row_array();
138         
139         $addressPrefix = $prefix->asString() . '_';
140         
141         $addressBlockArray = array(
142             $addressPrefix . 'name'              => (string)$addressBlock->getFirstname() . ' '
143                                                     . (string)$addressBlock->getLastname(),
144             $addressPrefix . 'firstname'         => (string)$addressBlock->getFirstname(),
145             $addressPrefix . 'lastname'          => (string)$addressBlock->getLastname(),
146             $addressPrefix . 'gender'            => (string)$addressBlock->getGender(),
147             $addressPrefix . 'company'           => (string)$addressBlock->getCompany(),
148             $addressPrefix . 'street_address'    => (string)$addressBlock->getStreet(),
149             $addressPrefix . 'suburb'            => (string)$addressBlock->getSuburb(),
150             $addressPrefix . 'city'              => (string)$addressBlock->getCity(),
151             $addressPrefix . 'postcode'          => (string)$addressBlock->getPostcode(),
152             $addressPrefix . 'state'             => (string)$addressBlock->getCountryZone()->getName(),
153             $addressPrefix . 'country'           => (string)$addressBlock->getCountry()->getName(),
154             $addressPrefix . 'address_format_id' => $country['address_format_id']
155         );
156         
157         if($prefix->asString() !== 'customers')
158         {
159             $addressBlockArray[$addressPrefix . 'country_iso_code_2'] = $addressBlock->getCountry()->getIso2();
160         }
161         
162         return $addressBlockArray;
163     }
164 }

API documentation generated by ApiGen