Finanzmanager/src/Models/Zahlungsauftrag.php

<?php

declare(strict_types=1);

namespace Finanzmanager\Models;

use Finanzmanager\Database;
use Finanzmanager\Mandant;

/**
 * Überweisungen: erfasst, geprüft, über FinTS abgesendet.
 *
 * Der Auftrag bleibt als Beleg stehen, auch wenn die Bank ihn ablehnt – mit der
 * Meldung daneben. Erst wenn die Bank ihn angenommen hat, entsteht die
 * zugehörige Buchung auf dem Auftragskonto; vorher wäre sie eine Behauptung.
 */
class Zahlungsauftrag
{
    public const STATUS = [
        'entwurf'   => 'Entwurf',
        'gesendet'  => 'gesendet',
        'fehler'    => 'fehlgeschlagen',
        'storniert' => 'storniert',
    ];

    /** @return list<array<string,mixed>> */
    public static function alle(string $status = ''): array
    {
        $params = [Mandant::id()];
        $sql    = 'SELECT z.*, k.name AS kontoname, kat.pfad AS kategorie_pfad
                     FROM zahlungsauftraege z
                     JOIN konten k       ON k.id = z.konto_id
                LEFT JOIN kategorien kat ON kat.id = z.kategorie_id
                    WHERE z.benutzer_id = ?';

        if ($status !== '' && array_key_exists($status, self::STATUS)) {
            $sql     .= ' AND z.status = ?';
            $params[] = $status;
        }

        return Database::fetchAll(
            $sql . ' ORDER BY z.status = \'gesendet\', z.ausfuehrung_am IS NULL,
                              z.ausfuehrung_am, z.erstellt_am DESC',
            $params
        );
    }

    public static function find(int $id): ?array
    {
        $zeile = Database::fetchOne(
            'SELECT * FROM zahlungsauftraege WHERE id = ? AND benutzer_id = ?',
            [$id, Mandant::id()]
        );
        return $zeile === false ? null : $zeile;
    }

    /** @param array<string,mixed> $daten */
    public static function anlegen(array $daten): int
    {
        $f = self::normalisiere($daten);

        Database::execute(
            'INSERT INTO zahlungsauftraege
                (benutzer_id, konto_id, zugang_id, empfaenger, iban, bic, betrag, waehrung,
                 verwendungszweck, ausfuehrung_am, kategorie_id, klasse_id, status)
             VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
            [
                Mandant::id(), $f['konto_id'], $f['zugang_id'], $f['empfaenger'], $f['iban'],
                $f['bic'], $f['betrag'], $f['waehrung'], $f['verwendungszweck'],
                $f['ausfuehrung_am'], $f['kategorie_id'], $f['klasse_id'], 'entwurf',
            ]
        );

        return Database::lastInsertId();
    }

    /** @param array<string,mixed> $daten */
    public static function speichern(int $id, array $daten): void
    {
        $auftrag = self::find($id);
        if ($auftrag === null) {
            throw new \RuntimeException('Den Zahlungsauftrag gibt es nicht.');
        }
        if ($auftrag['status'] === 'gesendet') {
            throw new \RuntimeException('Ein gesendeter Auftrag lässt sich nicht mehr ändern.');
        }

        $f = self::normalisiere($daten);

        Database::execute(
            'UPDATE zahlungsauftraege SET konto_id = ?, zugang_id = ?, empfaenger = ?, iban = ?,
                    bic = ?, betrag = ?, waehrung = ?, verwendungszweck = ?, ausfuehrung_am = ?,
                    kategorie_id = ?, klasse_id = ?, status = \'entwurf\', meldung = NULL
              WHERE id = ? AND benutzer_id = ?',
            [
                $f['konto_id'], $f['zugang_id'], $f['empfaenger'], $f['iban'], $f['bic'],
                $f['betrag'], $f['waehrung'], $f['verwendungszweck'], $f['ausfuehrung_am'],
                $f['kategorie_id'], $f['klasse_id'], $id, Mandant::id(),
            ]
        );
    }

    public static function loeschen(int $id): void
    {
        $auftrag = self::find($id);
        if ($auftrag !== null && $auftrag['status'] === 'gesendet') {
            throw new \RuntimeException('Ein gesendeter Auftrag bleibt als Beleg stehen.');
        }

        Database::execute('DELETE FROM zahlungsauftraege WHERE id = ? AND benutzer_id = ?', [$id, Mandant::id()]);
    }

    public static function stornieren(int $id): void
    {
        Database::execute(
            "UPDATE zahlungsauftraege SET status = 'storniert'
              WHERE id = ? AND benutzer_id = ? AND status <> 'gesendet'",
            [$id, Mandant::id()]
        );
    }

    /**
     * Vermerkt, dass die Bank den Auftrag angenommen hat, und bucht ihn auf dem
     * Auftragskonto.
     */
    public static function alsGesendetVermerken(int $id, string $meldung = ''): void
    {
        $auftrag = self::find($id);
        if ($auftrag === null) {
            return;
        }

        Database::transaktion(static function () use ($auftrag, $id, $meldung): void {
            // Eine Terminüberweisung wird zum Ausführungstag gebucht, eine
            // sofortige heute.
            $datum = (string)($auftrag['ausfuehrung_am'] ?? '') ?: date('Y-m-d');

            $buchungId = Buchung::anlegen([
                'konto_id'     => (int)$auftrag['konto_id'],
                'datum'        => $datum,
                // Eine Überweisung geht ab: Der Betrag wird negativ gebucht.
                'betrag'       => -abs((float)$auftrag['betrag']),
                'empfaenger'   => (string)$auftrag['empfaenger'],
                'buchungstext' => (string)$auftrag['verwendungszweck'],
                'kategorie_id' => $auftrag['kategorie_id'],
                'klasse_id'    => $auftrag['klasse_id'],
                'quelle'       => 'fints',
            ]);

            Database::execute(
                "UPDATE zahlungsauftraege
                    SET status = 'gesendet', gesendet_am = NOW(), meldung = ?, buchung_id = ?
                  WHERE id = ? AND benutzer_id = ?",
                [mb_substr($meldung, 0, 2000), $buchungId, $id, Mandant::id()]
            );
        });
    }

    public static function alsFehlerVermerken(int $id, string $meldung): void
    {
        Database::execute(
            "UPDATE zahlungsauftraege SET status = 'fehler', meldung = ?
              WHERE id = ? AND benutzer_id = ?",
            [mb_substr($meldung, 0, 2000), $id, Mandant::id()]
        );
    }

    public static function anzahlOffen(): int
    {
        return (int)Database::fetchValue(
            "SELECT COUNT(*) FROM zahlungsauftraege WHERE benutzer_id = ? AND status = 'entwurf'",
            [Mandant::id()],
            0
        );
    }

    /**
     * @param array<string,mixed> $daten
     * @return array<string,mixed>
     */
    private static function normalisiere(array $daten): array
    {
        $kontoId = (int)($daten['konto_id'] ?? 0);
        if ($kontoId === 0 || Konto::find($kontoId) === null) {
            throw new \InvalidArgumentException('Es fehlt ein gültiges Auftragskonto.');
        }

        $empfaenger = trim((string)($daten['empfaenger'] ?? ''));
        if ($empfaenger === '') {
            throw new \InvalidArgumentException('Es fehlt der Empfänger.');
        }

        $iban = strtoupper(str_replace(' ', '', (string)($daten['iban'] ?? '')));
        if (!Adresse::ibanIstGueltig($iban)) {
            throw new \InvalidArgumentException('Die IBAN des Empfängers ist nicht gültig.');
        }

        $betrag = round((float)($daten['betrag'] ?? 0), 2);
        if ($betrag <= 0.0) {
            throw new \InvalidArgumentException('Der Betrag muss größer als null sein.');
        }

        $termin = trim((string)($daten['ausfuehrung_am'] ?? ''));
        if ($termin !== '' && !Buchung::istDatum($termin)) {
            throw new \InvalidArgumentException('Der Ausführungstermin muss als JJJJ-MM-TT vorliegen.');
        }
        if ($termin !== '' && $termin < date('Y-m-d')) {
            throw new \InvalidArgumentException('Der Ausführungstermin liegt in der Vergangenheit.');
        }

        $id = static fn(mixed $wert): ?int =>
            ($wert === null || $wert === '' || (int)$wert === 0) ? null : (int)$wert;

        return [
            'konto_id'   => $kontoId,
            'zugang_id'  => $id($daten['zugang_id'] ?? null),
            'empfaenger' => mb_substr($empfaenger, 0, 255),
            'iban'       => $iban,
            'bic'        => mb_substr(strtoupper(trim((string)($daten['bic'] ?? ''))), 0, 11),
            'betrag'     => $betrag,
            'waehrung'   => mb_substr(strtoupper(trim((string)($daten['waehrung'] ?? 'EUR'))) ?: 'EUR', 0, 3),
            // 140 Zeichen sind das SEPA-Maß für den Verwendungszweck; was
            // darüber steht, würde die Bank ohnehin abschneiden.
            'verwendungszweck' => mb_substr(trim((string)($daten['verwendungszweck'] ?? '')), 0, 140),
            'ausfuehrung_am'   => $termin !== '' ? $termin : null,
            'kategorie_id'     => $id($daten['kategorie_id'] ?? null),
            'klasse_id'        => $id($daten['klasse_id'] ?? null),
        ];
    }
}