ControleOnline\Repository\ConfigRepository

Complexity

Total Complexity

14

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	updatePeopleConfigKey()	0	30	2
A	getItauConfigByPeople()	0	33	5
A	getMauticConfigByPeople()	0	24	3
A	__construct()	0	3	1
A	getKeyValuesByPeople()	0	24	3

<?php

namespace ControleOnline\Repository;

use ControleOnline\Entity\Config;
use ControleOnline\Entity\People;

The type ControleOnline\Entity\People was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;

The type Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\Persistence\ManagerRegistry;

The type Doctrine\Persistence\ManagerRegistry was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * @method User|null find($id, $lockMode = null, $lockVersion = null)
 * @method User|null findOneBy(array $criteria, array $orderBy = null)
 * @method User[]    findAll()
 * @method User[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
 */
class ConfigRepository extends ServiceEntityRepository
{
  public function __construct(ManagerRegistry $registry)
  {
    parent::__construct($registry, Config::class);
  }

  public function updatePeopleConfigKey(People $people, string $key, string $value): void
  {
    try {
      $params = [];

      $this->getEntityManager()->getConnection()
        ->executeQuery('START TRANSACTION', $params);

      $rawSQL = <<<SQL
          UPDATE config
            SET config_value = :value
          WHERE people_id = :id AND config_key = :key
        SQL;

      $params = [
        'id'    => $people->getId(),
        'key'   => $key,
        'value' => $value,
      ];

      $this->getEntityManager()->getConnection()
        ->executeQuery($rawSQL, $params);

      $this->getEntityManager()->getConnection()
        ->executeQuery('COMMIT', $params);
    } catch (\Exception $e) {
      $this->getEntityManager()->getConnection()
        ->executeQuery('ROLLBACK', $params);

      throw new \Exception($e->getMessage());
    }
  }

  public function getKeyValuesByPeople(People $people, string $key): ?array
  {
    $result = $this->createQueryBuilder('a')
      ->andWhere('a.people = :people')
      ->andWhere('a.config_key LIKE :prefix')
      ->setParameter('people', $people)
      ->setParameter('prefix', $key . '-%')

      ->getQuery()
      ->getResult();

    if (empty($result))
      return null;

    $configs = [];

    /**
     * @var Config $config
     */
    foreach ($result as $config) {
      $configs[$config->getConfigKey()] = $config->getConfigValue();
    }

    return $configs;
  }

  public function getItauConfigByPeople(People $people): ?array
  {

    $config = $this->getEntityManager()->getRepository(Config::class)->findOneBy([
      'people' => $people,
      'config_key' => 'payment_type'
    ]);


    if (empty($config) || $config->getConfigValue() != 'itau')
      return null;

    $result = $this->createQueryBuilder('a')
      ->andWhere('a.people = :people')
      ->andWhere('a.config_key LIKE :prefix')
      ->setParameter('people', $people)
      ->setParameter('prefix', 'itau-shopline-%')
      ->getQuery()
      ->getResult();

    if (empty($result))
      return null;

    $configs = [];

    /**
     * @var Config $config
     */
    foreach ($result as $config) {
      $configs[$config->getConfigKey()] = $config->getConfigValue();
    }

    return $configs;
  }

  public function getMauticConfigByPeople(People $people): ?array
  {
    $result = $this->createQueryBuilder('a')
      ->andWhere('a.people = :people')
      ->andWhere('a.config_key LIKE :prefix')
      ->setParameter('people', $people)
      ->setParameter('prefix', 'mautic-%')

      ->getQuery()
      ->getResult();

    if (empty($result))
      return null;

    $configs = [];

    /**
     * @var Config $config
     */
    foreach ($result as $config) {
      $configs[$config->getConfigKey()] = $config->getConfigValue();
    }

    return $configs;
  }
}