webstatement/app/Jobs/UnlockPdfJob.php

<?php

namespace Modules\Webstatement\Jobs;

use Exception;
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\Log;
use Illuminate\Support\Facades\File;
use Symfony\Component\Process\Process;
use Symfony\Component\Process\Exception\ProcessFailedException;

class UnlockPdfJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $baseDirectory;
    protected $password;

    /**
     * Create a new job instance.
     *
     * @param string $baseDirectory Base directory path to scan
     * @param string $password Password to unlock PDF files
     */
    public function __construct(string $baseDirectory, string $password = '123456')
    {
        $this->baseDirectory = $baseDirectory;
        $this->password = $password;
    }

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        try {
            Log::info("Starting PDF unlock process in directory: {$this->baseDirectory}");

            // Check if directory exists
            if (!File::isDirectory($this->baseDirectory)) {
                Log::error("Directory not found: {$this->baseDirectory}");
                return;
            }

            // Get all subdirectories (year folders like 202505)
            $yearDirectories = File::directories($this->baseDirectory);

            foreach ($yearDirectories as $yearDirectory) {
                $this->processYearDirectory($yearDirectory);
            }

            Log::info("PDF unlock process completed successfully.");
        } catch (Exception $e) {
            Log::error("Error unlocking PDF files: " . $e->getMessage());
        }
    }

    /**
     * Process a year directory (e.g., 202505)
     *
     * @param string $yearDirectory Directory path to process
     */
    protected function processYearDirectory(string $yearDirectory): void
    {
        try {
            // Get all ID directories (e.g., ID0010001)
            $idDirectories = File::directories($yearDirectory);

            foreach ($idDirectories as $idDirectory) {
                $this->processIdDirectory($idDirectory);
            }
        } catch (Exception $e) {
            Log::error("Error processing year directory {$yearDirectory}: " . $e->getMessage());
        }
    }

    /**
     * Process an ID directory (e.g., ID0010001)
     *
     * @param string $idDirectory Directory path to process
     */
    protected function processIdDirectory(string $idDirectory): void
    {
        try {
            // Get all PDF files in the directory
            $pdfFiles = File::glob($idDirectory . '/*.pdf');

            foreach ($pdfFiles as $pdfFile) {
                $this->unlockPdf($pdfFile);
            }
        } catch (Exception $e) {
            Log::error("Error processing ID directory {$idDirectory}: " . $e->getMessage());
        }
    }

    /**
     * Unlock a password-protected PDF file
     *
     * @param string $pdfFilePath Path to PDF file
     */
    protected function unlockPdf(string $pdfFilePath): void
    {
        try {
            $filename = pathinfo($pdfFilePath, PATHINFO_FILENAME);
            $directory = pathinfo($pdfFilePath, PATHINFO_DIRNAME);
            $decryptedPdfPath = $directory . '/' . $filename . '.dec.pdf';

            // Skip if the decrypted file already exists
            if (File::exists($decryptedPdfPath)) {
                Log::info("Decrypted file already exists: {$decryptedPdfPath}");
                return;
            }

            // Create qpdf command
            $command = ['qpdf', '--password=' . $this->password, '--decrypt', $pdfFilePath, $decryptedPdfPath];

            // Execute the command
            $process = new Process($command);
            $process->run();

            // Check if the command was successful
            if (!$process->isSuccessful()) {
                throw new ProcessFailedException($process);
            }

            Log::info("Unlocked PDF: {$pdfFilePath} to {$decryptedPdfPath}");
        } catch (Exception $e) {
            Log::error("Error unlocking PDF {$pdfFilePath}: " . $e->getMessage());
        }
    }
}