init commit

api/app/Jobs/Bpa/ExportacaoJob.php

@@ -0,0 +1,154 @@
+<?php
+
+namespace App\Jobs\Bpa;
+
+use App\Enums\Bpa\ExportacaoStatus;
+use App\Events\Bpa\ExportacaoFinalizadaEvent;
+use App\Models\Bpa\Exportacao;
+use App\Services\Bpa\ExportacaoService;
+use Carbon\Carbon;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Config;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Storage;
+use Throwable;
+
+class ExportacaoJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    const BASE_PATH = 'faturamento' . DIRECTORY_SEPARATOR . 'bpa' . DIRECTORY_SEPARATOR;
+
+    public $timeout = 0;
+    public $tries = 1;
+
+    protected $cliente;
+    protected $exportacaoId;
+
+    public function __construct($cliente, $exportacaoId)
+    {
+        $this->cliente = $cliente;
+        $this->exportacaoId = $exportacaoId;
+    }
+
+    public function handle()
+    {
+        set_time_limit(0);
+
+        $currentConnection = config('database.default');
+
+        try {
+            $this->setConnection();
+
+            $exportacao = Exportacao::find($this->exportacaoId);
+
+            if (is_null($exportacao)) {
+                Log::channel('bpa-exportacao')->error('Registro de exportação não encontrado', [
+                    'cliente' => $this->cliente,
+                    'origem' => 'ExportacaoJob',
+                    'exportacao_id' => $this->exportacaoId,
+                ]);
+
+                return;
+            }
+
+            $exportacao->status_id = ExportacaoStatus::EM_PROCESSAMENTO;
+            $exportacao->data_hora_inicio = Carbon::now();
+            $exportacao->save();
+
+            DB::transaction(function () use ($exportacao) {
+                $path = self::BASE_PATH . $this->cliente . DIRECTORY_SEPARATOR;
+
+                $params = [
+                    'exportacao_id' => $exportacao->id,
+                    'competencia_id' => $exportacao->competencia_id,
+                    'unidades' => $exportacao->unidades->pluck('id'),
+                    'financiamentos' => $exportacao->financiamentos->pluck('id'),
+                ];
+
+                $file = ExportacaoService::generate($this->cliente, $params);
+
+                $exportacao->status_id = ExportacaoStatus::PROCESSADO;
+                $exportacao->quantidade_consistencia = $file['consistencias'];
+                $exportacao->quantidade_inconsistencia = $file['inconsistencias'];
+
+                if (Storage::exists($path . $file['nome'])) {
+                    $exportacao->arquivo = $file['nome'];
+                    chmod(Storage::path($path . $file['nome']), 0775);
+                }
+
+                $exportacao->data_hora_fim = Carbon::now();
+                $exportacao->save();
+
+                ExportacaoFinalizadaEvent::dispatch($exportacao->createdLotacao->usuario_id, $exportacao->id, $exportacao->arquivo);
+            });
+        } finally {
+            $this->clearConnection();
+
+            Config::set('database.default', $currentConnection);
+        }
+    }
+
+    public function failed(Throwable $exception)
+    {
+        $currentConnection = config('database.default');
+
+        try {
+            $this->setConnection();
+
+            $exportacao = Exportacao::find($this->exportacaoId);
+
+            if ($exportacao) {
+                $exportacao->status_id = ExportacaoStatus::ERRO_NO_PROCESSAMENTO;
+                $exportacao->data_hora_fim = Carbon::now();
+                $exportacao->save();
+
+                $path = self::BASE_PATH . $this->cliente . DIRECTORY_SEPARATOR;
+                $fileName = $exportacao->arquivo;
+
+                if (!is_null($fileName) && Storage::exists($path . $fileName)) {
+                    Storage::delete($path . $fileName);
+                }
+            }
+
+            Log::channel('atencao-basica-exportacao')->error('Erro ao executar a exportação', [
+                'cliente' => $this->cliente,
+                'origem' => 'ExportacaoJob',
+                'erro' => $exception->getMessage(),
+            ]);
+        } finally {
+            $this->clearConnection();
+
+            Config::set('database.default', $currentConnection);
+        }
+    }
+
+    private function setConnection()
+    {
+        Config::set("database.connections.job-{$this->cliente}", [
+            'driver' => 'mysql',
+            'host' => env('QUEUE_DB_HOST'),
+            'port' => env('QUEUE_DB_PORT'),
+            'database' => "conectasus_{$this->cliente}",
+            'username' => env('QUEUE_DB_USERNAME'),
+            'password' => env('QUEUE_DB_PASSWORD'),
+            'charset' => 'utf8mb4',
+            'collation' => 'utf8mb4_unicode_ci',
+        ]);
+
+        Config::set('database.default', "job-{$this->cliente}");
+
+        $this->clearConnection();
+    }
+
+    private function clearConnection()
+    {
+        DB::disconnect("job-{$this->cliente}");
+        DB::purge("job-{$this->cliente}");
+    }
+}