1 <?php
  2 /* --------------------------------------------------------------
  3    CustomerWriter.inc.php 2015-02-18 gm
  4    Gambio GmbH
  5    http://www.gambio.de
  6    Copyright (c) 2015 Gambio GmbH
  7    Released under the GNU General Public License (Version 2)
  8    [http://www.gnu.org/licenses/gpl-2.0.html]
  9    --------------------------------------------------------------
 10 */
 11 
 12 MainFactory::load_class('CustomerWriterInterface');
 13 
 14 /**
 15  * Class CustomerWriter
 16  *
 17  * This class is used for writing customer data to the database
 18  *
 19  * @category   System
 20  * @package    Customer
 21  * @implements CustomerWriterInterface
 22  */
 23 class CustomerWriter implements CustomerWriterInterface
 24 {
 25     /**
 26      * Query builder.
 27      * @var CI_DB_query_builder
 28      */
 29     protected $db;
 30     
 31     
 32     /**
 33      * Constructor of the class CustomerWriter.
 34      *
 35      * @param CI_DB_query_builder $dbQueryBuilder Query builder.
 36      */
 37     public function __construct(CI_DB_query_builder $dbQueryBuilder)
 38     {
 39         $this->db = $dbQueryBuilder;
 40     }
 41 
 42 
 43     /**
 44      * Writes customer data.
 45      *
 46      * If customer does not exists it will perform an _insert(), otherwise it will perform an _update().
 47      *
 48      * @param CustomerInterface $customer Customer.
 49      */
 50     public function write(CustomerInterface $customer)
 51     {
 52         if($customer->getId() == null)
 53         {
 54             $this->_insert($customer);
 55         }
 56         else
 57         {
 58             $this->_update($customer);
 59         }
 60     }
 61     
 62 
 63     /**
 64      * Helper method to insert customer data into the database.
 65      *
 66      * @param CustomerInterface $customer Customer.
 67      */
 68     protected function _insert(CustomerInterface $customer)
 69     {
 70         // Insert customer record.
 71         $customerDataArray = array(
 72             'account_type'                 => (int)$customer->isGuest(),
 73             'customers_status'             => (int)$customer->getStatusId(),
 74             'customers_cid'                => (string)$customer->getCustomerNumber(),
 75             'customers_gender'             => (string)$customer->getGender(),
 76             'customers_firstname'          => (string)$customer->getFirstname(),
 77             'customers_lastname'           => (string)$customer->getLastname(),
 78             'customers_email_address'      => (string)$customer->getEmail(),
 79             'customers_password'           => (string)$customer->getPassword(),
 80             'customers_vat_id'             => (string)$customer->getVatNumber(),
 81             'customers_vat_id_status'      => (string)$customer->getVatNumberStatus(),
 82             'customers_dob'                => (string)$customer->getDateOfBirth()->format('Y-m-d'),
 83             'customers_telephone'          => (string)$customer->getTelephoneNumber(),
 84             'customers_fax'                => (string)$customer->getFaxNumber(),
 85             'customers_default_address_id' => (string)$customer->getDefaultAddress()->getId(),
 86             'customers_date_added'         => date('Y-m-d H:i:s')
 87         );
 88         $this->db->insert('customers', $customerDataArray);
 89         $customer->setId(new IdType($this->db->insert_id()));
 90         
 91         // Insert customer info record. 
 92         $customerInfoDataArray = array(
 93             'customers_info_id'                         => (string)$customer->getId(),
 94             'customers_info_date_of_last_logon'         => '0000-00-00',
 95             'customers_info_number_of_logons'           => '0',
 96             'customers_info_date_account_created'       => date('Y-m-d H:i:s'),
 97             'customers_info_date_account_last_modified' => '0000-00-00'
 98         );
 99         $this->db->insert('customers_info', $customerInfoDataArray);
100     }
101     
102 
103     /**
104      * Helper method to update customer data in the database.
105      *
106      * @param CustomerInterface $customer Customer.
107      *
108      * TODO Use wrapper function getDefaultAddressId() instead of getDefaultAddress()->getId()
109      */
110     protected function _update(CustomerInterface $customer)
111     {
112         $customerId = $customer->getId();
113         
114         // Update customer record. 
115         $customerDataArray = array(
116             'account_type'                 => (int)$customer->isGuest(),
117             'customers_status'             => (int)$customer->getStatusId(),
118             'customers_cid'                => (string)$customer->getCustomerNumber(),
119             'customers_gender'             => (string)$customer->getGender(),
120             'customers_firstname'          => (string)$customer->getFirstname(),
121             'customers_lastname'           => (string)$customer->getLastname(),
122             'customers_email_address'      => (string)$customer->getEmail(),
123             'customers_password'           => (string)$customer->getPassword(),
124             'customers_vat_id'             => (string)$customer->getVatNumber(),
125             'customers_vat_id_status'      => (string)$customer->getVatNumberStatus(),
126             'customers_dob'                => (string)$customer->getDateOfBirth()->format('Y-m-d'),
127             'customers_telephone'          => (string)$customer->getTelephoneNumber(),
128             'customers_fax'                => (string)$customer->getFaxNumber(),
129             'customers_default_address_id' => (string)$customer->getDefaultAddress()->getId(),
130             'customers_last_modified'      => date('Y-m-d H:i:s')
131         );
132 
133         $this->db->update('customers', $customerDataArray, array('customers_id' => $customerId));
134         
135         // Update customer info record.
136         $customerInfoDataArray = array(
137             'customers_info_date_account_last_modified' => date('Y-m-d H:i:s')
138         );
139         $this->db->update('customers_info', $customerInfoDataArray, array('customers_info_id' => $customerId));
140     }
141 } 

API documentation generated by ApiGen