Refactoring ServiceTimeout with repositories

service/ServiceTimeout.php

@@ -7,6 +7,7 @@ use app\Actions\SystemMessageAction;
 use app\Actions\TimeoutTalkAction;
 use app\Core\UtilsChannel;
 use app\Interfaces\IApiMedia;
+use app\Models\NotificaMediaModel;
 use app\Repositories\AtendimentoRepository;
 use app\Repositories\EventosAtendimentoRepository;
 use app\Repositories\MessageRepository;
@@ -69,17 +70,21 @@ class ServiceTimeout implements IService
         }
         if ($this->timeoutTalkAction->__invoke($uniqueid, $client) == 'ALERT') {
             $msg = $this->messageRepository->findLastMessage($uniqueid);
-            $retorno = $this->notificaMediaRepository->verificaNotifica(
+            $notification = new NotificaMediaModel(
+                null,
                 $uniqueid,
                 $client,
-                utf8_encode($this->mensagem['TALK_ALERT_FINISH']) . $msg->id
+                utf8_encode($this->mensagem['TALK_ALERT_FINISH']) . $msg->id,
+                'now()'
             );
-            if ($retorno->quant == 0) {
-                $this->notificaMediaRepository->addNotifica(
-                    $uniqueid,
-                    $client,
-                    utf8_encode($this->mensagem['TALK_ALERT_FINISH']) . $msg->id
-                );
+            $retorno = $this->notificaMediaRepository->get([
+                'uniqueid' => $notification->uniqueid,
+                'src' => $notification->src,
+                'msg' => $notification->msg
+            ]);
+
+            if (empty($retorno)) {
+                $this->notificaMediaRepository->create($notification);
                 $this->api->enviarMsg(
                     $client,
                     $this->mensagem['TALK_ALERT_FINISH']
@@ -97,10 +102,14 @@ class ServiceTimeout implements IService
         $diff = date_diff($date1, $date2);
         echo $diff->h . "\n";
         if ($diff->h > 23) {
-            $this->notificaMediaRepository->addNotifica(
-                $uniqueid,
-                $client,
-                utf8_encode($this->mensagem['TIMEOUT_CLIENT_INATIVIDADE']) . $uniqueid
+            $this->notificaMediaRepository->create(
+                NotificaMediaModel::ArrayTo(
+                    [
+                        'uniqueid' => $uniqueid,
+                        'src' => $client,
+                        'msg' => utf8_encode($this->mensagem['TIMEOUT_CLIENT_INATIVIDADE']) . $uniqueid
+                    ]
+                )
             );
             $this->api->enviarMsg(
                 $client,