entityManager = $entityManager; } public function process(Entity $entity, LoaderParams $params): void { /* @var $repository ImportRepository */ $repository = $this->entityManager->getRepository('Import'); $importedCount = $repository->countResultRecords($entity, 'imported'); $duplicateCount = $repository->countResultRecords($entity, 'duplicates'); $updatedCount = $repository->countResultRecords($entity, 'updated'); $entity->set([ 'importedCount' => $importedCount, 'duplicateCount' => $duplicateCount, 'updatedCount' => $updatedCount, ]); } }