*/ class DefaultAssignmentNotificator implements AssignmentNotificator { protected User $user; protected EntityManager $entityManager; protected UserEnabledChecker $userChecker; public function __construct(User $user, EntityManager $entityManager, UserEnabledChecker $userChecker) { $this->user = $user; $this->entityManager = $entityManager; $this->userChecker = $userChecker; } public function process(Entity $entity, Params $params): void { if (!$entity instanceof CoreEntity) { return; } if ($entity->hasLinkMultipleField('assignedUsers')) { /** @var string[] $userIdList */ $userIdList = $entity->getLinkMultipleIdList('assignedUsers'); /** @var ?string[] $fetchedAssignedUserIdList */ $fetchedAssignedUserIdList = $entity->getFetched('assignedUsersIds'); if (!is_array($fetchedAssignedUserIdList)) { $fetchedAssignedUserIdList = []; } foreach ($userIdList as $userId) { if (in_array($userId, $fetchedAssignedUserIdList)) { continue; } $this->processForUser($entity, $userId); } return; } if (!$entity->get('assignedUserId')) { return; } if (!$entity->isAttributeChanged('assignedUserId')) { return; } $assignedUserId = $entity->get('assignedUserId'); $this->processForUser($entity, $assignedUserId); } protected function processForUser(Entity $entity, string $assignedUserId): void { if (!$this->userChecker->checkAssignment($entity->getEntityType(), $assignedUserId)) { return; } if ($entity->hasAttribute('createdById') && $entity->hasAttribute('modifiedById')) { $isSelfAssignment = $entity->isNew() ? $assignedUserId === $entity->get('createdById') : $assignedUserId === $entity->get('modifiedById'); if ($isSelfAssignment) { return; } } $isSelfAssignment = $assignedUserId === $this->user->getId(); if ($isSelfAssignment) { return; } $this->entityManager->createEntity(Notification::ENTITY_TYPE, [ 'type' => Notification::TYPE_ASSIGN, 'userId' => $assignedUserId, 'data' => [ 'entityType' => $entity->getEntityType(), 'entityId' => $entity->getId(), 'entityName' => $entity->get('name'), 'isNew' => $entity->isNew(), 'userId' => $this->user->getId(), 'userName' => $this->user->getName(), ], 'relatedType' => $entity->getEntityType(), 'relatedId' => $entity->getId(), ]); } }