Stu\Orm\Repository\BuildingCommodityRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	getProductionByCommodityAndUser()	0	25	1
A	getProductionByColony()	0	29	1
A	getProductionSumForAllUserColonies()	0	28	1
A	getByBuilding()	0	5	1
A	canProduceCommodity()	0	24	1

<?php

declare(strict_types=1);

namespace Stu\Orm\Repository;

use Doctrine\ORM\EntityRepository;
use Doctrine\ORM\Query\ResultSetMapping;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use Stu\Component\Colony\ColonyFunctionManager;
use Stu\Lib\Colony\PlanetFieldHostInterface;
use Stu\Module\Commodity\CommodityTypeEnum;

The type Stu\Module\Commodity\CommodityTypeEnum was not found. Maybe you did not declare it correctly or list all dependencies?

use Stu\Orm\Entity\BuildingCommodity;
use Stu\Orm\Entity\ColonyClassInterface;
use Stu\Orm\Entity\UserInterface;

/**
 * @extends EntityRepository<BuildingCommodity>
 */
final class BuildingCommodityRepository extends EntityRepository implements BuildingCommodityRepositoryInterface
{
    #[Override]
    public function getByBuilding(int $buildingId): array
    {
        return $this->findBy([
            'buildings_id' => $buildingId
        ]);
    }

    #[Override]
    public function getProductionByColony(PlanetFieldHostInterface $host, ColonyClassInterface $colonyClass): iterable
    {
        $rsm = new ResultSetMapping();
        $rsm->addScalarResult('commodity_id', 'commodity_id', 'integer');
        $rsm->addScalarResult('production', 'production', 'integer');
        $rsm->addScalarResult('pc', 'pc', 'integer');

        return $this->getEntityManager()
            ->createNativeQuery(
                sprintf(
                    'SELECT a.id as commodity_id, COALESCE(SUM(c.count), 0) as production, COALESCE(MAX(d.count),0) as pc
                    FROM stu_commodity a
                        LEFT JOIN stu_colonies_fielddata b ON b.%s = :hostId AND b.aktiv = :state
                        LEFT JOIN stu_buildings_commodity c ON c.commodity_id = a.id AND c.buildings_id = b.buildings_id
                        LEFT JOIN stu_planets_commodity d ON d.commodity_id = a.id AND d.planet_classes_id = :colonyClassId
                    WHERE c.count != 0 OR d.count != 0
                    GROUP BY a.id
                    ORDER BY a.sort ASC',
                    $host->getPlanetFieldHostColumnIdentifier()
                ),
                $rsm
            )
            ->setParameters([
                'state' => 1,
                'hostId' => $host->getId(),
                'colonyClassId' => $colonyClass->getId()
            ])
            ->getResult();
    }

    #[Override]
    public function getProductionSumForAllUserColonies(UserInterface $user): iterable
    {
        $rsm = new ResultSetMapping();
        $rsm->addScalarResult('commodity_id', 'commodity_id', 'integer');
        $rsm->addScalarResult('amount', 'amount', 'integer');
        $rsm->addScalarResult('commodity_name', 'commodity_name');

        return $this->getEntityManager()
            ->createNativeQuery(
                'SELECT a.id as commodity_id, a.name as commodity_name, SUM(c.count) + COALESCE(MAX(d.count),0) as amount
                FROM stu_commodity a
                    LEFT JOIN stu_colonies col ON col.user_id = :userId
                    LEFT JOIN stu_colonies_fielddata b ON b.colonies_id = col.id AND b.aktiv = :state
                    LEFT JOIN stu_buildings_commodity c ON c.commodity_id = a.id AND c.buildings_id = b.buildings_id
                    LEFT JOIN stu_planets_commodity d ON d.commodity_id = a.id AND d.planet_classes_id = col.colonies_classes_id
                WHERE a.type = :commodityType
                GROUP BY a.id
                HAVING SUM(c.count) + COALESCE(MAX(d.count),0) != 0
                ORDER BY a.sort ASC',
                $rsm
            )
            ->setParameters([
                'state' => ColonyFunctionManager::STATE_ENABLED,
                'commodityType' => CommodityTypeEnum::COMMODITY_TYPE_STANDARD,
                'userId' => $user->getId(),
            ])
            ->toIterable();
    }

    #[Override]
    public function getProductionByCommodityAndUser(int $commodityId, UserInterface $user): int
    {
        $rsm = new ResultSetMapping();
        $rsm->addScalarResult('gc', 'gc', 'integer');

        return (int) $this->getEntityManager()->createNativeQuery(
            'SELECT SUM(c.count) as gc
            FROM stu_colonies d
            LEFT JOIN stu_colonies_fielddata b
                ON b.colonies_id = d.id
                AND b.aktiv = :state
            LEFT JOIN stu_buildings_commodity c
                ON c.buildings_id = b.buildings_id
            LEFT JOIN stu_commodity a
                ON c.commodity_id = a.id
            WHERE d.user_id = :userId
                AND a.id = :commodityId
                AND c.count != 0',
            $rsm
        )->setParameters([
            'state' => 1,
            'userId' => $user->getId(),
            'commodityId' => $commodityId
        ])->getSingleScalarResult();
    }

    public function canProduceCommodity(int $userId, int $commodityId): bool
    {
        $rsm = new ResultSetMapping();
        $rsm->addScalarResult('buildings_id', 'buildings_id', 'integer');

        $query = $this->getEntityManager()->createNativeQuery(
            'SELECT bc.buildings_id
            FROM stu_buildings_commodity bc
            JOIN stu_buildings b ON bc.buildings_id = b.id
            LEFT JOIN stu_researched r ON b.research_id = r.research_id AND r.user_id = :userId AND r.aktiv = 0
            WHERE bc.commodity_id = :commodityId
            AND bc.count > 0
            AND (b.research_id IS NULL OR r.id IS NOT NULL)',
            $rsm
        );

        $query->setParameters([
            'commodityId' => $commodityId,
            'userId' => $userId
        ]);

        $result = $query->getResult();

        return !empty($result);
    }
}