mivita/app/Services/Backoffice/SalesVolumePoints.php

<?php

namespace App\Services\Backoffice;

use App\Models\UserSalesVolume;
use App\Services\BusinessPlan\SalesPointsVolume;
use Illuminate\Support\Collection;

/**
 * Liefert SQL-Aggregat-Ausdrücke für die monatliche Punkte-/Umsatzauswertung
 * der Backoffice-Statistik.
 *
 * Wichtig: In `user_sales_volumes` existiert pro Bestellung eine Zeile, und die
 * Spalten `month_KP_points` / `month_shop_points` / `month_*_total_net` sind der
 * kumulative Monats-Laufstand zum Zeitpunkt der Bestellung – KEINE Einzelbeträge.
 * Eine SUM() über diese Spalten zählt mehrfach. Korrekt wird je Zeile die
 * `points`/`total_net`-Spalte summiert und nach `status` gefiltert – analog zu
 * {@see SalesPointsVolume::reCalculateSalesPointsVolume()}.
 *
 * Status-Zuordnung:
 *  - Eigenpunkte (KP): status 1, 4, 5, 6
 *  - Shop-/Kundenpunkte: status 2 (sowie status 6 mit status_turnover = 2)
 *  - status 0 (nicht zugeordnet) und 3 (pending) zählen nicht
 *
 * Alle Spalten werden voll qualifiziert, da `shopping_orders` ebenfalls eine
 * `points`-Spalte besitzt (Join-Mehrdeutigkeit).
 */
class SalesVolumePoints
{
    private const OWN_PREDICATE = 'user_sales_volumes.status IN (1, 4, 5, 6)';

    private const SHOP_PREDICATE = '(user_sales_volumes.status = 2 OR (user_sales_volumes.status = 6 AND user_sales_volumes.status_turnover = 2))';

    private const TURNOVER_PREDICATE = 'user_sales_volumes.status IN (1, 2, 4, 5, 6)';

    public static function ownPoints(): string
    {
        return self::sumWhere(self::OWN_PREDICATE, 'user_sales_volumes.points');
    }

    public static function externalPoints(): string
    {
        return self::sumWhere(self::SHOP_PREDICATE, 'user_sales_volumes.points');
    }

    public static function customerAboPoints(): string
    {
        return self::sumWhere(self::SHOP_PREDICATE.' AND shopping_orders.is_abo = 1', 'user_sales_volumes.points');
    }

    public static function customerSingleOrderPoints(): string
    {
        return self::sumWhere(self::SHOP_PREDICATE.' AND shopping_orders.id IS NOT NULL AND (shopping_orders.is_abo = 0 OR shopping_orders.is_abo IS NULL)', 'user_sales_volumes.points');
    }

    public static function customerOtherPoints(): string
    {
        return self::sumWhere(self::SHOP_PREDICATE.' AND shopping_orders.id IS NULL', 'user_sales_volumes.points');
    }

    public static function totalPoints(): string
    {
        return self::ownPoints().' + '.self::externalPoints();
    }

    /**
     * Monats-Gesamtpunkte je User als gebatchte Abfrage — die eine Stelle für
     * "Gesamtpunkte pro Berater" (Firstlines-Seite, Recruiter-Ranking,
     * Top-3-Karte), damit die Status-Semantik nicht in mehreren Kopien driftet.
     *
     * @param  int[]  $userIds
     * @return Collection<int, float> user_id => Punkte
     */
    public static function totalPointsByUser(array $userIds, int $month, int $year): Collection
    {
        if ($userIds === []) {
            return collect();
        }

        return UserSalesVolume::query()
            ->whereIn('user_id', $userIds)
            ->where('month', $month)
            ->where('year', $year)
            ->groupBy('user_id')
            ->select('user_id')
            ->selectRaw('('.self::totalPoints().') as total_points')
            ->pluck('total_points', 'user_id')
            ->map(fn ($points) => (float) $points);
    }

    /**
     * Punkte aus Abo-Bestellungen (eigene wie Kundenabos) — alle zählbaren Status.
     * Benötigt den Join auf shopping_orders.
     */
    public static function aboPoints(): string
    {
        return self::sumWhere(self::TURNOVER_PREDICATE.' AND shopping_orders.is_abo = 1', 'user_sales_volumes.points');
    }

    /**
     * Punkte, die nur als Karrierepunkte (KP) des Beraters zählen und NICHT als
     * Teampunkte in die Payline fließen (status_points = 2, z. B.
     * Neupartner-Einschreibungspunkte, manuelle Gutschriften) — vgl.
     * {@see SalesPointsVolume::add_KP_TP_Points()}.
     */
    public static function nonPaylinePoints(): string
    {
        return self::sumWhere(self::OWN_PREDICATE.' AND user_sales_volumes.status_points = 2', 'user_sales_volumes.points');
    }

    public static function turnoverNet(): string
    {
        return self::sumWhere(self::TURNOVER_PREDICATE, 'user_sales_volumes.total_net');
    }

    private static function sumWhere(string $predicate, string $column): string
    {
        return 'COALESCE(SUM(CASE WHEN '.$predicate.' THEN '.$column.' ELSE 0 END), 0)';
    }
}