ImportService::import() - Code Metrics - Inspection of "Adds support for child admin imports" - sigmapix/SigmapixSonataImportBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 1d945d...23ac57 )

unknown

created 2020-08-13 13:13 UTC

ImportService::import() B

↳ Parent: ImportService

Complexity

Conditions	7
Paths	12

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	42
rs	8.3146
c	0
b	0
f	0
cc	7
nc	12
nop	4

<?php

namespace Sigmapix\Sonata\ImportBundle\Service;

use Doctrine\ORM\EntityManagerInterface;
use Port\Csv\CsvReader;
use Port\Doctrine\DoctrineWriter;
use Port\Excel\ExcelReader;
use Port\Steps\Step\MappingStep;
use Port\Steps\StepAggregator;
use Sonata\AdminBundle\Admin\AdminInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Symfony\Component\Form\Form;
use Symfony\Component\Form\SubmitButton;
use Symfony\Component\HttpFoundation\File\UploadedFile;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Session\SessionInterface;
use Sigmapix\Sonata\ImportBundle\Step\AddParentStep;
use Symfony\Component\PropertyAccess\PropertyPath;

final class ImportService
{
    /**
     * @var EntityManagerInterface
     */
    private $em;

    /**
     * @var SessionInterface
     */
    private $session;

    /**
     * @var ContainerInterface
     */
    private $container;

    /**
     * @var string
     */
    private $doctrineWriterClass;

    /**
     * ImportService constructor.
     *
     * @param EntityManagerInterface $em
     * @param $session
     * @param ContainerInterface $container
     * @param string             $doctrineWriterClass
     */
    public function __construct(EntityManagerInterface $em, $session, ContainerInterface $container, string $doctrineWriterClass)
    {
        $this->em = $em;
        $this->session = $session;
        $this->container = $container;
        $this->doctrineWriterClass = $doctrineWriterClass;
    }

    /**
     * @param UploadedFile $file
     *
     * @return array
     */
    public function getHeaders(UploadedFile $file)
    {
        $reader = $this->getReader($file);
        $columnHeaders = array_filter($reader->getColumnHeaders(), function ($h) {return null !== $h; });
        $headers = array_flip($this->fixHeadersEncoding($columnHeaders));
        array_walk($headers, function (&$v, $k) use ($headers) { $v = $k; });

        return $headers;
    }

    /**
     * @param UploadedFile   $file
     * @param Form           $form
     * @param AdminInterface $admin
     *
     * @return mixed
     */
    public function import(UploadedFile $file, Form $form, AdminInterface $admin, Request $request)
    {
        $mapping = [];
        foreach ($form as $f) {
            if ($f instanceof SubmitButton) {
                continue;
            }
            $mapping[$f->getName()] = $f->getNormData();
        }

        $reader = $this->getReader($file);
        // Replace columnsHeader names with entity field name in our $mapping
        $columnHeaders = array_map(function ($h) use ($mapping) {
            $k = array_search($h, (array) $mapping, true);

            return false === $k ? $h : $k;
        }, $this->fixHeadersEncoding($reader->getColumnHeaders()));
        $reader->setColumnHeaders($columnHeaders);

        /** @var DoctrineWriter $writer */
        $writer = new $this->doctrineWriterClass($this->em, \get_class($form->getData()));
        if (method_exists($writer, 'setContainer')) {
            $writer->setContainer($this->container);
        }
        $writer->disableTruncate();

        $workflow = new StepAggregator($reader);

        if ($admin->isChild() && $admin->getParentAssociationMapping()) {

            $parent = $admin->getParent()->getObject($request->get($admin->getParent()->getIdParameter()));
            $propertyAccessor = $admin->getConfigurationPool()->getPropertyAccessor();
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
            $propertyPath = new PropertyPath($admin->getParentAssociationMapping());

            $workflow->addStep(new AddParentStep($propertyPath, $parent));
        }

        $workflow->addWriter($writer);
        $admin->configureImportSteps($workflow);


        $result = $workflow->process();

        return $result;
    }

    /**
     * Get session.
     *
     * @return
     */
    public function getSession()
    {
        return $this->session;
    }

    /**
     * Set session.
     *
     * @return $this
     */
    public function setSession($session)
    {
        $this->session = $session;

        return $this;
    }

    private function fixHeadersEncoding($columnHeaders)
    {
        $columnHeaders = array_map(
            function ($h) {
                if (!empty($h) && \is_string($h) && 'UTF-8' !== mb_detect_encoding($h)) {
                    $h = utf8_encode($h);
                }

                return trim($h);
            }, $columnHeaders);

        return $columnHeaders;
    }

    /**
     * @param UploadedFile $file
     *
     * @return CsvReader|ExcelReader
     */
    private function getReader(UploadedFile $file)
    {
        $pathFile = $file->getRealPath();
        $fileExtension = $file->guessExtension();
        $excelExtensions = ['xls', 'xlsx', 'zip'];

        if (\in_array($fileExtension, $excelExtensions)) {
            $reader = new ExcelReader(new \SplFileObject($pathFile), 0, 0, true);
        } else {
            $reader = new CsvReader(new \SplFileObject($pathFile), ';');
            $reader->setHeaderRowNumber(0, CsvReader::DUPLICATE_HEADERS_INCREMENT);
        }

        return $reader;
    }
}


1			<?php
2
3			namespace Sigmapix\Sonata\ImportBundle\Service;
4
5			use Doctrine\ORM\EntityManagerInterface;
6			use Port\Csv\CsvReader;
7			use Port\Doctrine\DoctrineWriter;
8			use Port\Excel\ExcelReader;
9			use Port\Steps\Step\MappingStep;
10			use Port\Steps\StepAggregator;
11			use Sonata\AdminBundle\Admin\AdminInterface;
12			use Symfony\Component\DependencyInjection\ContainerInterface;
13			use Symfony\Component\Form\Form;
14			use Symfony\Component\Form\SubmitButton;
15			use Symfony\Component\HttpFoundation\File\UploadedFile;
16			use Symfony\Component\HttpFoundation\Request;
17			use Symfony\Component\HttpFoundation\Session\SessionInterface;
18			use Sigmapix\Sonata\ImportBundle\Step\AddParentStep;
19			use Symfony\Component\PropertyAccess\PropertyPath;
20
21			final class ImportService
22			{
23			/**
24			* @var EntityManagerInterface
25			*/
26			private $em;
27
28			/**
29			* @var SessionInterface
30			*/
31			private $session;
32
33			/**
34			* @var ContainerInterface
35			*/
36			private $container;
37
38			/**
39			* @var string
40			*/
41			private $doctrineWriterClass;
42
43			/**
44			* ImportService constructor.
45			*
46			* @param EntityManagerInterface $em
47			* @param $session
48			* @param ContainerInterface $container
49			* @param string $doctrineWriterClass
50			*/
51			public function __construct(EntityManagerInterface $em, $session, ContainerInterface $container, string $doctrineWriterClass)
52			{
53			$this->em = $em;
54			$this->session = $session;
55			$this->container = $container;
56			$this->doctrineWriterClass = $doctrineWriterClass;
57			}
58
59			/**
60			* @param UploadedFile $file
61			*
62			* @return array
63			*/
64			public function getHeaders(UploadedFile $file)
65			{
66			$reader = $this->getReader($file);
67			$columnHeaders = array_filter($reader->getColumnHeaders(), function ($h) {return null !== $h; });
68			$headers = array_flip($this->fixHeadersEncoding($columnHeaders));
69			array_walk($headers, function (&$v, $k) use ($headers) { $v = $k; });
70
71			return $headers;
72			}
73
74			/**
75			* @param UploadedFile $file
76			* @param Form $form
77			* @param AdminInterface $admin
78			*
79			* @return mixed
80			*/
81			public function import(UploadedFile $file, Form $form, AdminInterface $admin, Request $request)
82			{
83			$mapping = [];
84			foreach ($form as $f) {
85			if ($f instanceof SubmitButton) {
86			continue;
87			}
88			$mapping[$f->getName()] = $f->getNormData();
89			}
90
91			$reader = $this->getReader($file);
92			// Replace columnsHeader names with entity field name in our $mapping
93			$columnHeaders = array_map(function ($h) use ($mapping) {
94			$k = array_search($h, (array) $mapping, true);
95
96			return false === $k ? $h : $k;
97			}, $this->fixHeadersEncoding($reader->getColumnHeaders()));
98			$reader->setColumnHeaders($columnHeaders);
99
100			/** @var DoctrineWriter $writer */
101			$writer = new $this->doctrineWriterClass($this->em, \get_class($form->getData()));
102			if (method_exists($writer, 'setContainer')) {
103			$writer->setContainer($this->container);
104			}
105			$writer->disableTruncate();
106
107			$workflow = new StepAggregator($reader);
108
109			if ($admin->isChild() && $admin->getParentAssociationMapping()) {
			0 ignored issues – show Bug introduced 2020-08-13 13:42 UTC by Report Bug Copy Issue Report The method `getParentAssociationMapping()` does not exist on `Sonata\AdminBundle\Admin\AdminInterface`. Did you maybe mean `getParent()`? This check marks calls to methods that do not seem to exist on an object. This is most likely the result of a method being renamed without all references to it being renamed likewise. Loading history...
110			$parent = $admin->getParent()->getObject($request->get($admin->getParent()->getIdParameter()));
111			$propertyAccessor = $admin->getConfigurationPool()->getPropertyAccessor();
			0 ignored issues – show Unused Code introduced 2020-08-13 13:42 UTC by Report Bug Copy Issue Report `$propertyAccessor` is not used, you could remove the assignment. This check looks for variable assignements that are either overwritten by other assignments or where the variable is not used subsequently. $myVar = 'Value'; $higher = false; if (rand(1, 6) > 3) { $higher = true; } else { $higher = false; } Both the `$myVar` assignment in line 1 and the `$higher` assignment in line 2 are dead. The first because `$myVar` is never used and the second because `$higher` is always overwritten for every possible time line. Loading history...
112			$propertyPath = new PropertyPath($admin->getParentAssociationMapping());
			0 ignored issues – show Bug introduced 2020-08-13 13:42 UTC by Report Bug Copy Issue Report The method `getParentAssociationMapping()` does not exist on `Sonata\AdminBundle\Admin\AdminInterface`. Did you maybe mean `getParent()`? This check marks calls to methods that do not seem to exist on an object. This is most likely the result of a method being renamed without all references to it being renamed likewise. Loading history...
113			$workflow->addStep(new AddParentStep($propertyPath, $parent));
114			}
115
116			$workflow->addWriter($writer);
117			$admin->configureImportSteps($workflow);
			0 ignored issues – show Bug introduced 2018-01-11 14:17 UTC by Report Bug Copy Issue Report The method `configureImportSteps()` does not exist on `Sonata\AdminBundle\Admin\AdminInterface`. Did you maybe mean `configure()`? This check marks calls to methods that do not seem to exist on an object. This is most likely the result of a method being renamed without all references to it being renamed likewise. Loading history...
118
119			$result = $workflow->process();
120
121			return $result;
122			}
123
124			/**
125			* Get session.
126			*
127			* @return
128			*/
129			public function getSession()
130			{
131			return $this->session;
132			}
133
134			/**
135			* Set session.
136			*
137			* @return $this
138			*/
139			public function setSession($session)
140			{
141			$this->session = $session;
142
143			return $this;
144			}
145
146			private function fixHeadersEncoding($columnHeaders)
147			{
148			$columnHeaders = array_map(
149			function ($h) {
150			if (!empty($h) && \is_string($h) && 'UTF-8' !== mb_detect_encoding($h)) {
151			$h = utf8_encode($h);
152			}
153
154			return trim($h);
155			}, $columnHeaders);
156
157			return $columnHeaders;
158			}
159
160			/**
161			* @param UploadedFile $file
162			*
163			* @return CsvReader\|ExcelReader
164			*/
165			private function getReader(UploadedFile $file)
166			{
167			$pathFile = $file->getRealPath();
168			$fileExtension = $file->guessExtension();
169			$excelExtensions = ['xls', 'xlsx', 'zip'];
170
171			if (\in_array($fileExtension, $excelExtensions)) {
172			$reader = new ExcelReader(new \SplFileObject($pathFile), 0, 0, true);
173			} else {
174			$reader = new CsvReader(new \SplFileObject($pathFile), ';');
175			$reader->setHeaderRowNumber(0, CsvReader::DUPLICATE_HEADERS_INCREMENT);
176			}
177
178			return $reader;
179			}
180			}
181

sigmapix / SigmapixSonataImportBundle

GitHub Access Token became invalid

Push — master ( 1d945d...23ac57 )

ImportService::import() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like