Chamilo\CourseBundle\Component\CourseCopy\CourseRestorer::restore_announcements()

Complexity

Conditions	16
Paths	113

Size

Total Lines	135
Code Lines	78

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	1	Features	0

<?php
    public function restore_announcements($sessionId = 0): void
    {
        if (!$this->course->has_resources(RESOURCE_ANNOUNCEMENT)) {
            return;
        }

        $sessionId = (int) $sessionId;
        $resources = $this->course->resources;

        $count = \is_array($resources[RESOURCE_ANNOUNCEMENT] ?? null)
            ? \count($resources[RESOURCE_ANNOUNCEMENT])
            : 0;

        $this->dlog('restore_announcements: begin', ['count' => $count]);

        /** @var EntityManagerInterface $em */
        $em = Database::getManager();
        $course = api_get_course_entity($this->destination_course_id);
        $session = api_get_session_entity($sessionId);
        $group = api_get_group_entity();
        $annRepo = Container::getAnnouncementRepository();
        $attachRepo = Container::getAnnouncementAttachmentRepository();

        // Origin path for ZIP/imported attachments (kept as-is)
        $originPath = rtrim($this->course->backup_path ?? '', '/').'/upload/announcements/';

        // Finder: existing announcement by title in this course/session
        $findExistingByTitle = function (string $title) use ($annRepo, $course, $session) {
            $qb = $annRepo->getResourcesByCourse($course, $session);
            $qb->andWhere('resource.title = :t')->setParameter('t', $title)->setMaxResults(1);

            return $qb->getQuery()->getOneOrNullResult();
        };

        foreach ($resources[RESOURCE_ANNOUNCEMENT] as $oldId => $a) {
            // Already mapped?
            $mapped = (int) ($a->destination_id ?? 0);
            if ($mapped > 0) {
                $this->dlog('restore_announcements: already mapped, skipping', [
                    'src_id' => (int) $oldId, 'dst_id' => $mapped,
                ]);

                continue;
            }

            $title = trim((string) ($a->title ?? ''));
            if ('' === $title) {
                $title = 'Announcement';
            }

            $contentHtml = (string) ($a->content ?? '');

            // Parse optional end date
            $endDate = null;

            try {
                $rawDate = (string) ($a->date ?? '');
                if ('' !== $rawDate) {
                    $endDate = new DateTime($rawDate);
                }
            } catch (Throwable $e) {
                $endDate = null;
            }

            $emailSent = (bool) ($a->email_sent ?? false);

            $existing = $findExistingByTitle($title);
            if ($existing) {
                switch ($this->file_option) {
                    case FILE_SKIP:
                        $destId = (int) $existing->getIid();
                        $this->course->resources[RESOURCE_ANNOUNCEMENT][$oldId] ??= new stdClass();
                        $this->course->resources[RESOURCE_ANNOUNCEMENT][$oldId]->destination_id = $destId;
                        $this->dlog('restore_announcements: reuse (SKIP)', [
                            'src_id' => (int) $oldId, 'dst_id' => $destId, 'title' => $existing->getTitle(),
                        ]);
                        // Still try to restore attachments on the reused entity
                        $this->restoreAnnouncementAttachments($a, $existing, $originPath, $attachRepo, $em);

                        continue 2;

                    case FILE_OVERWRITE:
                        // Continue to overwrite below
                        break;

                    case FILE_RENAME:
                    default:
                        // Rename to avoid collision
                        $base = $title;
                        $i = 1;
                        $candidate = $base;
                        while ($findExistingByTitle($candidate)) {
                            $i++;
                            $candidate = $base.' ('.$i.')';
                        }
                        $title = $candidate;

                        break;
                }
            }

            // Rewrite HTML content using centralized helper (replaces manual mapping logic)
            // Note: keeps attachments restoration logic unchanged.
            $contentRewritten = $this->rewriteHtmlForCourse($contentHtml, $sessionId, '[announcements.content]');

            // Create or reuse entity
            $entity = $existing ?: (new CAnnouncement());
            $entity
                ->setTitle($title)
                ->setContent($contentRewritten) // content already rewritten
                ->setParent($course)
                ->addCourseLink($course, $session, $group)
                ->setEmailSent($emailSent)
            ;

            if ($endDate instanceof DateTimeInterface) {
                $entity->setEndDate($endDate);
            }

            $em->persist($entity);
            $em->flush();

            $destId = (int) $entity->getIid();
            $this->course->resources[RESOURCE_ANNOUNCEMENT][$oldId] ??= new stdClass();
            $this->course->resources[RESOURCE_ANNOUNCEMENT][$oldId]->destination_id = $destId;

            $this->dlog($existing ? 'restore_announcements: overwrite' : 'restore_announcements: created', [
                'src_id' => (int) $oldId, 'dst_id' => $destId, 'title' => $title,
            ]);

            // Handle binary attachments from backup or source
            $this->restoreAnnouncementAttachments($a, $entity, $originPath, $attachRepo, $em);
        }

        $this->dlog('restore_announcements: end');
    }