ControleOnline\Service\PeopleService

Complexity

Total Complexity

63

Size/Duplication

Total Lines	265
Duplicated Lines	0 %

Importance

Changes	28
Bugs	0	Features	0

21 Methods

Rating	Name	Duplication	Size	Complexity
A	prePersist()	0	5	1
A	addClient()	0	1	1
A	__construct()	0	6	1
A	discoveryClient()	0	3	1
A	discoveryLink()	0	12	2
A	checkCompany()	0	9	2
A	discoveryDocumentType()	0	12	2
B	checkLink()	0	16	7
B	postPersist()	0	15	7
A	getPeopleTypeByDocumentLen()	0	3	2
B	discoveryPeople()	0	30	11
A	getEmail()	0	3	1
A	getPhone()	0	3	1
A	getDocumentTypeByDocumentLen()	0	3	2
A	addDocument()	0	17	4
A	addPhone()	0	16	4
A	addLink()	0	19	2
A	securityFilter()	0	3	1
A	getMyCompanies()	0	17	5
A	addEmail()	0	15	4
A	getDocument()	0	8	2

<?php

namespace ControleOnline\Service;

use ControleOnline\Entity\Document;
use ControleOnline\Entity\DocumentType;
use ControleOnline\Entity\Email;
use ControleOnline\Entity\ExtraData;

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

use ControleOnline\Entity\ExtraFields;

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

use ControleOnline\Entity\Language;

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

use ControleOnline\Entity\People;
use ControleOnline\Entity\PeopleLink;
use ControleOnline\Entity\Phone;
use Doctrine\ORM\EntityManagerInterface;

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

use Symfony\Component\HttpFoundation\RequestStack;

The type Symfony\Component\HttpFoundation\RequestStack was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface

The type Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface was not found. Maybe you did not declare it correctly or list all dependencies?

as Security;
use Doctrine\ORM\QueryBuilder;

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

use Exception;

class PeopleService
{
  private $request;

  public function __construct(
    private EntityManagerInterface $manager,
    private Security               $security,
    private RequestStack $requestStack,
  ) {
    $this->request  = $requestStack->getCurrentRequest();
  }

  public function prePersist(People $people)
  {
    $language = $this->manager->getRepository(Language::class)->findOneBy(['language' => 'pt-br']);
    $people->setLanguage($language);
    return $people;
  }

  public function addClient() {}


  public function discoveryClient(People $provider, People $client)
  {
    return $this->discoveryLink($provider, $client, 'client');
  }

  public function discoveryLink(People $company, People $people, $linkType): PeopleLink
  {
    $peopleLink =   $this->manager->getRepository(PeopleLink::class)->findOneBy([
      'company' => $company,
      'people' => $people,
      'link_type' => $linkType
    ]);

    if (!$peopleLink)
      $peopleLink = $this->addLink($company, $people, $linkType);

    return $peopleLink;
  }

  public function discoveryPeople(?string $document = null, ?string  $email = null, ?array $phone = [], ?string $name = null, ?string $peopleType = null): People
  {

    if (!empty($document))
      $people = $this->getDocument($document)?->getPeople();

    if (!$people && !empty($email))

The variable $people does not seem to be defined for all execution paths leading up to this point.

      $people = $this->getEmail($email)?->getPeople();

    if (!$people && !empty($phone))
      $people = $this->getPhone($phone['ddd'], $phone['phone'])?->getPeople();

    if (!$people) {
      $people = new People();
      $people->setName($name ?? 'Name not given');
      $people->setLanguage($this->manager->getRepository(Language::class)->findOneBy(['language' => 'pt-br']));
      $people->setPeopleType($peopleType ?: $this->getPeopleTypeByDocumentLen($document));
      $this->manager->persist($people);
      $this->manager->flush();
    }

    if ($document)
      $this->addDocument($people, $document);
    if ($email)
      $this->addEmail($people, $email);
    if ($phone)
      $this->addPhone($people, $phone);


    return $people;
  }

  public function addPhone(People $people, array $phone_number): Phone
  {
    $phone = $this->getPhone($phone_number['ddd'], $phone_number['phone']);
    if ($phone && $phone->getPeople()) {
      if ($phone->getPeople()->getId() != $people->getId())
        throw new Exception("Phone is in use by people " . $people->getId(), 1);
    } else {
      $phone = new Phone();
      $phone->setDdd((int) $phone_number['ddd']);
      $phone->setPhone((int) $phone_number['phone']);
      $phone->setPeople($people);
      $this->manager->persist($phone);
      $this->manager->flush();
    }

    return  $phone;
  }
  public function addDocument(People $people, string|int $document_number, ?string $document_type = null): Document
  {
    $document = $this->getDocument($document_number, $document_type);
    if ($document) {
      if ($document->getPeople()->getId() != $people->getId())
        throw new Exception("Document is in use by people " . $people->getId(), 1);
    } else {
      $document_type = $document_type ? $this->discoveryDocumentType($document_type) : $this->discoveryDocumentType($this->getDocumentTypeByDocumentLen($document_number));
      $document = new Document();
      $document->setDocument((int)$document_number);
      $document->setDocumentType($document_type);
      $document->setPeople($people);
      $this->manager->persist($document);
      $this->manager->flush();
    }

    return  $document;
  }

  public function addEmail(People $people, string $email_str): Email
  {
    $email = $this->getEmail($email_str);
    if ($email && $email->getPeople()) {
      if ($email->getPeople()->getId() != $people->getId())
        throw new Exception("Email is in use by people " . $people->getId(), 1);
    } else {
      $email = new Email();
      $email->setEmail($email_str);
      $email->setPeople($people);
      $this->manager->persist($email);
      $this->manager->flush();
    }

    return  $email;
  }

  public function getEmail(string $email): ?Email
  {
    return $this->manager->getRepository(Email::class)->findOneBy(['email' => $email]);
  }

  public function getPhone(string $ddd, string $phone): ?Phone
  {
    return $this->manager->getRepository(Phone::class)->findOneBy(['ddd' => $ddd, 'ddd' => $phone]);
  }


  public function discoveryDocumentType(string $document_type): DocumentType
  {
    $documentType =  $this->manager->getRepository(DocumentType::class)->findOneBy(['documentType' => $document_type]);

    if (!$documentType) {
      $documentType = new DocumentType();
      $documentType->setDocumentType($document_type);
      $this->manager->persist($documentType);
      $this->manager->flush();
    }

    return $documentType;
  }

  public function getDocument(string $document_number, ?string $document_type = null): ?Document
  {
    if (!$document_type)
      $document_type = $this->getDocumentTypeByDocumentLen($document_number);
    return $this->manager->getRepository(Document::class)->findOneBy([
      'document' => $document_number,
      'documentType' =>
      $this->discoveryDocumentType($document_type)
    ]);
  }

  public function getPeopleTypeByDocumentLen(?string $document_number = null)
  {
    return strlen($document_number) > 11 ? 'J' : 'F';

It seems like $document_number can also be of type null; however, parameter $string of strlen() does only seem to accept string, maybe add an additional type check?

  }

  public function getDocumentTypeByDocumentLen(?string $document_number = null)
  {
    return strlen($document_number) > 11 ? 'CNPJ' : 'CPF';

It seems like $document_number can also be of type null; however, parameter $string of strlen() does only seem to accept string, maybe add an additional type check?

  }

  public function postPersist(People $people)
  {
    $request = $this->requestStack->getCurrentRequest();
    if (!$request) return;
    $payload   = json_decode($request->getContent());
    if (isset($payload->link_type)) {
      $company = $this->manager->getRepository(People::class)->find(preg_replace('/\D/', '', $payload->company));
      if ($company)
        $this->discoveryLink($company, $people, $payload->link_type);
      else {
        $link = $this->manager->getRepository(People::class)->find(preg_replace('/\D/', '', $payload->link));
        if ($payload->link_type == 'employee' && $link) {
          $this->discoveryLink($people, $link, $payload->link_type);
          if ($payload->people_document)
            $this->addDocument($people, $payload->people_document);
        }
      }
    }
  }

  public function addLink(People $company, People $people, $link_type): PeopleLink
  {

    $peopleLink = $this->manager->getRepository(PeopleLink::class)->findOneBy([
      'company' => $company,
      'people' => $people,
      'link_type' => $link_type
    ]);

    if (!$peopleLink)
      $peopleLink = new PeopleLink();

    $peopleLink->setCompany($company);
    $peopleLink->setPeople($people);
    $peopleLink->setLinkType($link_type);

    $this->manager->persist($peopleLink);
    $this->manager->flush();
    return  $peopleLink;
  }

  public function securityFilter(QueryBuilder $queryBuilder, $resourceClass = null, $applyTo = null, $rootAlias = null): void
  {
    $this->checkLink($queryBuilder, $resourceClass, $applyTo, $rootAlias);
  }

  public function checkLink(QueryBuilder $queryBuilder, $resourceClass = null, $applyTo = null, $rootAlias = null): void

The parameter $applyTo is not used and could be removed.

The parameter $resourceClass is not used and could be removed.

  {

    $link   = $this->request->query->get('link',   null);
    $company = $this->request->query->get('company', null);
    $link_type = $this->request->query->get('link_type', null);

    if ($link_type) {
      $queryBuilder->join(sprintf('%s.' . ($link ? 'company' : 'link'), $rootAlias), 'PeopleLink');
      $queryBuilder->andWhere('PeopleLink.link_type IN(:link_type)');
      $queryBuilder->setParameter('link_type', $link_type);
    }

    if ($company || $link) {
      $queryBuilder->andWhere('PeopleLink.' . ($link ? 'people' : 'company') . ' IN(:people)');
      $queryBuilder->setParameter('people', preg_replace("/[^0-9]/", "", ($link ?: $company)));
    }
  }
  public function checkCompany($type, QueryBuilder $queryBuilder, $resourceClass = null, $applyTo = null, $rootAlias = null): void

The parameter $resourceClass is not used and could be removed.

The parameter $applyTo is not used and could be removed.

  {
    $companies   = $this->getMyCompanies();
    $queryBuilder->andWhere(sprintf('%s.' . $type . ' IN(:companies)', $rootAlias, $rootAlias));
    $queryBuilder->setParameter('companies', $companies);

    if ($payer = $this->request->query->get('company', null)) {
      $queryBuilder->andWhere(sprintf('%s.' . $type . ' IN(:people)', $rootAlias));
      $queryBuilder->setParameter('people', preg_replace("/[^0-9]/", "", $payer));
    }
  }

  public function getMyCompanies(): array
  {
    /**
     * @var \ControleOnline\Entity\User $currentUser
     */
    $token = $this->security->getToken();
    if (!$token) return [];
    $currentUser  =  $token->getUser();
    $companies    = [];
    if (!$currentUser) return [];

    if (!$currentUser->getPeople()->getLink()->isEmpty()) {
      foreach ($currentUser->getPeople()->getLink() as $company) {
        $companies[] = $company->getCompany();
      }
    }
    return $companies;
  }
}