Viewing file: Infobip.php (4.68 KB) -rw-r--r-- Select action/file-type: (+) | (+) | (+) | Code (+) | Session (+) | (+) | SDB (+) | (+) | (+) | (+) | (+) | (+) |
<?php
namespace App\SmsProvider;
use App\Models\MessageLog; use Illuminate\Support\Facades\Log;
class Infobip {
private $credentials; private $to_numbers; private $body; private $from_number; private $mms_files; private $message; private $send_fail=[];
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() { try { $destinations=[]; if (!isset($this->credentials->infobip_status) || $this->credentials->infobip_status !='active'){ throw new \Exception('This provider is not active. Please contact with the administrator'); } if (!$this->credentials->url_base_path) { throw new \Exception('Please Set Infobip URL First'); } if (!$this->credentials->infobip_prefix_key) { throw new \Exception('Please Set Infobip prefix key'); }
foreach ($this->to_numbers as $number){ if ($this->sms_type && $this->sms_type=='inbox') { $type = 'inbox'; }else{ $type = 'sent'; }
if($this->queue){ $this->message_log=MessageLog::updateOrCreate([ 'to'=>$number, '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'=>$number, 'from'=>$this->from_number, 'body'=>$this->body, 'message_id'=>$this->message->id, 'customer_id'=>$this->message->customer_id, 'type'=> $type, 'status'=>'succeed' ]); } $destinations[] = [ 'to' => $number, ]; }
$parameters = [ 'messages' => [ "from" => $this->from_number, "destinations" => [$destinations], 'text' => $this->body, ], ];
$header = [ "Authorization:".$this->credentials->infobip_prefix_key." ".$this->credentials->infobip_api_key, "Content-Type: application/json", "Accept: application/json", ];
$sending_url = rtrim($this->credentials->url_base_path, '/\\')."/sms/2/text/advanced"; $client = new \GuzzleHttp\Client(['verify' => false]); $response = $client->post($sending_url, [ 'form_params' => $parameters, 'header' => $header ]);
$responseString = $response->getBody()->getContents(); Log::info($responseString);
} catch (\Exception $ex) { Log::error($ex->getMessage()); if($this->message_log){ $this->message_log->update(['status'=>'failed']); } if ($this->queue){ $this->queue->update(['status'=>'failed']); } if ($type && $type=='sent') { $this->setSendFail([ 'message_id' => $this->message->id, 'from_number' => $this->from_number, 'to_number' => $number, 'created_at' => now(), 'updated_at' => now(), 'reason' => $ex->getMessage(), ]); }
} }
public function getSendFail(){ return $this->send_fail; }
private function setSendFail($sendFailArray){ $this->send_fail[]=$sendFailArray; } }
|