Viewing file: Textlocal.php (3.05 KB) -rw-r--r-- Select action/file-type: (+) | (+) | (+) | Code (+) | Session (+) | (+) | SDB (+) | (+) | (+) | (+) | (+) | (+) |
<?php
namespace App\WhatsAppProvider;
use App\Models\MessageLog;
use Illuminate\Support\Facades\Log;
class Textlocal implements SendMessageInterface
{
private $credentials;
private $to_numbers;
private $body;
private $from_number;
private $mms_files;
private $message;
private $send_fail=[];
private $message_log;
public function __construct($credentials)
{
$this->credentials=$credentials;
}
public function setTo($to)
{
$this->to_numbers = $to;
return $this;
}
public function setBody($body)
{
$this->body = $body;
return $this;
}
public function setFrom($from)
{
$this->from_number = $from;
return $this;
}
public function setFiles($files){
$this->mms_files=$files;
return $this;
}
public function setMessage($message){
$this->message=$message;
return $this;
}
public function process()
{
$apiKey = $this->credentials->textlocal_api_key;
foreach ($this->to_numbers as $to) {
try {
$this->message_log = MessageLog::create([
'to' => $to,
'from' => $this->from_number,
'body' => $this->body,
'message_id' => $this->message->id,
'customer_id' => $this->message->customer_id,
'type' => 'sent',
]);
$messages = array(
// Put parameters here such as force or test
'send_channel' => 'whatsapp',
'messages' => array(
array(
'number' => $to,
'template' => $this->body
)
)
);
$data = array(
'apikey' => $apiKey,
'data' => json_encode($messages)
);
$ch = curl_init('https://api.textlocal.in/bulk_json/');
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
$response = curl_exec($ch);
curl_close($ch);
} catch (\Exception $ex) {
if ($this->message_log) {
$this->message_log->update(['status' => 'failed']);
}
Log::error($ex);
$this->setSendFail([
'message_id' => $this->message->id,
'from_number' => $this->from_number,
'to_number' => $to,
'reason' => $ex->getMessage(),
]);
}
}
}
public function getSendFail(){
return $this->send_fail;
}
private function setSendFail($sendFailArray){
$this->send_fail[]=$sendFailArray;
}
}
|