File manager

File manager - Edit - /home/premiey/www/wp-content/plugins/ameliabooking/src/Application/Commands/Booking/Appointment/AddAppointmentCommandHandler.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\BookableApplicationService; use AmeliaBooking\Application\Services\Booking\AppointmentApplicationService; 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\Settings\SettingsService; use AmeliaBooking\Domain\ValueObjects\BooleanValueObject; use AmeliaBooking\Domain\ValueObjects\PositiveDuration; use AmeliaBooking\Domain\ValueObjects\String\BookingStatus; use AmeliaBooking\Infrastructure\Common\Exceptions\NotFoundException; use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException; use AmeliaBooking\Infrastructure\Repository\Booking\Appointment\AppointmentRepository; use AmeliaBooking\Infrastructure\WP\Translations\FrontendStrings; use Exception; use Interop\Container\Exception\ContainerException; use Slim\Exception\ContainerValueNotFoundException; /** * Class AddAppointmentCommandHandler * * @package AmeliaBooking\Application\Commands\Booking\Appointment / class AddAppointmentCommandHandler extends CommandHandler { /* * @var array / public $mandatoryFields = [ 'bookings', 'bookingStart', 'notifyParticipants', 'serviceId', 'providerId' ]; /* * @param AddAppointmentCommand $command * * @return CommandResult * @throws NotFoundException * @throws ContainerValueNotFoundException * @throws InvalidArgumentException * @throws QueryExecutionException * @throws ContainerException * @throws Exception / public function handle(AddAppointmentCommand $command) { $result = new CommandResult(); $this->checkMandatoryFields($command); /* @var AppointmentRepository $appointmentRepo / $appointmentRepo = $this->container->get('domain.booking.appointment.repository'); /* @var AppointmentApplicationService $appointmentAS / $appointmentAS = $this->container->get('application.booking.appointment.service'); /* @var BookableApplicationService $bookableAS / $bookableAS = $this->container->get('application.bookable.service'); /* @var UserApplicationService $userAS / $userAS = $this->getContainer()->get('application.user.service'); /* @var SettingsService $settingsDS / $settingsDS = $this->container->get('domain.settings.service'); try { /* @var AbstractUser $user / $user = $userAS->authorization( $command->getPage() === 'cabinet' ? $command->getToken() : null, $command->getCabinetType() ); } catch (AuthorizationException $e) { $result->setResult(CommandResult::RESULT_ERROR); $result->setData( [ 'reauthorize' => true ] ); return $result; } if ($userAS->isCustomer($user)) { throw new AccessDeniedException('You are not allowed to update appointment'); } if ($userAS->isProvider($user) && !$settingsDS->getSetting('roles', 'allowWriteAppointments')) { throw new AccessDeniedException('You are not allowed to add an appointment'); } $appointmentData = $command->getFields(); $paymentData = array_merge($command->getField('payment'), ['isBackendBooking' => true]); /* @var Service $service / $service = $bookableAS->getAppointmentService($appointmentData['serviceId'], $appointmentData['providerId']); $maxDuration = 0; foreach ($appointmentData['bookings'] as $booking) { if ($booking['duration'] > $maxDuration && ($booking['status'] === BookingStatus::APPROVED \|\| BookingStatus::PENDING)) { $maxDuration = $booking['duration']; } } if ($maxDuration) { $service->setDuration(new PositiveDuration($maxDuration)); } $appointmentAS->convertTime($appointmentData); /* @var Appointment $appointment / $appointment = $appointmentAS->build($appointmentData, $service); /* @var CustomerBooking $booking / foreach ($appointment->getBookings()->getItems() as $booking) { if (!$appointmentAS->processPackageAppointmentBooking( $booking, new Collection(), $appointment->getServiceId()->getValue(), $paymentData )) { $result->setResult(CommandResult::RESULT_ERROR); $result->setMessage(FrontendStrings::getCommonStrings()['package_booking_unavailable']); $result->setData( [ 'packageBookingUnavailable' => true ] ); return $result; } } $appointmentRepo->beginTransaction(); /* @var CustomerBooking $booking / foreach ($appointment->getBookings()->getItems() as $booking) { $booking->setChangedStatus(new BooleanValueObject(true)); } if (!$appointmentAS->canBeBooked($appointment, false)) { $result->setResult(CommandResult::RESULT_ERROR); $result->setMessage(FrontendStrings::getCommonStrings()['package_booking_unavailable']); $result->setData( [ 'timeSlotUnavailable' => true ] ); return $result; } $appointmentAS->add($appointment, $service, $paymentData, true); $recurringAppointments = []; foreach ($command->getField('recurring') as $recurringData) { $recurringAppointmentData = array_merge( $appointmentData, [ 'bookingStart' => $recurringData['bookingStart'], 'locationId' => $recurringData['locationId'], 'parentId' => $appointment->getId()->getValue() ] ); $appointmentAS->convertTime($recurringAppointmentData); /* @var Appointment $recurringAppointment / $recurringAppointment = $appointmentAS->build($recurringAppointmentData, $service); /* @var CustomerBooking $booking */ foreach ($recurringAppointment->getBookings()->getItems() as $booking) { $booking->setChangedStatus(new BooleanValueObject(true)); } if (!$appointmentAS->canBeBooked($recurringAppointment, false)) { $result->setResult(CommandResult::RESULT_ERROR); $result->setMessage(FrontendStrings::getCommonStrings()['time_slot_unavailable']); $result->setData( [ 'timeSlotUnavailable' => true ] ); return $result; } $appointmentAS->add($recurringAppointment, $service, $paymentData, true); $recurringAppointments[] = [ Entities::APPOINTMENT => $recurringAppointment->toArray() ]; } $result->setResult(CommandResult::RESULT_SUCCESS); $result->setMessage('Successfully added new appointment'); $result->setData( [ Entities::APPOINTMENT => $appointment->toArray(), 'recurring' => $recurringAppointments ] ); $appointmentRepo->commit(); return $result; } }

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