Add missing fields

This commit is contained in:
Boris Waaub
2026-03-02 09:26:50 +01:00
parent 99bf692328
commit 2e58775d4f

View File

@@ -28,6 +28,18 @@ readonly class PersonUpsertHandler
private EntityManagerInterface $entityManager,
) {}
private function _handlePersonMessage(UpsertMessage $message, Person $person): Person
{
if (null !== $message->firstName) {
$person->setFirstName($message->firstName);
}
if (null !== $message->lastName) {
$person->setLastName($message->lastName);
}
return $person;
}
public function __invoke(UpsertMessage $message): void
{
// 1. Retrieve definition
@@ -46,12 +58,7 @@ readonly class PersonUpsertHandler
if (0 === count($identifiers)) {
// 3. Create new entity Person
$person = new Person();
if (null !== $message->firstName) {
$person->setFirstName($message->firstName);
}
if (null !== $message->lastName) {
$person->setLastName($message->lastName);
}
$person = $this->_handlePersonMessage($message, $person);
$this->entityManager->persist($person);
// Create and bound identifier
@@ -64,12 +71,7 @@ readonly class PersonUpsertHandler
/** @var PersonIdentifier $identifier */
$identifier = $identifiers[0];
$person = $identifier->getPerson();
if (null !== $message->firstName) {
$person->setFirstName($message->firstName);
}
if (null !== $message->lastName) {
$person->setLastName($message->lastName);
}
$person = $this->_handlePersonMessage($message, $person);
}
$this->entityManager->flush();