Wabel / zoho-crm-copy-db

src/ZohoDatabasePusher.php

Spacing +10 added lines, -10 removed lines

@@ -46,7 +46,7 @@ 
             $this->logger = $logger;
         }
         $this->apiLimitInsertUpdateDelete = $apiLimitInsertUpdateDelete;
-        if($apiLimitInsertUpdateDelete === null){
+        if ($apiLimitInsertUpdateDelete === null) {
             $this->apiLimitInsertUpdateDelete = 100;
         }
     }
@@ -89,7 +89,7 @@ 
         $rowsDeleted = [];
         //@see https://www.zoho.com/crm/help/api/api-limits.html
         //To optimize your API usage, get maximum 200 records with each request and insert, update or delete maximum 100 records with each request.
-        do{
+        do {
             $statementLimiter = $this->connection->createQueryBuilder();
             $statementLimiter->select('DISTINCT table_name,uid')
                 ->from($localTable)->setMaxResults($this->apiLimitInsertUpdateDelete);
@@ -99,7 +99,7 @@ 
                 $statement->addSelect('l.field_name as updated_fieldname');
             }
             $statement->from($localTable, 'l')
-                ->join('l','('.$statementLimiter->getSQL().')','ll','ll.table_name = l.table_name and  ll.uid = l.uid')
+                ->join('l', '('.$statementLimiter->getSQL().')', 'll', 'll.table_name = l.table_name and  ll.uid = l.uid')
                 ->join('l', $tableName, 'zcrm', 'zcrm.uid = l.uid')
                 ->where('l.table_name=:table_name')
                 ->setParameters([
@@ -131,10 +131,10 @@ 
                     $rowsDeleted[] = $row['uid'];
                 }
             }
-            $this->sendDataToZohoCleanLocal($zohoDao,$zohoBeans,$rowsDeleted,$update);
+            $this->sendDataToZohoCleanLocal($zohoDao, $zohoBeans, $rowsDeleted, $update);
             $statementElement = $this->connection->createQueryBuilder();
-            $countElementToPush =  $statementElement->select('*')->from($localTable)->execute()->rowCount();
-        } while($countElementToPush > 0);
+            $countElementToPush = $statementElement->select('*')->from($localTable)->execute()->rowCount();
+        } while ($countElementToPush > 0);
     }
 
     /**
@@ -143,7 +143,7 @@ 
      * @param string[] $rowsDeleted
      * @param bool $update
      */
-    private function sendDataToZohoCleanLocal(AbstractZohoDao $zohoDao, array $zohoBeans,$rowsDeleted, $update = false)
+    private function sendDataToZohoCleanLocal(AbstractZohoDao $zohoDao, array $zohoBeans, $rowsDeleted, $update = false)
     {
         $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
         $zohoDao->save($zohoBeans);
@@ -155,13 +155,13 @@ 
                     // ID not exist we can update the new row with the Zoho ID
                     $this->connection->beginTransaction();
                     $this->connection->update($tableName, ['id' => $zohoBean->getZohoId()], ['uid' => $uid]);
-                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid ]);
+                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid]);
                     $this->connection->commit();
                 } else {
                     //ID already exist we need to delete the duplicate row.
                     $this->connection->beginTransaction();
-                    $this->connection->delete($tableName, ['uid' => $uid ]);
-                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid ]);
+                    $this->connection->delete($tableName, ['uid' => $uid]);
+                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid]);
                     $this->connection->commit();
                 }
             }