0

Boas Galera!

Tenho uma aplicação multi database onde cada schema é um cliente, tudo funciona perfeitamente, exceto as filas. estou direcionando todos os jobs para o banco de dados principal, os registros de jobs são registrados com sucesso, porém retorna falha na execução do:

php artisan queue:work
[2020-02-27 13:06:25][14] Processing: app\Jobs\SendEmail
[2020-02-27 13:06:25][14] Failed:     app\Jobs\SendEmail

observando o log que habita o /storage/logs, tenho o seguinte retorno:

[previous exception] [object] (PDOException(code: 3D000): SQLSTATE[3D000]: Invalid catalog name: 1046 No database selected at /var/www/html/projetos/my.project/vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/PDOConnection.php:61)

estou forçando a aplicação salvar os jobs no banco de dados principal dessa forma:

queue.php

'default' => env('QUEUE_CONNECTION', 'database'),

'connections' => [
           'database' => [
            'driver' => 'database',
            'connection'=>'mysql',
            'table' => 'jobs',
            'queue' => 'default',
            'retry_after' => 90,
        ],
],

database.php

'connections' => [


        'sqlite' => [
            'driver' => 'sqlite',
            'url' => env('DATABASE_URL'),
            'database' => env('DB_DATABASE', database_path('database.sqlite')),
            'prefix' => '',
            'foreign_key_constraints' => env('DB_FOREIGN_KEYS', true),
        ],

        'mysql' => [
            'driver' => 'mysql',
            'url' => env('DATABASE_URL'),
            'host' => env('DB_HOST', '127.0.0.1'),
            'port' => env('DB_PORT', '3306'),
            'database' => env('DB_DATABASE', 'db_principal'),
            'username' => env('DB_USERNAME', 'root'),
            'password' => env('DB_PASSWORD', ''),
            'unix_socket' => env('DB_SOCKET', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_unicode_ci',
            'prefix' => '',
            'prefix_indexes' => true,
            'strict' => true,
            'engine' => null,
            'options' => extension_loaded('pdo_mysql') ? array_filter([
                PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
            ]) : [],
        ],
],

MeuController.php

(...)

SendEmail::dispatch($cliente->email,
                    $insertPedido,
                    $remetente->from_name,
                    $pagamento
                    );
(...)

app/Jobs/SendEmail.php

class SendEmail implements ShouldQueue

{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $destino;
    protected $pedido;
    protected $remetente;
    protected $pagamento;

    public function __construct(
        $destino, 
        $pedido, 
        $remetente,
        $pagamento)
    {
        $this->destino = $destino;
        $this->pedido = $pedido;
        $this->remetente = $remetente;
        $this->pagamento = $pagamento;

    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
            //executa a conexão tenant
            TenantManager::setConnection(Auth::user()->banco_dados);
            //carrega as cpnfigurações de SMTP do cliente 
            EmailConfig::emailConfig()
            $mailAgenda = Mail::to($this->destino)->send(new Email($this->pedido, 
                                                            $this->remetente, 
                                                            $this->pagamento)
                                                        );

    }
}

app/Mails/Email.php

class Email extends Mailable implements ShouldQueue
{
    use Queueable, SerializesModels;

    protected $pedido;
    protected $remetente;
    protected $pagamento;

    public function __construct(
        $pedido, 
        $agenda,
        $remetente,
        $pagamento)
    {
        $this->pedido = $pedido;
        $this->remetente = $remetente;
        $this->pagamento = $pagamento;
    }

    /**
     * Build the message.
     *
     * @return $this
     */
    public function build()
    {
        return $this->markdown('emails.mail-markdown',
                                [
                                    'pedido' => $this->pedido,
                                    'remetente' => $this->remetente,
                                    'pagamento' => $this->pagamento
                                ]
                            );
    }
}

O que eu estou fazendo de errado? Alquém pode me auxiliar? Detalhe: cada cliente possui seu próprio SMTP.

Desde já Agradeço!

1
  • Boas galera! Consegui "resolver" da seguinte forma: Commented 4/03/2020 às 16:57

1 Resposta 1

0

Boas galera!

Consegui "resolver" da seguinte forma:

a) Desisti do smtp dinâmico, pois não iria funcionar devido ao erro de spoof que vários smtps geraria no mesmo domínio.

b) Abri mão do JOB, ao invés disso, contornei a situação com uma tabela que armazena todo o conteúdo do e-mail.

c) Criei um Observer que monitora a tabela que armazena os conteúdos de e-mails, toda vez que um registro é criado ele invoca uma notificação.

d) SMTP estático no .env

Funcionou ! Sei, não é elegante mas por hora resolveu essa questão.

E como eu fiz isso?

config/queue.php

 'default' => env('QUEUE_CONNECTION', 'database'),
'connections' => [

           'database' => [
            'driver' => 'database',
            'connection' => 'mysql',
            'table' => 'jobs',
            'queue' => 'default',
            'retry_after' => 90,
        ],

    'failed' => [
        'database' => env('DB_CONNECTION', 'mysql'),
        'table' => 'failed_jobs',
    ],

.env

MAIL_DRIVER=smtp
MAIL_HOST=smtp.gmail.com
MAIL_PORT=587
[email protected]
MAIL_PASSWORD=@XXXXXXXX
MAIL_ENCRYPTION=tls
[email protected]
MAIL_FROM_NAME="${APP_NAME}"

MeuController.php

(...)
   GerenciaEmailController::mailNewOrder($pedido->id);  
 (...)    

app/Models/GerenciaEmail.php

use Illuminate\Notifications\Notifiable;
use Illuminate\Database\Eloquent\Model;

    class GerenciaEmail extends Model
    {
        use Notifiable;

        protected $connection = 'mysql';
        protected $table = 'gerencia_emails';
        protected $primaryKey ='id';
        protected $fillable =[
            'payload',
            'action',
        ];
    }

É muito importante setar essa model para o banco de dados principal com protected $connection

GerenciaEmailController.php

public static function mailNewOrder($pedido_id):void
{

        $pedido = Pedido::find($pedido_id);
        $payload = Array('pedido' => $pedido,
            'cliente' =>  $pedido->cliente,
            'produto'=> $pedido->produto,
        );

        $insertEmail = new GerenciaEmail;           
        $insertEmail->payload= json_encode($payload);
        $insertEmail->action='novo';
        $insertEmail->save();

}

ObserverMail.php

use App\Models\GerenciaEmail;
use App\Notifications\NotificarCliente;

class ObserverMail
{
     /**
         * Listen to the User created event.
         *
         * @param  GerenciaEmail  $gerenciaEmail
         * @return void
         */
        public function created(GerenciaEmail $gerenciaEmail)
        {
            $gerenciaEmail->notify(new NotificarCliente());
        }

}

NotificarCliente.php

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Notifications\Messages\MailMessage;
use Illuminate\Notifications\Notification;

class NotificarCliente extends Notification implements ShouldQueue
{
    use Queueable;


    /**
     * Get the notification's delivery channels.
     *
     * @param  mixed  $notifiable
     * @return array
     */
    public function via($notifiable)
    {
        return ['mail'];
    }

    /**
     * Get the mail representation of the notification.
     *
     * @param  mixed  $notifiable
     * @return \Illuminate\Notifications\Messages\MailMessage
     */
    public function toMail($notifiable)
    {   
            return (new MailMessage)
                        ->subject('SEU PEDIDO!')
                        ->markdown('emails.pedido-markdown', ['payload' => $notifiable->payload]);
    }
}

Registre o Observer no App\Providers\AppServiceProvider

public function boot()
    {
       Schema::defaultStringLength(191);
       GerenciaEmail::observe(ObserverMail::class);

    }

Parece gambiarra, mas funciona que é uma beleza.

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .