Completed
Pull Request — 3.1 (#43)
by
unknown
01:30
created
src/LocalChangesTracker.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -49,7 +49,7 @@
 block discarded – undo
49 49
         $localDelete = $schema->createTable('local_delete');
50 50
         $localDelete->addColumn('table_name', 'string', ['length' => 100]);
51 51
         $localDelete->addColumn('uid', 'string', ['length' => 36]);
52
-        $localDelete->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
52
+        $localDelete->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
53 53
         $localDelete->setPrimaryKey(array('table_name', 'uid'));
54 54
         $localDelete->addUniqueIndex(['id', 'table_name']);
55 55
 
Please login to merge, or discard this patch.
src/ZohoDatabasePusher.php 1 patch
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -47,7 +47,7 @@  discard block
 block discarded – undo
47 47
             $this->logger = $logger;
48 48
         }
49 49
         $this->apiLimitInsertUpdateDelete = $apiLimitInsertUpdateDelete;
50
-        if($apiLimitInsertUpdateDelete === null) {
50
+        if ($apiLimitInsertUpdateDelete === null) {
51 51
             $this->apiLimitInsertUpdateDelete = 100;
52 52
         }
53 53
     }
@@ -81,7 +81,7 @@  discard block
 block discarded – undo
81 81
     {
82 82
         $localTable = $update ? 'local_update' : 'local_insert';
83 83
         $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
84
-        do{
84
+        do {
85 85
             $rowsDeleted = [];
86 86
             //@see https://www.zoho.com/crm/help/api/v2/#ra-update-records
87 87
             //To optimize your API usage, get maximum 200 records with each request and insert, update or delete maximum 100 records with each request.
@@ -128,11 +128,11 @@  discard block
 block discarded – undo
128 128
                     $rowsDeleted[] = $row['uid'];
129 129
                 }
130 130
             }
131
-            if($zohoBeans) {
131
+            if ($zohoBeans) {
132 132
                 $this->sendDataToZohoCleanLocal($zohoDao, $zohoBeans, $rowsDeleted, $update);
133 133
             }
134 134
             $countToPush = $this->countElementInTable($zohoDao, $update);
135
-        } while($countToPush > 0);
135
+        } while ($countToPush > 0);
136 136
     }
137 137
 
138 138
     /**
@@ -141,7 +141,7 @@  discard block
 block discarded – undo
141 141
      * @param string[]            $rowsDeleted
142 142
      * @param bool                $update
143 143
      */
144
-    private function sendDataToZohoCleanLocal(AbstractZohoDao $zohoDao, array $zohoBeans,$rowsDeleted, $update = false)
144
+    private function sendDataToZohoCleanLocal(AbstractZohoDao $zohoDao, array $zohoBeans, $rowsDeleted, $update = false)
145 145
     {
146 146
         $tableName = ZohoDatabaseHelper::getTableName($zohoDao, $this->prefix);
147 147
         $zohoDao->save($zohoBeans);
@@ -153,13 +153,13 @@  discard block
 block discarded – undo
153 153
                     // ID not exist we can update the new row with the Zoho ID
154 154
                     $this->connection->beginTransaction();
155 155
                     $this->connection->update($tableName, ['id' => $zohoBean->getZohoId()], ['uid' => $uid]);
156
-                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid ]);
156
+                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid]);
157 157
                     $this->connection->commit();
158 158
                 } else {
159 159
                     //ID already exist we need to delete the duplicate row.
160 160
                     $this->connection->beginTransaction();
161
-                    $this->connection->delete($tableName, ['uid' => $uid ]);
162
-                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid ]);
161
+                    $this->connection->delete($tableName, ['uid' => $uid]);
162
+                    $this->connection->delete('local_insert', ['table_name'=>$tableName, 'uid' => $uid]);
163 163
                     $this->connection->commit();
164 164
                 }
165 165
             }
@@ -187,7 +187,7 @@  discard block
 block discarded – undo
187 187
     {
188 188
         foreach ($row as $columnName => $columnValue) {
189 189
             $fieldMethod = $dao->getFieldFromFieldName($columnName);
190
-            if(!in_array($columnName, EntitiesGeneratorService::$defaultDateFields) && $fieldMethod
190
+            if (!in_array($columnName, EntitiesGeneratorService::$defaultDateFields) && $fieldMethod
191 191
                 && (!in_array($columnName, ['id', 'uid'])) && !is_null($columnValue)
192 192
             ) {
193 193
                 $type = $fieldMethod->getType();
@@ -231,10 +231,10 @@  discard block
 block discarded – undo
231 231
     {
232 232
         switch ($type) {
233 233
         case 'date':
234
-            $value = \DateTime::createFromFormat('Y-m-d', $value)?:null;
234
+            $value = \DateTime::createFromFormat('Y-m-d', $value) ?: null;
235 235
             break;
236 236
         case 'datetime':
237
-            $value = \DateTime::createFromFormat('Y-m-d H:i:s', $value)?:null;
237
+            $value = \DateTime::createFromFormat('Y-m-d H:i:s', $value) ?: null;
238 238
             break;
239 239
         case 'boolean' :
240 240
             $value = (bool) $value;
Please login to merge, or discard this patch.
src/ZohoDatabaseCopier.php 1 patch
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -102,7 +102,7 @@  discard block
 block discarded – undo
102 102
                         $object = $user->{$fieldMethod}();
103 103
                         $data[$column->getName()] = $object->getName();
104 104
                     }
105
-                    elseif($column->getName() === 'Currency') {
105
+                    elseif ($column->getName() === 'Currency') {
106 106
                         //Todo: Do a pull request about \ZCRMUser::geCurrency() to \ZCRMUser::getCurrency()
107 107
                         $data[$column->getName()] = $user->geCurrency();
108 108
                     }
@@ -114,14 +114,14 @@  discard block
 block discarded – undo
114 114
             $select->execute(['id' => $user->getId()]);
115 115
             $result = $select->fetch(\PDO::FETCH_ASSOC);
116 116
             if ($result === false && $data) {
117
-                $this->logger->debug("Inserting record with ID '" . $user->getId() . "'.");
117
+                $this->logger->debug("Inserting record with ID '".$user->getId()."'.");
118 118
 
119 119
                 $data['id'] = $user->getId();
120 120
                 $types['id'] = 'string';
121 121
 
122 122
                 $this->connection->insert($tableName, $data, $types);
123
-            } elseif($data) {
124
-                $this->logger->debug("Updating record with ID '" . $user->getId() . "'.");
123
+            } elseif ($data) {
124
+                $this->logger->debug("Updating record with ID '".$user->getId()."'.");
125 125
                 $identifier = ['id' => $user->getId()];
126 126
                 $types['id'] = 'string';
127 127
                 $this->connection->update($tableName, $data, $identifier, $types);
@@ -149,10 +149,10 @@  discard block
 block discarded – undo
149 149
             // Let's get the last modification date:
150 150
             $tableDetail = $this->connection->getSchemaManager()->listTableDetails($tableName);
151 151
             $lastActivityTime = null;
152
-            if($tableDetail->hasColumn('modifiedTime')) {
152
+            if ($tableDetail->hasColumn('modifiedTime')) {
153 153
                 $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(modifiedTime) FROM '.$tableName);
154 154
             }
155
-            if(!$lastActivityTime && $tableDetail->hasColumn('createdTime')) {
155
+            if (!$lastActivityTime && $tableDetail->hasColumn('createdTime')) {
156 156
                 $lastActivityTime = $this->connection->fetchColumn('SELECT MAX(createdTime) FROM '.$tableName);
157 157
             }
158 158
 
@@ -189,7 +189,7 @@  discard block
 block discarded – undo
189 189
                     continue;
190 190
                 } else {
191 191
                     $field = $dao->getFieldFromFieldName($column->getName());
192
-                    if(!$field) {
192
+                    if (!$field) {
193 193
                         continue;
194 194
                     }
195 195
                     $getterName = $field->getGetter();
Please login to merge, or discard this patch.
src/Log/ZohoSyncSQLLogger.php 1 patch
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -57,7 +57,7 @@
 block discarded – undo
57 57
         $query = null;
58 58
         if ($params && $this->authorizedSQLWithParams) {
59 59
             $this->logger->debug($sql.' -- Params : {params} - Types : {types}', ['params' => json_encode($params), 'types' => json_encode($types)]);
60
-        } elseif($this->authorizedSQLWithoutParams) {
60
+        } elseif ($this->authorizedSQLWithoutParams) {
61 61
             $this->logger->debug($sql);
62 62
         }
63 63
     }
Please login to merge, or discard this patch.
src/ZohoDatabaseModelSync.php 1 patch
Spacing   +10 added lines, -10 removed lines patch added patch discarded remove patch
@@ -86,15 +86,15 @@  discard block
 block discarded – undo
86 86
         $table = $schema->createTable($tableName);
87 87
 
88 88
         //@Temporary fix to use Mysql5.7 not strict
89
-        $table->addColumn('uid', 'string', ['length' => 36,'notnull'=>false]);
90
-        $table->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
89
+        $table->addColumn('uid', 'string', ['length' => 36, 'notnull'=>false]);
90
+        $table->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
91 91
         $table->addUniqueIndex(['id']);
92 92
         $table->setPrimaryKey(['uid']);
93 93
 
94 94
         foreach ($dao->getFields() as $field) {
95 95
             $columnName = $field->getName();
96 96
             //It seems sometime we can have the same field twice in the list of fields from the API.
97
-            if($table->hasColumn($columnName)) {
97
+            if ($table->hasColumn($columnName)) {
98 98
                 continue;
99 99
             }
100 100
 
@@ -105,23 +105,23 @@  discard block
 block discarded – undo
105 105
             switch ($field->getType()) {
106 106
             case 'fileupload':
107 107
                 $type = 'string';
108
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
108
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 255;
109 109
                 break;
110 110
             case 'lookup':
111 111
                 $type = 'string';
112
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
112
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 100;
113 113
                 $index = true;
114 114
                 break;
115 115
             case 'userlookup':
116 116
             case 'ownerlookup':
117 117
                 $type = 'string';
118 118
                 $index = true;
119
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 25;
119
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 25;
120 120
                 break;
121 121
             case 'formula':
122 122
                 // Note: a Formula can return any type, but we have no way to know which type it returns...
123 123
                 $type = 'string';
124
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 100;
124
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 100;
125 125
                 break;
126 126
             case 'datetime':
127 127
                 $type = 'datetime';
@@ -145,7 +145,7 @@  discard block
 block discarded – undo
145 145
             case 'picklist':
146 146
             case 'website':
147 147
                 $type = 'string';
148
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
148
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 255;
149 149
                 break;
150 150
             case 'multiselectlookup':
151 151
             case 'multiuserlookup':
@@ -161,7 +161,7 @@  discard block
 block discarded – undo
161 161
             case 'autonumber':
162 162
             case 'integer':
163 163
                 $type = 'integer';
164
-                $length = $field->getMaxlength() && $field->getMaxlength() > 0?$field->getMaxlength() : 255;
164
+                $length = $field->getMaxlength() && $field->getMaxlength() > 0 ? $field->getMaxlength() : 255;
165 165
                 break;
166 166
             case 'currency':
167 167
             case 'decimal':
@@ -213,7 +213,7 @@  discard block
 block discarded – undo
213 213
         $schema = new Schema();
214 214
         $table = $schema->createTable($tableName);
215 215
 
216
-        $table->addColumn('id', 'string', ['length' => 100,'notnull'=>false]);
216
+        $table->addColumn('id', 'string', ['length' => 100, 'notnull'=>false]);
217 217
         $table->setPrimaryKey(['id']);
218 218
         foreach (ZCRMUser::$defaultKeys as $field) {
219 219
             if ($field === 'id') {
Please login to merge, or discard this patch.
src/ZohoSyncDatabaseCommand.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -101,7 +101,7 @@  discard block
 block discarded – undo
101 101
         $this->zohoDatabaseModelSync = $zohoDatabaseModelSync;
102 102
         $this->zohoDatabaseCopier = $zohoDatabaseCopier;
103 103
         $this->zohoDatabaseSync = $zohoDatabaseSync;
104
-        $this->zohoEntitiesGenerator =  $zohoEntitiesGenerator;
104
+        $this->zohoEntitiesGenerator = $zohoEntitiesGenerator;
105 105
         $this->zohoClient = $zohoClient;
106 106
         $this->pathZohoDaos = $pathZohoDaos;
107 107
         $this->namespaceZohoDaos = $namespaceZohoDaos;
@@ -137,7 +137,7 @@  discard block
 block discarded – undo
137 137
             if ($input->getOption('log-path') && $input->getOption('clear-logs')) {
138 138
                 $output->writeln('Clearing logs...');
139 139
                 $path = $input->getOption('log-path');
140
-                $logFile = $path . '/ZCRMClientLibrary.log';
140
+                $logFile = $path.'/ZCRMClientLibrary.log';
141 141
                 if (file_exists($logFile)) {
142 142
                     if (is_writable($logFile)) {
143 143
                         if (file_put_contents($logFile, '') === false) {
@@ -151,7 +151,7 @@  discard block
 block discarded – undo
151 151
                 }
152 152
             }
153 153
 
154
-            if(!$input->getOption('limit')) {
154
+            if (!$input->getOption('limit')) {
155 155
                 ini_set('memory_limit', '-1');
156 156
             }
157 157
 
@@ -176,7 +176,7 @@  discard block
 block discarded – undo
176 176
             if ($input->getOption('log-path') && $input->getOption('dump-logs')) {
177 177
                 $output->writeln('Dumping logs...');
178 178
                 $path = $input->getOption('log-path');
179
-                $logFile = $path . '/ZCRMClientLibrary.log';
179
+                $logFile = $path.'/ZCRMClientLibrary.log';
180 180
                 if (file_exists($logFile)) {
181 181
                     if (is_readable($logFile)) {
182 182
                         $output->writeln(file_get_contents($logFile));
@@ -296,7 +296,7 @@  discard block
 block discarded – undo
296 296
     {
297 297
         $output->writeln('Start to synchronize Zoho data into Zoho CRM.');
298 298
         foreach ($this->zohoDaos as $zohoDao) {
299
-            if($zohoDao->getFieldFromFieldName('createdTime')) {
299
+            if ($zohoDao->getFieldFromFieldName('createdTime')) {
300 300
                 $this->zohoDatabaseSync->pushToZoho($zohoDao);
301 301
             }
302 302
         }
Please login to merge, or discard this patch.