Shopware_Controllers_Backend_WbmQueryManager::runAction() - Code Metrics - webmatch/WbmQueryManager - Measure and Improve Code Quality continuously with Scrutinizer

runAction() B
last analyzed 2019-07-09 14:08 UTC

↳ Parent: Shopware_Controllers_Backend_WbmQueryManager

Complexity

Conditions	9
Paths	86

Size

Total Lines

Duplication

Lines	3
Ratio	4.05 %

Importance

Changes

Metric	Value
dl	3
loc	74
rs	7.0117
c	0
b	0
f	0
cc	9
nc	86
nop	0

How to fix Long Method

<?php
/**
 * Query Manager
 * Copyright (c) Webmatch GmbH
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 */

use WbmQueryManager\Models\Query;

/**
 * Class Shopware_Controllers_Backend_WbmQueryManager
 */
class Shopware_Controllers_Backend_WbmQueryManager extends Shopware_Controllers_Backend_ExtJs {

    public function postDispatch()
    {
        if (
            $this->Request()->getActionName() === 'load' &&
            $this->container->get('config')->getByNamespace('WbmQueryManager', 'autocomplete')
        ) {
            $dbData = $this->container->getParameter('shopware.db');
            $sql = "SELECT TABLE_NAME, COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = ?";
            $tables = $this->container->get('shopware.db')->fetchAll(
                $sql,
                array($dbData['dbname']), \Zend_Db::FETCH_GROUP|\Zend_Db::FETCH_COLUMN
            );
            $columns = [];
            foreach ($tables as $table => $content) {
                foreach ($content as $column) {
                    $columns[] = array(
                        'caption' => $table . '.' . $column,
                        'value' => '`' . $table . '`.`' . $column . '`',
                        'meta' => 'Column'
                    );
                }
            }
            $hintOptions = json_encode(
                array_merge(
                    array_map(
                        function($tableName) {
                            return array(
                                'caption' => $tableName,
                                'value' => '`' . $tableName . '`',
                                'meta' => 'Table'
                            );
                        },
                        array_keys($tables)
                    ),
                    $columns
                )
            );
            $this->View()->hintOptions = $hintOptions;
            $this->View()->autocompleteActive = true;
        }
    }
    
    public function indexAction() 
    {
        $this->View()->loadTemplate("backend/wbm_query_manager/app.js");
    }
    
    public function listAction()
    {
        $id = $this->Request()->getParam('id', null);

        /** @var \Doctrine\ORM\QueryBuilder $qb */
        $qb = $this->container->get('models')->createQueryBuilder();
        $qb->select(
                array(
                    'query'
                )
            )
            ->from('WbmQueryManager\Models\Query', 'query');
        
        if(!empty($id)){
            $qb->where('query.id = :id')
                ->setParameter(':id', $id);
        } else {
            $qb->addOrderBy('query.name', 'ASC');
        }

        $data = $qb->getQuery()->getArrayResult();
        
        $this->View()->assign(
            array('success' => true, 'data' => $data)
        );
    }
    
    public function createAction() 
    {
        $params = $this->Request()->getPost();
        
        if($params['hasCronjob'] && empty($params['nextRun'])){
            $params['nextRun'] = new \DateTime();
        }
        
        $query = new Query();
        $query->fromArray($params);

        $this->container->get('models')->persist($query);
        $this->container->get('models')->flush();

        $this->View()->assign(
            array(
                'success' => true,
                'id' => $query->getId()
            )
        );
    }

    public function updateAction() 
    {
        $params = $this->Request()->getPost();
        $id = (int)$this->Request()->get('id');
        
        if($params['hasCronjob'] && empty($params['nextRun'])){
            $params['nextRun'] = new \DateTime();
        }

        /** @var Query $query */
        $query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);
        $query->fromArray($params);

        $this->container->get('models')->persist($query);
        $this->container->get('models')->flush();
        
        $this->View()->assign(
            array('success' => true)
        );
    }
    
    public function deleteAction() 
    {
        $id = (int)$this->Request()->get('id');

        /** @var Query $query */
        $query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);

        $this->container->get('models')->remove($query);
        $this->container->get('models')->flush();
        
        $this->View()->assign(
            array('success' => true)
        );
    }
    
    public function cloneAction() 
    {
        $id = (int)$this->Request()->get('id');

        /** @var Query $query */
        $query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);

        $query = clone $query;
        $query->setId(null);
        $query->setName('(Clone) ' . $query->getName());


        $this->container->get('models')->persist($query);
        $this->container->get('models')->flush();
        
        $this->View()->assign(
            array('success' => true)
        );
    }
    
    public function runAction() 
    {
        $sql = $this->Request()->get('query');
        $download = $this->Request()->get('download');
        $rowsetKey = $this->Request()->get('rowset');
        
        try {
            /** @var \mysqli|\Zend_Db_Statement_Pdo $query */
            $query = $this->container->get('wbm_query_manager.db')->query($sql);
            $data = array();
            $i = 0;

            do {
                $data[$i]['rowsetKey'] = $i;

                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){
                        $i++;
                        continue;
                    }

                    $recordFields = array_keys($records[0]);
                    $columns = array();
                    foreach($recordFields as $recordField){
                        $columns[] = array(
                            'header' => $recordField,
                            'dataIndex' => $recordField,
                            'flex' => 1
                        );
                    }

                    $data[$i]['fetchData'] = array(
                        'records' => $records,
                        'recordFields' => $recordFields,
                        'columns' => $columns
                    );

                    if($download){
                        $this->container->get('plugins')->Controller()->ViewRenderer()->setNoRender();
                        $now = new \DateTime();
                        $file = "query_" . $now->format('Y_m_d_h_i_s') . ".csv";
                        header("Content-Type: text/csv");
                        header("Content-Disposition: attachment; filename=\"$file\"");

                        $outputBuffer = fopen("php://output", 'w');
                        foreach(array_merge(array(0 => $recordFields),$records) as $val) {

                            fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
                        }
                        fclose($outputBuffer);

                        exit();
                    }
                } else {
                    $data[$i]['rowCount'] = $this->container->get('wbm_query_manager.db')->getRowCount($query);
                    $data[$i]['fetchData'] = null;
                }

                $i++;
            } while ($this->container->get('wbm_query_manager.db')->nextResult($query));

            $this->container->get('wbm_query_manager.db')->close($query);

            $this->View()->assign(
                array('success' => true, 'data' => array_reverse($data))
            );
        } catch (Exception $e) {
            $this->View()->assign(
                array('success' => false, 'data' => $e->getMessage())
            );
        }
    }
    
}



1		<?php
2		/**
3		* Query Manager
4		* Copyright (c) Webmatch GmbH
5		*
6		* This program is free software: you can redistribute it and/or modify
7		* it under the terms of the GNU General Public License as published by
8		* the Free Software Foundation, either version 3 of the License, or
9		* (at your option) any later version.
10		*
11		* This program is distributed in the hope that it will be useful,
12		* but WITHOUT ANY WARRANTY; without even the implied warranty of
13		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14		* GNU General Public License for more details.
15		*/
16
17		use WbmQueryManager\Models\Query;
18
19		/**
20		* Class Shopware_Controllers_Backend_WbmQueryManager
21		*/
22		class Shopware_Controllers_Backend_WbmQueryManager extends Shopware_Controllers_Backend_ExtJs {
23
24		public function postDispatch()
25		{
26		if (
27		$this->Request()->getActionName() === 'load' &&
28		$this->container->get('config')->getByNamespace('WbmQueryManager', 'autocomplete')
29		) {
30		$dbData = $this->container->getParameter('shopware.db');
31		$sql = "SELECT TABLE_NAME, COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = ?";
32		$tables = $this->container->get('shopware.db')->fetchAll(
33		$sql,
34		array($dbData['dbname']), \Zend_Db::FETCH_GROUP\|\Zend_Db::FETCH_COLUMN
35		);
36		$columns = [];
37		foreach ($tables as $table => $content) {
38		foreach ($content as $column) {
39		$columns[] = array(
40		'caption' => $table . '.' . $column,
41		'value' => '`' . $table . '`.`' . $column . '`',
42		'meta' => 'Column'
43		);
44		}
45		}
46		$hintOptions = json_encode(
47		array_merge(
48		array_map(
49		function($tableName) {
50		return array(
51		'caption' => $tableName,
52		'value' => '`' . $tableName . '`',
53		'meta' => 'Table'
54		);
55		},
56		array_keys($tables)
57		),
58		$columns
59		)
60		);
61		$this->View()->hintOptions = $hintOptions;
62		$this->View()->autocompleteActive = true;
63		}
64		}
65
66		public function indexAction()
67		{
68		$this->View()->loadTemplate("backend/wbm_query_manager/app.js");
69		}
70
71		public function listAction()
72		{
73		$id = $this->Request()->getParam('id', null);
74
75		/** @var \Doctrine\ORM\QueryBuilder $qb */
76		$qb = $this->container->get('models')->createQueryBuilder();
77		$qb->select(
78		array(
79		'query'
80		)
81		)
82		->from('WbmQueryManager\Models\Query', 'query');
83
84		if(!empty($id)){
85		$qb->where('query.id = :id')
86		->setParameter(':id', $id);
87		} else {
88		$qb->addOrderBy('query.name', 'ASC');
89		}
90
91		$data = $qb->getQuery()->getArrayResult();
92
93		$this->View()->assign(
94		array('success' => true, 'data' => $data)
95		);
96		}
97
98		public function createAction()
99		{
100		$params = $this->Request()->getPost();
101
102		if($params['hasCronjob'] && empty($params['nextRun'])){
103		$params['nextRun'] = new \DateTime();
104		}
105
106		$query = new Query();
107		$query->fromArray($params);
108
109		$this->container->get('models')->persist($query);
110		$this->container->get('models')->flush();
111
112		$this->View()->assign(
113		array(
114		'success' => true,
115		'id' => $query->getId()
116		)
117		);
118		}
119
120		public function updateAction()
121		{
122		$params = $this->Request()->getPost();
123		$id = (int)$this->Request()->get('id');
124
125		if($params['hasCronjob'] && empty($params['nextRun'])){
126		$params['nextRun'] = new \DateTime();
127		}
128
129		/** @var Query $query */
130		$query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);
131		$query->fromArray($params);
132
133		$this->container->get('models')->persist($query);
134		$this->container->get('models')->flush();
135
136		$this->View()->assign(
137		array('success' => true)
138		);
139		}
140
141		public function deleteAction()
142		{
143		$id = (int)$this->Request()->get('id');
144
145		/** @var Query $query */
146		$query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);
147
148		$this->container->get('models')->remove($query);
149		$this->container->get('models')->flush();
150
151		$this->View()->assign(
152		array('success' => true)
153		);
154		}
155
156		public function cloneAction()
157		{
158		$id = (int)$this->Request()->get('id');
159
160		/** @var Query $query */
161		$query = $this->container->get('models')->getRepository('WbmQueryManager\Models\Query')->find($id);
162
163		$query = clone $query;
164		$query->setId(null);
165		$query->setName('(Clone) ' . $query->getName());
		0 ignored issues – show Bug introduced 2017-03-07 15:57 UTC by Report Bug Copy Issue Report Consider using `$query->name`. There is an issue with `getName()` and APC-enabled PHP versions. Loading history...
166
167		$this->container->get('models')->persist($query);
168		$this->container->get('models')->flush();
169
170		$this->View()->assign(
171		array('success' => true)
172		);
173		}
174
175		public function runAction()
176		{
177		$sql = $this->Request()->get('query');
178		$download = $this->Request()->get('download');
179		$rowsetKey = $this->Request()->get('rowset');
180
181		try {
182		/** @var \mysqli\|\Zend_Db_Statement_Pdo $query */
183		$query = $this->container->get('wbm_query_manager.db')->query($sql);
184		$data = array();
185		$i = 0;
186
187		do {
188		$data[$i]['rowsetKey'] = $i;
189
190		if($this->container->get('wbm_query_manager.db')->getColumnCount($query)){
191		$records = $this->container->get('wbm_query_manager.db')->fetchAll($query);
192		$data[$i]['rowCount'] = $this->container->get('wbm_query_manager.db')->getRowCount($query);
193
194		if($download && $rowsetKey != $i){
195		$i++;
196		continue;
197		}
198
199		$recordFields = array_keys($records[0]);
200		$columns = array();
201		foreach($recordFields as $recordField){
202		$columns[] = array(
203		'header' => $recordField,
204		'dataIndex' => $recordField,
205		'flex' => 1
206		);
207		}
208
209		$data[$i]['fetchData'] = array(
210		'records' => $records,
211		'recordFields' => $recordFields,
212		'columns' => $columns
213		);
214
215		if($download){
216		$this->container->get('plugins')->Controller()->ViewRenderer()->setNoRender();
217		$now = new \DateTime();
218		$file = "query_" . $now->format('Y_m_d_h_i_s') . ".csv";
219		header("Content-Type: text/csv");
220		header("Content-Disposition: attachment; filename=\"$file\"");
221
222		$outputBuffer = fopen("php://output", 'w');
223	View Code Duplication	foreach(array_merge(array(0 => $recordFields),$records) as $val) {
		0 ignored issues – show Duplication introduced 2017-03-07 15:57 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
224		fputcsv($outputBuffer, $val, $this->container->get('config')->getByNamespace('WbmQueryManager', 'csv_field_separator'));
225		}
226		fclose($outputBuffer);
227
228		exit();
229		}
230		} else {
231		$data[$i]['rowCount'] = $this->container->get('wbm_query_manager.db')->getRowCount($query);
232		$data[$i]['fetchData'] = null;
233		}
234
235		$i++;
236		} while ($this->container->get('wbm_query_manager.db')->nextResult($query));
237
238		$this->container->get('wbm_query_manager.db')->close($query);
239
240		$this->View()->assign(
241		array('success' => true, 'data' => array_reverse($data))
242		);
243		} catch (Exception $e) {
244		$this->View()->assign(
245		array('success' => false, 'data' => $e->getMessage())
246		);
247		}
248		}
249
250		}
251
252

webmatch / WbmQueryManager

runAction() B last analyzed 2019-07-09 14:08 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

runAction() B
last analyzed 2019-07-09 14:08 UTC