ControleOnline / api-platform-tasks

src/Service/TaskInterationService.php

<?php

namespace ControleOnline\Service;

use ControleOnline\Entity\People;

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

use ControleOnline\Entity\Task;
use ControleOnline\Entity\TaskInteration;
use ControleOnline\Messages\MessageInterface;

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

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\Security\Core\Authentication\Token\Storage\TokenStorageInterface as Security;

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

class TaskInterationService
{

  private bool $notify = true;

  public function __construct(
    private EntityManagerInterface $manager,
    private Security $security,
    private StatusService $statusService,

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

    private PeopleService $peopleService,

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

    private FileService $fileService,

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

    private IntegrationService $integrationService

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

  ) {}

  public function addClientInteration(MessageInterface $message, People $provider, string $type): TaskInteration
  {

    $this->notify = false;
    $number = preg_replace('/\D/', '', $message->getOriginNumber());
    $name = '';
    $phone = [
      'ddi' => substr($number, 0, 2),
      'ddd' => substr($number, 2, 2),
      'phone' => substr($number, 4)
    ];
    $registredBy = $this->peopleService->discoveryPeople(null,  null,  $phone,  $name, null);
    $task = $this->discoveryOpenTask($provider, $registredBy, $type, $number);

    return $this->addInteration($registredBy, $message, $task, $type, 'public');
  }

  public function addInteration(People $registredBy, MessageInterface $message, Task $task, string $type, ?string $visibility = 'private')
  {

    $file = null;
    $media = $message->getMessageContent()->getMedia();
    if ($media)
      $file = $this->fileService->addFile(
        $registredBy,
        pack("C*", ...$media->getData()),
        $type
      );

    $taskInteration = new TaskInteration();
    $taskInteration->setTask($task);
    $taskInteration->setType($type);
    $taskInteration->setVisibility($visibility);
    $taskInteration->setBody($message->getMessageContent()->getBody());
    $taskInteration->setRegisteredBy($registredBy);
    if ($file)
      $taskInteration->setFile($file);

    $this->manager->persist($taskInteration);
    $this->manager->flush();

    return $taskInteration;
  }

  public function discoveryOpenTask(People $provider, People $registredBy, string $type, ?string $announce = null): Task
  {

    $openStatus = $this->statusService->discoveryStatus('open', 'open', $type);
    $pendingStatus = $this->statusService->discoveryStatus('pending', 'pending', $type);

    $task = $this->manager->getRepository(Task::class)->findOneBy([
      'taskStatus' => [$openStatus, $pendingStatus],
      'provider' => $provider,
      'registeredBy' => $registredBy,
      'type' => $type
    ]);

    if (!$task) {
      $task = new Task();
      $task->setRegisteredBy($registredBy);
      $task->setProvider($provider);
      $task->settype($type);
    }

    if ($announce) $task->addAnnounce($announce);
    $task->setTaskStatus($openStatus);
    $this->manager->persist($task);
    $this->manager->flush();

    return $task;
  }

  public function notifyClient(TaskInteration $taskInteration): TaskInteration
  {
    if (!$this->notify) return $taskInteration;
    $task = $taskInteration->getTask();
    $origin = "551131360353";

    foreach ($task->getAnnounce(true) as $destination) {
      if ($origin != $destination) {
        $message = json_encode([
          "action" => "sendMessage",
          "origin" => $origin,
          "destination" => $destination,
          "message" => $taskInteration->getBody(),
          //"file" => $taskInteration->getFile()
        ]);
        $this->integrationService->addIntegration($message, 'WhatsApp', null, null, $task->getProvider());
      }
    }

    return  $taskInteration;
  }

  public function prePersist(TaskInteration $taskInteration): TaskInteration
  {
    if (!$taskInteration->getRegisteredBy())
      $taskInteration->setRegisteredBy($this->security->getToken()->getUser()->getPeople());
    return  $taskInteration;
  }

  public function postPersist(TaskInteration $taskInteration): TaskInteration
  {
    return $this->notifyClient($taskInteration);
  }
}