BCRM / www

use Symfony\Component\Console\Input\InputInterface;

use Symfony\Component\Console\Output\OutputInterface;

class SendConfirmUnregistrationMailCommand extends ContainerAwareCommand

{

    protected function configure()

    {

        $this

            ->setName('bcrm:unregistration:confirm')

            ->setDescription('Send unregistration confirmation emails');

    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {

        /** @var \BCRM\BackendBundle\Entity\Event\UnregistrationRepository $repo */

        $repo = $this->getContainer()->get('bcrm.backend.repo.unregistration');

        /** @var \LiteCQRS\Bus\CommandBus $commandBus */

        $commandBus = $this->getContainer()->get('command_bus');

        foreach ($repo->getNewUnregistrations() as $unregistration) {

            if ($output->getVerbosity() > OutputInterface::VERBOSITY_NORMAL) {

                $output->writeln(sprintf('Sending unregistration confirmation mail for %s', $unregistration));

            }

            $command                 = new SendUnregistrationConfirmationMailCommand();

            $command->unregistration = $unregistration;

            $command->schemeAndHost  = $this->getContainer()->getParameter('scheme_and_host');

            $commandBus->handle($command);

        }

    }

}

use Symfony\Component\Console\Input\InputInterface;

use Symfony\Component\Console\Output\OutputInterface;

class SendPayRegistrationMailCommand extends ContainerAwareCommand

{

    protected function configure()

    {

        $this

            ->setName('bcrm:registration:pay')

            ->setDescription('Send registration payment emails');

    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {

        /** @var \BCRM\BackendBundle\Entity\Event\RegistrationRepository $repo */

        $repo = $this->getContainer()->get('bcrm.backend.repo.registration');

        /** @var \LiteCQRS\Bus\CommandBus $commandBus */

        $commandBus = $this->getContainer()->get('command_bus');

        foreach ($repo->getToPay() as $registration) {

            if ($output->getVerbosity() > OutputInterface::VERBOSITY_NORMAL) {

                $output->writeln(sprintf('Sending payment notification mail for %s', $registration));

            }

            $command                = new SendPaymentNotificationMailCommand();

            $command->registration  = $registration;

            $command->schemeAndHost = $this->getContainer()->getParameter('scheme_and_host');

            $commandBus->handle($command);

        }

    }

}