Архивы php - Страница 4 из 21

OTP авторизация

27.03.2023 Павел Грибов PHP

Суть в чём: для каждого пользователя хранится некий OTP ключ (соль), на основании которого генерируется некий код, который в один момент времени (плюс-минус 30 секунд) будет одинаковый с ключём сгенерированным сторонним приложением. Естественно этому стороннему приложению сначала необходимо передать ключ.

Соответственно если код сгенерированный при проверке одинаков с ключем сгенерированным приложением, можно считать что идентификация успешно пройдена.

OTP авторизация обычно используется как «дополнительная», т.е. в качестве реализации двухфакторной авторизации.

Соберём класс для генерации кода на основании токена:

class TOTP {

 const keyRegeneration  = 30; // Время действия ключа
 const otpLength  = 6; // длина кода OTP

 private static $lut = array( 
  "A" => 0, "B" => 1,"C" => 2, "D" => 3,"E" => 4, "F" => 5,"G" => 6, "H" => 7,"I" => 8, "J" => 9,"K" => 10, "L" => 11,
  "M" => 12, "N" => 13,"O" => 14, "P" => 15,"Q" => 16, "R" => 17,"S" => 18, "T" => 19,"U" => 20, "V" => 21,"W" => 22, "X" => 23,
  "Y" => 24, "Z" => 25,"2" => 26, "3" => 27,"4" => 28, "5" => 29,"6" => 30, "7" => 31
 );


 /**
 * Возвратим текущее время Unix Timestamp округлённое до времени действия ключа
 * @return integer
 **/
 public static function get_timestamp() {
  return floor( (microtime(true) + 10) /self::keyRegeneration);
 }

 /**
 * Перекодируем строку base32 в бинарный вид
 **/
 public static function base32_decode($b32) {
  $b32  = strtoupper($b32);
  if (!preg_match('/^[ABCDEFGHIJKLMNOPQRSTUVWXYZ234567]+$/', $b32, $match))
   throw new Exception('Используются не верные символы в ключе.');
  $l  = strlen($b32);
  $n = 0;
  $j = 0;
  $binary = "";
  for ($i = 0; $i < $l; $i++) {
   $n = $n << 5;     // Move buffer left by 5 to make room
   $n = $n + self::$lut[$b32[$i]];  // Add value into buffer
   $j = $j + 5;    // Keep track of number of bits in buffer
   if ($j >= 8) {
    $j = $j - 8;
    $binary .= chr(($n & (0xFF << $j)) >> $j);
   }
  }
  return $binary;
 }

 /**
 * Вернём текущий код
 * @param binary $key - бинарный ключ
 * @param integer $counter - Timestamp
 * @return string
 **/
 public static function oath_hotp($key, $counter){
    if (strlen($key) < 8)
      throw new Exception('Секретный ключ слишком мал.Он должен быть больше 16 символов');
    $bin_counter = pack('N*', 0) . pack('N*', $counter);  
    $hash  = hash_hmac ('sha1', $bin_counter, $key, true);
    return str_pad(self::oath_truncate($hash), self::otpLength, '0', STR_PAD_LEFT);
 }

 /**
 * Вычленяет OTP из SHA1 hash.
 * @param binary $hash
 * @return integer
 **/
 public static function oath_truncate($hash){
    $offset = ord($hash[19]) & 0xf;
    return (
        ((ord($hash[$offset+0]) & 0x7f) << 24 ) |
        ((ord($hash[$offset+1]) & 0xff) << 16 ) |
        ((ord($hash[$offset+2]) & 0xff) << 8 ) |
        (ord($hash[$offset+3]) & 0xff)
    ) % pow(10, self::otpLength);
 }
}

class TOTP {

const keyRegeneration = 30; // Время действия ключа

const otpLength = 6; // длина кода OTP

private static $lut = array(

"A" => 0, "B" => 1,"C" => 2, "D" => 3,"E" => 4, "F" => 5,"G" => 6, "H" => 7,"I" => 8, "J" => 9,"K" => 10, "L" => 11,

"M" => 12, "N" => 13,"O" => 14, "P" => 15,"Q" => 16, "R" => 17,"S" => 18, "T" => 19,"U" => 20, "V" => 21,"W" => 22, "X" => 23,

"Y" => 24, "Z" => 25,"2" => 26, "3" => 27,"4" => 28, "5" => 29,"6" => 30, "7" => 31

);

/**

* Возвратим текущее время Unix Timestamp округлённое до времени действия ключа

* @return integer

**/

public static function get_timestamp() {

return floor( (microtime(true) + 10) /self::keyRegeneration);

}

/**

* Перекодируем строку base32 в бинарный вид

**/

public static function base32_decode($b32) {

$b32 = strtoupper($b32);

if (!preg_match('/^[ABCDEFGHIJKLMNOPQRSTUVWXYZ234567]+$/', $b32, $match))

throw new Exception('Используются не верные символы в ключе.');

$l = strlen($b32);

$n = 0;

$j = 0;

$binary = "";

for ($i = 0; $i < $l; $i++) {

$n = $n << 5; // Move buffer left by 5 to make room

$n = $n + self::$lut[$b32[$i]]; // Add value into buffer

$j = $j + 5; // Keep track of number of bits in buffer

if ($j >= 8) {

$j = $j - 8;

$binary .= chr(($n & (0xFF << $j)) >> $j);

}

return $binary;

}

/**

* Вернём текущий код

* @param binary $key - бинарный ключ

* @param integer $counter - Timestamp

* @return string

**/

public static function oath_hotp($key, $counter){

if (strlen($key) < 8)

throw new Exception('Секретный ключ слишком мал.Он должен быть больше 16 символов');

$bin_counter = pack('N*', 0) . pack('N*', $counter);

$hash = hash_hmac ('sha1', $bin_counter, $key, true);

return str_pad(self::oath_truncate($hash), self::otpLength, '0', STR_PAD_LEFT);

}

/**

* Вычленяет OTP из SHA1 hash.

* @param binary $hash

* @return integer

**/

public static function oath_truncate($hash){

$offset = ord($hash[19]) & 0xf;

return (

((ord($hash[$offset+0]) & 0x7f) << 24 ) |

((ord($hash[$offset+1]) & 0xff) << 16 ) |

((ord($hash[$offset+2]) & 0xff) << 8 ) |

(ord($hash[$offset+3]) & 0xff)

) % pow(10, self::otpLength);

}

Использование:

$InitalizationKey = "QWERTYUIOPASDFGH";     // Начальный ключ

$TimeStamp  = TOTP::get_timestamp();
$secretkey   = TOTP::base32_decode($InitalizationKey); // Перекодируем в бинарную строку
$otp         = TOTP::oath_hotp($secretkey, $TimeStamp); // получим текщий токен

echo("Ключ: $InitalizationKey\n");
echo("Timestamp: $TimeStamp\n");
echo("Код OTP: $otp\n");

$InitalizationKey = "QWERTYUIOPASDFGH"; // Начальный ключ

$TimeStamp = TOTP::get_timestamp();

$secretkey = TOTP::base32_decode($InitalizationKey); // Перекодируем в бинарную строку

$otp = TOTP::oath_hotp($secretkey, $TimeStamp); // получим текщий токен

echo("Ключ: $InitalizationKey\n");

echo("Timestamp: $TimeStamp\n");

echo("Код OTP: $otp\n");

Для того чтобы руками не вводить в OTP приложение начальный токен, можно генерировать QR код, с текстом вида:

otpauth://totp/мой_сайт:логин?secret=токен&issuer=логин

Оставить комментарий otp, php, qr, totp, двухфакторая авторизация

RabbitMQ: Отложеная доставка и время жизни пакета

29.06.2022 Павел Грибов PHP

Собрал наконец в одном классе, всё что мне нужно от RabbitMQ: а именно отправка сообщения в очередь, с отложеной доставкой, плюс уничтожение сообщения по прошествии какого то времени «не доставки».

Ну да, казалось бы элементарные вещи, но на PHP примеров для этого случая не сказать что уж слишком много как оказалось..

<?php

//Необходимые классы
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Wire\AMQPTable;


class TRabbit extends TLog{ 
    public $host="";
    public $login="";
    public $password="";
    public $port="";
    public $connection=null;
    public static $isInstance=false; 
    // настройки касающиеся очереди
    public $passive=false;      // может использоваться для проверки того, инициирован ли обмен, без того, чтобы изменять состояние сервера
    public $durable=true;       // убедимся, что RabbitMQ никогда не потеряет очередь при падении - очередь переживёт перезагрузку брокера
    public $exclusive=false;    // используется только одним соединением, и очередь будет удалена при закрытии соединения
    public $autodelete=false;   // очередь удаляется, когда отписывается последний подписчик
    public $ttl=3000;           // время жизни пакета, через которое оно при недоставке дропнется,в милисекундах
            
    public function __destruct(){
        if (self::$isInstance==false) {        
          $this->connection->close();  
        }
    }    
    public function __construct(){
        self::$isInstance=true;
        $this->host= TConfig::GetConfigKeyValue("rabbitmq_host");
        $this->login= TConfig::GetConfigKeyValue("rabbitmq_login");
        $this->host= "localhost";
        
        $this->password= TConfig::GetConfigKeyValue("rabbitmq_password");
        $this->password="guest";
        $this->port= TConfig::GetConfigKeyValue("rabbitmq_port");        
        $this->connection = new AMQPStreamConnection($this->host, $this->port, $this->login, $this->password);        
    }    
    /**
     * Поставить в очередь сообщение
     * @global type $db
     * @param type $queue   - имя очереди
     * @param type $message - сообщение в json формате
     * @param type $delay   - отсрочка доставки в секундах (необязательно)
     * @param type $ttl     - время жизни пакета, через которое оно при недоставке дропнется
     * @return type
     */
    public function  Producer($queue,$message,$delay=0,$ttl=null) {  
     global $db;
        try {    
          $answer = AnswerStrucNext(false, "Failed to queue a RabbitMQ message");             
             $channel = $this->connection->channel();      
            $channel->exchange_declare(
                'delay',
                'x-delayed-message',
                false,            /* не создается очереь если нет её */
                $this->durable,   /* гарантированная доставка */
                false,            /* удаление очереди если пустая и нет слушателей */
                false,            /* internal */
                false,            /* не ждать ответа от сервера (т. е. продолжать получение) */
                [
                    'x-delayed-type' => ['S', 'direct']                    
                ]);
             if (is_null($ttl)) $ttl=$this->ttl;
             $channel->queue_declare($queue, $this->passive, $this->durable, $this->exclusive, $this->autodelete,false,
                array(
                        "x-message-ttl" => array("I", $ttl)
                    )                     
                );
             $channel->queue_bind($queue, "delay", $queue);
               if ($delay==0){
                  $msg = new AMQPMessage($message);		        
               } else {
                   $msg = new AMQPMessage($message, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);		
                   $msg->set('application_headers', new AMQPTable(['x-delay' => $delay*1000]));        
               };
          $channel->basic_publish($msg,"delay",$queue);                  
          $channel->close();
          $answer = AnswerStrucNext(false, "ok");             
       } catch(Exception $err) {
           $this->InsertLog(TLog::PT_PLAIN,"Ошибка постановки в очередь $queue (RabbitMQ)", TLog::R_Error, $message);
       };          
     return $answer;
    }
}

<?php

//Необходимые классы

use PhpAmqpLib\Connection\AMQPStreamConnection;

use PhpAmqpLib\Message\AMQPMessage;

use PhpAmqpLib\Wire\AMQPTable;

class TRabbit extends TLog{

public $host="";

public $login="";

public $password="";

public $port="";

public $connection=null;

public static $isInstance=false;

// настройки касающиеся очереди

public $passive=false; // может использоваться для проверки того, инициирован ли обмен, без того, чтобы изменять состояние сервера

public $durable=true; // убедимся, что RabbitMQ никогда не потеряет очередь при падении - очередь переживёт перезагрузку брокера

public $exclusive=false; // используется только одним соединением, и очередь будет удалена при закрытии соединения

public $autodelete=false; // очередь удаляется, когда отписывается последний подписчик

public $ttl=3000; // время жизни пакета, через которое оно при недоставке дропнется,в милисекундах

public function __destruct(){

if (self::$isInstance==false) {

$this->connection->close();

}

public function __construct(){

self::$isInstance=true;

$this->host= TConfig::GetConfigKeyValue("rabbitmq_host");

$this->login= TConfig::GetConfigKeyValue("rabbitmq_login");

$this->host= "localhost";

$this->password= TConfig::GetConfigKeyValue("rabbitmq_password");

$this->password="guest";

$this->port= TConfig::GetConfigKeyValue("rabbitmq_port");

$this->connection = new AMQPStreamConnection($this->host, $this->port, $this->login, $this->password);

}

/**

* Поставить в очередь сообщение

* @global type $db

* @param type $queue - имя очереди

* @param type $message - сообщение в json формате

* @param type $delay - отсрочка доставки в секундах (необязательно)

* @param type $ttl - время жизни пакета, через которое оно при недоставке дропнется

* @return type

public function Producer($queue,$message,$delay=0,$ttl=null) {

global $db;

try {

$answer = AnswerStrucNext(false, "Failed to queue a RabbitMQ message");

$channel = $this->connection->channel();

$channel->exchange_declare(

'delay',

'x-delayed-message',

false, /* не создается очереь если нет её */

$this->durable, /* гарантированная доставка */

false, /* удаление очереди если пустая и нет слушателей */

false, /* internal */

false, /* не ждать ответа от сервера (т. е. продолжать получение) */

[

'x-delayed-type' => ['S', 'direct']

]);

if (is_null($ttl)) $ttl=$this->ttl;

$channel->queue_declare($queue, $this->passive, $this->durable, $this->exclusive, $this->autodelete,false,

array(

"x-message-ttl" => array("I", $ttl)

)

);

$channel->queue_bind($queue, "delay", $queue);

if ($delay==0){

$msg = new AMQPMessage($message);

} else {

$msg = new AMQPMessage($message, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

$msg->set('application_headers', new AMQPTable(['x-delay' => $delay*1000]));

};

$channel->basic_publish($msg,"delay",$queue);

$channel->close();

$answer = AnswerStrucNext(false, "ok");

} catch(Exception $err) {

$this->InsertLog(TLog::PT_PLAIN,"Ошибка постановки в очередь $queue (RabbitMQ)", TLog::R_Error, $message);

};

return $answer;

}

Оставить комментарий php, rabbitmq, x-message-ttl

PHP: работа с файлами Excel

27.06.2022 Павел Грибов PHP

Одним из вариантов работы с файлами Эксель является библиотека PhpSpreadsheet.

Установка:

composer require phpoffice/phpspreadsheet

Пример использования:

composer require phpoffice/phpspreadsheet

Пример использования:

/require_once('vendor/autoload.php');
 
use PhpOffice\PhpSpreadsheet\IOFactory;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Style\{Font, Border, Alignment};
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;

$oSpreadsheet = IOFactory::load("akt.xlsx"); // шаблон с шапкой

$oSpreadsheet->getProperties()
   ->setCreator('SSK, OOO')
   ->setLastModifiedBy('SSK, OOO')
   ->setTitle('Акт сверки с клиентом') 
   ->setSubject('Акт сверки с клиентом')
   ->setKeywords('кцмукмц ')
   ->setCategory('узщшамыуозк ')
;

$oSpreadsheet->setActiveSheetIndex(0);
$wSheet = $oSpreadsheet->getActiveSheet();

$wSheet->setCellValueByColumnAndRow(1, 3, "Клиент: " . $res->result->user);
$wSheet->setCellValueByColumnAndRow(1, 4, "Дата с: " . $res->result->from);
$wSheet->setCellValueByColumnAndRow(1, 5, "Дата по: " . $res->result->from);

$totalrow=8;

$balance=0;
foreach($res->result->table as $row) {
    $source="";
    if ($row->doc_reservation>0){$source="уцкацук м №".$row->doc_reservation;};
    if ($row->doc_charge>0){$source="ы укмыу №".$row->doc_charge;};
    if ($row->doc_payment>0){
        $source="уфыкмыукм №".$row->doc_payment;
        if ($row->connector>0){$source=$source.",фыумукау №".$row->connector;};        
    }; 
    
    $wSheet->setCellValueByColumnAndRow(1, $totalrow, $row->date);    //дата
    $wSheet->setCellValueByColumnAndRow(2, $totalrow, $source);    // источник     
    $wSheet->setCellValueByColumnAndRow(3, $totalrow, $row->debit);    // дебет
    $wSheet->setCellValueByColumnAndRow(4, $totalrow, $row->credit);    // кредит
    $wSheet->setCellValueByColumnAndRow(5, $totalrow, $row->balance);    // баланс
    $wSheet->setCellValueByColumnAndRow(6, $totalrow, $row->ezs);    // ЭЗС
    $balance=$row->balance;
    $totalrow++;
}

$wSheet->setCellValueByColumnAndRow(1, $totalrow, "Текущий баланс: " . $balance);
$wSheet->getStyle('A'.$totalrow)->applyFromArray([
    'font' => [
      'name' => 'Arial',
      'bold' => true,
      'italic' => false,
      'underline' => Font::UNDERLINE_DOUBLE,
      'strikethrough' => false,
      'color' => [
          'rgb' => '808080' 
        ]
    ],
    'borders' => [
        'allBorders' => [
            'borderStyle' => Border::BORDER_THIN,
            'color' => [
                'rgb' => '808080'
            ]
        ],
    ],
    'alignment' => [
        'horizontal' => Alignment::HORIZONTAL_CENTER,
        'vertical' => Alignment::VERTICAL_CENTER,
        'wrapText' => true,
    ]
]);
// установить цвет фона ячейки
$wSheet->getStyle('A'.$totalrow)->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB('00FF7F');
 

$oWriter = IOFactory::createWriter($oSpreadsheet, 'Xlsx');
$oWriter->save('php://output');

/require_once('vendor/autoload.php');

use PhpOffice\PhpSpreadsheet\IOFactory;

use PhpOffice\PhpSpreadsheet\Spreadsheet;

use PhpOffice\PhpSpreadsheet\Style\{Font, Border, Alignment};

use PhpOffice\PhpSpreadsheet\Writer\Xlsx;

$oSpreadsheet = IOFactory::load("akt.xlsx"); // шаблон с шапкой

$oSpreadsheet->getProperties()

->setCreator('SSK, OOO')

->setLastModifiedBy('SSK, OOO')

->setTitle('Акт сверки с клиентом')

->setSubject('Акт сверки с клиентом')

->setKeywords('кцмукмц ')

->setCategory('узщшамыуозк ')

;

$oSpreadsheet->setActiveSheetIndex(0);

$wSheet = $oSpreadsheet->getActiveSheet();

$wSheet->setCellValueByColumnAndRow(1, 3, "Клиент: " . $res->result->user);

$wSheet->setCellValueByColumnAndRow(1, 4, "Дата с: " . $res->result->from);

$wSheet->setCellValueByColumnAndRow(1, 5, "Дата по: " . $res->result->from);

$totalrow=8;

$balance=0;

foreach($res->result->table as $row) {

$source="";

if ($row->doc_reservation>0){$source="уцкацук м №".$row->doc_reservation;};

if ($row->doc_charge>0){$source="ы укмыу №".$row->doc_charge;};

if ($row->doc_payment>0){

$source="уфыкмыукм №".$row->doc_payment;

if ($row->connector>0){$source=$source.",фыумукау №".$row->connector;};

};

$wSheet->setCellValueByColumnAndRow(1, $totalrow, $row->date); //дата

$wSheet->setCellValueByColumnAndRow(2, $totalrow, $source); // источник

$wSheet->setCellValueByColumnAndRow(3, $totalrow, $row->debit); // дебет

$wSheet->setCellValueByColumnAndRow(4, $totalrow, $row->credit); // кредит

$wSheet->setCellValueByColumnAndRow(5, $totalrow, $row->balance); // баланс

$wSheet->setCellValueByColumnAndRow(6, $totalrow, $row->ezs); // ЭЗС

$balance=$row->balance;

$totalrow++;

}

$wSheet->setCellValueByColumnAndRow(1, $totalrow, "Текущий баланс: " . $balance);

$wSheet->getStyle('A'.$totalrow)->applyFromArray([

'font' => [

'name' => 'Arial',

'bold' => true,

'italic' => false,

'underline' => Font::UNDERLINE_DOUBLE,

'strikethrough' => false,

'color' => [

'rgb' => '808080'

]

'borders' => [

'allBorders' => [

'borderStyle' => Border::BORDER_THIN,

'color' => [

'rgb' => '808080'

]

'alignment' => [

'horizontal' => Alignment::HORIZONTAL_CENTER,

'vertical' => Alignment::VERTICAL_CENTER,

'wrapText' => true,

]

]);

// установить цвет фона ячейки

$wSheet->getStyle('A'.$totalrow)->getFill()->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID)->getStartColor()->setARGB('00FF7F');

$oWriter = IOFactory::createWriter($oSpreadsheet, 'Xlsx');

$oWriter->save('php://output');

Оставить комментарий excel, php

Отправка PUSH уведомлений в приложение IOS

11.04.2022 Павел Грибов PHP

Задача: в приложение на IOS отправить push уведомление из PHP

Решение:

public function SendPushIOS($token,$title,$message){     
     $rs=false;
     $notification_payload = [
        "aps" => [
            "alert" => [
                //"title" => "Зарядись!",
                "body" => $message,
               // "action-loc-key" => "PLAY"
            ],
            "badge" => 0,
            "sound" => "bingbong.aiff"
        ]
     ];     
        $token_key = $this->server_key_ios;
        //echo "!! token_id IOS: $this->server_token_id_ios\n";
        $jwt_header = [
                'alg' => 'ES256', 
                'kid' => $this->server_token_id_ios
        ];
        //echo "!!team_id:$this->server_team_id_ios\n";
        $jwt_payload = [
                'iss' => $this->server_team_id_ios, 
                'iat' => time()
        ];
        $raw_token_data = self::b64($jwt_header, true).".".self::b64($jwt_payload, true);
        $signature = '';        
        openssl_sign($raw_token_data, $signature, $token_key, 'SHA256');
        $jwt = $raw_token_data.".".self::b64($signature);
        // send push
        $request_body = json_encode($notification_payload);
        $endpoint = 'https://api.push.apple.com/3/device';
        $url = "$endpoint/$token";
        $ch = curl_init($url);
        //echo "!!server_bandle_id_ios:$this->server_bandle_id_ios\n";
        curl_setopt_array($ch, [
                CURLOPT_POSTFIELDS => $request_body,
                CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_2_0,
                CURLOPT_HTTPHEADER => [
                        "content-type: application/json",
                        "authorization: bearer $jwt",
                        "apns-topic: $this->server_bandle_id_ios"
                ]
        ]);
        $result_curl=curl_exec($ch);
        $result = json_decode($result_curl);

        if (is_null($result)) {
            $log= new TLog($this->api);
            $log->InsertLogBoiler([
                "source_id"=> TLog::S_Messages,
                "comment"=>"Ошибка отправки PUSH IOS",
                "raw_package"=>curl_error($ch).$result_curl,
                "reason"=> TLog::R_Error
            ]);           
        } else { 
                if ((int)$result>0){
                //if ($result->success>0){
                  $rs=true;  
                };
        };
        

        curl_close($ch);        
     return $rs;
    }
 public function b64($raw, $json=false){
            if($json) $raw = json_encode($raw);
            return str_replace('=', '', strtr(base64_encode($raw), '+/', '-_')); 
    }

public function SendPushIOS($token,$title,$message){

$rs=false;

$notification_payload = [

"aps" => [

"alert" => [

//"title" => "Зарядись!",

"body" => $message,

// "action-loc-key" => "PLAY"

"badge" => 0,

"sound" => "bingbong.aiff"

]

];

$token_key = $this->server_key_ios;

//echo "!! token_id IOS: $this->server_token_id_ios\n";

$jwt_header = [

'alg' => 'ES256',

'kid' => $this->server_token_id_ios

];

//echo "!!team_id:$this->server_team_id_ios\n";

$jwt_payload = [

'iss' => $this->server_team_id_ios,

'iat' => time()

];

$raw_token_data = self::b64($jwt_header, true).".".self::b64($jwt_payload, true);

$signature = '';

openssl_sign($raw_token_data, $signature, $token_key, 'SHA256');

$jwt = $raw_token_data.".".self::b64($signature);

// send push

$request_body = json_encode($notification_payload);

$endpoint = 'https://api.push.apple.com/3/device';

$url = "$endpoint/$token";

$ch = curl_init($url);

//echo "!!server_bandle_id_ios:$this->server_bandle_id_ios\n";

curl_setopt_array($ch, [

CURLOPT_POSTFIELDS => $request_body,

CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_2_0,

CURLOPT_HTTPHEADER => [

"content-type: application/json",

"authorization: bearer $jwt",

"apns-topic: $this->server_bandle_id_ios"

]

]);

$result_curl=curl_exec($ch);

$result = json_decode($result_curl);

if (is_null($result)) {

$log= new TLog($this->api);

$log->InsertLogBoiler([

"source_id"=> TLog::S_Messages,

"comment"=>"Ошибка отправки PUSH IOS",

"raw_package"=>curl_error($ch).$result_curl,

"reason"=> TLog::R_Error

]);

} else {

if ((int)$result>0){

//if ($result->success>0){

$rs=true;

};

curl_close($ch);

return $rs;

}

public function b64($raw, $json=false){

if($json) $raw = json_encode($raw);

return str_replace('=', '', strtr(base64_encode($raw), '+/', '-_'));

}

Оставить комментарий ios, iphone, php, push

Отправка PUSH уведомлений в приложение Android из PHP

07.04.2022 Павел Грибов PHP

Для того чтобы отправлять пуш уведомления, необходимо получить ключ установки приложения и знать «ключ сервера». Более подробная информация в консоли Firebase

public function SendPushAndroid($server_key,$token,$title,$message){
        $data = json_encode([
            "to" => $token,
            "notification" => [
                "body" => $message,
                "title" => $title,
                "icon" => "ic_launcher"
            ]
        ]);

        $url = 'https://fcm.googleapis.com/fcm/send';
        $server_key = $server_key;
        $headers = array('Content-Type:application/json','Authorization:key='.$server_key);
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        $result = curl_exec($ch);
        var_dump($result);
        if ($result === FALSE) {
            die('Oops! FCM Send Error: ' . curl_error($ch));
        }
        curl_close($ch);        
    }

public function SendPushAndroid($server_key,$token,$title,$message){

$data = json_encode([

"to" => $token,

"notification" => [

"body" => $message,

"title" => $title,

"icon" => "ic_launcher"

]

]);

$url = 'https://fcm.googleapis.com/fcm/send';

$server_key = $server_key;

$headers = array('Content-Type:application/json','Authorization:key='.$server_key);

$ch = curl_init();

curl_setopt($ch, CURLOPT_URL, $url);

curl_setopt($ch, CURLOPT_POST, true);

curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);

curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

curl_setopt($ch, CURLOPT_POSTFIELDS, $data);

$result = curl_exec($ch);

var_dump($result);

if ($result === FALSE) {

die('Oops! FCM Send Error: ' . curl_error($ch));

}

curl_close($ch);

}

Оставить комментарий android, firebase, php, push

« 1 2 3 4 5 6 … 21 »

Май 2024
Пн	Вт	Ср	Чт	Пт	Сб	Вс
		1	2	3	4	5
6	7	8	9	10	11	12
13	14	15	16	17	18	19
20	21	22	23	24	25	26
27	28	29	30	31