Viewing file:  Telnyx.php (6.01 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace App\SmsProvider;
use App\Models\Expense;
use App\Models\MessageLog;
use App\Models\SmsQueue;
use Illuminate\Support\Facades\Log;
use Vonage\Client\Credentials\Basic;
class Telnyx
{
private $credentials;
private $to_numbers;
private $body;
private $from_number;
private $mms_files;
private $message;
private $send_fail=[];
private $message_log;
private $queue=null;
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 setQueue($queue){
$this->queue=$queue;
return $this;
}
public function setType($response){
$this->sms_type=$response;
return $this;
}
public function send()
{
if (!isset($this->credentials->tl_status) || $this->credentials->tl_status !='active'){
throw new \Exception('This provider is not active. Please contact with the administrator');
}
\Telnyx\Telnyx::setApiKey($this->credentials->tl_api_key);
foreach ($this->to_numbers as $to) {
try {
if ($this->sms_type && $this->sms_type=='inbox') {
$type = 'inbox';
}else{
$type = 'sent';
}
if($this->queue){
$this->message_log=MessageLog::updateOrCreate([
'to'=>$to,
'from'=>$this->from_number,
'body'=>$this->body,
'message_id'=>$this->message->id,
'customer_id'=>$this->message->customer_id,
'type'=>'sent',
],['status'=>'succeed','queue_id'=>$this->queue->id]);
}else{
$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'=>$type,
'status'=>'succeed'
]);
}
$messageResponse = '';
if ($this->mms_files) {
$newMessageFiles = $this->mms_files;
array_walk($newMessageFiles, function (&$value, $index) {
$value = asset('uploads/' . $value);
});
$messageResponse= \Telnyx\Message::Create(['from' => $this->from_number, 'to' => $to, 'text' => $this->body, 'media_urls' => $newMessageFiles]);
} else {
$messageResponse= \Telnyx\Message::Create(['from' => $this->from_number, 'to' => $to, 'text' => $this->body]);
}
if (isset($messageResponse->id) && $messageResponse->id){
$smsQueueArray=['delivered_at'=>now(), 'response_id'=>$messageResponse->id,'response_code'=>null];
if(isset($messageResponse->errors) && isset($messageResponse->errors[0]) && isset($messageResponse->errors[0]->code)) {
$smsQueueArray['response_code'] = $messageResponse->errors[0]->code;
}
if ($this->queue){
SmsQueue::where('id',$this->queue->id)->update($smsQueueArray);
}
$messageLogArray=['response_id'=>$messageResponse->id,'response_code'=>null];
if(isset($messageResponse->errors) && isset($messageResponse->errors[0]) && isset($messageResponse->errors[0]->code)) {
$messageLogArray['response_code'] = $messageResponse->errors[0]->code;
$messageLogArray['status'] = "failed";
}
if($this->message_log){
$this->message_log->update($messageLogArray);
}
if ($this->queue && isset($messageResponse->errors) && isset($messageResponse->errors[0])){
$this->queue->update(['status'=>'failed']);
}
}
if (isset($messageResponse->cost) && isset($messageResponse->cost->amount)){
$expense= new Expense();
$expense->type='sent';
$expense->cost=$messageResponse->cost->amount;
$expense->message_log_id=$this->message_log->id;
$expense->customer_id=$this->message->customer_id;
$expense->save();
}
} catch (\Exception $ex) {
if($this->message_log){
$this->message_log->update(['status'=>'failed','response_code'=>$ex->getTelnyxCode()]);
}
if ($this->queue){
$this->queue->update(['status'=>'failed','response_code'=>$ex->getTelnyxCode()]);
}
if ($type && $type=='sent') {
$this->setSendFail([
'message_id' => $this->message->id,
'from_number' =>$this->from_number,
'to_number' => $to,
'created_at' => now(),
'updated_at' => now(),
'reason' => $ex->getMessage(),
]);
}
}
}
}
public function getSendFail(){
return $this->send_fail;
}
private function setSendFail($sendFailArray){
$this->send_fail[]=$sendFailArray;
}
}
|