chamilo
/
chamilo-lms
mirror of https://github.com/chamilo/chamilo-lms/tree/1.11.x
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Migrations: Add c_student_publication migration (WIP)

Browse Source
pull/3733/head
Julio Montoya 4 years ago
parent fef7a7e155
commit cdd0281177
1 changed files with 206 additions and 0 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 206
      src/CoreBundle/Migrations/Schema/V200/Version20201216124011.php

206
src/CoreBundle/Migrations/Schema/V200/Version20201216124011.php
Unescape View File

@ -0,0 +1,206 @@
<?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\Node\UserRepository;
use Chamilo\CoreBundle\Repository\SessionRepository;
use Chamilo\CourseBundle\Entity\CStudentPublication;
use Chamilo\CourseBundle\Entity\CStudentPublicationComment;
use Chamilo\CourseBundle\Entity\CStudentPublicationCorrection;
use Chamilo\CourseBundle\Repository\CGroupRepository;
use Chamilo\CourseBundle\Repository\CStudentPublicationCommentRepository;
use Chamilo\CourseBundle\Repository\CStudentPublicationCorrectionRepository;
use Chamilo\CourseBundle\Repository\CStudentPublicationRepository;
use Chamilo\Kernel;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Schema;
final class Version20201216124011 extends AbstractMigrationChamilo
{
public function getDescription(): string
{
return 'Migrate c_student_publication';
}
public function up(Schema $schema): void
{
$container = $this->getContainer();
$doctrine = $container->get('doctrine');
$em = $doctrine->getManager();
/** @var Connection $connection */
$connection = $em->getConnection();
$studentPublicationRepo = $container->get(CStudentPublicationRepository::class);
$studentPublicationCommentRepo = $container->get(CStudentPublicationCommentRepository::class);
$studentPublicationCorrectionRepo = $container->get(CStudentPublicationCorrectionRepository::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();
$admin = $this->getAdmin();
$q = $em->createQuery('SELECT c FROM Chamilo\CoreBundle\Entity\Course c');
/** @var Course $course */
foreach ($q->toIterable() as $course) {
$courseId = $course->getId();
$course = $courseRepo->find($courseId);
// Assignments folders
$sql = "SELECT * FROM c_student_publication WHERE contains_file = 0 AND c_id = $courseId
ORDER BY iid";
$result = $connection->executeQuery($sql);
$items = $result->fetchAllAssociative();
foreach ($items as $itemData) {
$id = $itemData['iid'];
/** @var CStudentPublication $resource */
$resource = $studentPublicationRepo->find($id);
if ($resource->hasResourceNode()) {
continue;
}
$result = $this->fixItemProperty(
'work',
$studentPublicationRepo,
$course,
$admin,
$resource,
$course
);
if (false === $result) {
continue;
}
$em->persist($resource);
$em->flush();
}
$em->flush();
$em->clear();
// Assignments files
$sql = "SELECT * FROM c_student_publication
WHERE contains_file = 1 AND c_id = $courseId
ORDER BY iid";
$result = $connection->executeQuery($sql);
$items = $result->fetchAllAssociative();
foreach ($items as $itemData) {
$id = $itemData['iid'];
$path = $itemData['url'];
$title = $itemData['title'];
$parentId = $itemData['parent_id'];
/** @var CStudentPublication $resource */
$resource = $studentPublicationRepo->find($id);
if ($resource->hasResourceNode()) {
continue;
}
$parent = $studentPublicationRepo->find($parentId);
$result = $this->fixItemProperty(
'work',
$studentPublicationRepo,
$course,
$admin,
$resource,
$parent
);
if (false === $result) {
continue;
}
$filePath = $rootPath.'/app/courses/'.$course->getDirectory().'/'.$path;
$this->addLegacyFileToResource($filePath, $studentPublicationRepo, $resource, $id, $title);
$em->persist($resource);
$em->flush();
}
$em->flush();
$em->clear();
$admin = $this->getAdmin();
// Corrections.
$sql = "SELECT * FROM c_student_publication
WHERE
(title_correction <> '' OR title_correction IS NOT NULL) AND
c_id = $courseId
ORDER BY iid";
$result = $connection->executeQuery($sql);
$items = $result->fetchAllAssociative();
foreach ($items as $itemData) {
$id = $itemData['iid'];
$title = $itemData['title_correction'];
$path = $itemData['url_correction'];
$course = $courseRepo->find($courseId);
/** @var CStudentPublication $studentPublication */
$studentPublication = $studentPublicationRepo->find($id);
$correction = $studentPublication->getCorrection();
if (null !== $correction) {
continue;
}
$correction = new CStudentPublicationCorrection();
$correction->setTitle($title);
$correction->setParent($studentPublication);
$studentPublicationCorrectionRepo->addResourceNode($correction, $admin, $studentPublication);
$em->persist($correction);
$filePath = $rootPath.'/app/courses/'.$course->getDirectory().'/'.$path;
$this->addLegacyFileToResource($filePath, $studentPublicationCorrectionRepo, $correction, null, $title);
$em->persist($correction);
$em->flush();
}
$em->flush();
$em->clear();
// Comments
$sql = "SELECT * FROM c_student_publication_comment WHERE c_id = $courseId
ORDER BY iid";
$result = $connection->executeQuery($sql);
$items = $result->fetchAllAssociative();
foreach ($items as $itemData) {
$id = $itemData['iid'];
$file = $itemData['file'];
$workId = $itemData['work_id'];
/** @var CStudentPublicationComment $resource */
$resource = $studentPublicationCommentRepo->find($id);
if ($resource->hasResourceNode()) {
continue;
}
/** @var CStudentPublication $parent */
$parent = $studentPublicationRepo->find($workId);
$sql = "SELECT * FROM c_student_publication WHERE c_id = $courseId AND id = $workId";
$result = $connection->executeQuery($sql);
$work = $result->fetchAssociative();
if (empty($work)) {
continue;
}
$session = empty($work['session_id']) ? null : $sessionRepo->find($work['session_id']);
$group = empty($work['post_group_id']) ? null : $groupRepo->find($work['post_group_id']);
$resource->setParent($parent);
$resource->addCourseLink($course, $session, $group, ResourceLink::VISIBILITY_PUBLISHED);
$filePath = $rootPath.'/app/courses/'.$course->getDirectory().'/'.$file;
$this->addLegacyFileToResource($filePath, $studentPublicationRepo, $resource, $id, $title);
$em->persist($resource);
$em->flush();
}
}
}
}
Write Preview
Loading…
Cancel
Save