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!