DoctrineMigrations\Version20210425203036

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getDescription()	0	4	1
A	up()	0	7	1
A	down()	0	3	1
A	insertData()	0	40	4

<?php

declare(strict_types=1);

namespace DoctrineMigrations;

use App\Enum\EmployeeStaffEnum;
use Doctrine\DBAL\Schema\Schema;
use Doctrine\Migrations\AbstractMigration;

final class Version20210425203036 extends AbstractMigration
{
    private const DATA = __DIR__.'/data/performances_duration_producers_age_limits.csv';

    public function getDescription() : string
    {
        return 'Added: performance age limit data, performance producer field with data, performance len with data';
    }

    public function up(Schema $schema) : void
    {
        $this->addSql('ALTER TABLE performances ADD producer_id INT DEFAULT NULL, ADD durationInMin INT NOT NULL, ADD extProducer VARCHAR(255) DEFAULT NULL');
        $this->addSql('ALTER TABLE performances ADD CONSTRAINT FK_8133AB2B89B658FE FOREIGN KEY (producer_id) REFERENCES employees (id) ON DELETE SET NULL');
        $this->addSql('CREATE INDEX IDX_8133AB2B89B658FE ON performances (producer_id)');
        $this->insertData();
    }

    public function down(Schema $schema) : void
    {
    }

    public function insertData()
    {
        $performances = array_map('str_getcsv', file(self::DATA));
        array_shift($performances); // remove headers

        foreach ($performances as $performance) {
            $slug = array_shift($performance);
            $title = array_shift($performance);

$title is not used, you could remove the assignment.

            $link = array_shift($performance);

$link is not used, you could remove the assignment.

            $ageLimit = array_shift($performance);
            $producer = array_shift($performance);
            $len = array_shift($performance);

            $inHouseProducer = $this->connection->fetchAssociative(
                'SELECT id, deletedAt FROM employees WHERE lastName LIKE :lastName',
                ['lastName' => '%'.trim(explode(' ', $producer)[0]).'%']
            );

            if ($inHouseProducer) {
                $this->addSql(
                    'UPDATE performances SET durationInMin=:len, ageLimit=:ageLimit, producer_id=:producer WHERE slug=:slug',
                    ['len' => (int) $len, 'ageLimit' => (int) $ageLimit, 'producer' => $inHouseProducer['id'], 'slug' => $slug]
                );

                if ($inHouseProducer['deletedAt']) {
                    $this->addSql(
                        'UPDATE employees SET deletedAt=NULL, deletedBy=NULL, staff=:staff WHERE id=:id',
                        ['staff' => EmployeeStaffEnum::EPOCH, 'id' => $inHouseProducer['id']]
                    );
                }

                continue;
            }

            $this->addSql(
                'UPDATE performances SET durationInMin=:len, ageLimit=:ageLimit, extProducer=:producer WHERE slug=:slug',
                ['len' => (int) $len, 'ageLimit' => (int) $ageLimit, 'producer' => $producer, 'slug' => $slug]
            );
        }
    }
}