src/MessageHandler/Query/Partner/Order/GetPartnerOnlineLiveHandler.php line 49

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\MessageHandler\Query\Partner\Order;
  7. use DateTimeImmutable;
  8. use League\Period\Period;
  9. use Slivki\Dao\Director\DirectorDaoInterface;
  10. use Slivki\Dao\Partner\History\PartnerHistoryDaoInterface;
  11. use Slivki\Message\Query\Partner\Order\GetPartnerOnlineOrderLiveQuery;
  12. use Slivki\Response\Partner\Order\GetPartnerOnlineLiveResponse;
  13. use Slivki\Services\Partner\PartnerUserService;
  14. use Slivki\Services\UserGetter;
  15. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  17. final class GetPartnerOnlineLiveHandler implements MessageHandlerInterface
  18. {
  19.     private PartnerHistoryDaoInterface $partnerHistoryDao;
  20.     private PartnerUserService $partnerUserService;
  21.     private UserGetter $userGetter;
  22.     private DirectorDaoInterface $directorDao;
  24.     public function __construct(
  25.         PartnerHistoryDaoInterface $partnerHistoryDao,
  26.         PartnerUserService $partnerUserService,
  27.         UserGetter $userGetter,
  28.         DirectorDaoInterface $directorDao
  29.     ) {
  30.         $this->partnerHistoryDao = $partnerHistoryDao;
  31.         $this->partnerUserService = $partnerUserService;
  32.         $this->userGetter = $userGetter;
  33.         $this->directorDao = $directorDao;
  34.     }
  36.     public function __invoke(GetPartnerOnlineOrderLiveQuery $query): GetPartnerOnlineLiveResponse
  37.     {
  38.         $user = $this->userGetter->get();
  39.         $directorUser = $this->partnerUserService->getDirectorUserByLoggedUser($user);
  41.         $period = new Period(
  42.             new DateTimeImmutable('-24 hours'),
  43.             new DateTimeImmutable('now'),
  44.             Period::INCLUDE_ALL,
  45.         );
  47.         $orders = $this->partnerHistoryDao->getOnlineOrderHistory($period, $this->directorDao->getDirectorIdByEmail($directorUser->getEmail()));
  49.         return new GetPartnerOnlineLiveResponse($orders->getOnlineOrders());
  50.     }
  51. }