gruene-seele/app/Http/Controllers/Admin/Inventory/OrderFulfillmentController.php

<?php

namespace App\Http\Controllers\Admin\Inventory;

use App\Http\Controllers\Controller;
use App\Models\ShoppingOrder;
use App\Repositories\InvoiceRepository;
use App\Services\Invoice;
use App\Services\OrderStatusService;
use App\Services\PDFMerger;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Response;
use Illuminate\Support\Facades\Storage;
use Illuminate\Validation\Rule;

/**
 * AP-33a: Abwicklungs-Board („Bestellungen → Abwicklung") — kompakte Tagesübersicht
 * für die Bestellabwicklung durch Versand-Mitarbeiter (copyreader): Packliste je
 * Bestellung, Dokumente (Rechnung/Lieferschein), Statuswechsel konfektioniert/versendet.
 * Statusaktionen sind bewusst auf Vorwärts-Schritte beschränkt; Storno/Rücksetzung
 * bleibt der Verkäufe-Seite (admin ≥ 7) vorbehalten.
 */
class OrderFulfillmentController extends Controller
{
    private const INDEX_LIMIT = 500;

    public function index(Request $request)
    {
        $filter = (string) $request->query('filter', '');
        $limit = $request->query('all') ? null : self::INDEX_LIMIT;

        $withRelations = ['shopping_user', 'shopping_payment_last', 'shipping_country.country', 'shopping_order_items.product.setItems'];

        // Offene Abwicklung (Status offen/in Bearbeitung) — Basis für Liste und Kachel-Zähler
        $open = ShoppingOrder::query()
            ->with($withRelations)
            ->whereIn('shipped', [0, 1])
            ->orderByDesc('id')
            ->when($limit !== null, fn ($query) => $query->limit($limit))
            ->get();

        $counts = [
            'today' => ShoppingOrder::query()->whereDate('created_at', today())->count(),
            'pick' => $open->where('shipped', 0)->filter->isReadyToShip()->count(),
            'ready' => $open->where('shipped', 1)->filter->isReadyToShip()->count(),
            'shipped_today' => ShoppingOrder::query()->whereDate('shipped_at', today())->count(),
        ];

        $orders = match ($filter) {
            'today' => ShoppingOrder::query()->with($withRelations)->whereDate('created_at', today())->orderByDesc('id')->get(),
            'pick' => $open->where('shipped', 0)->filter->isReadyToShip()->values(),
            'ready' => $open->where('shipped', 1)->filter->isReadyToShip()->values(),
            'shipped_today' => ShoppingOrder::query()->with($withRelations)->whereDate('shipped_at', today())->orderByDesc('id')->get(),
            default => $open,
        };

        return view('admin.inventory.orders.index', [
            'orders' => $orders,
            'counts' => $counts,
            'filter' => $filter,
            'listLimit' => $limit,
        ]);
    }

    /**
     * Statuswechsel aus dem Board: nur vorwärts (1 = konfektioniert, 2 = versendet),
     * nur aus offen/in Bearbeitung. Setzt das Sperr-Flag (Kundenentscheid 16.07.2026):
     * die Bestell-Detailseite verändert den Status danach nicht mehr automatisch.
     */
    public function updateStatus(Request $request, int $id)
    {
        $request->validate([
            'shipped' => ['required', 'integer', Rule::in([1, 2])],
        ]);

        $order = ShoppingOrder::query()->findOrFail($id);
        if (! in_array((int) $order->shipped, [0, 1], true)) {
            session()->flash('alert-error', __('Bestellung ist nicht mehr in der Abwicklung (Status: :status).', ['status' => $order->getShippedType()]));

            return redirect()->route('admin.inventory.orders.index');
        }

        app(OrderStatusService::class)->setShipped($id, (int) $request->input('shipped'), auth()->id(), lockStatus: true);

        session()->flash('alert-success', (int) $request->input('shipped') === 2
            ? __('Bestellung #:id als versendet gebucht — Produktbestand wurde abgezogen.', ['id' => $id])
            : __('Bestellung #:id als konfektioniert markiert.', ['id' => $id]));

        return redirect()->route('admin.inventory.orders.index', array_filter(['filter' => $request->input('back_filter')]));
    }

    /**
     * Rechnung + Lieferschein erstellen (halbautomatisch, Kundenentscheid 16.07.2026):
     * nur für Partnercenter-Bestellungen — API-Bestellungen haben ihre Rechnung im
     * externen Shop (wp_invoice_path).
     */
    public function createDocuments(Request $request, int $id)
    {
        $order = ShoppingOrder::query()->findOrFail($id);

        if ($order->isApiOrder()) {
            session()->flash('alert-error', __('API-Bestellung — die Rechnung liegt im externen Shop.'));
        } elseif (Invoice::isInvoice($order)) {
            session()->flash('alert-error', __('Rechnung und Lieferschein existieren bereits.'));
        } else {
            (new InvoiceRepository($order))->create([]);
            session()->flash('alert-success', __('Rechnung und Lieferschein für Bestellung #:id erstellt.', ['id' => $id]));
        }

        return redirect()->route('admin.inventory.orders.index', array_filter(['filter' => $request->input('back_filter')]));
    }

    /**
     * AP-33b: Sammel-Dokumente — Lieferscheine (optional inkl. Rechnungen) der
     * ausgewählten Bestellungen als EIN zusammengeführtes PDF zum Stapeldruck.
     * Fehlende Dokumente werden dabei erzeugt (ohne Mailversand); API-Bestellungen
     * werden übersprungen (Rechnung liegt im externen Shop).
     */
    public function batchDocuments(Request $request)
    {
        $data = $request->validate([
            'order_ids' => ['required', 'array', 'min:1', 'max:100'],
            'order_ids.*' => ['integer', 'exists:shopping_orders,id'],
            'type' => ['required', Rule::in(['delivery', 'combined'])],
        ]);

        $orders = ShoppingOrder::query()->whereIn('id', $data['order_ids'])->orderBy('id')->get();
        $printable = $orders->reject(fn (ShoppingOrder $order) => $order->isApiOrder())->values();

        if ($printable->isEmpty()) {
            session()->flash('alert-error', __('Nur API-Bestellungen ausgewählt — deren Rechnungen liegen im externen Shop.'));

            return redirect()->route('admin.inventory.orders.index');
        }

        foreach ($printable as $order) {
            if (! Invoice::isInvoice($order)) {
                (new InvoiceRepository($order))->create([]);
            } else {
                // Fehlende Dateien (Altdaten) mit bestehender Nummer regenerieren —
                // prüft Rechnung UND Lieferschein (Review 20.07.2026)
                (new InvoiceRepository($order))->ensureFilesOnDisk();
            }
        }

        $filename = ($data['type'] === 'combined' ? 'Rechnungen-Lieferscheine-' : 'Lieferscheine-')
            .now()->format('d-m-Y_Hi').'.pdf';

        return $this->pdfResponse($this->mergedPdf($printable, $data['type'] === 'combined', $filename), $filename);
    }

    /**
     * Dokument-Download für Versand-Mitarbeiter (copyreader) — die allgemeine
     * storage_file-Route verlangt admin ≥ 7 bzw. den Besteller selbst.
     */
    public function document(int $id, string $type)
    {
        abort_unless(in_array($type, ['invoice', 'delivery', 'combined', 'label'], true), 404);

        $order = ShoppingOrder::query()->findOrFail($id);

        // AP-32 Brückenlösung: lokal gespeicherte Kopie des DHL-Labels aus dem
        // WooCommerce-Shop (privater Storage — bewusst nicht die öffentliche Shop-URL)
        if ($type === 'label') {
            abort_unless($order->wp_label_path && Storage::disk('local')->exists($order->wp_label_path), 404);

            return $this->pdfResponse(Storage::disk('local')->get($order->wp_label_path), 'DHL-Label-Bestellung-'.$order->id.'.pdf');
        }

        abort_unless(Invoice::isInvoice($order), 404);
        // Fehlende Dateien (Altdaten) mit bestehender Nummer regenerieren — vorher
        // lief der combined-Zweig ungeprüft in eine Exception (Review 20.07.2026)
        abort_unless((new InvoiceRepository($order))->ensureFilesOnDisk(), 404);

        if ($type === 'combined') {
            $filename = str_replace('Rechnung-', 'Rechnung-Lieferschein-', Invoice::getFilename($order));

            return $this->pdfResponse($this->mergedPdf([$order], true, $filename), $filename);
        }

        $path = $type === 'invoice' ? Invoice::getDownloadPath($order) : Invoice::getDownloadPathDelivery($order);
        $filename = $type === 'invoice' ? Invoice::getFilename($order) : Invoice::getDeliveryFilename($order);

        abort_unless(Storage::disk('public')->exists($path), 404);

        return $this->pdfResponse(Storage::disk('public')->get($path), $filename);
    }

    /**
     * Rechnung (optional) + Lieferschein der Bestellungen zu EINEM PDF mergen —
     * gemeinsame Implementierung für Einzel-Kombi und Sammel-Druck.
     *
     * @param  iterable<ShoppingOrder>  $orders
     */
    private function mergedPdf(iterable $orders, bool $withInvoice, string $filename): string
    {
        $merger = new PDFMerger;
        $merger->init();

        foreach ($orders as $order) {
            if ($withInvoice) {
                $merger->addPDF(Invoice::getDownloadPath($order, true));
            }
            $merger->addPDF(Invoice::getDownloadPathDelivery($order, true));
        }

        $merger->setFileName($filename);
        $merger->merge();

        return $merger->output();
    }

    private function pdfResponse(string $content, string $filename)
    {
        return Response::make($content, 200)
            ->header('Content-Type', 'application/pdf')
            ->header('Content-disposition', 'inline; filename="'.$filename.'"');
    }
}