Proyectos de Subversion LeadersLinked - Antes de SPA

<?php

declare(strict_types=1);

namespace LeadersLinked\Command;

use Symfony\Component\Console\Command\Command;

use Symfony\Component\Console\Input\InputInterface;

use Symfony\Component\Console\Output\OutputInterface;

use Laminas\Db\Adapter\AdapterInterface;

use LeadersLinked\Cache\CacheInterface;

use Laminas\Log\LoggerInterface;

use LeadersLinked\Mapper\PushMapper;

use LeadersLinked\Model\Push;

class ProcessQueuePushCommand extends Command

{

    /**

     *

     * @var AdapterInterface

     */

    private $adapter;

    /**

     *

     * @var CacheInterface

     */

    private $cache;

    /**

     *

     * @var  LoggerInterface

     */

    private $logger;

    /**

     *

     * @var array

     */

    private $config;

    /**

     *

     * @param AdapterInterface $adapter

     * @param CacheInterface $cache

     * @param LoggerInterface $logger

     * @param array $config

     */

     public function __construct($adapter, $cache, $logger, $config)

    {

        $this->adapter      = $adapter;

        $this->cache        = $cache;

        $this->logger       = $logger;

        $this->config       = $config;

        parent::__construct();

    }

    protected function execute(InputInterface $input, OutputInterface $output) : int

    {

        $batch_size = $this->config['leaderslinked.fcm.batch_size'];

        $output->writeln('Inicio del proceso de la cola de Push');

        $pushCompleted = 0;

        $pushError = 0;

        $pushMapper = PushMapper::getInstance($this->adapter);

        $pushs = $pushMapper->fetchBatch($batch_size);

        if($pushs) {

            foreach($pushs as $push)

            {

                $data = json_decode($push->data, true);

                $auth_key = $data['server']['key'] ;

                $fields = $data['push'];

                $headers = [

                    'Authorization: key=' . $auth_key,

                    'Content-Type: application/json'

                ];

                $ch = curl_init();

                curl_setopt( $ch,CURLOPT_URL, 'https://fcm.googleapis.com/fcm/send' );

                curl_setopt( $ch,CURLOPT_POST, true );

                curl_setopt( $ch,CURLOPT_HTTPHEADER, $headers );

                curl_setopt( $ch,CURLOPT_RETURNTRANSFER, true );

                curl_setopt( $ch,CURLOPT_SSL_VERIFYPEER, false );

                curl_setopt( $ch,CURLOPT_POSTFIELDS, json_encode( $fields ) );

                $result = curl_exec($ch );

                curl_close( $ch );

                if($result) {

                    $json = json_decode($result, true);

                    if($json) {

                        //{"multicast_id":8921821776092049363,"success":0,"failure":1,"canonical_ids":0,"results":[{"error":"MismatchSenderId"}]}

                        //print_r($json);

                        $succes = isset($json['success']) ? $json['success'] : 0;

                        $failure = isset($json['failure']) ? $json['failure'] : 0;

                        $pushError = $pushError + $failure;

                        $pushCompleted = $pushCompleted +  $succes;

                        if($succes) {

                            $push->status = Push::STATUS_COMPLETED;

                        } else {

                            $push->status = Push::STATUS_ERROR;

                        }

                    } else {

                        $push->status = Push::STATUS_ERROR;

                    }

                } else {

                    $push->status = Push::STATUS_ERROR;

                }

                $pushMapper->update($push);

            }

        }

        $output->writeln('Push con Errores descartados: ' . $pushError);

        $output->writeln('Push enviados correctamente:'  . $pushCompleted);

        $output->writeln('Fin del proceso de la cola de Push');

        return 0;

    }

}