Chamilo\CoreBundle\Migrations\Schema\V200\Version20201212195112

Complexity

Total Complexity

11

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getDescription()	0	3	1
C	up()	0	95	10

<?php

/* For licensing terms, see /license.txt */

namespace Chamilo\CoreBundle\Migrations\Schema\V200;

use Chamilo\CoreBundle\Entity\Course;
use Chamilo\CoreBundle\Entity\ResourceLink;
use Chamilo\CoreBundle\Migrations\AbstractMigrationChamilo;
use Chamilo\CoreBundle\Repository\Node\CourseRepository;
use Chamilo\CoreBundle\Repository\SessionRepository;
use Chamilo\CourseBundle\Entity\CGroup;
use Chamilo\CourseBundle\Entity\CGroupCategory;
use Chamilo\CourseBundle\Repository\CGroupCategoryRepository;
use Chamilo\CourseBundle\Repository\CGroupRepository;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;

final class Version20201212195112 extends AbstractMigrationChamilo
{
    public function getDescription(): string
    {
        return 'Migrate c_group_info ';
    }

    public function up(Schema $schema): void
    {
        $container = $this->getContainer();
        $doctrine = $container->get('doctrine');
        $em = $doctrine->getManager();
        /** @var Connection $connection */
        $connection = $em->getConnection();
        $courseRepo = $container->get(CourseRepository::class);
        $sessionRepo = $container->get(SessionRepository::class);
        $groupRepo = $container->get(CGroupRepository::class);
        $groupCategoryRepo = $container->get(CGroupCategoryRepository::class);

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

        // Migrating c_tool.
        $q = $em->createQuery('SELECT c FROM Chamilo\CoreBundle\Entity\Course c');
        /** @var Course $course */
        foreach ($q->toIterable() as $course) {
            // Categories
            $counter = 1;
            $courseId = $course->getId();
            $sql = "SELECT * FROM c_group_category
                    WHERE c_id = $courseId ";
            $result = $connection->executeQuery($sql);
            $categories = $result->fetchAllAssociative();

            foreach ($categories as $categoryData) {
                /** @var CGroupCategory $category */
                $category = $groupCategoryRepo->find($categoryData['iid']);
                if ($category->hasResourceNode()) {
                    continue;
                }

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

                $admin = $this->getAdmin();
                $category->setParent($course);
                $groupRepo->addResourceNode($category, $admin, $course);
                $newVisibility = ResourceLink::VISIBILITY_PUBLISHED;
                $category->addCourseLink($course, $session, null, $newVisibility);
                $em->persist($category);
                if (0 === $counter % $batchSize) {
                    $em->flush();
                    $em->clear();
                }
                $counter++;
            }

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

            // Groups
            $counter = 1;
            $courseId = $course->getId();
            $sql = "SELECT * FROM c_group_info
                    WHERE c_id = $courseId ";
            $result = $connection->executeQuery($sql);
            $groups = $result->fetchAllAssociative();

            foreach ($groups as $groupData) {
                /** @var CGroup $group */
                $group = $groupRepo->find($groupData['iid']);
                if ($group->hasResourceNode()) {
                    continue;
                }

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

                $admin = $this->getAdmin();
                $group->setParent($course);
                $groupRepo->addResourceNode($group, $admin, $course);
                $newVisibility = ResourceLink::VISIBILITY_PENDING;
                if (1 === $group->getStatus()) {
                    $newVisibility = ResourceLink::VISIBILITY_PUBLISHED;
                }
                $group->addCourseLink($course, $session, null, $newVisibility);
                $em->persist($group);
                if (0 === $counter % $batchSize) {
                    $em->flush();
                    $em->clear();
                }
                $counter++;
            }
        }
        $em->flush();
        $em->clear();
    }
}