Version20201212203625::up() - Code Metrics - Inspection of "Resources: Fix repo calls after migration fixes" - chamilo/chamilo-lms - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 0b60a0...db12d9 )

by Julito

created 2020-12-14 15:56 UTC

Version20201212203625::up() F

↳ Parent: Version20201212203625

Complexity

Conditions	22
Paths	4629

Size

Total Lines	188
Code Lines	114

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	22
eloc	114
nc	4629
nop	1
dl	0
loc	188
rs	0
c	1
b	0
f	0

How to fix Long Method Complexity

<?php

declare(strict_types=1);

namespace Chamilo\CoreBundle\Migrations\Schema\V200;

use Chamilo\CoreBundle\Entity\AccessUrl;
use Chamilo\CoreBundle\Entity\AccessUrlRelCourse;
use Chamilo\CoreBundle\Entity\ResourceLink;
use Chamilo\CoreBundle\Migrations\AbstractMigrationChamilo;
use Chamilo\CoreBundle\Repository\Node\CourseRepository;
use Chamilo\CoreBundle\Repository\Node\UserRepository;
use Chamilo\CoreBundle\Repository\SessionRepository;
use Chamilo\CourseBundle\Entity\CDocument;
use Chamilo\CourseBundle\Repository\CDocumentRepository;
use Chamilo\CourseBundle\Repository\CGroupRepository;
use Chamilo\Kernel;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;
use Symfony\Component\HttpFoundation\File\UploadedFile;

/**
 * Auto-generated Migration: Please modify to your needs!
 */
final class Version20201212203625 extends AbstractMigrationChamilo
{
    public function getDescription(): string
    {
        return 'Migrate documents';
    }

    public function up(Schema $schema): void
    {
        $container = $this->getContainer();
        $doctrine = $container->get('doctrine');
        $em = $doctrine->getManager();
        /** @var Connection $connection */
        $connection = $em->getConnection();

        $documentRepo = $container->get(CDocumentRepository::class);
        $courseRepo = $container->get(CourseRepository::class);
        $sessionRepo = $container->get(SessionRepository::class);
        $groupRepo = $container->get(CGroupRepository::class);
        $userRepo = $container->get(UserRepository::class);

        /** @var Kernel $kernel */
        $kernel = $container->get('kernel');
        $rootPath = $kernel->getProjectDir();

        $userList = [];
        $groupList = [];
        $sessionList = [];
        $batchSize = self::BATCH_SIZE;
        $urlRepo = $em->getRepository(AccessUrl::class);
        $urls = $urlRepo->findAll();

        // Adding documents to the resource node tree.
        $admin = $this->getAdmin();
        /** @var AccessUrl $url */
        foreach ($urls as $url) {
            $accessUrlRelCourses = $url->getCourses();
            /** @var AccessUrlRelCourse $accessUrlRelCourse */
            foreach ($accessUrlRelCourses as $accessUrlRelCourse) {
                $counter = 1;
                $course = $accessUrlRelCourse->getCourse();
                $courseId = $course->getId();
                $courseCode = $course->getCode();
                $course = $courseRepo->find($courseId);

                $sql = "SELECT * FROM c_document WHERE c_id = $courseId ORDER BY filetype DESC";
                $result = $connection->executeQuery($sql);
                $documents = $result->fetchAllAssociative();
                foreach ($documents as $documentData) {
                    $documentId = $documentData['iid'];
                    $documentPath = $documentData['path'];

                    /** @var CDocument $document */
                    $document = $documentRepo->find($documentId);
                    if ($document->hasResourceNode()) {
                        continue;
                    }

                    $sql = "SELECT * FROM c_item_property
                            WHERE tool = 'document' AND c_id = $courseId AND ref = $documentId";
                    $result = $connection->executeQuery($sql);
                    $items = $result->fetchAllAssociative();

                    // For some reason this document doesnt have a c_item_property value.
                    if (empty($items)) {
                        continue;
                    }

                    $createNode = false;
                    $resourceNode = null;
                    $parent = null;
                    if ('.' !== dirname($documentPath)) {
                        $parentId = \DocumentManager::get_document_id(
                            ['real_id' => $courseId],
                            dirname($documentPath)
                        );
                        $parent = $documentRepo->find($parentId);
                        /*$dirList = explode('/', $documentPath);
                        $dirList = array_filter($dirList);
                        $len = count($dirList) + 1;
                        $realDir = '';
                        for ($i = 1; $i < $len; $i++) {
                            $realDir .= '/'.(isset($dirList[$i]) ? $dirList[$i] : '');
                            $parentId = \DocumentManager::get_document_id(['real_id'=> $courseId], $realDir);
                            var_dump($parentId);
                            if (!empty($parentId)) {
                            }
                        }*/
                    }

                    if (null === $parent) {
                        $parent = $course;
                    }

                    $document->setParent($parent);
                    foreach ($items as $item) {
                        $sessionId = $item['session_id'];
                        $visibility = $item['visibility'];
                        $userId = $item['insert_user_id'];
                        $groupId = $item['to_group_id'];

                        $newVisibility = ResourceLink::VISIBILITY_PENDING;
                        switch ($visibility) {
                            case 0:
                                $newVisibility = ResourceLink::VISIBILITY_PENDING;
                                break;
                            case 1:
                                $newVisibility = ResourceLink::VISIBILITY_PUBLISHED;
                                break;
                            case 2:
                                $newVisibility = ResourceLink::VISIBILITY_DELETED;
                                break;
                        }

                        if (isset($userList[$userId])) {
                            $user = $userList[$userId];
                        } else {
                            $user = $userList[$userId] = $userRepo->find($userId);
                        }

                        if (null === $user) {
                            $user = $admin;
                        }

                        $session = null;
                        if (!empty($sessionId)) {
                            if (isset($sessionList[$sessionId])) {
                                $session = $sessionList[$sessionId];
                            } else {
                                $session = $sessionList[$sessionId] = $sessionRepo->find($sessionId);
                            }
                        }

                        $group = null;
                        if (!empty($groupId)) {
                            if (isset($groupList[$groupId])) {
                                $group = $groupList[$groupId];
                            } else {
                                $group = $groupList[$groupId] = $groupRepo->find($groupId);
                            }
                        }

                        if (null === $resourceNode) {
                            $resourceNode = $documentRepo->addResourceNode($document, $user, $parent);
                            $em->persist($resourceNode);
                        }
                        $document->addCourseLink($course, $session, $group, $newVisibility);
                        $em->persist($document);
                        $createNode = true;
                    }

                    $filePath = $rootPath.'/app/courses/'.$course->getDirectory().'/document/'.$documentPath;
                    if (!is_dir($filePath)) {
                        $createNode = false;
                        if (file_exists($filePath)) {
                            $mimeType = mime_content_type($filePath);
                            $file = new UploadedFile($filePath, basename($documentPath), $mimeType, null, true);
                            if ($file) {
                                $createNode = true;
                                $documentRepo->addFile($document, $file);
                            } else {
                                $this->warnIf(
                                    true,
                                    'Cannot migrate doc #'.$documentData['iid'].' path: '.$documentPath.' '
                                );
                                $createNode = false;
                            }
                        } else {
                            $this->warnIf(
                                true,
                                'Cannot migrate doc #'.$documentData['iid'].' file not found: '.$documentPath
                            );
                        }
                    }

                    //var_dump($createNode,$documentPath, $documentData['iid'], file_exists($filePath));
                    $em->persist($document);
                    $em->flush();
                    //$em->clear();
                    /*if ($createNode) {
                        $em->persist($document);
                        if (0 === $counter % $batchSize) {
                            $em->flush();
                            $em->clear();
                        }

                        $counter++;
                    } else {
                        $em->clear();
                    }*/
                }
            }

            $em->flush();
            $em->clear();
        }
    }

    public function down(Schema $schema): void
    {
        // this down() migration is auto-generated, please modify it to your needs
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Chamilo\CoreBundle\Migrations\Schema\V200;
6
7			use Chamilo\CoreBundle\Entity\AccessUrl;
8			use Chamilo\CoreBundle\Entity\AccessUrlRelCourse;
9			use Chamilo\CoreBundle\Entity\ResourceLink;
10			use Chamilo\CoreBundle\Migrations\AbstractMigrationChamilo;
11			use Chamilo\CoreBundle\Repository\Node\CourseRepository;
12			use Chamilo\CoreBundle\Repository\Node\UserRepository;
13			use Chamilo\CoreBundle\Repository\SessionRepository;
14			use Chamilo\CourseBundle\Entity\CDocument;
15			use Chamilo\CourseBundle\Repository\CDocumentRepository;
16			use Chamilo\CourseBundle\Repository\CGroupRepository;
17			use Chamilo\Kernel;
18			use Doctrine\DBAL\Connection;
19			use Doctrine\DBAL\Schema\Schema;
20			use Symfony\Component\HttpFoundation\File\UploadedFile;
21
22			/**
23			* Auto-generated Migration: Please modify to your needs!
24			*/
25			final class Version20201212203625 extends AbstractMigrationChamilo
26			{
27			public function getDescription(): string
28			{
29			return 'Migrate documents';
30			}
31
32			public function up(Schema $schema): void
33			{
34			$container = $this->getContainer();
35			$doctrine = $container->get('doctrine');
36			$em = $doctrine->getManager();
37			/** @var Connection $connection */
38			$connection = $em->getConnection();
39
40			$documentRepo = $container->get(CDocumentRepository::class);
41			$courseRepo = $container->get(CourseRepository::class);
42			$sessionRepo = $container->get(SessionRepository::class);
43			$groupRepo = $container->get(CGroupRepository::class);
44			$userRepo = $container->get(UserRepository::class);
45
46			/** @var Kernel $kernel */
47			$kernel = $container->get('kernel');
48			$rootPath = $kernel->getProjectDir();
49
50			$userList = [];
51			$groupList = [];
52			$sessionList = [];
53			$batchSize = self::BATCH_SIZE;
54			$urlRepo = $em->getRepository(AccessUrl::class);
55			$urls = $urlRepo->findAll();
56
57			// Adding documents to the resource node tree.
58			$admin = $this->getAdmin();
59			/** @var AccessUrl $url */
60			foreach ($urls as $url) {
61			$accessUrlRelCourses = $url->getCourses();
62			/** @var AccessUrlRelCourse $accessUrlRelCourse */
63			foreach ($accessUrlRelCourses as $accessUrlRelCourse) {
64			$counter = 1;
65			$course = $accessUrlRelCourse->getCourse();
66			$courseId = $course->getId();
67			$courseCode = $course->getCode();
68			$course = $courseRepo->find($courseId);
69
70			$sql = "SELECT * FROM c_document WHERE c_id = $courseId ORDER BY filetype DESC";
71			$result = $connection->executeQuery($sql);
72			$documents = $result->fetchAllAssociative();
73			foreach ($documents as $documentData) {
74			$documentId = $documentData['iid'];
75			$documentPath = $documentData['path'];
76
77			/** @var CDocument $document */
78			$document = $documentRepo->find($documentId);
79			if ($document->hasResourceNode()) {
80			continue;
81			}
82
83			$sql = "SELECT * FROM c_item_property
84			WHERE tool = 'document' AND c_id = $courseId AND ref = $documentId";
85			$result = $connection->executeQuery($sql);
86			$items = $result->fetchAllAssociative();
87
88			// For some reason this document doesnt have a c_item_property value.
89			if (empty($items)) {
90			continue;
91			}
92
93			$createNode = false;
94			$resourceNode = null;
95			$parent = null;
96			if ('.' !== dirname($documentPath)) {
97			$parentId = \DocumentManager::get_document_id(
98			['real_id' => $courseId],
99			dirname($documentPath)
100			);
101			$parent = $documentRepo->find($parentId);
102			/*$dirList = explode('/', $documentPath);
103			$dirList = array_filter($dirList);
104			$len = count($dirList) + 1;
105			$realDir = '';
106			for ($i = 1; $i < $len; $i++) {
107			$realDir .= '/'.(isset($dirList[$i]) ? $dirList[$i] : '');
108			$parentId = \DocumentManager::get_document_id(['real_id'=> $courseId], $realDir);
109			var_dump($parentId);
110			if (!empty($parentId)) {
111			}
112			}*/
113			}
114
115			if (null === $parent) {
116			$parent = $course;
117			}
118
119			$document->setParent($parent);
120			foreach ($items as $item) {
121			$sessionId = $item['session_id'];
122			$visibility = $item['visibility'];
123			$userId = $item['insert_user_id'];
124			$groupId = $item['to_group_id'];
125
126			$newVisibility = ResourceLink::VISIBILITY_PENDING;
127			switch ($visibility) {
128			case 0:
129			$newVisibility = ResourceLink::VISIBILITY_PENDING;
130			break;
131			case 1:
132			$newVisibility = ResourceLink::VISIBILITY_PUBLISHED;
133			break;
134			case 2:
135			$newVisibility = ResourceLink::VISIBILITY_DELETED;
136			break;
137			}
138
139			if (isset($userList[$userId])) {
140			$user = $userList[$userId];
141			} else {
142			$user = $userList[$userId] = $userRepo->find($userId);
143			}
144
145			if (null === $user) {
146			$user = $admin;
147			}
148
149			$session = null;
150			if (!empty($sessionId)) {
151			if (isset($sessionList[$sessionId])) {
152			$session = $sessionList[$sessionId];
153			} else {
154			$session = $sessionList[$sessionId] = $sessionRepo->find($sessionId);
155			}
156			}
157
158			$group = null;
159			if (!empty($groupId)) {
160			if (isset($groupList[$groupId])) {
161			$group = $groupList[$groupId];
162			} else {
163			$group = $groupList[$groupId] = $groupRepo->find($groupId);
164			}
165			}
166
167			if (null === $resourceNode) {
168			$resourceNode = $documentRepo->addResourceNode($document, $user, $parent);
169			$em->persist($resourceNode);
170			}
171			$document->addCourseLink($course, $session, $group, $newVisibility);
172			$em->persist($document);
173			$createNode = true;
174			}
175
176			$filePath = $rootPath.'/app/courses/'.$course->getDirectory().'/document/'.$documentPath;
177			if (!is_dir($filePath)) {
178			$createNode = false;
179			if (file_exists($filePath)) {
180			$mimeType = mime_content_type($filePath);
181			$file = new UploadedFile($filePath, basename($documentPath), $mimeType, null, true);
182			if ($file) {
183			$createNode = true;
184			$documentRepo->addFile($document, $file);
185			} else {
186			$this->warnIf(
187			true,
188			'Cannot migrate doc #'.$documentData['iid'].' path: '.$documentPath.' '
189			);
190			$createNode = false;
191			}
192			} else {
193			$this->warnIf(
194			true,
195			'Cannot migrate doc #'.$documentData['iid'].' file not found: '.$documentPath
196			);
197			}
198			}
199
200			//var_dump($createNode,$documentPath, $documentData['iid'], file_exists($filePath));
201			$em->persist($document);
202			$em->flush();
203			//$em->clear();
204			/*if ($createNode) {
205			$em->persist($document);
206			if (0 === $counter % $batchSize) {
207			$em->flush();
208			$em->clear();
209			}
210
211			$counter++;
212			} else {
213			$em->clear();
214			}*/
215			}
216			}
217
218			$em->flush();
219			$em->clear();
220			}
221			}
222
223			public function down(Schema $schema): void
224			{
225			// this down() migration is auto-generated, please modify it to your needs
226			}
227			}
228

chamilo / chamilo-lms

Push — master ( 0b60a0...db12d9 )

Version20201212203625::up() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like