Wabel / zoho-crm-copy-db

src/ZohoDatabaseHelper.php

Doc Comments +1 added lines

@@ -16,6 +16,7 @@
      * Computes the name of the table based on the DAO plural module name.
      *
      * @param AbstractZohoDao $dao
+     * @param string $prefix
      *
      * @return string
      */

src/ZohoDatabaseCopier.php

Unused Use Statements -1 removed lines

@@ -6,7 +6,6 @@
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 use Wabel\Zoho\CRM\AbstractZohoDao;
-use Wabel\Zoho\CRM\Request\Response;
 
 /**
  * This class is in charge of synchronizing one table of your database with Zoho records.

Spacing +2 added lines, -2 removed lines

@@ -128,10 +128,10 @@
             // Let's get the last modification date:
             $tableDetail = $this->connection->getSchemaManager()->listTableDetails($tableName);
             $lastActivityTime = null;
-            if($tableDetail->hasColumn('modifiedTime')){
+            if ($tableDetail->hasColumn('modifiedTime')) {
                 $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM '.$tableName);
             }
-            if(!$lastActivityTime && $tableDetail->hasColumn('createdTime'))
+            if (!$lastActivityTime && $tableDetail->hasColumn('createdTime'))
             {
                 $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM '.$tableName);
             }

src/ZohoDatabaseModelSync.php

Unused Use Statements -1 removed lines

@@ -7,7 +7,6 @@
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 use Wabel\Zoho\CRM\AbstractZohoDao;
-use Wabel\Zoho\CRM\Request\Response;
 
 /**
  * This class is in charge of synchronizing one table MODEL with Zoho.

Spacing +4 added lines, -4 removed lines

@@ -86,15 +86,15 @@ 
 
         $flatFields = ZohoDatabaseHelper::getFlatFields($dao->getFields());
         //@Temporary fix to use Mysql5.7 not strict
-        $table->addColumn('uid', 'string', ['length' => 36,'notnull'=>false]);
-        $table->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
+        $table->addColumn('uid', 'string', ['length' => 36, 'notnull'=>false]);
+        $table->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
         $table->addUniqueIndex(['id']);
         $table->setPrimaryKey(['uid']);
 
         foreach ($flatFields as $field) {
             $columnName = $field['name'];
             //It seems sometime we can have the same field twice in the list of fields from the API.
-            if($table->hasColumn($columnName)){
+            if ($table->hasColumn($columnName)) {
                 continue;
             }
 
@@ -202,7 +202,7 @@ 
         $table = $schema->createTable($tableName);
 
         $flatFields = $users->getUserFields();
-        $table->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
+        $table->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
         $table->setPrimaryKey(['id']);
         foreach ($flatFields as $field) {
             if (in_array($field, ['id'])) {

src/LocalChangesTracker.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
         $localDelete = $schema->createTable('local_delete');
         $localDelete->addColumn('table_name', 'string', ['length' => 100]);
         $localDelete->addColumn('uid', 'string', ['length' => 36]);
-        $localDelete->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
+        $localDelete->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
         $localDelete->setPrimaryKey(array('table_name', 'uid'));
         $localDelete->addUniqueIndex(['id', 'table_name']);
 

src/ZohoSyncDatabaseCommand.php

Doc Comments -1 removed lines

@@ -194,7 +194,6 @@
     
     /**
      * Regerate Zoho Daos
-     * @param InputInterface $input
      * @param OutputInterface $output
      */
     private function regenerateZohoDao(OutputInterface $output)

Spacing +5 added lines, -5 removed lines

@@ -99,7 +99,7 @@ 
         $this->zohoDatabaseModelSync = $zohoDatabaseModelSync;
         $this->zohoDatabaseCopier = $zohoDatabaseCopier;
         $this->zohoDatabaseSync = $zohoDatabaseSync;
-        $this->zohoEntitiesGenerator =  $zohoEntitiesGenerator;
+        $this->zohoEntitiesGenerator = $zohoEntitiesGenerator;
         $this->zohoClient = $zohoClient;
         $this->pathZohoDaos = $pathZohoDaos;
         $this->namespaceZohoDaos = $namespaceZohoDaos;
@@ -127,8 +127,8 @@ 
                 $this->lock->acquireLock();
             }
 
-            if(!$input->getOption('limit')){
-                ini_set('memory_limit','-1');
+            if (!$input->getOption('limit')) {
+                ini_set('memory_limit', '-1');
             }
             
             $this->logger->addLogger(new DateTimeFormatter(new ConsoleLogger($output)));
@@ -194,7 +194,7 @@ 
      */
     private function getListFieldName(AbstractZohoDao $zohoDao)
     {
-        $fieldNames= array();
+        $fieldNames = array();
         foreach ($zohoDao->getFields() as $fieldsDescriptor) {
             foreach (array_values($fieldsDescriptor) as $fieldDescriptor) {
                 $fieldNames[] = $fieldDescriptor['name'];
@@ -218,7 +218,7 @@ 
             $zohoDao = new $daoFullClassName($this->zohoClient);
             //To have more module which is use time of modification (createdTime or lastActivityTime).
             //use an array of Excluded Dao by full namespace
-            if (($this->excludedZohoDao && in_array(get_class($zohoDao),$this->excludedZohoDao)) || !in_array('createdTime', $this->getListFieldName($zohoDao))) {
+            if (($this->excludedZohoDao && in_array(get_class($zohoDao), $this->excludedZohoDao)) || !in_array('createdTime', $this->getListFieldName($zohoDao))) {
                 continue;
             }
             $this->zohoDaos [] = $zohoDao;

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;
         }
     }
@@ -99,7 +99,7 @@ 
         $localTable = $update ? 'local_update' : 'local_insert';
         $fieldsMatching = $this->findMethodValues($zohoDao);
         $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
-        do{
+        do {
             $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.
@@ -112,7 +112,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([
@@ -144,9 +144,9 @@ 
                     $rowsDeleted[] = $row['uid'];
                 }
             }
-            $this->sendDataToZohoCleanLocal($zohoDao,$zohoBeans,$rowsDeleted,$update);
-            $countToPush = $this->countElementInTable($zohoDao,$update);
-        } while($countToPush > 0);
+            $this->sendDataToZohoCleanLocal($zohoDao, $zohoBeans, $rowsDeleted, $update);
+            $countToPush = $this->countElementInTable($zohoDao, $update);
+        } while ($countToPush > 0);
     }
 
     /**
@@ -155,7 +155,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);
@@ -167,13 +167,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();
                 }
             }