#ConcreteCMS A job to clear invalid workflow notifications

clear_invalid_workflow_notifications.php

<?php

// application/jobs/clear_invalid_workflow_notifications.php

namespace Application\Job;

use Concrete\Core\Entity\Notification\WorkflowProgressNotification;
use Concrete\Core\Job\Job;
use Concrete\Core\Support\Facade\Application;
use Doctrine\ORM\EntityManagerInterface;

class ClearInvalidWorkflowNotifications extends Job
{
    public function run()
    {
        $found = 0;
        $removed = 0;
        $app = Application::getFacadeApplication();
        /** @var EntityManagerInterface $entityManager */
        $entityManager = $app->make(EntityManagerInterface::class);
        $repository = $entityManager->getRepository(WorkflowProgressNotification::class);
        /** @var WorkflowProgressNotification $notification */
        foreach ($repository->findAll() as $notification) {
            $progress = $notification->getWorkflowProgressObject();
            if (!is_object($progress)) {
                $entityManager->refresh($notification);
                $entityManager->remove($notification);
                $entityManager->flush();
                $removed++;
            }
            $found++;
        }

        return t('%d workflow progress notifications found. %s notifications are invalid and deleted.', $found, $removed);
    }

    public function getJobName()
    {
        return t('Clear Invalid Notifications');
    }

    public function getJobDescription()
    {
        return t('Fix "Call to a member function getWorkflowObject on null" error');
    }

}