Wabel / zoho-crm-copy-db

src/ZohoDatabaseCopier.php

Spacing +20 added lines, -20 removed lines

@@ -71,11 +71,11 @@ 
     {
         $users = $this->zohoUserService->getUsers();
         $tableName = 'users';
-        $this->logger->info('Fetched ' . count($users) . ' records');
+        $this->logger->info('Fetched '.count($users).' records');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
         foreach ($users as $user) {
@@ -112,14 +112,14 @@ 
             $select->execute(['id' => $user->getId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false && $data) {
-                $this->logger->debug("Inserting record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Inserting record with ID '".$user->getId()."'.");
 
                 $data['id'] = $user->getId();
                 $types['id'] = 'string';
 
                 $this->connection->insert($tableName, $data, $types);
             } elseif ($data) {
-                $this->logger->debug("Updating record with ID '" . $user->getId() . "'.");
+                $this->logger->debug("Updating record with ID '".$user->getId()."'.");
                 $identifier = ['id' => $user->getId()];
                 $types['id'] = 'string';
                 $this->connection->update($tableName, $data, $identifier, $types);
@@ -151,10 +151,10 @@ 
                 $tableDetail = $this->connection->getSchemaManager()->listTableDetails($tableName);
                 $lastActivityTime = null;
                 if ($tableDetail->hasColumn('modifiedTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM '.$tableName);
                 }
                 if (!$lastActivityTime && $tableDetail->hasColumn('createdTime')) {
-                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM ' . $tableName);
+                    $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM '.$tableName);
                 }
 
                 if ($lastActivityTime !== null) {
@@ -164,7 +164,7 @@ 
                 }
 
                 if ($lastActivityTime) {
-                    $this->logger->info('Incremental copy from ' . $lastActivityTime->format(\DateTime::ATOM) . ' started');
+                    $this->logger->info('Incremental copy from '.$lastActivityTime->format(\DateTime::ATOM).' started');
                 } else {
                     $this->logger->info('Incremental copy started');
                 }
@@ -172,21 +172,21 @@ 
                 $this->logger->info('Fetching the records to insert/update...');
                 $records = $dao->getRecords(null, null, null, $lastActivityTime);
                 $totalRecords = count($records);
-                $this->logger->debug($totalRecords . ' records fetched.');
+                $this->logger->debug($totalRecords.' records fetched.');
                 $this->logger->info('Fetching the records to delete...');
                 $deletedRecords = $dao->getDeletedRecordIds($lastActivityTime);
                 $totalRecordsDeleted = count($deletedRecords);
-                $this->logger->debug($totalRecordsDeleted . ' records fetched.');
+                $this->logger->debug($totalRecordsDeleted.' records fetched.');
             } else {
                 $this->logger->info('Full copy started');
                 $this->logger->info('Fetching the records to insert/update...');
                 $records = $dao->getRecords();
                 $totalRecords = count($records);
-                $this->logger->debug($totalRecords . ' records fetched.');
+                $this->logger->debug($totalRecords.' records fetched.');
                 $deletedRecords = [];
             }
         } catch (ZCRMException $exception) {
-            $this->logger->error('Error when getting records for module ' . $tableName . ': ' . $exception->getMessage(), [
+            $this->logger->error('Error when getting records for module '.$tableName.': '.$exception->getMessage(), [
                 'exception' => $exception
             ]);
             if ($throwErrors) {
@@ -194,11 +194,11 @@ 
             }
             return;
         }
-        $this->logger->info('Inserting/updating ' . $totalRecords . ' records into table ' . $tableName . '...');
+        $this->logger->info('Inserting/updating '.$totalRecords.' records into table '.$tableName.'...');
 
         $table = $this->connection->getSchemaManager()->createSchema()->getTable($tableName);
 
-        $select = $this->connection->prepare('SELECT * FROM ' . $tableName . ' WHERE id = :id');
+        $select = $this->connection->prepare('SELECT * FROM '.$tableName.' WHERE id = :id');
 
         $this->connection->beginTransaction();
 
@@ -212,7 +212,7 @@ 
         $processedRecords = 0;
         foreach ($records as $record) {
             if (($processedRecords % $logOffset) === 0) {
-                $this->logger->info($processedRecords . '/' . $totalRecords . ' records processed');
+                $this->logger->info($processedRecords.'/'.$totalRecords.' records processed');
             }
             ++$processedRecords;
             $data = [];
@@ -243,7 +243,7 @@ 
             $select->execute(['id' => $record->getZohoId()]);
             $result = $select->fetch(\PDO::FETCH_ASSOC);
             if ($result === false) {
-                $this->logger->debug("Inserting record with ID '" . $record->getZohoId() . "'...");
+                $this->logger->debug("Inserting record with ID '".$record->getZohoId()."'...");
 
                 $data['id'] = $record->getZohoId();
                 $types['id'] = 'string';
@@ -254,7 +254,7 @@ 
                     $listener->onInsert($data, $dao);
                 }
             } else {
-                $this->logger->debug("Updating record with ID '" . $record->getZohoId() . "'...");
+                $this->logger->debug("Updating record with ID '".$record->getZohoId()."'...");
                 $identifier = ['id' => $record->getZohoId()];
                 $types['id'] = 'string';
 
@@ -268,16 +268,16 @@ 
             }
         }
 
-        $this->logger->info('Deleting ' . $totalRecordsDeleted . ' records into table ' . $tableName . '...');
-        $sqlStatementUid = 'select uid from ' . $this->connection->quoteIdentifier($tableName) . ' where id = :id';
+        $this->logger->info('Deleting '.$totalRecordsDeleted.' records into table '.$tableName.'...');
+        $sqlStatementUid = 'select uid from '.$this->connection->quoteIdentifier($tableName).' where id = :id';
         $processedRecords = 0;
         $logOffset = $totalRecordsDeleted >= 500 ? 100 : 50;
         foreach ($deletedRecords as $deletedRecord) {
             if (($processedRecords % $logOffset) === 0) {
-                $this->logger->info($processedRecords . '/' . $totalRecordsDeleted . ' records processed');
+                $this->logger->info($processedRecords.'/'.$totalRecordsDeleted.' records processed');
             }
             ++$processedRecords;
-            $this->logger->debug("Deleting record with ID '" . $deletedRecord->getEntityId() . "'...");
+            $this->logger->debug("Deleting record with ID '".$deletedRecord->getEntityId()."'...");
             $uid = $this->connection->fetchColumn($sqlStatementUid, ['id' => $deletedRecord->getEntityId()]);
             $recordsModificationCounts['delete'] += $this->connection->delete($tableName, ['id' => $deletedRecord->getEntityId()]);
             if ($twoWaysSync) {