Phase\TakeATicket\SongLoader

Complexity

Total Complexity

13

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	run()	0	49	6
A	setShowProgress()	0	5	1
B	printProgressMarker()	0	15	5
A	getRowMapper()	0	4	1

<?php

/**
 * Created by PhpStorm.
 * User: wechsler
 * Date: 21/08/15
 * Time: 06:53
 */

namespace Phase\TakeATicket;

use Doctrine\DBAL\Connection;
use Iterator;
use Phase\TakeATicket\DataSource\Factory;
use Phase\TakeATicket\SongLoader\RclRowMapper;

class SongLoader
{
    const CODE_LENGTH = 6; // min to avoid clashes

    protected $startRow = 2;

    protected $showProgress = false;

    /**
     * Store contents of specified XLS file to the given database handle
     *
     * @param  string $sourceFile Path to file
     * @param  Connection $dbConn DB connection
     * @return int Number of non-duplicate songs stored
     * @throws \PHPExcel_Exception
     * @throws \PHPExcel_Reader_Exception
     * @throws \Doctrine\DBAL\DBALException
     */
    public function run($sourceFile, Connection $dbConn)
    {

        $objPHPExcel = \PHPExcel_IOFactory::load($sourceFile);
        $dataStore = Factory::datasourceFromDbConnection($dbConn);
        // empty table - reset autoincrement if it has one
        $dataStore->resetCatalogue(); //FIXME clear tickets here too?
        $mapper = $this->getRowMapper($dataStore);
        $mapper->init();

        $iterator = $objPHPExcel->getSheet()->getRowIterator($this->startRow);

        $i = 1;
        foreach ($iterator as $sourceRow) {
            $flattenedRow = [];
            /**
             * @var \PHPExcel_Worksheet_Row $sourceRow
             */
            $cells = $sourceRow->getCellIterator();
            /**
             * @var Iterator $cells
             */
            foreach ($cells as $cell) {
                /**
                 * @var \PHPExcel_Cell $cell
                 */
                $column = $cell->getColumn();
                $content = $cell->getFormattedValue();

                $flattenedRow[$column] = trim($content);
            }

            if (implode($flattenedRow, '') !== '') {
                $storedOk = $mapper->storeRawRow($flattenedRow);
                if ($storedOk) {
                    $this->printProgressMarker($i);
                } else {
                    print('x');
                }
                $i++;
            }
        }

        $total = $i - 1;
        if ($this->showProgress) {
            echo "\nImported $total songs\n";
        }
        return $total;
    }

    /**
     * @param bool $showProgress
     * @return SongLoader
     */
    public function setShowProgress($showProgress)
    {
        $this->showProgress = $showProgress;
        return $this;
    }

    /**
     * @param $i
     */
    protected function printProgressMarker($i)
    {
        if ($this->showProgress) {
            if (!($i % 100)) {
                echo $i;
            } else {
                if (!($i % 10)) {
                    echo '.';
                }
            }
            if (!($i % 1000)) {
                echo "\n";
            }
        }
    }

    /**
     * FIXME redefine as return RowMapperInterface
     *
     * @param $dataStore
     * @return RclRowMapper
     */
    protected function getRowMapper($dataStore)
    {
        return new RclRowMapper($dataStore);
    }
}