sirdiego / importr

Classes/Service/Targets/InsertUpdateTable.php

Doc Comments +1 added lines

@@ -136,6 +136,7 @@
      *
      * Fetch all records from the target table, where the PID equals the PID specified in the target section of the strategy 
      *
+     * @param string $selectFields
      * @return void
      */
     public function getRecords($selectFields)

Unused Use Statements -2 removed lines

@@ -2,8 +2,6 @@
 namespace HDNET\Importr\Service\Targets;
 
 use HDNET\Importr\Domain\Model\Strategy;
-use TYPO3\CMS\Extbase\DomainObject\AbstractEntity;
-use HDNET\Importr\Utility;
 
   /**
   * Imports records from a .CSV file into the target table which you can specify on the target section in your strategy.

Indentation +58 added lines, -58 removed lines

@@ -5,49 +5,49 @@ 
 use TYPO3\CMS\Extbase\DomainObject\AbstractEntity;
 use HDNET\Importr\Utility;
 
-  /**
-  * Imports records from a .CSV file into the target table which you 
-	* can specify on the target section in your strategy.
-  * If a record does not exist in the table, it will be inserted, 
-	* otherwise it will be just updated. No duplicates are created.
-  *
-  * complete example (strategy target):
-  *
-  * HDNET\Importr\Service\Targets\InsertUpdateTable:
-  *   model: TYPO3\CMS\Extbase\Domain\Model\FrontendUser
-  *   repository: TYPO3\CMS\Extbase\Domain\Repository\FrontendUserRepository
-  *   target_table: fe_users
-  *   exclude_from_update:
-  *     0: password
-  *     1: first_name
-  *     2: zip
-  *   pid: 324
-  *   mapping:
-  *     0: username
-  *     1: password
-  *     2: usergroup
-  *     3: name
-  *     4: first_name
-  *     5: address
-  *     6: telephone
-  *     7: email
-  *     8: zip
-  *     9: city
-  *     10: company
-  *     
-  * Example CSV:
-  *
-  * username;password;usergroup;name;first_name;address;telephone;email;zip;city;company
-  * EduardFekete;BestPwEU1234;3;Fekete;Eduard; Mystreet 21; +049123456789;eduard.fekete@mbconnectline.de;91550;Feuchtwangen;MB Connect Line GmbH
-  * HansVader;SecondBestPwEU1234;3;Vader;Hans; Hisstreet 22; +049123456710;hans_vader@universe.com;99900;Universe;Hollywood Studios
-  *
-  * ------------------------------------------------------------------------------------------------
-  *
-  *   exclude_from_update:    the elements specified in this array, are never being updated
-  *
-  * ------------------------------------------------------------------------------------------------
-  * @author Eduard Fekete
-  */
+    /**
+     * Imports records from a .CSV file into the target table which you 
+     * can specify on the target section in your strategy.
+     * If a record does not exist in the table, it will be inserted, 
+     * otherwise it will be just updated. No duplicates are created.
+     *
+     * complete example (strategy target):
+     *
+     * HDNET\Importr\Service\Targets\InsertUpdateTable:
+     *   model: TYPO3\CMS\Extbase\Domain\Model\FrontendUser
+     *   repository: TYPO3\CMS\Extbase\Domain\Repository\FrontendUserRepository
+     *   target_table: fe_users
+     *   exclude_from_update:
+     *     0: password
+     *     1: first_name
+     *     2: zip
+     *   pid: 324
+     *   mapping:
+     *     0: username
+     *     1: password
+     *     2: usergroup
+     *     3: name
+     *     4: first_name
+     *     5: address
+     *     6: telephone
+     *     7: email
+     *     8: zip
+     *     9: city
+     *     10: company
+     *     
+     * Example CSV:
+     *
+     * username;password;usergroup;name;first_name;address;telephone;email;zip;city;company
+     * EduardFekete;BestPwEU1234;3;Fekete;Eduard; Mystreet 21; +049123456789;eduard.fekete@mbconnectline.de;91550;Feuchtwangen;MB Connect Line GmbH
+     * HansVader;SecondBestPwEU1234;3;Vader;Hans; Hisstreet 22; +049123456710;hans_vader@universe.com;99900;Universe;Hollywood Studios
+     *
+     * ------------------------------------------------------------------------------------------------
+     *
+     *   exclude_from_update:    the elements specified in this array, are never being updated
+     *
+     * ------------------------------------------------------------------------------------------------
+     * @author Eduard Fekete
+     */
 
 class InsertUpdateTable extends AbstractTarget implements TargetInterface
 {
@@ -180,13 +180,13 @@ 
         $GLOBALS['TYPO3_DB']->sql_insert_id();
     }
 
-     /**
-     * Update a record in the target table which you have specified in the target section of the strategy (don't update the password)
-     *
-     * @param array $entry
-     *
-     * @return void
-     */
+        /**
+         * Update a record in the target table which you have specified in the target section of the strategy (don't update the password)
+         *
+         * @param array $entry
+         *
+         * @return void
+         */
     public function updateRecord(array $entry)
     {
         $into_table       = $this->configuration['target_table'];
@@ -207,14 +207,14 @@ 
     }
 
     /**
-    * This function creates a duplicate of a associative array and optionally removes
-    * any entries which are also elements of a second array
-    *
-    * @param array $arr
-    * @param array $exclude_arr
-    *
-    * @return array
-    */
+     * This function creates a duplicate of a associative array and optionally removes
+     * any entries which are also elements of a second array
+     *
+     * @param array $arr
+     * @param array $exclude_arr
+     *
+     * @return array
+     */
     public function duplicateArray(array $arr, array $exclude_arr = null)
     {
         $exclude = false;

Spacing +15 added lines, -16 removed lines

@@ -106,16 +106,16 @@ 
         $record_exists    = false;
         $entry_username   = $entry['0'];
 
-        $this->configuration    = $this->getConfiguration();
+        $this->configuration = $this->getConfiguration();
 
         if ($this->firstTime == "1") {
             $this->firstTime = 0;
             $this->getRecords("*");
         }
 
-        foreach ($this->table_records as $record){
-            if ($record['deleted'] == 0){
-                if ($record['username'] == $entry_username){
+        foreach ($this->table_records as $record) {
+            if ($record['deleted'] == 0) {
+                if ($record['username'] == $entry_username) {
                     $record_exists = true;
                     break;
                 }
@@ -125,7 +125,7 @@ 
             }
         }
 
-        if ($record_exists){
+        if ($record_exists) {
             $this->updateRecord($entry);
             return TargetInterface::RESULT_UPDATE;
         }
@@ -144,12 +144,11 @@ 
     public function getRecords($selectFields)
     {
         $fromTable        = $this->configuration['target_table'];
-        $whereStatement   = "pid = '".$this->configuration['pid']."'";
+        $whereStatement   = "pid = '" . $this->configuration['pid'] . "'";
 
         $GLOBALS['TYPO3_DB']->store_lastBuiltQuery = 1;
 
-        $this->table_records = $GLOBALS['TYPO3_DB']->exec_SELECTgetRows
-        (
+        $this->table_records = $GLOBALS['TYPO3_DB']->exec_SELECTgetRows(
             $selectFields,
             $fromTable,
             $whereStatement
@@ -168,7 +167,7 @@ 
         $field_values       = array();
         $into_table         = $this->configuration['target_table'];
 
-        foreach ($this->configuration["mapping"] as $key => $value){
+        foreach ($this->configuration["mapping"] as $key => $value) {
             $field_values[$value] = $entry[$key];
         }
 
@@ -176,7 +175,7 @@ 
         $field_values['tstamp']   = time();
         $field_values['crdate']   = time();
               
-        $GLOBALS['TYPO3_DB']->exec_INSERTquery( $into_table, $field_values);
+        $GLOBALS['TYPO3_DB']->exec_INSERTquery($into_table, $field_values);
         $GLOBALS['TYPO3_DB']->sql_insert_id();
     }
 
@@ -190,19 +189,19 @@ 
     public function updateRecord(array $entry)
     {
         $into_table       = $this->configuration['target_table'];
-        $whereStatement   = "pid = '".$this->configuration['pid']."' AND username = '".$entry[0]."'";
+        $whereStatement   = "pid = '" . $this->configuration['pid'] . "' AND username = '" . $entry[0] . "'";
                            
         $field_values     = array();
         $tmp_arr          = array();
 
-        foreach ($this->configuration["mapping"] as $key => $value){
+        foreach ($this->configuration["mapping"] as $key => $value) {
             $tmp_arr[$value] = $entry[$key];
         }
 
-        $field_values = $this->duplicateArray($tmp_arr,$this->configuration['exclude_from_update']);
+        $field_values = $this->duplicateArray($tmp_arr, $this->configuration['exclude_from_update']);
         $field_values['tstamp'] = time();
         
-        $res = $GLOBALS['TYPO3_DB']->exec_UPDATEquery( $into_table , $whereStatement , $field_values );
+        $res = $GLOBALS['TYPO3_DB']->exec_UPDATEquery($into_table, $whereStatement, $field_values);
         $cnt = $GLOBALS['TYPO3_DB']->sql_affected_rows();
     }
 
@@ -221,7 +220,7 @@ 
 
         if ($exclude_arr != null) {
             $exclude_max = count($exclude_arr);
-            if (count($exclude_arr) > 0){
+            if (count($exclude_arr) > 0) {
                 $exclude = true;
             }
 
@@ -231,7 +230,7 @@ 
 
                 if ($exclude) {
                     foreach ($exclude_arr as $key => $value) {
-                        if ($value == $parentkey){
+                        if ($value == $parentkey) {
                             unset($arr[$parentkey]);
                         }
                     }

Braces +2 added lines, -4 removed lines

@@ -119,8 +119,7 @@ 
                     $record_exists = true;
                     break;
                 }
-            }
-            else {
+            } else {
                 continue;
             }
         }
@@ -128,8 +127,7 @@ 
         if ($record_exists){
             $this->updateRecord($entry);
             return TargetInterface::RESULT_UPDATE;
-        }
-        else { 
+        } else { 
             $this->insertRecord($entry);
             return TargetInterface::RESULT_INSERT;
         }