Stu\Component\Refactor\RefactorRunner::migrateAllianceJobSystem()

Complexity

Conditions	12
Paths	66

Size

Total Lines	119
Code Lines	76

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	156

Importance

Changes

0

<?php
    private function migrateAllianceJobSystem(): void
    {
        $connection = $this->entityManager->getConnection();

        $oldJobs = $connection->fetchAllAssociative(
            'SELECT id, alliance_id, user_id, type FROM stu_alliances_jobs WHERE type != :pending ORDER BY alliance_id, type',
            ['pending' => AllianceJobTypeEnum::PENDING->value]
        );

        echo "Found " . count($oldJobs) . " existing jobs (excluding pending)\n";

        $processedAlliances = [];
        $jobMapping = [];

        foreach ($oldJobs as $oldJob) {
            $allianceId = (int) $oldJob['alliance_id'];
            $userId = (int) $oldJob['user_id'];
            $type = (int) $oldJob['type'];

            if (!isset($processedAlliances[$allianceId])) {
                $processedAlliances[$allianceId] = [];
            }

            if (!isset($processedAlliances[$allianceId][$type])) {
                $title = $this->getTitleForType($allianceId, $type);

                $newJob = new AllianceJob();
                $alliance = $this->allianceRepository->find($allianceId);
                if ($alliance === null) {
                    continue;
                }

                $newJob->setAlliance($alliance);
                $newJob->setTitle($title);
                $newJob->setSort($this->getSortForType($type));
                $newJob->setIsFounderPermission($type === AllianceJobTypeEnum::FOUNDER->value);
                $newJob->setIsSuccessorPermission($type === AllianceJobTypeEnum::SUCCESSOR->value);
                $newJob->setIsDiplomaticPermission($type === AllianceJobTypeEnum::DIPLOMATIC->value);

                $this->entityManager->persist($newJob);
                $this->entityManager->flush();

                $processedAlliances[$allianceId][$type] = $newJob->getId();
                $jobMapping[$oldJob['id']] = $newJob->getId();

                echo "  Created new job '{$title}' (ID: {$newJob->getId()}) for Alliance {$allianceId}\n";
            }

            $jobId = $processedAlliances[$allianceId][$type];
            $newJob = $this->allianceJobRepository->find($jobId);
            $user = $this->entityManager->getReference('Stu\\Orm\\Entity\\User', $userId);

            if ($newJob !== null && $user !== null) {
                $memberJob = new AllianceMemberJob();
                $memberJob->setJob($newJob);
                $memberJob->setUser($user);

                $this->entityManager->persist($memberJob);
            }
        }

        $this->entityManager->flush();

        echo "\nProcessing pending applications...\n";

        $pendingApplications = $connection->fetchAllAssociative(
            'SELECT id, alliance_id, user_id FROM stu_alliances_jobs WHERE type = :pending',
            ['pending' => AllianceJobTypeEnum::PENDING->value]
        );

        echo "Found " . count($pendingApplications) . " pending applications\n";

        foreach ($pendingApplications as $pending) {
            $allianceId = (int) $pending['alliance_id'];
            $userId = (int) $pending['user_id'];

            $alliance = $this->allianceRepository->find($allianceId);
            $user = $this->entityManager->getReference('Stu\\Orm\\Entity\\User', $userId);

            if ($alliance === null || $user === null) {
                continue;
            }

            if (!isset($processedAlliances[$allianceId]['pending'])) {
                $pendingJob = new AllianceJob();
                $pendingJob->setAlliance($alliance);
                $pendingJob->setTitle('Bewerber');
                $pendingJob->setSort(999);
                $pendingJob->setIsFounderPermission(false);
                $pendingJob->setIsSuccessorPermission(false);
                $pendingJob->setIsDiplomaticPermission(false);

                $this->entityManager->persist($pendingJob);
                $this->entityManager->flush();

                $processedAlliances[$allianceId]['pending'] = $pendingJob->getId();

                echo "  Created 'Bewerber' job (ID: {$pendingJob->getId()}) for Alliance {$allianceId}\n";
            }

            $jobId = $processedAlliances[$allianceId]['pending'];
            $pendingJob = $this->allianceJobRepository->find($jobId);

            if ($pendingJob !== null) {
                $memberJob = new AllianceMemberJob();
                $memberJob->setJob($pendingJob);
                $memberJob->setUser($user);

                $this->entityManager->persist($memberJob);
            }
        }

        $this->entityManager->flush();

        $totalJobs = count(array_unique(array_merge(...array_values($processedAlliances))));
        echo "\nSummary:\n";
        echo "  - Alliances processed: " . count($processedAlliances) . "\n";
        echo "  - Jobs created: {$totalJobs}\n";
        echo "  - Member assignments created\n";
    }