src/Diplix/KMGBundle/Console/Command/CronCommand.php line 38

Open in your IDE?
  1. <?php
  2. namespace Diplix\KMGBundle\Console\Command;
  5. use Diplix\Commons\DataHandlingBundle\Entity\SysLogEntry;
  6. use Diplix\Commons\DataHandlingBundle\Repository\SysLogRepository;
  7. use Diplix\KMGBundle\Entity\Order;
  8. use Diplix\KMGBundle\Entity\OrderStatus;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\Console\Exception\CommandNotFoundException;
  12. use Symfony\Component\Console\Input\ArrayInput;
  13. use Symfony\Component\Console\Input\InputInterface;
  14. use Symfony\Component\Console\Output\OutputInterface;
  15. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  17. /**
  18.  * Wrap all commands to be run with a single cron call in one command
  19.  */
  20. class CronCommand extends BaseCommand
  21. {
  22.     public function __construct(
  23.         protected EntityManagerInterface $em,
  24.         protected LoggerInterface $log,
  25.         protected ParameterBagInterface $params,
  26.         ?string $name = null)
  27.     {
  28.         parent::__construct($name);
  29.     }
  31.     protected function configure()
  32.     {
  33.         $this
  34.             ->setName('kmg:cron')
  35.         ;
  36.     }
  38.     protected function runCommand($commandName,$arguments = array(),OutputInterface $output)
  39.     {
  40.         try
  41.         {
  42.             $command = $this->getApplication()->find($commandName);
  43.             $cmdIn = new ArrayInput($arguments);
  44.             $command->run($cmdIn,$output);
  45.             return true;
  46.         }
  47.         catch (CommandNotFoundException $ex)
  48.         {
  49.             $output->writeln("<error>Command not found: ".$commandName."</error>");
  50.             return false;
  51.         }
  52.     }
  54.     protected function actuallyExecute(InputInterface $input, OutputInterface $output)
  55.     {
  56.         // $this->runCommand("tami:updatestatus",array(),$output);
  57.         $this->runCommand("notifications:send",[],$output);
  58.         $this->runCommand("telegram:updates",[],$output);
  59.         $this->runCommand("kmg:runallocator",[],$output);
  60.         $this->confirmRides($this->log);
  61.     }
  63.     protected function confirmRides(LoggerInterface  $log)
  64.     {
  65.         $repo = $this->em->getRepository(Order::class);
  66.         $timeThreshold = (new \DateTime())->modify("- 120 minutes"); // fahrt schon mind. 2h alt
  67.         $oldThreshold = (new \DateTime())->modify("- 180 minutes");   // aber fahrten nicht älter als 3h
  68.         $qb = $repo
  69.             ->createQueryBuilder('A')
  70.             ->leftJoin('A.customer','C')
  71.             ->andWhere('A.assignedTo is not null')
  72.             ->andWhere('A.assignmentConfirmed = 1')
  73.             ->andWhere('A.orderStatus = :status')->setParameter('status',OrderStatus::STATUS_VERMITTELT)
  74.             ->andWhere('A.orderTime <= :time')->setParameter('time',$timeThreshold->format('Y-m-d H:i:s'))
  75.             ->andWhere('A.orderTime >= :old')->setParameter('old',$oldThreshold->format('Y-m-d H:i:s'));
  76.         $orders = $qb->getQuery()->getResult();
  77.         $lmm = sprintf('%d Bestellungen im Status vermittelt werden aktualisiert',count($orders));
  78.         $log->info($lmm);
  79.         if (count($orders)>0)
  80.         {
  81.             SysLogRepository::logMessage($this->em->getConnection(),SysLogEntry::SYS_INFO,$lmm);
  82.         }
  83.         $stat = $this->em->getReference(OrderStatus::class, OrderStatus::STATUS_FINISHED);
  84.         /** @var Order $order */
  85.         foreach ($orders as $order)
  86.         {
  87.             $order->setOrderStatus($stat);
  88.         }
  89.         $this->em->flush();
  90.     }
  92.     protected function execute(InputInterface $input, OutputInterface $output): int
  93.     {
  94.         // todo: refactor so that only error messages get printed.
  95.         // todo: by that we can make use of the fact that console output can be automatically mailed to the admin
  97.         $output->writeln(date("[Y-m-d H:i]")." >> CRON START ");
  99.         // check for execution lock
  100.         $lockFile = $this->params->get('dx.temp_dir')."cron.lock";
  101.         $lastRunFile = $this->params->get('dx.temp_dir')."cron.lastrun";
  102.         if (file_exists($lockFile))
  103.         {
  104.             $lockinfo = file_get_contents($lockFile);
  105.             $output->writeln(sprintf("There is already a running instance of CronCommand (Lock: %s). Aborting.",$lockinfo));
  106.             return \Symfony\Component\Console\Command\Command::FAILURE;
  107.         }
  108.         try
  109.         {
  110.             $r = file_put_contents($lockFile,date("d.m.Y H:i.s"),LOCK_EX);
  111.             if ($r === false)
  112.             {
  113.                 $output->writeln("Unable to aquire a lock. Aborting.");
  114.                 return \Symfony\Component\Console\Command\Command::FAILURE;
  115.             }
  117.             // Run the actual commands
  118.             $this->actuallyExecute($input,$output);
  119.             file_put_contents($lastRunFile,date("U"));
  120.         }
  121.         finally
  122.         {
  123.             // remove lock
  124.             $r = unlink($lockFile);
  125.             if (!$r)
  126.             {
  127.                 $output->writeln("Warning: Unable to remove lock.");
  128.             }
  129.         }
  130.         // ... and we're done
  131.         $output->writeln(date("[Y-m-d H:i]")." >> CRON END ");
  132.         return \Symfony\Component\Console\Command\Command::SUCCESS;
  133.     }
  134. }