presseportale/app/Services/Company/CompanyMergeReport.php

<?php

namespace App\Services\Company;

use App\Enums\CompanyAddressClass;
use App\Models\Company;
use App\Scopes\PortalScope;
use Illuminate\Support\Str;

/**
 * Trockenlauf-Bericht zur Newsroom-Konsolidierung (Roadmap 1a.1).
 *
 * Beantwortet die Frage, die vor jeder Zusammenführung stehen muss: Wie viele
 * Firmen fallen über die Firmen-E-Mail zusammen, und welche Adressen tragen in
 * Wahrheit mehrere verschiedene Firmen? Die Klassifizierung selbst liegt im
 * CompanyAddressClassifier — derselbe Code, den auch die Persistierung (1a.2)
 * benutzt, damit Bericht und spätere Zusammenführung dieselbe Antwort geben.
 */
class CompanyMergeReport
{
    public function __construct(private readonly CompanyAddressClassifier $classifier) {}

    /**
     * @param  int  $collectionThreshold  ab wie vielen abweichenden Namen eine Adresse als Sammeladresse gilt (Entscheidung E1)
     * @return array{
     *     schwellwert: int,
     *     gesamt: array{firmen: int, adressen_mehrfach: int, firmen_mehrfach: int},
     *     klassen: list<array{klasse: string, beschreibung: string, adressen: int, firmen: int, faellt_weg: int, firmen_mit_pm: int}>,
     *     sammeladressen: list<array{email: string, namen: int, firmen: int, firmen_mit_pm: int, beispiele: string}>,
     *     nie_veroeffentlicht: list<array{email: string, namen: int, firmen: int, firmen_mit_pm: int}>,
     * }
     */
    public function build(int $collectionThreshold, int $limit = 15): array
    {
        $groups = $this->classifier->classifyAll($collectionThreshold);

        $classes = [];

        foreach (CompanyAddressClass::cases() as $class) {
            $classes[$class->value] = [
                'klasse' => $class->value,
                'beschreibung' => $class->description(),
                'adressen' => 0,
                'firmen' => 0,
                'faellt_weg' => 0,
                'firmen_mit_pm' => 0,
            ];
        }

        $collections = [];
        $junk = [];

        foreach ($groups as $group) {
            $class = $group['klasse'];
            $key = $class->value;

            $classes[$key]['adressen']++;
            $classes[$key]['firmen'] += $group['firmen'];
            $classes[$key]['firmen_mit_pm'] += $group['firmen_mit_pm'];

            // Wegfallen können nur die Klassen, die tatsächlich verschmolzen
            // werden. Bei allem anderen bleibt jede Firma stehen.
            if ($class->isMergeable()) {
                $classes[$key]['faellt_weg'] += $group['firmen'] - 1;
            }

            if ($class === CompanyAddressClass::CollectionAddress) {
                $collections[] = [
                    'email' => $group['email'],
                    'namen' => $group['namen'],
                    'firmen' => $group['firmen'],
                    'firmen_mit_pm' => $group['firmen_mit_pm'],
                    'beispiele' => Str::limit(implode(' | ', array_slice($group['beispiele'], 0, 3)), 90),
                ];
            }

            if ($class === CompanyAddressClass::NeverPublished) {
                $junk[] = [
                    'email' => $group['email'],
                    'namen' => $group['namen'],
                    'firmen' => $group['firmen'],
                    'firmen_mit_pm' => $group['firmen_mit_pm'],
                ];
            }
        }

        usort($collections, static fn (array $a, array $b): int => $b['firmen'] <=> $a['firmen']);
        usort($junk, static fn (array $a, array $b): int => $b['firmen'] <=> $a['firmen']);

        return [
            'schwellwert' => $collectionThreshold,
            'gesamt' => [
                'firmen' => Company::query()->withoutGlobalScope(PortalScope::class)->count(),
                'adressen_mehrfach' => count($groups),
                'firmen_mehrfach' => array_sum(array_column($groups, 'firmen')),
            ],
            'klassen' => array_values($classes),
            'sammeladressen' => array_slice($collections, 0, $limit),
            'nie_veroeffentlicht' => array_slice($junk, 0, $limit),
        ];
    }
}