BGC-192 @fixed patch

src/Phoenix/DoctrineMigrations/Version20191203165250.php

@@ -0,0 +1,70 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Logipro\Phoenix\DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+use Symfony\Component\Filesystem\Filesystem;
+use Logipro\Phoenix\Service\FileUploader;
+use Logipro\Phoenix\Service\FileUploaderInterface;
+use Logipro\Phoenix\Entity\Sequence;
+use Symfony\Component\DependencyInjection\ContainerAwareInterface;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+
+final class Version20191203165250 extends AbstractMigration
+implements ContainerAwareInterface
+{
+    private $fileUploader;
+
+    public function setContainer(ContainerInterface $container = null)
+    {
+        $this->fileUploader = $container->get(FileUploader::class);
+    }
+    public function up(Schema $schema): void
+    {
+        $fileUploader = $this->fileUploader;
+        $filesystem = new Filesystem();
+        $sequence = new Sequence();
+        $propertyName = 'image';
+
+        // extrait les images des sequences et regarde les sequences qui utilisent plusieurs fois la même image
+        $query = "SELECT COUNT(*) as `number`,`image` FROM `phx_sequence` WHERE `image` != '' GROUP BY `image` HAVING `number` > 1";
+        foreach ($this->connection->fetchAll($query) as $result) {
+            $imageName = $result['image'];
+
+            // recherche les identifiants des sequences de l'image
+            $query = 'SELECT `sequence_id` FROM `phx_sequence` WHERE `image`=\'' . $imageName . '\'';
+            $results = $this->connection->fetchAll($query);
+
+            // supprime le premier
+            array_shift($results);
+
+            // parcours les identifiants pour la copie
+            $queries = array();
+            foreach ($results as $result) {
+                $newFileName = $fileUploader->generateNewName($imageName);
+                try {
+                    $filesystem->copy(
+                        $fileUploader->buildUploadPublicPath($imageName, $sequence, $propertyName),
+                        $fileUploader->buildUploadPublicPath($newFileName, $sequence, $propertyName)
+                    );
+
+                    // après la copie, on met a jour l'objet
+                    $queries[] = 'UPDATE `phx_sequence` SET `image`=\'' . $newFileName . '\' WHERE `sequence_id`=' . $result['sequence_id'];
+                } catch (\Exception $exp) {
+                    dump($exp->getMessage());
+                }
+            }
+
+            foreach ($queries as $query)
+            {
+                $this->connection->executeQuery($query);
+            }
+        }
+    }
+
+    public function down(Schema $schema): void
+    { }
+}

src/Phoenix/Service/FileUploader.php

@@ -97,14 +97,27 @@ implements FileUploaderInterface
 	 * @param string $path Chemin relatif du fichier
 	 * @return string
 	 */
-	public function buildUploadPublicPath(string $path)
+	public function buildUploadPublicPath(string $path = null, AbstractEntity $entity = null, string $propertyName = null)
 	{
-		$pathPrefix = $this->getUploadPublicRootPath();
-
 		// Elimine le slash au début
-		$path = ltrim($path, '/');
+		$path = ltrim($path, DIRECTORY_SEPARATOR);
 
-		return sprintf('%s/%s', $pathPrefix, $path);
+		if ($entity && $propertyName) {
+			// ici, sert uniquement à tester si la méthode de l'entité existe
+			$this->getEntityValue($entity, $propertyName);
+
+			// plugin vich uploader
+			$mapping = $this->factory->fromObject($entity);
+			foreach ($mapping as $map) {
+
+				if ($map->getFileNamePropertyName() == $propertyName) {
+					$pathPrefix = $map->getUploadDestination();
+					return $pathPrefix . DIRECTORY_SEPARATOR . $path;
+				}
+			}
+		}
+		$pathPrefix = $this->getUploadPublicRootPath();
+		return $pathPrefix . DIRECTORY_SEPARATOR . $path;
 	}
 
 	/**
@@ -123,6 +136,14 @@ implements FileUploaderInterface
 		return sprintf('%s/%s', $pathPrefix, $path);
 	}
 
+	public function getUploadPublicPath(AbstractEntity $entity, string $propertyName)
+	{
+		$oldFileName = $this->getEntityValue($entity, $propertyName);
+
+		// fonctionnement normal
+		return $this->buildUploadPublicPath($oldFileName, $entity, $propertyName);
+	}
+
 	/**
 	 * Retourne l'URL complète vers un fichier à partir de son chemin
 	 * relatif dans le répertoire public des uploads.
@@ -139,32 +160,36 @@ implements FileUploaderInterface
 		return sprintf('%s/%s', $urlPrefix, $path);
 	}
 
-	public function cloneFile(AbstractEntity $entity, string $propertyName): string
+	private function getEntityValue(AbstractEntity $entity, string $propertyName)
+	{
+		// test le lien entre le propriété et l'objet
+		$getter = 'get' . ucfirst($propertyName);
+		if (!method_exists($entity, $getter)) {
+			throw new \Exception();
+		}
+		return $entity->{$getter}();
+	}
+
+	public function generateNewName(string $oldFileName): string
 	{
-		$mapping = $this->factory->fromObject($entity);
+		return uniqid() . '.' . pathinfo($oldFileName, PATHINFO_EXTENSION);
+	}
 
-		$newFileName = '';
+	public function cloneFile(AbstractEntity $entity, string $propertyName): string
+	{
 		$filesystem = new Filesystem();
-		foreach ($mapping as $map) {
-
-			if ($map->getFileNamePropertyName() == $propertyName) {
-				$getter = 'get' . ucfirst($propertyName);
-				$oldFileName = $entity->$getter();
-				$oldFilePath = $map->getUploadDestination() . DIRECTORY_SEPARATOR . $oldFileName;
-
-				if (is_file($oldFilePath)) {
-					$newFileName = uniqid() . '.' . pathinfo($oldFileName, PATHINFO_EXTENSION);
-					$newFilePath = $map->getUploadDestination() . DIRECTORY_SEPARATOR . $newFileName;
-
-					try {
-						$filesystem->copy($oldFilePath, $newFilePath);
-					} catch (\Exception $exp) {
-						dd($exp->getMessage());
-					}
-				}
-				break;
-			}
+		$oldFileName = $this->getEntityValue($entity, $propertyName);
+		$newFileName = $this->generateNewName($oldFileName);
+
+		try {
+			$filesystem->copy(
+				$this->buildUploadPublicPath($oldFileName, $entity, $propertyName),
+				$this->buildUploadPublicPath($newFileName, $entity, $propertyName)
+			);
+		} catch (\Exception $exp) {
+			dd($exp->getMessage());
 		}
+
 		return $newFileName;
 	}
 }