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

Complexity

Conditions	3
Paths	4

Size

Total Lines	55
Code Lines	41

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function up(Schema $schema): void
    {
        // Decide whether we can join directly via resource_node.cid (preferred)
        // or need a fallback via resource_link.c_id (when cid is not present).
        $hasCid = false;

        if ($schema->hasTable('resource_node')) {
            $table = $schema->getTable('resource_node');
            $hasCid = $table->hasColumn('cid');
        }

        if ($hasCid) {
            // Preferred: "created in course" is stored on resource_node.cid
            $sqlNode = <<<SQL
UPDATE resource_node rn
INNER JOIN course c ON c.id = rn.cid
INNER JOIN language l ON l.isocode = c.course_language
SET rn.language_id = l.id
WHERE rn.language_id IS NULL
  AND rn.cid IS NOT NULL
  AND c.course_language IS NOT NULL
  AND c.course_language <> ''
SQL;
            $this->addSql($sqlNode);
        } else {
            // Fallback: infer a course from existing links (best-effort).
            // We pick MIN(c_id) per resource_node_id to have a deterministic choice.
            $sqlNode = <<<SQL
UPDATE resource_node rn
INNER JOIN (
    SELECT rl.resource_node_id, MIN(rl.c_id) AS c_id
    FROM resource_link rl
    WHERE rl.c_id IS NOT NULL
    GROUP BY rl.resource_node_id
) x ON x.resource_node_id = rn.id
INNER JOIN course c ON c.id = x.c_id
INNER JOIN language l ON l.isocode = c.course_language
SET rn.language_id = l.id
WHERE rn.language_id IS NULL
  AND c.course_language IS NOT NULL
  AND c.course_language <> ''
SQL;
            $this->addSql($sqlNode);
        }

        // Copy node language to files when file language is not set yet.
        $sqlFile = <<<SQL
UPDATE resource_file rf
INNER JOIN resource_node rn ON rn.id = rf.resource_node_id
SET rf.language_id = rn.language_id
WHERE rf.language_id IS NULL
  AND rn.language_id IS NOT NULL
SQL;

        $this->addSql($sqlFile);
    }