<?php
namespace AmeliaBooking\Infrastructure\Repository\Booking\Event;
use AmeliaBooking\Domain\Entity\Booking\Event\EventTicket;
use AmeliaBooking\Domain\Factory\Booking\Event\EventTicketFactory;
use AmeliaBooking\Domain\Repository\Booking\Event\EventRepositoryInterface;
use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException;
use AmeliaBooking\Infrastructure\Repository\AbstractRepository;
/**
* Class EventTicketRepository
*
* @package AmeliaBooking\Infrastructure\Repository\Booking\Event
*/
class EventTicketRepository extends AbstractRepository implements EventRepositoryInterface
{
public const FACTORY = EventTicketFactory::class;
/**
* @param EventTicket $entity
*
* @return int
* @throws QueryExecutionException
*/
public function add($entity)
{
$data = $entity->toArray();
$params = [
':eventId' => $data['eventId'],
':name' => $data['name'],
':enabled' => $data['enabled'] ? 1 : 0,
':price' => $data['price'],
':spots' => $data['spots'],
':waitingListSpots' => $data['waitingListSpots'] ?: 0,
':dateRanges' => $data['dateRanges'],
':translations' => $data['translations'],
];
try {
$statement = $this->connection->prepare(
"INSERT INTO {$this->table}
(
`eventId`,
`name`,
`enabled`,
`price`,
`spots`,
`waitingListSpots`,
`dateRanges`,
`translations`
)
VALUES (
:eventId,
:name,
:enabled,
:price,
:spots,
:waitingListSpots,
:dateRanges,
:translations
)"
);
$statement->execute($params);
return $this->connection->lastInsertId();
} catch (\Exception $e) {
throw new QueryExecutionException('Unable to add data in ' . __CLASS__ . '. ' . $e->getMessage(), $e->getCode(), $e);
}
}
/**
* @param int $id
* @param EventTicket $entity
*
* @return mixed
* @throws QueryExecutionException
*/
public function update($id, $entity)
{
$data = $entity->toArray();
$params = [
':id' => $id,
':eventId' => $data['eventId'],
':name' => $data['name'],
':enabled' => $data['enabled'] ? 1 : 0,
':price' => $data['price'],
':spots' => $data['spots'],
':waitingListSpots' => $data['waitingListSpots'] ?: 0,
':dateRanges' => $data['dateRanges'],
':translations' => $data['translations'],
];
try {
$statement = $this->connection->prepare(
"UPDATE {$this->table}
SET
`eventId` = :eventId,
`name` = :name,
`enabled` = :enabled,
`price` = :price,
`spots` = :spots,
`waitingListSpots` = :waitingListSpots,
`dateRanges` = :dateRanges,
`translations` = :translations
WHERE id = :id"
);
$statement->execute($params);
return true;
} catch (\Exception $e) {
throw new QueryExecutionException('Unable to save data in ' . __CLASS__ . '. ' . $e->getMessage(), $e->getCode(), $e);
}
}
}