invoiceninja/app/Http/Controllers/EInvoicePeppolController.php

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

namespace App\Http\Controllers;

use Illuminate\Http\JsonResponse;
use Illuminate\Http\Response;
use App\Http\Requests\EInvoice\Peppol\StoreEntityRequest;
use App\Services\EDocument\Gateway\Storecove\Storecove;
use App\Http\Requests\EInvoice\Peppol\DisconnectRequest;
use App\Http\Requests\EInvoice\Peppol\AddTaxIdentifierRequest;
use App\Http\Requests\EInvoice\Peppol\RemoveTaxIdentifierRequest;
use App\Http\Requests\EInvoice\Peppol\RetrySendRequest;
use App\Http\Requests\EInvoice\Peppol\ShowEntityRequest;
use App\Http\Requests\EInvoice\Peppol\UpdateEntityRequest;
use App\Services\EDocument\Jobs\SendEDocument;

class EInvoicePeppolController extends BaseController
{
    /**
     * Returns the legal entity ID
     *
     * @param  ShowEntityRequest $request
     * @return JsonResponse
     */
    public function show(ShowEntityRequest $request, Storecove $storecove): JsonResponse
    {
        $company = auth()->user()->company();

        $response_array = $storecove->proxy->setCompany($company)->getLegalEntity($company->legal_entity_id);

        return response()->json($response_array, $response_array['code'] ?? 200);
    }

    /**
     * Create a legal entity id, response will be
     * the same as show()
     *
     * @param  StoreEntityRequest $request
     * @param  Storecove $storecove
     * @return Response
     */
    public function setup(StoreEntityRequest $request, Storecove $storecove): Response|JsonResponse
    {
        /**
         * @var \App\Models\Company
         */
        $company = auth()->user()->company();

        $response = $storecove
            ->proxy
            ->setCompany($company)
            ->setup($request->validated());

        if (data_get($response, 'status') === 'error') {
            return response()->json(data_get($response, 'message'), status: $response['code']);
        }

        $company->legal_entity_id = $response['legal_entity_id'];

        $tax_data = $company->tax_data;

        $tax_data->acts_as_sender = $request->acts_as_sender;
        $tax_data->acts_as_receiver = $request->acts_as_receiver;

        $settings = $company->settings;

        $settings->name = $request->party_name;
        $settings->country_id = (string) $request->country_id;
        $settings->address1 = $request->line1;
        $settings->address2 = $request->line2;
        $settings->city = $request->city;
        $settings->state = $request->county;
        $settings->postal_code = $request->zip;

        $settings->e_invoice_type = 'PEPPOL';
        $settings->vat_number = $request->vat_number ?? $company->settings->vat_number;
        $settings->id_number = $request->id_number ?? $company->settings->id_number;
        $settings->classification = $request->classification ?? $company->settings->classification;
        $settings->enable_e_invoice = true;
        $settings->inclusive_taxes = false;

        $company->tax_data = $tax_data;
        $company->settings = $settings;

        $company->enabled_tax_rates = 0;
        $company->enabled_item_tax_rates = 1;

        $company->save();

        return response()->noContent();
    }

    /**
     * Update legal properties such as acting as sender or receiver.
     *
     * @param \App\Http\Requests\EInvoice\Peppol\UpdateEntityRequest $request
     * @return JsonResponse
     */
    public function updateLegalEntity(UpdateEntityRequest $request, Storecove $storecove): JsonResponse
    {
        $company = auth()->user()->company();

        $response = $storecove
            ->proxy
            ->setCompany($company)
            ->updateLegalEntity($request->validated());

        if (data_get($response, 'status') === 'error') {
            return response()->json(data_get($response, 'message'), status: $response['code']);
        }

        $tax_data = $company->tax_data;

        $tax_data->acts_as_sender = $request->acts_as_sender;
        $tax_data->acts_as_receiver = $request->acts_as_receiver;

        $company->tax_data = $tax_data;

        $company->save();

        return response()->json();
    }

    /**
     * Removed the legal identity from the Peppol network
     *
     * @param  DisconnectRequest $request
     *
     */
    public function disconnect(DisconnectRequest $request, Storecove $storecove): JsonResponse
    {
        /**
         * @var \App\Models\Company $company
         */
        $company = auth()->user()->company();

        $response = $storecove
            ->proxy
            ->setCompany($company)
            ->disconnect();

        if (data_get($response, 'status') === 'error') {
            return response()->json(data_get($response, 'message'), status: $response['code']);
        }

        $company->legal_entity_id = null;
        $company->tax_data = $this->unsetVatNumbers($company->tax_data);

        $settings = $company->settings;
        $settings->e_invoice_type = 'EN16931';

        $company->settings = $settings;

        $company->save();

        return response()->json();
    }

    /**
     * Add an additional tax identifier to
     * an existing legal entity id
     *
     * Response will be the same as show()
     *
     * @param  AddTaxIdentifierRequest $request
     * @param  Storecove $storecove
     * @return \Illuminate\Http\JsonResponse
     */
    public function addAdditionalTaxIdentifier(AddTaxIdentifierRequest $request, Storecove $storecove): JsonResponse
    {

        $company = auth()->user()->company();
        $tax_data = $company->tax_data;

        $vat_number = $request->vat_number;
        $country = $request->country;

        if ($country == 'GB') {
            $additional_vat = $tax_data->regions->UK->subregions->{$country}->vat_number ?? null;
        } else {
            $additional_vat = $tax_data->regions->EU->subregions->{$country}->vat_number ?? null;
        }

        if (!is_null($additional_vat) && !empty($additional_vat)) {
            return response()->json(['message' => 'Identifier already exists for this region.'], 400);
        }

        $response = $storecove
            ->proxy
            ->setCompany($company)
            ->addAdditionalTaxIdentifier($request->validated());

        if (data_get($response, 'status') === 'error') {
            return response()->json(data_get($response, 'message'), status: $response['code']);
        }

        if ($country == 'GB') {
            $tax_data->regions->UK->subregions->{$country}->vat_number = $vat_number;
        } else {
            $tax_data->regions->EU->subregions->{$country}->vat_number = $vat_number;
        }

        $company->tax_data = $tax_data;
        $company->save();

        return response()->json(['message' => 'ok'], 200);
    }

    public function removeAdditionalTaxIdentifier(RemoveTaxIdentifierRequest $request, Storecove $storecove): JsonResponse
    {
        /** @var \App\Models\Company $company */
        $company = auth()->user()->company();
        $tax_data = $company->tax_data;

        $response = $storecove
            ->proxy
            ->setCompany($company)
            ->removeAdditionalTaxIdentifier($request->validated());

        if (data_get($response, 'status') === 'error') {
            return response()->json(data_get($response, 'message'), status: $response['code']);
        }

        if (is_bool($response)) {
            // This means we run into "internal error" which means user request disconnect for VAT,
            // that wasn't found on legal entity and Storecove network.

            // This is place to do some logging, inform user, etc.
        }

        $country = $request->country;

        if ($request->country === 'GB' && data_get($tax_data->regions->UK->subregions, "{$country}.vat_number")) {
            $tax_data->regions->UK->subregions->{$country}->vat_number = null;
        }

        if ($request->country !== 'GB' && data_get($tax_data->regions->EU->subregions, "{$country}.vat_number")) {
            $tax_data->regions->EU->subregions->{$country}->vat_number = null;
        }

        $company->tax_data = $tax_data;
        $company->save();

        return response()->json([]);
    }

    public function retrySend(RetrySendRequest $request)
    {
        
        SendEDocument::dispatch($request->entity, $request->entity_id, auth()->user()->company()->db);

        return response()->json(['message' => 'trying....'], 200);
    }

    private function unsetVatNumbers(mixed $taxData): mixed
    {
        if (isset($taxData->regions->EU->subregions)) {
            foreach ($taxData->regions->EU->subregions as $country => $data) {
                if (isset($data->vat_number)) {
                    $newData = new \stdClass();
                    if (is_object($data)) {
                        $dataArray = get_object_vars($data);
                        foreach ($dataArray as $key => $value) {
                            if ($key !== 'vat_number') {
                                $newData->$key = $value;
                            }
                        }
                    }
                    $taxData->regions->EU->subregions->$country = $newData;
                }
            }
        }

        return $taxData;
    }
}