Chamilo\CoreBundle\Migrations\Schema\V200\Version20201212195011::up()

Complexity

Conditions	15
Paths	315

Size

Total Lines	113
Code Lines	74

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function up(Schema $schema): void
    {
        $container = $this->getContainer();
        $em = $this->getEntityManager();
        $connection = $em->getConnection();

        $courseRepo = $container->get(CourseRepository::class);
        $sessionRepo = $container->get(SessionRepository::class);
        $toolRepo = $container->get(CToolRepository::class);
        $urlRepo = $em->getRepository(AccessUrl::class);
        $userRepo = $container->get(UserRepository::class);

        $batchSize = self::BATCH_SIZE;
        $admin = $this->getAdmin();
        $adminId = $admin->getId();

        // Adding courses to the resource node tree.
        $urls = $urlRepo->findAll();

        /** @var AccessUrl $url */
        foreach ($urls as $url) {
            $counter = 1;
            /** @var AccessUrl $urlEntity */
            $urlEntity = $urlRepo->find($url->getId());
            $accessUrlRelCourses = $urlEntity->getCourses();
            /** @var AccessUrlRelCourse $accessUrlRelCourse */
            foreach ($accessUrlRelCourses as $accessUrlRelCourse) {
                $course = $accessUrlRelCourse->getCourse();
                $course = $courseRepo->find($course->getId());
                if ($course->hasResourceNode()) {
                    continue;
                }
                $urlEntity = $urlRepo->find($url->getId());
                $adminEntity = $userRepo->find($adminId);
                $courseRepo->addResourceNode($course, $adminEntity, $urlEntity);
                $em->persist($course);

                // Add groups.
                //$course = $course->getGroups();
                if (($counter % $batchSize) === 0) {
                    $em->flush();
                    $em->clear(); // Detaches all objects from Doctrine!
                }
                $counter++;
            }
        }

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

        // Special course.
        $extraFieldType = ExtraField::COURSE_FIELD_TYPE;
        $sql = "SELECT id FROM extra_field
                WHERE extra_field_type = $extraFieldType AND variable = 'special_course'";
        $result = $connection->executeQuery($sql);
        $extraFieldId = $result->fetchOne();

        $specialCourses = '';
        if (!empty($extraFieldId)) {
            $sql = 'SELECT DISTINCT(item_id)
                    FROM extra_field_values
                    WHERE field_id = '.$extraFieldId." AND value = '1'";
            $result = $connection->executeQuery($sql);
            $specialCourses = $result->fetchAllAssociative();
            if (!empty($specialCourses)) {
                $specialCourses = array_column($specialCourses, 'item_id');
            }
        }

        // Migrating c_tool.
        $q = $em->createQuery('SELECT c FROM Chamilo\CoreBundle\Entity\Course c');
        /** @var Course $course */
        foreach ($q->toIterable() as $course) {
            $counter = 1;
            $courseId = $course->getId();

            if (!empty($specialCourses) && in_array($courseId, $specialCourses)) {
                $this->addSql("UPDATE course SET sticky = 1 WHERE id = $courseId ");
            }

            $sql = "SELECT * FROM c_tool
                    WHERE c_id = {$courseId} ";
            $result = $connection->executeQuery($sql);
            $tools = $result->fetchAllAssociative();

            foreach ($tools as $toolData) {
                /** @var CTool $tool */
                $tool = $toolRepo->find($toolData['iid']);
                if ($tool->hasResourceNode()) {
                    continue;
                }

                $course = $courseRepo->find($courseId);
                $session = null;
                if (!empty($toolData['session_id'])) {
                    $session = $sessionRepo->find($toolData['session_id']);
                }

                $admin = $this->getAdmin();
                $tool->setParent($course);
                $toolRepo->addResourceNode($tool, $admin, $course);
                $newVisibility = 1 === (int) $toolData['visibility'] ? ResourceLink::VISIBILITY_PUBLISHED : ResourceLink::VISIBILITY_PENDING;
                $tool->addCourseLink($course, $session, null, $newVisibility);
                $em->persist($tool);
                if (($counter % $batchSize) === 0) {
                    $em->flush();
                    $em->clear(); // Detaches all objects from Doctrine!
                }
                $counter++;
            }
        }
        $em->flush();
        $em->clear();
    }