invoiceninja/app/Services/EDocument/Standards/Verifactu/SendToAeat.php

<?php
/**
 * Invoice Ninja (https://invoiceninja.com).
 *
 * @link https://github.com/invoiceninja/invoiceninja source repository
 *
 * @copyright Copyright (c) 2025. Invoice Ninja LLC (https://invoiceninja.com)
 *
 * @license https://www.elastic.co/licensing/elastic-license
 */

namespace App\Services\EDocument\Standards\Verifactu;

use Mail;
use App\Utils\Ninja;
use App\Models\Company;
use App\Models\Invoice;
use App\Models\Activity;
use App\Models\SystemLog;
use App\Libraries\MultiDB;
use Illuminate\Bus\Queueable;
use App\Jobs\Util\SystemLogger;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Cache;
use Illuminate\Mail\Mailables\Address;
use Illuminate\Queue\SerializesModels;
use App\Repositories\ActivityRepository;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use App\Services\EDocument\Standards\Verifactu;
use Illuminate\Queue\Middleware\WithoutOverlapping;

class SendToAeat implements ShouldQueue
{
    use Dispatchable;
    use InteractsWithQueue;
    use Queueable;
    use SerializesModels;

    public $tries = 5;

    public $deleteWhenMissingModels = true;
    
    /**
     * Modification Invoices - (modify) 
     *  - If Amount < 0 - We generate a R2 document which is a negative modification on the original invoice.
     * Create Invoices - (create) Generates a F1 document.
     * Cancellation Invoices - (cancel) Generates a R3 document with full negative values of the original invoice.
     */

    /**
     * __construct
     *
     * @param  int $invoice_id
     * @param  Company $company
     * @param  string $action create, modify, cancel
     * @return void
     */
    public function __construct(private int $invoice_id, private Company $company, private string $action)
    {
    }

    public function backoff()
    {
        return [5, 30, 240, 3600, 7200];
    }

    public function handle(ActivityRepository $activity_repository)
    {
        MultiDB::setDB($this->company->db);

        $invoice = Invoice::withTrashed()->find($this->invoice_id);

        $invoice = $invoice->service()->markSent()->save();
        
        switch($this->action) {
            case 'create':
                $this->createInvoice($invoice);
                break;
            case 'cancel':
                $this->cancelInvoice($invoice);
                break;
        }

    }
    
    /**
     * modifyInvoice
     *
     * Two code paths here:
     * 1. F3 - we are replacing the invoice with a new one: ie. invoice->amount >=0
     * 2. R2 - we are modifying the invoice with a negative amount: ie. invoice->amount < 0
     * @param  Invoice $invoice
     * @return void
     */
    
    public function createInvoice(Invoice $invoice)
    {
        $verifactu = new Verifactu($invoice);
        $verifactu->run();

        $envelope = $verifactu->getEnvelope();

        $response = $verifactu->send($envelope);

        nlog($response);

        $message = '';
        if (isset($response['errors'][0]['message'])) {
            $message = $response['errors'][0]['message'];
        }

        if($response['success']) {
            $invoice->backup->guid = $response['guid'];
            $invoice->saveQuietly();
        }

        $this->writeActivity($invoice, $response['success'] ? Activity::VERIFACTU_INVOICE_SENT : Activity::VERIFACTU_INVOICE_SENT_FAILURE, $message);
        $this->systemLog($invoice, $response, $response['success'] ? SystemLog::EVENT_VERIFACTU_SUCCESS : SystemLog::EVENT_VERIFACTU_FAILURE, SystemLog::TYPE_VERIFACTU_INVOICE);

    }

    public function cancelInvoice(Invoice $invoice)
    {

        $verifactu = new Verifactu($invoice);
        
        $document = (new RegistroAlta($invoice))->run()->getInvoice();
        $document->setNumSerieFactura($invoice->backup->parent_invoice_number);
        $last_hash = $invoice->company->verifactu_logs()->first();

        $huella = $this->cancellationHash($document, $last_hash->hash);

        $cancellation = $document->createCancellation();

        $cancellation->setHuella($huella);

        $soapXml = $cancellation->toSoapEnvelope();

        $response = $verifactu->setInvoice($document)
                        ->setHuella($huella)
                        ->setPreviousHash($last_hash->hash)
                        ->send($soapXml);

        nlog($response);
        
        $message = '';

        if($response['success']) {
            //if successful, we need to pop this invoice from the child array of the parent invoice!
            $parent = Invoice::withTrashed()->find($invoice->backup->parent_invoice_id);
            
            if($parent) {
                $parent->backup->child_invoice_ids = $parent->backup->child_invoice_ids->reject(fn($id) => $id === $invoice->hashed_id);
                $parent->saveQuietly();
            }

            $invoice->backup->guid = $response['guid'];
            $invoice->saveQuietly();

        }

        if(isset($response['errors'][0]['message'])){
            $message = $response['errors'][0]['message'];
        }

        //@todo - verifactu logging
        $this->writeActivity($invoice, $response['success'] ? Activity::VERIFACTU_CANCELLATION_SENT : Activity::VERIFACTU_CANCELLATION_SENT_FAILURE, $message);
        $this->systemLog($invoice, $response, $response['success'] ? SystemLog::EVENT_VERIFACTU_SUCCESS : SystemLog::EVENT_VERIFACTU_FAILURE, SystemLog::TYPE_VERIFACTU_CANCELLATION);
    }

    public function middleware()
    {
        return [(new WithoutOverlapping("send_to_aeat_{$this->company->company_key}"))->releaseAfter(30)->expireAfter(30)];
    }

    public function failed($exception = null)
    {
        nlog($exception);
    }

    private function writeActivity(Invoice $invoice, int $activity_id, string $notes = ''): void
    {
        $activity = new Activity();
        $activity->user_id = $invoice->user_id;
        $activity->client_id = $invoice->client_id;
        $activity->company_id = $invoice->company_id;
        $activity->account_id = $invoice->company->account_id;
        $activity->activity_type_id = $activity_id;
        $activity->invoice_id = $invoice->id;
        $activity->notes = str_replace('"', '', $notes);
        $activity->is_system = true;

        $activity->save();

    }

    private function systemLog(Invoice $invoice, array $data, int $event_id, int $type_id): void
    {
        (new SystemLogger(
                $data,
                SystemLog::CATEGORY_VERIFACTU,
                $event_id,
                $type_id,
                $invoice->client,
                $invoice->company
            )
        )->handle();
    }
    
    /**
     * cancellationHash
     *
     * @param  mixed $document
     * @param  string $huella
     * @return string
     */
    private function cancellationHash($document, string $huella): string
    {

        $idEmisorFacturaAnulada = $document->getIdFactura()->getIdEmisorFactura();
        $numSerieFacturaAnulada = $document->getIdFactura()->getNumSerieFactura();
        $fechaExpedicionFacturaAnulada = $document->getIdFactura()->getFechaExpedicionFactura();
        $fechaHoraHusoGenRegistro = $document->getFechaHoraHusoGenRegistro();

        $hashInput = "IDEmisorFacturaAnulada={$idEmisorFacturaAnulada}&" .
            "NumSerieFacturaAnulada={$numSerieFacturaAnulada}&" .
            "FechaExpedicionFacturaAnulada={$fechaExpedicionFacturaAnulada}&" .
            "Huella={$huella}&" .
            "FechaHoraHusoGenRegistro={$fechaHoraHusoGenRegistro}";

        return strtoupper(hash('sha256', $hashInput));

    }
}