M3: Reorder + Inspiration – Schritt 1 (Logik): Reorder-UseCase, Inspiration-Query (ADR-006), Adopt-UseCase + Unit-Tests
This commit is contained in:
@@ -0,0 +1,23 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\Dto;
|
||||
|
||||
/**
|
||||
* Request-DTO: die Reihenfolge der Planungsliste festlegen.
|
||||
*
|
||||
* `reihenfolge` ist die Liste der Mahlzeiten-IDs in der gewünschten
|
||||
* (neuen) Reihenfolge. Die Use-Case-Implementierung nummeriert daraus
|
||||
* `sortOrder` neu (Position 1..N).
|
||||
*
|
||||
* @param list<int> $reihenfolge
|
||||
*/
|
||||
final class MahlzeitReorderRequest
|
||||
{
|
||||
/** @param list<int> $reihenfolge */
|
||||
public function __construct(
|
||||
public readonly array $reihenfolge,
|
||||
) {
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,43 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\Dto;
|
||||
|
||||
use App\Logic\Essen\Model\Mahlzeit;
|
||||
use App\Logic\Essen\Model\Wochentag;
|
||||
|
||||
/**
|
||||
* Read-Modell eines Inspiration-Vorschlags (ein Gericht aus dem Archiv).
|
||||
*
|
||||
* `score` ist der gewichtete Inspiration-Score (ADR-006), `auftraete` die
|
||||
* Gesamtzahl aller Einträge (geplant + gegessen) mit diesem Namen.
|
||||
*
|
||||
* @param list<Wochentag> $wochentage
|
||||
*/
|
||||
final class MahlzeitVorschlagResponse
|
||||
{
|
||||
public function __construct(
|
||||
public readonly int $id,
|
||||
public readonly string $name,
|
||||
public readonly string $notiz,
|
||||
public readonly array $wochentage,
|
||||
public readonly float $score,
|
||||
public readonly ?\DateTimeImmutable $gegessenAm,
|
||||
public readonly int $auftraete,
|
||||
) {
|
||||
}
|
||||
|
||||
public static function fromModel(Mahlzeit $m, float $score, int $auftraete): self
|
||||
{
|
||||
return new self(
|
||||
id: $m->id,
|
||||
name: $m->name,
|
||||
notiz: $m->notiz,
|
||||
wochentage: $m->wochentage,
|
||||
score: $score,
|
||||
gegessenAm: $m->gegessenAm,
|
||||
auftraete: $auftraete,
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\Event;
|
||||
|
||||
/**
|
||||
* Domain-Event: ein Archiv-Gericht wurde per 1-Klick als neuer `geplant`-Eintrag
|
||||
* übernommen (Adopt, nach Commit). `quellId` verweist auf die übernommenen Quelle.
|
||||
*/
|
||||
final readonly class MahlzeitAdoptedEvent
|
||||
{
|
||||
public function __construct(
|
||||
public int $id,
|
||||
public string $name,
|
||||
public int $quellId,
|
||||
) {
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\Event;
|
||||
|
||||
/**
|
||||
* Domain-Event: die Reihenfolge der Planungsliste wurde geändert (nach Commit).
|
||||
* Trägt die neue ID-Reihenfolge (State-Carry, kein ORM-Wissen).
|
||||
*
|
||||
* @param list<int> $reihenfolge
|
||||
*/
|
||||
final readonly class MahlzeitReorderedEvent
|
||||
{
|
||||
/** @param list<int> $reihenfolge */
|
||||
public function __construct(
|
||||
public array $reihenfolge,
|
||||
) {
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,127 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\Query;
|
||||
|
||||
use App\Logic\Common\ClockInterface;
|
||||
use App\Logic\Essen\Dto\MahlzeitVorschlagResponse;
|
||||
use App\Logic\Essen\Manager\MahlzeitManagerInterface;
|
||||
use App\Logic\Essen\Model\MahlzeitStatus;
|
||||
|
||||
/**
|
||||
* Read-Query: Inspiration (ADR-006).
|
||||
*
|
||||
* Schlägt Gerichte **aus dem Archiv** (mindestens ein `gegessen`-Eintrag) vor,
|
||||
* bewertet nach einem gewichteten Mix:
|
||||
* score = w_slow * staleness (lange nicht gekocht, primär)
|
||||
* + w_rare * rarity (seltene Gerichte, sekundär)
|
||||
* + w_hot * popularity (beliebte Gerichte, tertiär)
|
||||
*
|
||||
* - staleness: `now - letzte_geschmack`, normalisiert an die längste Pause.
|
||||
* - rarity: `1 / (auftraete + 1)`, auftraete = Anzahl ALLER Einträge (Name).
|
||||
* - popularity: `auftraete / max(auftraete)`.
|
||||
*
|
||||
* `ausschluss` (bereits vorgeschlagene Repräsentanten-IDs) wird übersprungen,
|
||||
* damit "Weitere 5" neue Gerichte liefert. Sortierung absteigend nach Score.
|
||||
*/
|
||||
final readonly class MahlzeitInspirationQuery
|
||||
{
|
||||
public function __construct(
|
||||
private MahlzeitManagerInterface $mahlzeiten,
|
||||
private ClockInterface $clock,
|
||||
private float $gewichtSlow = 0.5,
|
||||
private float $gewichtRare = 0.3,
|
||||
private float $gewichtHot = 0.2,
|
||||
) {
|
||||
}
|
||||
|
||||
/**
|
||||
* @param list<int> $ausschluss bereits vorgeschlagene Repräsentanten-IDs
|
||||
* @return list<MahlzeitVorschlagResponse>
|
||||
*/
|
||||
public function execute(int $limit = 5, array $ausschluss = []): array
|
||||
{
|
||||
$alle = $this->mahlzeiten->list(null);
|
||||
if ($alle === []) {
|
||||
return [];
|
||||
}
|
||||
|
||||
$jetzt = $this->clock->now();
|
||||
|
||||
/** @var array<string, array{letzte: ?\DateTimeImmutable, anzahl: int, repraesentant: mixed}> $perName */
|
||||
$perName = [];
|
||||
foreach ($alle as $m) {
|
||||
$e = &$perName[$m->name];
|
||||
if (!isset($e)) {
|
||||
$e = ['letzte' => null, 'anzahl' => 0, 'repraesentant' => $m];
|
||||
}
|
||||
$e['anzahl']++;
|
||||
if ($m->status === MahlzeitStatus::Gegessen && $m->gegessenAm !== null) {
|
||||
if ($e['letzte'] === null || $m->gegessenAm > $e['letzte']) {
|
||||
$e['letzte'] = $m->gegessenAm;
|
||||
$e['repraesentant'] = $m;
|
||||
}
|
||||
}
|
||||
}
|
||||
unset($e);
|
||||
|
||||
// Nur Gerichte, die im Archiv stehen (>= 1 gegessener Eintrag).
|
||||
$kandidaten = [];
|
||||
foreach ($perName as $name => $e) {
|
||||
if ($e['letzte'] !== null) {
|
||||
$kandidaten[] = [
|
||||
'name' => $name,
|
||||
'letzte' => $e['letzte'],
|
||||
'anzahl' => $e['anzahl'],
|
||||
'repraesentant' => $e['repraesentant'],
|
||||
];
|
||||
}
|
||||
}
|
||||
if ($kandidaten === []) {
|
||||
return [];
|
||||
}
|
||||
|
||||
// Normalisierungs-Maxima.
|
||||
$maxStale = 0;
|
||||
$maxAnzahl = 0;
|
||||
foreach ($kandidaten as $k) {
|
||||
$stale = $jetzt->getTimestamp() - $k['letzte']->getTimestamp();
|
||||
if ($stale > $maxStale) {
|
||||
$maxStale = $stale;
|
||||
}
|
||||
if ($k['anzahl'] > $maxAnzahl) {
|
||||
$maxAnzahl = $k['anzahl'];
|
||||
}
|
||||
}
|
||||
|
||||
$scored = [];
|
||||
foreach ($kandidaten as $k) {
|
||||
$stale = $jetzt->getTimestamp() - $k['letzte']->getTimestamp();
|
||||
$staleness = $maxStale > 0 ? $stale / $maxStale : 0.0;
|
||||
$rarity = 1.0 / ($k['anzahl'] + 1);
|
||||
$popularity = $maxAnzahl > 0 ? $k['anzahl'] / $maxAnzahl : 0.0;
|
||||
$score = $this->gewichtSlow * $staleness + $this->gewichtRare * $rarity + $this->gewichtHot * $popularity;
|
||||
$scored[] = ['k' => $k, 'score' => $score];
|
||||
}
|
||||
|
||||
// Absteigend nach Score; bei Gleichstand alphabetisch (deterministisch).
|
||||
usort($scored, static fn (array $a, array $b): int => $b['score'] <=> $a['score'] ?: strcmp($a['k']['name'], $b['k']['name']));
|
||||
|
||||
$ausschlussSet = array_flip(array_map('intval', $ausschluss));
|
||||
$ergebnis = [];
|
||||
foreach ($scored as $s) {
|
||||
/** @var \App\Logic\Essen\Model\Mahlzeit $repraesentant */
|
||||
$repraesentant = $s['k']['repraesentant'];
|
||||
if (isset($ausschlussSet[$repraesentant->id])) {
|
||||
continue;
|
||||
}
|
||||
$ergebnis[] = MahlzeitVorschlagResponse::fromModel($repraesentant, $s['score'], (int) $s['k']['anzahl']);
|
||||
if (\count($ergebnis) >= $limit) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
return $ergebnis;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,51 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\UseCase;
|
||||
|
||||
use App\Logic\Common\ClockInterface;
|
||||
use App\Logic\Common\EventDispatcherInterface;
|
||||
use App\Logic\Common\TransactionManagerInterface;
|
||||
use App\Logic\Essen\Dto\MahlzeitCreateRequest;
|
||||
use App\Logic\Essen\Dto\MahlzeitResponse;
|
||||
use App\Logic\Essen\Event\MahlzeitAdoptedEvent;
|
||||
use App\Logic\Essen\Manager\MahlzeitManagerInterface;
|
||||
use App\Logic\Essen\Mapping\MahlzeitFactory;
|
||||
|
||||
/**
|
||||
* Use-Case: ein Gericht (z. B. aus dem Archiv) per 1-Klick als NEUEN
|
||||
* `geplant`-Eintrag übernehmen (Kopie – `gegessenAm` bleibt leer, neue ID,
|
||||
* am Ende der Planungsliste angehängt).
|
||||
*
|
||||
* Wirft `MahlzeitNotFoundException` (→ 404), wenn die Quelle unbekannt ist.
|
||||
*/
|
||||
final readonly class MahlzeitAdoptUseCase
|
||||
{
|
||||
public function __construct(
|
||||
private TransactionManagerInterface $tx,
|
||||
private MahlzeitManagerInterface $mahlzeiten,
|
||||
private MahlzeitFactory $factory,
|
||||
private EventDispatcherInterface $events,
|
||||
private ClockInterface $clock,
|
||||
) {
|
||||
}
|
||||
|
||||
public function execute(int $quellId): MahlzeitResponse
|
||||
{
|
||||
$quelle = $this->mahlzeiten->find($quellId);
|
||||
|
||||
$req = new MahlzeitCreateRequest(
|
||||
name: $quelle->name,
|
||||
notiz: $quelle->notiz,
|
||||
wochentage: $quelle->wochentage,
|
||||
);
|
||||
$mahlzeit = $this->factory->createFromCreateRequest($req, $this->clock->now());
|
||||
|
||||
$gespeichert = $this->tx->execute(fn () => $this->mahlzeiten->create($mahlzeit));
|
||||
|
||||
$this->events->dispatch(new MahlzeitAdoptedEvent(id: $gespeichert->id, name: $gespeichert->name, quellId: $quellId));
|
||||
|
||||
return MahlzeitResponse::fromModel($gespeichert);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Logic\Essen\UseCase;
|
||||
|
||||
use App\Logic\Common\EventDispatcherInterface;
|
||||
use App\Logic\Common\TransactionManagerInterface;
|
||||
use App\Logic\Essen\Dto\MahlzeitReorderRequest;
|
||||
use App\Logic\Essen\Event\MahlzeitReorderedEvent;
|
||||
use App\Logic\Essen\Manager\MahlzeitManagerInterface;
|
||||
|
||||
/**
|
||||
* Use-Case: die Reihenfolge der Planungsliste ändern (Drag & Drop).
|
||||
*
|
||||
* Die übergebene ID-Liste wird in `sortOrder` neu nummeriert (Position 1..N).
|
||||
* Läuft in einer Transaktion; unbekannte IDs werfen `MahlzeitNotFoundException`
|
||||
* (→ 404). Eine leere Liste ist ein No-Op.
|
||||
*/
|
||||
final readonly class MahlzeitReorderUseCase
|
||||
{
|
||||
public function __construct(
|
||||
private TransactionManagerInterface $tx,
|
||||
private MahlzeitManagerInterface $mahlzeiten,
|
||||
private EventDispatcherInterface $events,
|
||||
) {
|
||||
}
|
||||
|
||||
public function execute(MahlzeitReorderRequest $req): void
|
||||
{
|
||||
$reihenfolge = array_values($req->reihenfolge);
|
||||
if ($reihenfolge === []) {
|
||||
return;
|
||||
}
|
||||
|
||||
$this->tx->execute(function () use ($reihenfolge): void {
|
||||
foreach ($reihenfolge as $position => $id) {
|
||||
$sortOrder = $position + 1;
|
||||
$mahlzeit = $this->mahlzeiten->find($id);
|
||||
|
||||
// Unveränderte Positionen überspringen (keine unnötigen Writes).
|
||||
if ($mahlzeit->sortOrder !== $sortOrder) {
|
||||
$this->mahlzeiten->update($mahlzeit->mitSortOrder($sortOrder));
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
$this->events->dispatch(new MahlzeitReorderedEvent($reihenfolge));
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user