Browse Source

ajustes no metodos listarFilas e enviar msg

websocket
lucascardo12 3 years ago
parent
commit
91b3c00c5a
  1. 5
      app/Core/CoreMedia.php
  2. 27
      app/Middleware/ApiAgente.php
  3. 16
      app/Providers/Positus.php
  4. 7
      app/Providers/RequestURL.php

5
app/Core/CoreMedia.php

@ -65,15 +65,12 @@ class CoreMedia
{
/** Validate $data */
$this->build($data);
logger('debuge')->debug(var_export($data, true));
$this->api = $api;
$this->api->setHook($this->request);
$msg = $this->api->getIsValidMessage();
// logger('deburguer')->info(var_export($msg, true));
$this->ws->enviaMsg('att');
if (empty($msg)) {
return;
}
if (!$this->api->baixarMidia()) {
$this->api->enviarMsg($this->api->getPhone(), utf8_encode("Não foi possivel entregar o aquivo para o agente. Envie novamente!"));
}

27
app/Middleware/ApiAgente.php

@ -8,6 +8,7 @@ use app\Controllers\QueueController;
use app\Models\Agent;
use app\Models\Atendimento;
use app\Models\Evento;
use app\Models\ListaNegraPalavras;
use app\Models\Message;
use app\Models\Parametros;
use app\Models\Pause;
@ -255,7 +256,11 @@ class ApiAgente
{
$queue = new QueueController();
$search = $queue->listaAllFilas();
echo json_encode($search);
$this->retorno(
$search ? "Sucesso" : "Erro",
$search ? $search : null,
$search ? $search : null
);
return null;
}
@ -317,7 +322,10 @@ class ApiAgente
$modelMensagem = new Message();
if ($mensagem['type'] == 'text') {
// logger('enviaMsg')->info(print_r($mensagem, true));
$retuno = $provider->enviarMsg($mensagem['dst'], $mensagem['content']);
$retuno = $provider->enviarMsg(
$mensagem['dst'],
$this->validaPalavroes($mensagem['content'])
);
} else {
$anmeArquivo = __DIR__ . "/../../storage/files/" . $mensagem['id_provedor'];
$texto = base64_decode($mensagem['content']);
@ -598,4 +606,19 @@ class ApiAgente
logger('monitora')->info($th->getMessage(), debug_backtrace());
}
}
public function validaPalavroes($msg)
{
try {
$palavroes = new ListaNegraPalavras();
$palavras = $palavroes->getAll();
foreach ($palavras as $key => $value) {
$pattern = "/\b($value->palavra)\b/i";
$msg = preg_replace($pattern, '*' . str_repeat('*', strlen($value->palavra)) . '*', $msg);
}
} catch (\Throwable $th) {
logger('telegram')->info(print_r($th, true), true);
}
return $msg;
}
}

16
app/Providers/Positus.php

@ -244,7 +244,9 @@ class Positus implements IApiMedia
$this->requestType("GET");
$this->setMetodo('media/' . $name);
$pathfile = $this->storage . $name;
file_put_contents($pathfile, $this->exec());
$retorno = $this->exec();
logger('debuge')->debug(var_export($retorno, true));
file_put_contents($pathfile, $retorno);
if (file_exists($pathfile)) {
return true;
}
@ -462,27 +464,27 @@ class Positus implements IApiMedia
}
$this->request->header($header);
$this->request->method_request($this->requestType);
return $this->request->exec_request();
$response = $this->request->exec_request();
return $this->response($response);
}
function response($result)
{
// logger('deburguer')->info(print_r($result, true));
logger('deburguer')->info(gettype($result));
if ($result) {
try {
if (json_decode($result, true) !== null) {
return json_decode($result, true);
}
return json_decode($result, true);
} catch (\Exception $th) {
logger('deburguer')->info($th->getMessage());
return $result;
} catch (\Throwable $th) {
logger('deburguer')->info(print_r($result, true));
return false;
}
} else {
return false;
}
}
/**
* Create file and download in browser
*/

7
app/Providers/RequestURL.php

@ -71,9 +71,12 @@ class RequestURL
private function response($result)
{
// logger('deburguer')->info(print_r($result, true));
try {
if ($result) {
if (json_decode($result, true) !== null) {
return json_decode($result, true);
} catch (\Throwable $th) {
}
return $result;
} else {
return false;
}
}

Loading…
Cancel
Save