src/Library/Subscribers/GrapperSubscriber.php line 134

Open in your IDE?
  1. <?php
  3. namespace App\Library\Subscribers;
  6. use App\Library\Database;
  7. use App\Library\Event\GrapperEvent;
  8. use App\Library\Event\GrapperProcessEvent;
  9. use App\Library\Event\GrapperQueueEvent;
  10. use App\models\acount;
  11. use App\models\eadr;
  12. use App\models\grapperLizenz;
  13. use App\models\grapperQueue;
  14. use App\models\grapperStatistik;
  15. use DateTime;
  16. use Doctrine\DBAL\Exception;
  17. use Doctrine\DBAL\Statement;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Process\Process;
  20. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  22. class GrapperSubscriber implements EventSubscriberInterface
  23. {
  24.     const COMMAND = '%s %s %s/bin/console rce:grapper:send %s %s';
  25.     const PHP_BIN = 'php8.2';
  26.     const ENV_BIN = '/usr/bin/env';
  28.     /**
  29.      * Defining required events
  30.      * @return \array[][]
  31.      */
  32.     public static function getSubscribedEvents()
  33.     {
  34.         return [
  35.             GrapperEvent::EVENT => [
  36.                 [ 'processCustomers', 1000 ],
  37.             ],
  38.             GrapperQueueEvent::EVENT_FETCH=>[
  39.                 ['initQueueLizenz',900],
  40.                 ['insertQueueSendEmails', 850],
  41.             ],
  42.             GrapperProcessEvent::EVENT_FETCH=>[
  43.                 ['initQueueLizenz',900],
  44.             ],
  45.             GrapperQueueEvent::EVENT_RUN=>[
  46.               ['grapperExecute', 1000],
  47.             ],
  48.             GrapperEvent::EVENT_PROCESS_CUSTOMER=>[
  49.                 [ 'initLizenz', 1000 ],
  50.                 [ 'insertSendEmails', 500 ],
  51.                 [ 'grapperStore', 100 ],
  52.             ],
  53.             GrapperQueueEvent::EVENT_POST=>[
  54.                 [
  55.                     'finishQueueSend', 100,
  56.                 ]
  57.             ],
  58.         ];
  59.     }
  61.     /**
  62.      * @param EventDispatcherInterface $eventDispatcher
  63.      * @param Database $database
  64.      */
  65.     public function __construct(
  66.         private readonly EventDispatcherInterface $eventDispatcher,
  67.         private readonly Database $database
  68.     ){
  70.     }
  72.     public function initLizenz(GrapperEvent $event):void{
  73.         if($event->getCustomer() !== null && !$event->getLizenz() instanceof grapperLizenz){
  74.             /** @var grapperLizenz|null $lizenz */
  75.             $lizenz = $this->database->getData(grapperLizenz::class, grapperLizenz::LIZENZ, [$event->getCustomer()->getLizenzid()]);
  76.             if($lizenz===null){
  77.                 $event->setNoLicense(true);
  78.             }else{
  79.                 $event->setNoLicense(false);
  80.                 $event->setLizenz($lizenz);
  81.                 $event->getCustomer()->setLizenz($lizenz);
  82.             }
  83.         }
  84.     }
  86.     /**
  87.      * @param GrapperQueueEvent $event
  88.      * @return void
  89.      */
  90.     public function grapperExecute(GrapperQueueEvent $event): void
  91.     {
  92.         $path = realpath(__DIR__.'/../../../');
  93.         $i=0;
  94.         foreach($event->getAddresses() as $row){
  95.               $event->addVerboseOutput('Remaining Mails: '.$event->getAcount()->getLizenz()->getRemainingMails().' <=> Sending Email '.$i);
  96.               dump($i);
  97.               if($i < $event->getAcount()->getLizenz()->getRemainingMails()){
  98.                   
  99.               $i++;
  100.                 /** @var eadr $row */
  101.                 $command = sprintf(self::COMMAND, self::ENV_BIN, self::PHP_BIN, $path, $event->getAcount()->getId(), $row->getId()).' -vvv';
  102.                 $prozess = Process::fromShellCommandline($command);
  103.                 $prozess->run();
  104.                 $event->addVerboseOutput($prozess->getOutput());
  105.                 if($prozess->isSuccessful()){
  106.                     $event->addSuccess();
  107.                     $event->addSuccessAddress($row->getEmail());
  108.                 }else{
  109.                     $event->addFailure();
  110.                     $event->addFailureAddress($row->getEmail());
  111.                 }
  112.               }
  113.         }
  114.     }
  116.     public function initQueueLizenz(GrapperQueueEvent|GrapperProcessEvent $event):void{
  117.         if($event->getAcount() !== null){
  118.             /** @var grapperLizenz|null $lizenz */
  119.             $lizenz = $this->database->getData(grapperLizenz::class, grapperLizenz::LIZENZ, [$event->getAcount()->getLizenzid()]);
  120.             if($lizenz===null){
  121.                 $event->stopPropagation();
  122.             }else{
  123.                 $event->getAcount()->setLizenz($lizenz);
  124.             }
  125.         }
  126.     }
  128.     /**
  129.      * Query Customers and execute one grepper run per customer
  130.      * @param GrapperEvent $event
  131.      * @return void
  132.      * @throws Exception
  133.      */
  134.     public function processCustomers(GrapperEvent $event): void
  135.     {
  136.         if($event->isIndividualCustomer()){
  137.             $event->addVerboseOutput('Processing Specific Customer');
  138.             $stmt = $this->database->getConnection()->prepare(acount::GET_SPECIFIC_GRAPPER_CUSTOMERS);
  139.             $stmt->bindValue(1, $event->getIndividualCustomer());
  140.         }else{
  141.             $event->addVerboseOutput('Processing All Customers');
  142.             $stmt = $this->database->getConnection()->prepare(acount::GET_ALL_GRAPPER_CUSTOMERS);
  143.         }
  144.         $resultSet = $stmt->executeQuery();
  145.         while($row = $resultSet->fetchAssociative()){
  146.             $customer = new acount();
  147.             $customer->init($row);
  148.             $event->setCustomer($customer);
  149.             $this->eventDispatcher->dispatch($event, GrapperEvent::EVENT_PROCESS_CUSTOMER);
  150.         }
  151.     }
  153.     public function insertSendEmails(GrapperEvent $event): void
  154.     {
  155.         if($event->getCustomer() instanceof acount){
  156.             $stmt = $this->database->getConnection()->prepare(grapperStatistik::SELECT_COUNTER);
  157.             $stmt->bindValue(1, $event->getCustomer()->getId());
  158.             $stmt->bindValue(2, date('Y') . '-' . date('m') . '-01 00:00:00');
  159.             $stmt->bindValue(3, date('Y') . '-' . date('m') . '-' . date('t') . '-00:00:00');
  160.             $rowResult = $stmt->executeQuery();
  161.         if($event->getLizenz()===null){
  162.                 file_put_contents(__DIR__.'/../../../var/log/error.log', date('d.m.Y H:i:s '). PHP_EOL.var_export($event, true).PHP_EOL.'=============='.PHP_EOL, FILE_APPEND);
  163.                 $event->stopPropagation();
  164.                 return;
  165.             }
  166.             $event->getLizenz()->setRemainingMails($event->getLizenz()->getMailsPerMonth() - $rowResult->rowCount());
  167.             $event->getCustomer()->getLizenz()->setRemainingMails($event->getLizenz()->getMailsPerMonth() - $rowResult->rowCount());
  168.             $event->addVerboseOutput('Processing Customer '.$event->getCustomer()->getId().' Adding Available Messages of '.$event->getLizenz()->getRemainingMails());
  169.         }
  170.     }
  172.     public function grapperStore(GrapperEvent $event):void{
  173.         if($event->getCustomer() instanceof acount){
  174.               $now = new \DateTime();
  175.               $next = $event->getCustomer()->getLastSend();
  176.               if(empty($next)){
  177.             $next = new \DateTime();
  178.               }
  179.               $delta = new \DateInterval($event->getCustomer()->getDatesBetweenSend());
  180.               $next->add($delta);
  181.               if($next >= $now){
  182.             $event->addVerboseOutput('Processing Customer '.$event->getCustomer()->getId().' Job is not up for Prossing unitl: '.$next->format('d.m.Y H:i:s'));
  183.               }else{
  184.                 if($event->getLizenz()->getMailsPerMonth() > 0){
  185.                     /** @var grapperQueue $jobExists */
  186.                     $stmt = $this->database->getConnection()->prepare(grapperQueue::CHECK_JOB_EXISTS);
  187.                     $stmt->bindValue(1, $event->getCustomer()->getId());
  188.                     $rowResult = $stmt->executeQuery();
  189.                     $event->addVerboseOutput('Processing Customer '.$event->getCustomer()->getId().' Jobs Exist: '.($rowResult->rowCount() < 1?'no':'yes'));
  190.                     if($rowResult->rowCount() < 1){
  191.                         $queue = new grapperQueue(null, (new DateTime()), null, $event->getCustomer()->getId());
  192.                         $event->addVerboseOutput('Processing Customer '.$event->getCustomer()->getId().' adding Job');
  193.                         $this->database->insert(grapperQueue::INSERT_QUEUE_STEP, $queue->toArrayInsert());
  194.                         $this->database->update(acount::UPDATE_GRAPPER_LAST_SEND, [(new \DateTime())->format('Y-m-d H:i:s')],[$event->getCustomer()->getId()]);
  195.                     }else{
  196.                         $event->addVerboseOutput('Processing Customer '.$event->getCustomer()->getId().' Job already exists with id: '.$jobExists->getId());
  197.                     }
  198.                 }
  199.               }
  200.         }
  201.     }
  203.     /**
  204.      * @param GrapperQueueEvent $event
  205.      * @return void
  206.      * @throws Exception
  207.      */
  208.     public function insertQueueSendEmails(GrapperQueueEvent $event):void{
  209.         if($event->getAcount() instanceof acount && $event->getAcount()->getId() > 0){
  210.             $stmt = $this->database->getConnection()->prepare(grapperStatistik::SELECT_COUNTER);
  211.             $stmt->bindValue(1, $event->getAcount()->getId());
  212.             $stmt->bindValue(2, date('Y') . '-' . date('m') . '-01 00:00:00');
  213.             $stmt->bindValue(3, date('Y') . '-' . date('m') . '-' . date('t') . '-00:00:00');
  214.             $rowResult = $stmt->executeQuery();
  215.             $event->getAcount()->getLizenz()->setRemainingMails($event->getAcount()->getLizenz()->getMailsPerMonth() - $rowResult->rowCount());
  216.             if($event->getAcount()->getLizenz()->getRemainingMails() > $event->getAcount()->getMailsPerBatch()){
  217.             $event->getAcount()->getLizenz()->setRemainingMails($event->getAcount()->getMailsPerBatch());
  218.             }
  219.         }
  220.     }
  222.     /**
  223.      * @throws Exception
  224.      */
  225.     public function finishQueueSend(GrapperQueueEvent $event):void{
  226.         /** @var grapperQueue $item */
  227.         $item = $this->database->getData(grapperQueue::class, grapperQueue::CHECK_JOB_EXISTS, [0=>$event->getAcount()->getId()]);
  228.         if($event->getSuccess() > 0){
  229.                 return;
  230.         }
  231.         //@todo check if all queue items have been processed
  232.         $item->setFinished(new DateTime());
  233.         $stmt = $this->database->getConnection()->prepare(grapperQueue::UPDATE_QUEUE_STEP);
  234.         $stmt->bindValue(2, $event->getQueue()->getId());
  235.         $stmt->bindValue(1, $item->getFinished()->format('Y-m-d H:i:s'));
  236.         $stmt->executeQuery();
  238.         $stmt = $this->database->getConnection()->prepare(acount::UPDATE_LAST_SEND);
  239.         $stmt->bindValue(1, $event->getQueue()->getId());
  240.         $stmt->executeQuery();
  242.     }
  243. }