File manager

File manager - Edit - /home/premiey/www/wp-content/plugins/ameliabooking/src/Application/Commands/Booking/Appointment/GetAppointmentsCommandHandler.php

Back
<?php namespace AmeliaBooking\Application\Commands\Booking\Appointment; use AmeliaBooking\Application\Commands\CommandHandler; use AmeliaBooking\Application\Commands\CommandResult; use AmeliaBooking\Application\Common\Exceptions\AccessDeniedException; use AmeliaBooking\Application\Services\Bookable\PackageApplicationService; use AmeliaBooking\Application\Services\Booking\AppointmentApplicationService; use AmeliaBooking\Application\Services\Booking\BookingApplicationService; use AmeliaBooking\Application\Services\User\UserApplicationService; use AmeliaBooking\Domain\Collection\Collection; use AmeliaBooking\Domain\Common\Exceptions\AuthorizationException; use AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException; use AmeliaBooking\Domain\Entity\Bookable\Service\Service; use AmeliaBooking\Domain\Entity\Booking\Appointment\Appointment; use AmeliaBooking\Domain\Entity\Booking\Appointment\CustomerBooking; use AmeliaBooking\Domain\Entity\Entities; use AmeliaBooking\Domain\Entity\User\AbstractUser; use AmeliaBooking\Domain\Services\DateTime\DateTimeService; use AmeliaBooking\Domain\Services\Settings\SettingsService; use AmeliaBooking\Domain\ValueObjects\String\BookingStatus; use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException; use AmeliaBooking\Infrastructure\Repository\Bookable\Service\ServiceRepository; use AmeliaBooking\Infrastructure\Repository\Booking\Appointment\AppointmentRepository; use Interop\Container\Exception\ContainerException; /** * Class GetAppointmentsCommandHandler * * @package AmeliaBooking\Application\Commands\Booking\Appointment / class GetAppointmentsCommandHandler extends CommandHandler { /* * @param GetAppointmentsCommand $command * * @return CommandResult * * @throws InvalidArgumentException * @throws QueryExecutionException * @throws AccessDeniedException * @throws ContainerException / public function handle(GetAppointmentsCommand $command) { $result = new CommandResult(); /* @var AppointmentRepository $appointmentRepository / $appointmentRepository = $this->container->get('domain.booking.appointment.repository'); /* @var ServiceRepository $serviceRepository / $serviceRepository = $this->container->get('domain.bookable.service.repository'); /* @var PackageApplicationService $packageAS / $packageAS = $this->container->get('application.bookable.package'); /* @var SettingsService $settingsDS / $settingsDS = $this->container->get('domain.settings.service'); /* @var UserApplicationService $userAS / $userAS = $this->container->get('application.user.service'); /* @var BookingApplicationService $bookingAS / $bookingAS = $this->container->get('application.booking.booking.service'); /* @var AppointmentApplicationService $appointmentAS / $appointmentAS = $this->container->get('application.booking.appointment.service'); $params = $command->getField('params'); $isCabinetPage = $command->getPage() === 'cabinet'; $isCabinetPackageRequest = $isCabinetPage && isset($params['activePackages']); $isDashboardPackageRequest = !$isCabinetPage && isset($params['packageId']); try { /* @var AbstractUser $user / $user = $userAS->authorization($isCabinetPage ? $command->getToken() : null, $command->getCabinetType()); } catch (AuthorizationException $e) { $result->setResult(CommandResult::RESULT_ERROR); $result->setData( [ 'reauthorize' => true ] ); return $result; } $readOthers = $this->container->getPermissionsService()->currentUserCanReadOthers(Entities::APPOINTMENTS); if (!empty($params['dates'])) { !empty($params['dates'][0]) ? $params['dates'][0] .= ' 00:00:00' : null; !empty($params['dates'][1]) ? $params['dates'][1] .= ' 23:59:59' : null; if ($isCabinetPage && !empty($params['timeZone'])) { foreach ([0, 1] as $index) { if (!empty($params['dates'][$index])) { $params['dates'][$index] = DateTimeService::getDateTimeObjectInTimeZone( $params['dates'][$index], $params['timeZone'] )->setTimezone(DateTimeService::getTimeZone())->format('Y-m-d H:i:s'); } } } } $entitiesIds = !empty($params['search']) && !$isCabinetPackageRequest ? $appointmentAS->getAppointmentEntitiesIdsBySearchString($params['search']) : []; $countParams = $params; $appointmentsIds = []; if (!empty($params['search']) && !$entitiesIds['customers'] && !$entitiesIds['services'] && !$entitiesIds['providers'] ) { $result->setResult(CommandResult::RESULT_SUCCESS); $result->setMessage('Successfully retrieved appointments'); $result->setData( [ Entities::APPOINTMENTS => [], 'availablePackageBookings' => [], 'occupied' => [], 'total' => 0, 'totalApproved' => 0, 'totalPending' => 0, ] ); return $result; } $availablePackageBookings = []; if (!$isCabinetPackageRequest && !$isDashboardPackageRequest) { $upcomingAppointmentsLimit = $settingsDS->getSetting('general', 'appointmentsPerPage'); /* @var Collection $periodAppointments / $periodAppointments = $appointmentRepository->getPeriodAppointments( array_merge( [ 'customers' => $isCabinetPage && $user->getType() === Entities::CUSTOMER ? [$user->getId()->getValue()] : [], 'providers' => $isCabinetPage && $user->getType() === Entities::PROVIDER ? [$user->getId()->getValue()] : [], ], $params, $entitiesIds, ['skipBookings' => !$isCabinetPage && empty($params['customerId']) && empty($entitiesIds['customers'])] ), $upcomingAppointmentsLimit ); /* @var Appointment $appointment / foreach ($periodAppointments->getItems() as $appointment) { $appointmentsIds[] = $appointment->getId()->getValue(); } } /* @var Collection $appointments / $appointments = new Collection(); $customerId = isset($params['customerId']) ? $params['customerId'] : null; if (isset($params['customerId'])) { unset($params['customerId']); } if (!$isCabinetPackageRequest && $appointmentsIds) { $appointments = $appointmentRepository->getFiltered( array_merge( $params, [ 'ids' => $appointmentsIds, 'skipServices' => isset($params['skipServices']) ? $params['skipServices'] : false, 'skipProviders' => isset($params['skipProviders']) ? $params['skipProviders'] : false, ] ) ); } elseif ($isDashboardPackageRequest \|\| ($user && $user->getId() && $isCabinetPackageRequest)) { $availablePackageBookings = $packageAS->getPackageAvailability( $appointments, [ 'purchased' => !empty($params['dates']) ? $params['dates'] : [], 'customerId' => $isCabinetPackageRequest ? $user->getId()->getValue() : $customerId, 'packageId' => !$isCabinetPackageRequest && !empty($params['packageId']) ? (int)$params['packageId'] : null, ] ); } /* @var Collection $services / $services = $serviceRepository->getAllArrayIndexedById(); if (!$isCabinetPage) { $packageAS->setPackageBookingsForAppointments($appointments); } $occupiedTimes = []; $currentDateTime = DateTimeService::getNowDateTimeObject(); $groupedAppointments = []; /* @var Appointment $appointment / foreach ($appointments->getItems() as $appointment) { /* @var Service $service / $service = $services->getItem($appointment->getServiceId()->getValue()); $bookingsCount = 0; /* @var CustomerBooking $booking / foreach ($appointment->getBookings()->getItems() as $booking) { // fix for wrongly saved JSON if ($booking->getCustomFields() && json_decode($booking->getCustomFields()->getValue(), true) === null ) { $booking->setCustomFields(null); } if ($bookingAS->isBookingApprovedOrPending($booking->getStatus()->getValue())) { $bookingsCount++; } } $providerId = $appointment->getProviderId()->getValue(); $isGroup = false; // skip appointments/bookings for other customers if user is customer, and remember that time/date values if ($userAS->isCustomer($user)) { /* @var CustomerBooking $booking / foreach ($appointment->getBookings()->getItems() as $bookingKey => $booking) { if (!$user->getId() \|\| $booking->getCustomerId()->getValue() !== $user->getId()->getValue()) { /* @var CustomerBooking $otherBooking / $otherBooking = $appointment->getBookings()->getItem($bookingKey); if ($otherBooking->getStatus()->getValue() === BookingStatus::APPROVED \|\| $otherBooking->getStatus()->getValue() === BookingStatus::PENDING ) { $isGroup = true; } $appointment->getBookings()->deleteItem($bookingKey); } } if ($appointment->getBookings()->length() === 0) { $serviceTimeBefore = $service->getTimeBefore() ? $service->getTimeBefore()->getValue() : 0; $serviceTimeAfter = $service->getTimeAfter() ? $service->getTimeAfter()->getValue() : 0; $occupiedTimeStart = DateTimeService::getCustomDateTimeObject( $appointment->getBookingStart()->getValue()->format('Y-m-d H:i:s') )->modify('-' . $serviceTimeBefore . ' second')->format('H:i:s'); $occupiedTimeEnd = DateTimeService::getCustomDateTimeObject( $appointment->getBookingEnd()->getValue()->format('Y-m-d H:i:s') )->modify('+' . $serviceTimeAfter . ' second')->format('H:i:s'); $occupiedTimes[$appointment->getBookingStart()->getValue()->format('Y-m-d')][] = [ 'employeeId' => $providerId, 'startTime' => $occupiedTimeStart, 'endTime' => $occupiedTimeEnd, ]; continue; } } // skip appointments for other providers if user is provider if ((!$readOthers \|\| $isCabinetPage) && $user->getType() === Entities::PROVIDER && $user->getId()->getValue() !== $providerId ) { continue; } $appointmentAS->calculateAndSetAppointmentEnd($appointment, $service); $minimumCancelTimeInSeconds = $settingsDS ->getEntitySettings($service->getSettings()) ->getGeneralSettings() ->getMinimumTimeRequirementPriorToCanceling(); $minimumCancelTime = DateTimeService::getCustomDateTimeObject( $appointment->getBookingStart()->getValue()->format('Y-m-d H:i:s') )->modify("-{$minimumCancelTimeInSeconds} seconds"); $date = $appointment->getBookingStart()->getValue()->format('Y-m-d'); $cancelable = $currentDateTime <= $minimumCancelTime; $minimumRescheduleTimeInSeconds = $settingsDS ->getEntitySettings($service->getSettings()) ->getGeneralSettings() ->getMinimumTimeRequirementPriorToRescheduling(); $minimumRescheduleTime = DateTimeService::getCustomDateTimeObject( $appointment->getBookingStart()->getValue()->format('Y-m-d H:i:s') )->modify("-{$minimumRescheduleTimeInSeconds} seconds"); $reschedulable = $currentDateTime <= $minimumRescheduleTime; if ($isCabinetPage) { $timeZone = 'UTC'; if (!empty($params['timeZone'])) { $timeZone = $params['timeZone']; } $appointment->getBookingStart()->getValue()->setTimezone(new \DateTimeZone($timeZone)); $appointment->getBookingEnd()->getValue()->setTimezone(new \DateTimeZone($timeZone)); $date = $appointment->getBookingStart()->getValue()->format('Y-m-d'); foreach ($availablePackageBookings as &$packageCustomerPurchase) { foreach ($packageCustomerPurchase['packages'] as &$packagePurchase) { foreach ($packagePurchase['services'] as &$packageService) { foreach ($packageService['bookings'] as &$purchase) { $purchasedDate = DateTimeService::getCustomDateTimeObjectInTimeZone( $purchase['purchased'], $timeZone ); $purchase['purchased'] = $purchasedDate->format('Y-m-d H:i'); } } } } } $groupedAppointments[$date]['date'] = $date; $groupedAppointments[$date]['appointments'][] = array_merge( $appointment->toArray(), [ 'cancelable' => $cancelable, 'reschedulable' => $reschedulable, 'past' => $currentDateTime >= $appointment->getBookingStart()->getValue(), 'isGroup' => $isGroup, ] ); } $emptyBookedPackages = null; if (!empty($params['packageId']) && empty($params['services']) && empty($params['providers']) && empty($params['locations']) ) { /* @var PackageApplicationService $packageApplicationService / $packageApplicationService = $this->container->get('application.bookable.package'); /* @var Collection $emptyBookedPackages */ $emptyBookedPackages = $packageApplicationService->getEmptyPackages( [ 'packages' => [$params['packageId']], 'purchased' => !empty($params['dates']) ? $params['dates'] : [], 'customerId' => $customerId, ] ); } $periodsAppointmentsCount = 0; $periodsAppointmentsApprovedCount = 0; $periodsAppointmentsPendingCount = 0; if (!$isCabinetPackageRequest && !$isCabinetPage) { if ((!$readOthers) && $user->getType() === Entities::PROVIDER ) { $countParams['providerId'] = $user->getId()->getValue(); } $periodsAppointmentsCount = $appointmentRepository->getPeriodAppointmentsCount( array_merge($countParams, $entitiesIds, ['ids' => $appointmentsIds,]) ); $periodsAppointmentsApprovedCount = $appointmentRepository->getPeriodAppointmentsCount( array_merge( $countParams, ['status' => BookingStatus::APPROVED, 'ids' => $appointmentsIds], $entitiesIds ) ); $periodsAppointmentsPendingCount = $appointmentRepository->getPeriodAppointmentsCount( array_merge( $countParams, ['status' => BookingStatus::PENDING, 'ids' => $appointmentsIds], $entitiesIds ) ); } $result->setResult(CommandResult::RESULT_SUCCESS); $result->setMessage('Successfully retrieved appointments'); $result->setData( [ Entities::APPOINTMENTS => $groupedAppointments, 'availablePackageBookings' => $availablePackageBookings, 'emptyPackageBookings' => !empty($emptyBookedPackages) ? $emptyBookedPackages->toArray() : [], 'occupied' => $occupiedTimes, 'total' => $periodsAppointmentsCount, 'totalApproved' => $periodsAppointmentsApprovedCount, 'totalPending' => $periodsAppointmentsPendingCount, 'currentUser' => $user ? $user->toArray() : null ] ); return $result; } }

| ver. 1.4 | Github | . | PHP 5.4.45 | Generation time: 0 | proxy | phpinfo | Settings