webmatch / WbmQueryManager

Controllers/Backend/WbmQueryManager.php

Spacing +8 added lines, -8 removed lines

@@ -58,7 +58,7 @@ 
             )
             ->from('WbmQueryManager\Models\Query', 'query');
         
-        if(!empty($id)){
+        if (!empty($id)) {
             $qb->where('query.id = :id')
                 ->setParameter(':id', $id);
         } else {
@@ -76,7 +76,7 @@ 
     {
         $params = $this->Request()->getPost();
         
-        if($params['hasCronjob'] && empty($params['nextRun'])){
+        if ($params['hasCronjob'] && empty($params['nextRun'])) {
             $params['nextRun'] = new \DateTime();
         }
         
@@ -99,7 +99,7 @@ 
         $params = $this->Request()->getPost();
         $id = (int)$this->Request()->get('id');
         
-        if($params['hasCronjob'] && empty($params['nextRun'])){
+        if ($params['hasCronjob'] && empty($params['nextRun'])) {
             $params['nextRun'] = new \DateTime();
         }
 
@@ -164,18 +164,18 @@ 
             do {
                 $data[$i]['rowsetKey'] = $i;
 
-                if($this->container->get('wbm_query_manager.db')->getColumnCount($query)){
+                if ($this->container->get('wbm_query_manager.db')->getColumnCount($query)) {
                     $records = $this->container->get('wbm_query_manager.db')->fetchAll($query);
                     $data[$i]['rowCount'] = $this->container->get('wbm_query_manager.db')->getRowCount($query);
 
-                    if($download && $rowsetKey != $i){
+                    if ($download && $rowsetKey != $i) {
                         $i++;
                         continue;
                     }
 
                     $recordFields = array_keys($records[0]);
                     $columns = array();
-                    foreach($recordFields as $recordField){
+                    foreach ($recordFields as $recordField) {
                         $columns[] = array(
                             'header' => $recordField,
                             'dataIndex' => $recordField,
@@ -189,7 +189,7 @@ 
                         'columns' => $columns
                     );
 
-                    if($download){
+                    if ($download) {
                         $this->container->get('plugins')->Controller()->ViewRenderer()->setNoRender();
                         $now = new \DateTime();
                         $file = "query_" . $now->format('Y_m_d_h_i_s') . ".csv";
@@ -197,7 +197,7 @@ 
                         header("Content-Disposition: attachment; filename=\"$file\"");
 
                         $outputBuffer = fopen("php://output", 'w');
-                        foreach(array_merge(array(0 => $recordFields),$records) as $val) {
+                        foreach (array_merge(array(0 => $recordFields), $records) as $val) {
                             fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
                         }
                         fclose($outputBuffer);

WbmQueryManager.php

Spacing +1 added lines, -1 removed lines

@@ -60,7 +60,7 @@
      */
     public function update(UpdateContext $context)
     {
-        if(version_compare($context->getCurrentVersion(), '2.0.0', '<')) {
+        if (version_compare($context->getCurrentVersion(), '2.0.0', '<')) {
             $sql = "ALTER TABLE `wbm_query_manager` CHANGE `interval` `interval_int` INT(11) NULL DEFAULT '0';
                     ALTER TABLE `wbm_query_manager` CHANGE `sql` `sql_string` LONGTEXT NOT NULL;";
 

Services/QueryManagerDb.php

Spacing +10 added lines, -10 removed lines

@@ -51,11 +51,11 @@ 
      */
     private function getConnection($query)
     {
-        if(function_exists('mysqli_connect') && class_exists('Zend_Db_Adapter_Mysqli')) {
+        if (function_exists('mysqli_connect') && class_exists('Zend_Db_Adapter_Mysqli')) {
             $config = $this->container->getParameter('shopware.db');
             $mysqli = new \Zend_Db_Adapter_Mysqli($config);
             $connection = $mysqli->getConnection();
-            if($connection->multi_query($query)){
+            if ($connection->multi_query($query)) {
                 return $connection;
             }
         }
@@ -69,7 +69,7 @@ 
     public function query($query)
     {
         $connection = $this->getConnection($query);
-        if(get_class($connection) == 'mysqli'){
+        if (get_class($connection) == 'mysqli') {
             return $connection;
         }
         return $connection->query($query);
@@ -81,7 +81,7 @@ 
      */
     public function getRowCount($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->affected_rows;
         }
         return $query->rowCount();
@@ -93,7 +93,7 @@ 
      */
     public function getColumnCount($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->field_count;
         }
         return $query->columnCount();
@@ -105,10 +105,10 @@ 
      */
     public function fetchAll($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             $results = array();
-            if($result = $query->store_result()){
-                while($row = $result->fetch_assoc()){
+            if ($result = $query->store_result()) {
+                while ($row = $result->fetch_assoc()) {
                     $results[] = $row;
                 }
             }
@@ -123,7 +123,7 @@ 
      */
     public function nextResult($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->next_result();
         }
         return false;
@@ -135,7 +135,7 @@ 
      */
     public function close($query)
     {
-        if(get_class($query) == 'mysqli'){
+        if (get_class($query) == 'mysqli') {
             return $query->close();
         } else {
             $query->closeCursor();

Subscriber/Backend/QueryManagerCron.php

Spacing +9 added lines, -9 removed lines

@@ -76,13 +76,13 @@ 
         $data = array();
         $clearCacheAfter = false;
 
-        foreach($cronJobs as $cronJob){
+        foreach ($cronJobs as $cronJob) {
             $i = 0;
             $numRows = 0;
             try {
                 /** @var \mysqli|\Zend_Db_Statement_Pdo $query */
                 $query = $this->container->get('wbm_query_manager.db')->query($cronJob['sqlString']);
-                if($query instanceof \Zend_Db_Statement_Pdo) {
+                if ($query instanceof \Zend_Db_Statement_Pdo) {
                     $query->closeCursor();
                 }
 
@@ -90,7 +90,7 @@ 
                 $snippets = $this->container->get('snippets')->getNamespace("backend/plugins/wbm/querymanager");
 
                 do {
-                    if($this->container->get('wbm_query_manager.db')->getColumnCount($query)){
+                    if ($this->container->get('wbm_query_manager.db')->getColumnCount($query)) {
                         $records = $this->container->get('wbm_query_manager.db')->fetchAll($query);
                         $rowCount = $this->container->get('wbm_query_manager.db')->getRowCount($query);
                         $recordFields = array_keys($records[0]);
@@ -102,13 +102,13 @@ 
                         $csvPath = $this->container->get('application')->DocPath() . 'var/log/' . $file;
 
                         $outputBuffer = fopen($csvPath, 'w');
-                        foreach(array_merge(array(0 => $recordFields),$records) as $val) {
+                        foreach (array_merge(array(0 => $recordFields), $records) as $val) {
                             fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
                         }
                         fclose($outputBuffer);
 
                         $mailRecipient = $this->container->get('config')->getByNamespace('WbmQueryManager', 'mail_address_receiver');
-                        if(!empty($mailRecipient)){
+                        if (!empty($mailRecipient)) {
                             $mail = clone $this->container->get('mail');
                             $mail->setFrom($this->container->get('config')->get('mail'));
                             $mail->addTo($mailRecipient);
@@ -124,7 +124,7 @@ 
                             $mail->send();
                         }
 
-                        if(!$this->container->get('config')->getByNamespace('WbmQueryManager', 'log_csv')){
+                        if (!$this->container->get('config')->getByNamespace('WbmQueryManager', 'log_csv')) {
                             unlink($csvPath);
                         }
 
@@ -144,7 +144,7 @@ 
             $query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($cronJob['id']);
             $query->setLastLog($result);
             /** @var \DateTime $lastRun */
-            $lastRun = $query->getLastRun() ? : new \DateTime();
+            $lastRun = $query->getLastRun() ?: new \DateTime();
             $query->setLastRun($now);
             $query->setNextRun($lastRun->add(\DateInterval::createFromDateString($query->getIntervalInt() . ' seconds')));
 
@@ -152,14 +152,14 @@ 
             $this->container->get('models')->flush();
             $this->container->get('models')->clear();
 
-            if($cronJob['clear_cache']){
+            if ($cronJob['clear_cache']) {
                 $clearCacheAfter = true;
             }
 
             $data[$cronJob['name']] = $result;
         }
 
-        if($clearCacheAfter){
+        if ($clearCacheAfter) {
             $cacheManager = $this->container->get('shopware.cache_manager');
             $cacheManager->clearHttpCache();
             $cacheManager->clearTemplateCache();